mongoDB4.0中怎么实现事务回滚-创新互联

本篇文章为大家展示了mongoDB 4.0中怎么实现事务回滚,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

文成网站制作公司哪家好,找成都创新互联公司!从网页设计、网站建设、微信开发、APP开发、成都响应式网站建设公司等网站项目制作,到程序开发,运营维护。成都创新互联公司于2013年创立到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选成都创新互联公司

1.准备工作

升级mongodb至4.0.0

$ brew upgrade mongodb

升级或安装mongodb.js v3.1.0 以上

$ npm i mongodb --save-dev

升级完上述后,db.js里连接mongo时,

会警告,让你在connect的option里加一个字段

useNewUrlParser:true

这时如果有用户验证,还需要在connect的option里再加一个字段

authSource:用户所在的db,一般为admin

否则会报验证失败,找不到用户的错误,比如

 const mongoClient = await MongoClient.connect(mongoClientUrl, {
  auth: {
  user: config.dbUserName,
  password: config.dbUserPassword,
  },
  authSource:'admin',
  useNewUrlParser:true,
 });

2.将已有的数据库改造成复制集

目前事务回滚只能在复制集上操作,单独的mongodb server是不能操作事务的

关掉所有的mongod

在平时启动mongod的命令后添加--replSet rs0,比如

$ mongod -dbpath ./db --port 27017 --replSet rs0

再开个shell,创一个不同端口的mongo实例,比如

$ mongod -dbpath ./db_repl --port 27018 --replSet rs0

连接27017的mongo实例,并设置

$ mongo
$ rs.initiate()
$ rs.add('localhost:27018');

完成

3.写回滚代码

在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年时间来实现这个操作。

上述内容就是mongoDB 4.0中怎么实现事务回滚,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。


网站栏目:mongoDB4.0中怎么实现事务回滚-创新互联
网站网址:http://bzwzjz.com/article/desejc.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 营销型网站建设 成都网站建设 上市集团网站建设 成都网站建设流程 营销型网站建设 定制网站制作 成都网站建设公司 成都网站建设 手机网站建设 成都网站建设 成都网站制作 成都网站设计 专业网站建设 成都网站制作 定制网站设计 重庆企业网站建设 网站建设方案 网站制作 企业网站建设 高端网站设计推广 企业网站设计 网站制作