mongoDB 4.0事务回滚的辛酸历程探究

前言

主管前几天发现mongoDB已经升级到4.0了，迫不及待得让我实现他期待已久的事务回滚，发现还是有很多坑啊！

下面是我将已有的本地mongoDB升级到支持事务回滚的历程，分享出来，有错误的地方欢迎指正！

以mac为例哈

部署mongodb事务回滚

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

5.参考链接

总结

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

赞 (0)

相关推荐

  • mongodb 添加用户及权限设置详解

    例如:mysql安装配置好后,有一个自带的mysql数据库,里面有一张user表,用来存放用户,以及用户权限,而mongodb这个最像关系型的数据库,有没有这样的表呢. 一,掌握权限,理解下面4条基本上就差不多 1,mongodb是没有默认管理员账号,所以要先添加管理员账号,在开启权限认证. 2,切换到admin数据库,添加的账号才是管理员账号. 3,用户只能在用户所在数据库登录,包括管理员账号. 4,管理员可以管理所有数据库,但是不能直接管理其他数据库,要先在admin数据库认证后才可以.这一

  • MongoDB各种查询操作详解

    MongoDB各种查询操作详解

    一.find操作 MongoDB中使用find来进行查询,通过指定find的第一个参数可以实现全部和部分查询. 1.查询全部 空的查询文档{}会匹配集合的全部内容.如果不指定查询文档,默认就是{}. 2.部分查询 3.键的筛选 键的筛选是查询时只返回自己感兴趣的键值,通过指定find的第二个参数来实现.这样可以节省传输的数据量,又能节省客户端解码文档的时间和内存消耗. 查询时,数据库所关心的查询文档的值必须是常量. 二.查询条件 1.比较查询 $lt,$lte,$gt,$gte,$ne和<,<

  • mongodb 查看数据库和表大小

    1,查看数据库 > db.stats(); { "db" : "test", //当前数据库 "collections" : 3, //当前数据库多少表 "objects" : 4, //当前数据库所有表多少条数据 "avgObjSize" : 51, //每条数据的平均大小 "dataSize" : 204, //所有数据的总大小 "storageSize"

  • MongoDB 语法使用小结

    他支持的数据结构非常松散,是类似json的bjson格式,因此可以存储比较复杂的数据类型.Mongo最大的特点是他支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引. 它的特点是高性能.易部署.易使用,存储数据非常方便. 1. MongoDB的获取和安装 (1)获取地址 http://www.mongodb.org/downloads 根据自己需要选择相应的版本,linux下可以使用wget 命令. (2)解压

  • MongoDB数据库两阶段提交实现事务的方法详解

    本文实例讲述了MongoDB数据库两阶段提交实现事务的方法.分享给大家供大家参考,具体如下: MongoDB数据库中操作单个文档总是原子性的,然而,涉及多个文档的操作,通常被作为一个"事务",而不是原子性的.因为文档可以是相当复杂并且包含多个嵌套文档,单文档的原子性对许多实际用例提供了支持.尽管单文档操作是原子性的,在某些情况下,需要多文档事务.在这些情况下,使用两阶段提交,提供这些类型的多文档更新支持.因为文档可以表示为Pending数据和状态,可以使用一个两阶段提交确保数据是一致的

  • PHP中MongoDB数据库的连接、添加、修改、查询、删除等操作实例

    PHP中MongoDB数据库的连接、添加、修改、查询、删除等操作实例

    PHP 扩展mongon.mod.dll下载http://cn.php.net/manual/en/mongo.installation.php#mongo.installation.windows 然后php.ini添加 extension=php_mongo.dll 最后phpinfo() 查找到 表标PHP已经自带了mongo功能,你就可以操作下面的代码(但是你必须有安装mongodb服务器) 一.连接数据库 使用下面的代码创建一个数据库链接 复制代码 代码如下: <?php $conne

  • mongodb与mysql命令详细对比

    传统的关系数据库一般由数据库(database).表(table).记录(record)三个层次概念组成,MongoDB是由数据库(database).集合(collection).文档对象(document)三个层次组成.MongoDB对于关系型数据库里的表,但是集合中没有列.行和关系概念,这体现了模式自由的特点. MySQL MongoDB 说明 mysqld mongod 服务器守护进程 mysql mongo 客户端工具 mysqldump mongodump 逻辑备份工具 mysql

  • Linux系统下MongoDB的简单安装与基本操作

    Linux系统下MongoDB的简单安装与基本操作

    Mongo DB ,是目前在IT行业非常流行的一种非关系型数据库(NoSql),其灵活的数据存储方式,备受当前IT从业人员的青睐.Mongo DB很好的实现了面向对象的思想(OO思想),在Mongo DB中 每一条记录都是一个Document对象.Mongo DB最大的优势在于所有的数据持久操作都无需开发人员手动编写SQL语句,直接调用方法就可以轻松的实现CRUD操作. 一.下载mongodb 前往mongodb官网下载页面:https://www.mongodb.org/downloads下载

  • MongoDB下根据数组大小进行查询的方法

    注意:作者使用的mongodb版本为2.4.7. 首先插入测试数据 复制代码 代码如下: db.data.insert({name:'a', num:[12,123,22,34,1]});db.data.insert({name:'b', num:[42,22]});db.data.insert({name:'c', num:[49]}); 键num对应的值是数组. 查询num的数组值具有指定大小的document 最好的方法是使用$size,例如指定大小为2,可以: 复制代码 代码如下: db

  • 1亿条记录的MongoDB数据库随机查询性能测试

    mongdb性能压力测试,随机查询,数据量1亿条记录 操作系统centos6.4x64位 从测试结果看,当mongodb将数据全部载入到内存后,查询速度根据文档的大小,性能瓶颈通常会是在网络流量和CPU的处理性能(该次测试中当数据全部在内存后,纯粹的查询速度可以稳定在10W/S左右,系统load可以维持在1以下,由于此时CPU已经被使用到极限了,当并发再大时load值会直线飙升,性能急剧下降). 压力生成服务器与Mongodb服务器基本配置 cpu型号:Intel(R) Xeon(R) CPU

  • mongodb中使用distinct去重的简单方法

    MongoDB的destinct命令是获取特定字段中不同值列表.该命令适用于普通字段,数组字段和数组内嵌文档. mongodb的distinct的语句: 复制代码 代码如下: db.users.distinct('last_name') 等同于 SQL 语句: 复制代码 代码如下: select DISTINCT last_name from users 表示的是根据指定的字段返回不同的记录集. 一个简单的实例: // > db.addresses.insert({"zip-code&qu

随机推荐