今天就跟大家聊聊有關MongoDB有沒有事務，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

創(chuàng)新互聯(lián)建站專注于企業(yè)成都全網(wǎng)營銷推廣、網(wǎng)站重做改版、玉龍網(wǎng)站定制設計、自適應品牌網(wǎng)站建設、H5頁面制作、商城系統(tǒng)網(wǎng)站開發(fā)、集團公司官網(wǎng)建設、外貿(mào)網(wǎng)站建設、高端網(wǎng)站制作、響應式網(wǎng)頁設計等建站業(yè)務，價格優(yōu)惠性價比高，為玉龍等各大城市提供網(wǎng)站開發(fā)制作服務。

MongoDB 4.0 引入的事務功能，支持多文檔 ACID 特性，例如使用 mongo shell 進行事務操作。

> s = db.getMongo().startSession()
    session { "id" : UUID("3bf55e90-5e88-44aa-a59e-a30f777f1d89") }
    > s.startTransaction()
    > session.getDatabase("mytest").coll01.insert({x: 1, y: 1})
    WriteResult({ "nInserted" : 1 })
    > session.getDatabase("mytest").coll02.insert({x: 1, y: 1})
    WriteResult({ "nInserted" : 1 })
    > s.commitTransaction()  （或者 s.abortTransaction()回滾事務）

支持 MongoDB 4.0 的其他語言 Driver 也封裝了事務相關接口，用戶需要創(chuàng)建一個 Session，然后在 Session 上開啟事務，提交事務。例如：

python 版本

with client.start_session() as s:
    s.start_transaction()
    collection_one.insert_one(doc_one, session=s)
    collection_two.insert_one(doc_two, session=s)
    s.commit_transaction()

java 版本

try (ClientSession clientSession = client.startSession()) {
   clientSession.startTransaction();
   collection.insertOne(clientSession, docOne);
   collection.insertOne(clientSession, docTwo);
   clientSession.commitTransaction();
}

一、預備工作

1、MongoDB需要4.0版本+

2、需要自己搭建MongoDB復制集，單個mongodb server 不支持事務。

事務原理：mongodb的復制至少需要兩個節(jié)點。其中一個是主節(jié)點，負責處理客戶端請求，其余的都是從節(jié)點，負責復制主節(jié)點上的數(shù)據(jù)。mongodb各個節(jié)點常見的搭配方式為：一主一從、一主多從。主節(jié)點記錄在其上的所有操作oplog，從節(jié)點定期輪詢主節(jié)點獲取這些操作，然后對自己的數(shù)據(jù)副本執(zhí)行這些操作，從而保證從節(jié)點的數(shù)據(jù)與主節(jié)點一致。

3、搭建復制集步驟

啟動mongo主節(jié)點實例，bin目錄下命令窗口執(zhí)行，復制集命名為doudou, 8080端口的數(shù)據(jù)庫文件位于db1目錄下，--dbpath=路徑寫自己的，啟動后勿關閉命令窗口

mongod --replSet doudou --dbpath=E:\mongoDb\data\db1 --port=8080　　

啟動mongo從節(jié)點實例，bin目錄下命令窗口執(zhí)行，復制集命名為doudou, 8081端口的數(shù)據(jù)庫文件位于db2目錄下，--dbpath=路徑寫自己的，啟動后勿關閉命令窗口

mongod --replSet doudou --dbpath=E:\mongoDb\data\db2 --port=8081

兩個節(jié)點啟動后，bin目錄下打開命令窗口，連接主節(jié)點

mongo --port=8080

命令初始化

rs.initiate()

兩個節(jié)點啟動后，bin目錄下打開命令窗口，連接主節(jié)點

mongo --port=8080

成功后如圖：

命令初始化

rs.initiate()

效果如圖：

成功的結果是（ok項是1，失敗是0）

查看是否是主節(jié)點 rs.isMaster()

查看復制集狀態(tài) rs.status()

初始化配置

rs.conf()

向主節(jié)點添加從節(jié)點

rs.add("localhost:8081")

查看主節(jié)點狀態(tài)

rs.status()

復制集配置完成。

二、復制集中的坑點

1、需使用mongoose.connection對集合進行事務操作，其他model的CRUD方法不支持事務。

mongoose.connection.collection('集合名') // 注：集合名需要小寫且加s,如model為Cat,集合名這里應寫為cats

2、觸發(fā)Schema定義的中間件默認值需要構造model實例

const CatSchema = new Schema({
    name: {
        type: String
        default: 'cat'
    },
    created: {
　　　　 type: Date,
　　　　 default: Date.now
　　}
})
 
const Cat = mongoose.model('Cat', CatSchema)
 
new Cat() // 觸發(fā)中間件

3、insertOne，findOneAndUpdate等方法對數(shù)據(jù)的新增，需上面第二點進行依賴，否則直接insertOne插入一條數(shù)據(jù)，定義的默認值不會觸發(fā)，如created字段，chema內(nèi)部定義的type:Schema.ObjectId的相應字段，insertOne插入后都會變成字符串類型，不是Schema.ObjectId類型。

// 解決方式
//新增
 
const Cat= new Cat();
const data = {name: 5}
for (let key in data) {
      Cat[key] = data[key];
    }
db.collection('cats').insertOne(Cat);
 
// 查詢修改
 
db.collection('cats')
.findOneAndUpdate({_id: mongoose.Types.ObjectId(你的id)}, {$set: {name: 修改值}})

三、開始事務

注：以下皆為egg實例代碼

封裝獲取session函數(shù)

// 獲取session，回滾事務
  async getSession(opt = {
    readConcern: { level: "snapshot" },
    writeConcern: { w: "majority" }
  }) {
    const { mongoose } = this.app
    const session = await mongoose.startSession(opt);
    await session.startTransaction();
    return session
  }

執(zhí)行事務邏輯

const { mongoose } = this.ctx.app;
const session = await this.ctx.getSession();
const db = mongoose.connection;
try {
  const data = this.ctx.request.body;
  const Cat = new this.ctx.model.Cat();
  for (let key in data) {
    Cat[key] = data[key]
  }
  await db
    .collection('cats')
    .insertOne(Cat, { session });
  // 提交事務
  await session.commitTransaction();
  this.ctx.end();
} catch (err) {
  // 回滾事務
  await session.abortTransaction();
  this.ctx.logger.error(new Error(err));
} finally {
  await session.endSession();
}

看完上述內(nèi)容，你們對mongodb有沒有事務有進一步的了解嗎？如果還想了解更多知識或者相關內(nèi)容，請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

當前名稱：mongodb有沒有事務
瀏覽路徑：http://aaarwkj.com/article36/gghcsg.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供營銷型網(wǎng)站建設、微信公眾號、企業(yè)建站、面包屑導航、網(wǎng)站設計、品牌網(wǎng)站設計

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)