概述
- Mongodb 4.0 支持副本集的多文檔事務(wù)
- Mongodb 4.2 支持分片集群的多文檔事務(wù)
單個Server是不支持使用事務(wù)烛亦，所以要學(xué)習(xí)事務(wù)，需要搭建一個副本集/分片集群
另外需要說明是橘沥，單個文檔操作是原子操作魁袜，而mongodb是文檔型數(shù)據(jù)庫养渴，在單個文檔上爆办，可以嵌入對象/數(shù)組這種格式來維護數(shù)據(jù)的關(guān)系难咕，而不應(yīng)該使用多個集合來維護數(shù)據(jù)之間的關(guān)系。由于mongodb的這種特性距辆，所以單個文檔操作消除了很多需要事務(wù)的需求余佃。
搭建副本集
下面以最簡單的方式搭建一個副本集
- 啟動多個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"
參數(shù)說明
- replSet : 設(shè)置副本集名稱
- port : 設(shè)置端口跨算，因為我是單機爆土，所以只能設(shè)置不同端口
- dbpath: 數(shù)據(jù)文件路徑，注：文件夾必須是存在诸蚕，mongod不會自動創(chuàng)建
- logpath: 日志文件名稱步势，這個不需要提前新建，若不存在mongod會自動創(chuàng)建
- 連接任意一個實例挫望，這里就選擇27017這個默認端口
mongo
- 啟動副本集
rs.initiate({
_id: "rs0",
members: [
{ _id: 0, host: "127.0.0.1:27017" },
{ _id: 1, host: "127.0.0.1:27018" }
]
})
參數(shù)說明
- _id : 副本集名稱，就是啟動實例時指定那個名稱
- members : 這個就是所有成員狂窑，_id每個成員的標(biāo)識媳板，整數(shù)型[0,255]
返回字段"ok" : 1 代表創(chuàng)建成功
rs.initiate({})，這里除了幾個必須的泉哈，都是使用默認配置去啟動蛉幸，更多配置參數(shù)可以參考replica-configuration
- 查看當(dāng)前配置信息
rs.conf()
- 查看副本集信息
rs.status()
到這破讨，副本集就搭建完成
事務(wù)
- 連接副本集
mongo mongodb://127.0.0.1:27017,127.0.0.1:27018/?replicaSet=rs0
- 準備2條數(shù)據(jù)
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 } });
測試正常提交
模擬一個扣錢動作，其中扣款和流水在一個事務(wù)里
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 } },
]);
結(jié)果
{ "name" : "Wilson", "balance" : 50, "changs" : [ { "change" : 100, "balance" : 100 }, { "change" : -50, "balance" : 50 } ] }
測試失敗回滾
事務(wù)內(nèi)多增加一個插入不存在的集合操作奕纫，讓事務(wù)報錯
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
再查看當(dāng)前余額情況
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 } ] }
可以看到提陶，余額和流水都沒變化。
