【Mongodb】事务

 

概述

• mongodb 4.0 支持副本集的多文档事务
• mongodb 4.2 支持分片集群的多文档事务

单个server是不支持使用事务，所以要学习事务，需要搭建一个副本集/分片集群

另外需要说明是，单个文档操作是原子操作，而mongodb是文档型数据库，在单个文档上，可以嵌入对象/数组这种格式来维护数据的关系，而不应该使用多个集合来维护数据之间的关系。由于mongodb的这种特性，所以单个文档操作消除了很多需要事务的需求。

 

搭建副本集

下面以最简单的方式搭建一个副本集

1.  启动多个mongod实例，这里使用cmd命令启动

start "mongodb service - 27017" /min mongod --port 27017 --replset "rs0" --dbpath "f:\database\mongodb\data27017" --logpath "f:\database\mongodb\log\mongod.27017.log"
start "mongodb service - 27018" /min mongod --port 27018 --replset "rs0" --dbpath "f:\database\mongodb\data27018" --logpath "f:\database\mongodb\log\mongod.27018.log"

参数说明

• replset : 设置副本集名称
• port : 设置端口，因为我是单机，所以只能设置不同端口
• dbpath: 数据文件路径，注：文件夹必须是存在，mongod不会自动创建
• logpath: 日志文件名称，这个不需要提前新建，若不存在mongod会自动创建

2.  连接任意一个实例，这里就选择27017这个默认端口

mongo

 

3. 启动副本集

rs.initiate({
    _id: "rs0",
    members: [
        { _id: 0, host: "127.0.0.1:27017" },
        { _id: 1, host: "127.0.0.1:27018" }
    ]
})

参数说明

• _id : 副本集名称，就是启动实例时指定那个名称
• members : 这个就是所有成员，_id每个成员的标识，整数型[0,255]

返回字段"ok" : 1 代表创建成功

rs.initiate({})，这里除了几个必须的，都是使用默认配置去启动，更多配置参数可以参考

 

4. 查看当前配置信息

rs.conf()

 

5. 查看副本集信息

rs.status()

 

到这，副本集就搭建完成

 

事务

1. 连接副本集

mongo mongodb://127.0.0.1:27017,127.0.0.1:27018/?replicaset=rs0

可以直接连接主副本的实例，也可以用这种url形式可以自动连接主副本（推荐使用后者）

 

2. 准备2条数据

db.balance.insert({ name: "wilson", balance: 100 }, { writeconcern: { w: "majority", wtimeout: 2000 } });
db.record.insert({ name: "wilson", change: 100, balance: 100, }, { writeconcern: { w: "majority", wtimeout: 2000 } });

 

测试正常提交

模拟一个扣钱动作，其中扣款和流水在一个事务里

session = db.getmongo().startsession({ readpreference: { mode: "primary" } });
balancecol = session.getdatabase("mongo").balance;
recordcol = session.getdatabase("mongo").record;
session.starttransaction({ readconcern: { level: "local" }, writeconcern: { w: "majority" } });

try {
    balancecol.updateone({ "name": "wilson" }, { $set: { "balance": 50 } });
    recordcol.insertone({ "name": "wilson", change: -50, balance: 50 });
} catch (error) {
    session.aborttransaction();
} 
session.committransaction();
session.endsession();

 

查看余额情况

db.balance.aggregate([
    { $lookup: { from: "record", localfield: "name", foreignfield: "name", as: "changs" } },
    { $project: { "_id": 0, "changs._id": 0, "changs.name": 0 } },
]);

结果，可以看到余额扣了，多了一条流水

{ "name" : "wilson", "balance" : 50, "changs" : [ { "change" : 100, "balance" : 100 }, { "change" : -50, "balance" : 50 } ] }

 

 

测试失败回滚

事务内多增加一个插入不存在的集合操作，让事务报错

session.starttransaction({ readconcern: { level: "local" }, writeconcern: { w: "majority" } });
try {
    balancecol.updateone({ "name": "wilson" }, { $set: { "balance": -50 } });
    recordcol.insertone({ "name": "wilson", change: -50, balance: 0 });
    session.getdatabase("mongo").user.insert({ "time": new date() });    //多增加操作一个不存在的表
} catch (error) {
    session.aborttransaction();
    throw error;
}
session.committransaction();
session.endsession();

 

返回报错信息，显示事务被中断了

2020-04-15t21:37:05.576+0800 e  query    [js] uncaught exception: error: command failed: {
        "errorlabels" : [
                "transienttransactionerror"
        ],
        "operationtime" : timestamp(1586957825, 1),
        "ok" : 0,
        "errmsg" : "transaction 0 has been aborted.",
        "code" : 251,
        "codename" : "nosuchtransaction",
        "$clustertime" : {
                "clustertime" : timestamp(1586957825, 1),
                "signature" : {
                        "hash" : bindata(0,"aaaaaaaaaaaaaaaaaaaaaaaaaaa="),
                        "keyid" : numberlong(0)
                }
        }
} :
_geterrorwithcode@src/mongo/shell/utils.js:25:13
doassert@src/mongo/shell/assert.js:18:14
_assertcommandworked@src/mongo/shell/assert.js:583:17
assert.commandworked@src/mongo/shell/assert.js:673:16
committransaction@src/mongo/shell/session.js:971:17
@(shell):1:1

再查看当前余额情况

db.balance.aggregate([
    { $lookup: { from: "record", localfield: "name", foreignfield: "name", as: "changs" } },
    { $project: { "_id": 0, "changs._id": 0, "changs.name": 0 } },
]);

可以看到，余额和流水都没变化。

{ "name" : "wilson", "balance" : 50, "changs" : [ { "change" : 100, "balance" : 100 }, { "change" : -50, "balance" : 50 } ] }

 

 参考文章

---

replication — mongodb manual

transactions — mongodb manual

转发请标明出处：https://www.cnblogs.com/wilsonpan/p/12708710.html