mongodb有沒有事務

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

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 也封裝了事務相關接口，用戶需要創建一個 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的復制至少需要兩個節點。其中一個是主節點，負責處理客戶端請求，其余的都是從節點，負責復制主節點上的數據。mongodb各個節點常見的搭配方式為：一主一從、一主多從。主節點記錄在其上的所有操作oplog，從節點定期輪詢主節點獲取這些操作，然后對自己的數據副本執行這些操作，從而保證從節點的數據與主節點一致。

3、搭建復制集步驟

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

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

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

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

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

mongo --port=8080

命令初始化

rs.initiate()

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

mongo --port=8080

成功后如圖：

命令初始化

rs.initiate()

效果如圖：

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

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

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

初始化配置

rs.conf()

向主節點添加從節點

rs.add("localhost:8081")

查看主節點狀態

rs.status()

復制集配置完成。

二、復制集中的坑點

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

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

2、觸發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() // 觸發中間件

3、insertOne，findOneAndUpdate等方法對數據的新增，需上面第二點進行依賴，否則直接insertOne插入一條數據，定義的默認值不會觸發，如created字段，chema內部定義的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函數

// 獲取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
  }

執行事務邏輯

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();
}

看完上述內容，你們對mongodb有沒有事務有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。