mongoDB 4.0事务回滚的辛酸历程探究(2)-木庄网络博客

在db.js里新增了一个方法

 export const getSession = async function() {
  return await state.mongoClient.startSession();
 };

每次在需要回滚的mongo代码前调用这个方法拿到session，开始回滚的标记

 const session = await db.getSession();
 session.startTransaction({
  readConcern: {level: 'snapshot'},
  writeConcern: {w: 'majority'},
 });

在每次调用mongodb.js的方法操作数据库时，都要带上session，比如

 db
 .collection(this.collecitonName)
 .insertOne(doc,{session});

在你处理错误并觉得需要回滚了，执行

await session.abortTransaction();

在你觉得没问题，一起正常结束时，执行

await session.commitTransaction();

我的代码里可能有一些封装的代码没有放上去，导致不一定能理解。我只是举个栗子去实现，具体的代码实现可以看参考链接1

4.总结

useNewUrlParser这个属性会在url里识别验证用户所需的db，未升级前是不需要指定的，升级到一定要指定，不管是在url后面，还是用authSource

事务回滚只能在复制集上操作，我猜测实现的原理可能是这样：先记录主节点的session，然后回滚的话，通过这个session查找副节点的数据快照，然后将这快照再应用到主节点上，实现回滚。当然，实际情况应该相当复杂，不然mongoDB也不会用3年时间来实现这个操作。

5.参考链接

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对的支持。

标签：MongoDB

数据库系统概念第6版

￥41.1元 机械工业出版社

本书主要讲述了数据模型、基于对象的数据库和XML、数据存储和查询、事务管理、体系结构等方面的内容。