概述
- 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({})，這里除了幾個必須的，都是使用默認配置去啟動，更多配置引數可以參考replica-configuration
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
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/8812.html
標籤：NoSQL
下一篇：Oracle自動存盤管理ASM