node+mongoose+transaction(事務處理)

第一步：創建副本集（具體操作見菜鳥教程），因為mongodb的事務是基於副本集生效的

第二步：用mongoose創建session

// 這個寫在文件最上方起聲明作用
const mongoose = require('mongoose');

// 這個寫在路由內
const session = await mongoose.startSession();

第三步： 在model的方法里面，比如：findOneAndUpdate加入session參數

static async removeMembers(data, session) {
    const { roleId, userId } = data;
    const result = await this.findOneAndUpdate(
      { _id: roleId },
      { $pull: { members: userId } },
      { session, new: true }
　　　　// new: true 的意思是result返回的結果是更新后的，去掉則返回更新前的結果，原因是事務還沒有commit
    );
    return result;
  }

第四步： 在路由方法內將事務commit並且關閉session

await session.commitTransaction();
session.endSession();

第五步： 在catch里面使用回滾並關閉session

await session.abortTransaction();
session.endSession();

notice： 當兩個連接，后面一個連接需要用到前面save的id的話，需要在方法后面添加.session(session)

 

 

例如