【Mongodb】事務

Mongodb從4.0開始支援副本集的多文檔事務，4.2支援分片叢集的多文檔事務，本文介紹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({})，這裡除了幾個必須的，都是使用預設配置去啟動，更多配置參數可以參考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