node+mongoose+transaction(事务处理)

2022/2/15 14:42:44

本文主要是介绍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)

例如

 



这篇关于node+mongoose+transaction(事务处理)的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!


扫一扫关注最新编程教程