第一步:创建副本集(具体操作见菜鸟教程),因为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)
例如