2. 程式人生 > >【MongoDB】4.0版本事務上手測試

【MongoDB】4.0版本事務上手測試

阿新 • • 發佈：2018-06-30
進行 ted back edi 單文檔 .get -m javascrip 多行

事務上手測試

基礎：

原來3版本的只能叫單文檔事務，即針對行的事務。所以沒必要顯式提供調用，多文檔事務由於有損耗，照顧到性能的需求，提供了事務開啟關閉的接口。
多行，多集合，多庫之間讀肯定會牽扯到一致性讀，所以多文檔事務肯定是有必要的。
4.2版本可能會支持分片系統多文檔事務，4.0的多文檔事務最多只面向復制集

準備

集合：

use dba;
[10.240.129.36:30001_primary@dba]> db.coll_2.find()
[10.240.129.36:30001_primary@dba]> db.coll_1.find()
{ "_id" : ObjectId("5b371e120d6160b73a9fcee6"), "test" : true }
{ "_id" : ObjectId("5b371e6d0d6160b73a9fcee7"), "test" : true }

精簡命令：


// 顯式開啟一個會話（難道通過shell鏈接來本身不就是會話嗎？）
session=db.getMongo().startSession()
// 顯式開啟事務
session.startTransaction()
// 獲取表對象
coll_1=session.getDatabase(‘dba‘).coll_1
coll_2=session.getDatabase(‘dba‘).coll_2;
// 使用表對象的插入函數進行插入
coll_1.insertOne({‘not_test‘:false})
coll_2.insertOne({‘not_test‘:false})
// 提交事務
session.commitTransaction()
// 回滾事務
session.abortTransaction()
// 檢查事務準確性
db.coll_1.find()
db.coll_2.find()

超時參數怎麽設置？

默認事務生命周期為60秒，超出後會被自動清理

// The minimum value for transactionLifetimeLimitSeconds is 1 second.
db.adminCommand( { setParameter: 1, transactionLifetimeLimitSeconds: 30 } )
// You can also set parameter transactionLifetimeLimitSeconds at startup time.
// 可以考慮寫在配置文件中
mongod --setParameter "transactionLifetimeLimitSeconds=30"

第一次嘗試

因為忘記設置後向兼容性，執行失敗，在同一個shell中進行設置後，再次插入，提示事務不存在

[10.240.129.36:30001_primary@dba]> Session.startTransactions()
2018-06-30T14:17:10.670+0800 E QUERY    [js] ReferenceError: Session is not defined :
@(shell):1:1
[10.240.129.36:30001_primary@dba]> db.getMongo()
connection to 127.0.0.1:30001
[10.240.129.36:30001_primary@dba]> db.getMongo().startSession()
session { "id" : UUID("887f4564-4f8a-4783-886d-a55a536f41aa") }
[10.240.129.36:30001_primary@dba]> session=db.getMongo().startSession()
session { "id" : UUID("9b3e10b9-93cd-4010-b1a3-0e7b49796db3") }
[10.240.129.36:30001_primary@dba]> session.startTransaction()
[10.240.129.36:30001_primary@dba]> coll_1=session.getDatabase(‘dba‘).coll_1;
dba.coll_1
[10.240.129.36:30001_primary@dba]> coll_2=session.getDatabase(‘dba‘).coll_2;
dba.coll_2
[10.240.129.36:30001_primary@dba]> coll_1.insertOne({‘not_test‘:false})
// 後向兼容性要求為4，也就是說想開啟事務必須是mongod4以上的版本
2018-06-30T14:28:55.708+0800 E QUERY    [js] WriteCommandError: Transactions are only supported in featureCompatibilityVersion 4.0. See http://dochub.mongodb.org/core/4.0-feature-compatibility for more information. :
WriteCommandError({
    "ok" : 0,
    "errmsg" : "Transactions are only supported in featureCompatibilityVersion 4.0. See http://dochub.mongodb.org/core/4.0-feature-compatibility for more information.",
    "code" : 50773,
    "codeName" : "Location50773"
})
WriteCommandError@src/mongo/shell/bulk_api.js:420:48
Bulk/executeBatch@src/mongo/shell/bulk_api.js:902:1
Bulk/this.execute@src/mongo/shell/bulk_api.js:1150:21
DBCollection.prototype.insertOne@src/mongo/shell/crud_api.js:252:9
@(shell):1:1
[10.240.129.36:30001_primary@dba]> db.adminCommand({setFeatureCompatibilityVersion:‘4.0‘})
{ "ok" : 1 }

// 可以看到，報錯，重新設置版本兼容性後，原先的事務出現了問題
[10.240.129.36:30001_primary@dba]> coll_1.insertOne({‘not_test‘:false})
2018-06-30T14:31:16.706+0800 E QUERY    [js] WriteCommandError: Given transaction number 0 does not match any in-progress transactions. :
WriteCommandError({
    "errorLabels" : [
        "TransientTransactionError"
    ],
    "ok" : 0,
    "errmsg" : "Given transaction number 0 does not match any in-progress transactions.",
    "code" : 251,
    "codeName" : "NoSuchTransaction"
})
WriteCommandError@src/mongo/shell/bulk_api.js:420:48
Bulk/executeBatch@src/mongo/shell/bulk_api.js:902:1
Bulk/this.execute@src/mongo/shell/bulk_api.js:1150:21
DBCollection.prototype.insertOne@src/mongo/shell/crud_api.js:252:9
@(shell):1:1

// 事務怎麽也調不好了

[10.240.129.36:30001_primary@dba]> session.startTransaction()
2018-06-30T14:33:53.293+0800 E QUERY    [js] Error: Transaction already in progress on this session. :
startTransaction@src/mongo/shell/session.js:732:1
startTransaction@src/mongo/shell/session.js:925:17
@(shell):1:1
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]>
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]> db.getMongo().abortTransaction
[10.240.129.36:30001_primary@dba]> exit
// 直接退出當前連接

第二次嘗試：

[10.240.129.36:30001_primary@admin]> session=db.getMongo().startSession()
session { "id" : UUID("b82d71b0-b698-4909-b5b8-a7845dba98b2") }
[10.240.129.36:30001_primary@admin]>  session.startTransaction()
[10.240.129.36:30001_primary@admin]> coll_1=session.getDatabase(‘dba‘).coll_1
dba.coll_1
[10.240.129.36:30001_primary@admin]> coll_2=session.getDatabase(‘dba‘).coll_2;
dba.coll_2
[10.240.129.36:30001_primary@admin]> coll_1.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b37270429c5c0c486b4b17b")
}
[10.240.129.36:30001_primary@admin]> coll_2.insertOne({‘not_test‘:false})

// 這裏的事務回滾可能是因為超時引起的，默認事務生命周期最大值為1分鐘

2018-06-30T15:00:50.629+0800 E QUERY    [js] WriteCommandError: Transaction 0 has been aborted. :
WriteCommandError({
    "errorLabels" : [
        "TransientTransactionError"
    ],
    "ok" : 0,
    "errmsg" : "Transaction 0 has been aborted.",
    "code" : 251,
    "codeName" : "NoSuchTransaction"
})
WriteCommandError@src/mongo/shell/bulk_api.js:420:48
Bulk/executeBatch@src/mongo/shell/bulk_api.js:902:1
Bulk/this.execute@src/mongo/shell/bulk_api.js:1150:21
DBCollection.prototype.insertOne@src/mongo/shell/crud_api.js:252:9
@(shell):1:1
[10.240.129.36:30001_primary@admin]> coll_2.insertOne({‘not_test‘:false})
2018-06-30T15:00:59.308+0800 E QUERY    [js] WriteCommandError: Transaction 0 has been aborted. :
WriteCommandError({
    "errorLabels" : [
        "TransientTransactionError"
    ],
    "ok" : 0,
    "errmsg" : "Transaction 0 has been aborted.",
    "code" : 251,
    "codeName" : "NoSuchTransaction"
})
WriteCommandError@src/mongo/shell/bulk_api.js:420:48
Bulk/executeBatch@src/mongo/shell/bulk_api.js:902:1
Bulk/this.execute@src/mongo/shell/bulk_api.js:1150:21
DBCollection.prototype.insertOne@src/mongo/shell/crud_api.js:252:9
@(shell):1:1

// 事務超時回滾之後，應該還可以重開新的事務才對，這裏老是報錯

[10.240.129.36:30001_primary@admin]> session.startTransaction()
2018-06-30T15:01:04.932+0800 E QUERY    [js] Error: Transaction already in progress on this session. :
startTransaction@src/mongo/shell/session.js:732:1
startTransaction@src/mongo/shell/session.js:925:17
@(shell):1:1

// 內部已經回滾掉了，結果竟然需要我手動回滾才行，暈

[10.240.129.36:30001_primary@admin]> session.abortTransaction()
[10.240.129.36:30001_primary@admin]> session.startTransaction()
[10.240.129.36:30001_primary@admin]> coll_1.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b372ac229c5c0c486b4b17e")
}
[10.240.129.36:30001_primary@admin]> coll_2.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b372ac529c5c0c486b4b17f")
}

// 試試能不能進行explain操作

[10.240.129.36:30001_primary@admin]> coll_1.explain().find({‘test_explain‘:1})
2018-06-30T15:03:09.375+0800 E QUERY    [js] Error: explain failed: {
    "ok" : 0,
    "errmsg" : "Cannot run ‘explain‘ in a multi-document transaction.",
    "code" : 50767,
    "codeName" : "Location50767"
} :  // 果然是報錯了呢，在事務中不能進行explain操作
_getErrorWithCode@src/mongo/shell/utils.js:25:13
throwOrReturn@src/mongo/shell/explainable.js:31:1
constructor/this.finish@src/mongo/shell/explain_query.js:171:24
constructor/this.shellPrint@src/mongo/shell/explain_query.js:210:26
shellPrintHelper@src/mongo/shell/utils.js:594:1
@(shell2):1:1

// 嘗試提交時報錯
[10.240.129.36:30001_primary@admin]> session.commitTransaction()
2018-06-30T15:04:21.985+0800 E QUERY    [js] Error: command failed: {
    "errorLabels" : [
        "TransientTransactionError"
    ],
    "ok" : 0,
    "errmsg" : "Transaction 1 has been aborted.",
    "code" : 251,
    "codeName" : "NoSuchTransaction"
} :
_getErrorWithCode@src/mongo/shell/utils.js:25:13
doassert@src/mongo/shell/assert.js:18:14
_assertCommandWorked@src/mongo/shell/assert.js:534:17
assert.commandWorked@src/mongo/shell/assert.js:618:16
commitTransaction@src/mongo/shell/session.js:929:17
@(shell):1:1

[10.240.129.36:30001_primary@dba]> db.coll_1.find()
{ "_id" : ObjectId("5b371e120d6160b73a9fcee6"), "test" : true }
{ "_id" : ObjectId("5b371e6d0d6160b73a9fcee7"), "test" : true }
[10.240.129.36:30001_primary@dba]> db.coll_2.find()
// 這邊可以看到，插入語句並沒有真正被執行

[10.240.129.36:30001_primary@dba]> session.commitTransaction()
2018-06-30T15:05:46.288+0800 E QUERY    [js] Error: command failed: {
    "errorLabels" : [
        "TransientTransactionError"
    ],
    "ok" : 0,
    "errmsg" : "Transaction 1 has been aborted.",
    "code" : 251,
    "codeName" : "NoSuchTransaction"
} :
_getErrorWithCode@src/mongo/shell/utils.js:25:13
doassert@src/mongo/shell/assert.js:18:14
_assertCommandWorked@src/mongo/shell/assert.js:534:17
assert.commandWorked@src/mongo/shell/assert.js:618:16
commitTransaction@src/mongo/shell/session.js:929:17
@(shell):1:1

// 這兒又抽風了，內部回滾之後禁止提交操作，嘗試進行回滾，結果說已經提交了，不能回滾，真是暈死

[10.240.129.36:30001_primary@dba]> session.abortTransaction()
2018-06-30T15:06:04.162+0800 E QUERY    [js] Error: Cannot call abortTransaction after calling commitTransaction. :
abortTransaction@src/mongo/shell/session.js:764:1
abortTransaction@src/mongo/shell/session.js:934:17
@(shell):1:1

第三次嘗試（成功提交）：

[10.240.129.36:30001_primary@admin]> session=db.getMongo().startSession()
session { "id" : UUID("e7935985-160d-4969-adfe-3bae401e155f") }
[10.240.129.36:30001_primary@admin]> session.startTransaction()
[10.240.129.36:30001_primary@admin]> coll_1=session.getDatabase(‘dba‘).coll_1
dba.coll_1
[10.240.129.36:30001_primary@admin]> coll_2=session.getDatabase(‘dba‘).coll_2;
dba.coll_2
[10.240.129.36:30001_primary@admin]> coll_1.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b373202d0b208b7386e9c20")
}
[10.240.129.36:30001_primary@admin]> coll_2.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b373202d0b208b7386e9c21")
}
[10.240.129.36:30001_primary@admin]> session.commitTransaction()
[10.240.129.36:30001_primary@admin]> use dba
switched to db dba
[10.240.129.36:30001_primary@dba]> db.coll_1.find()
{ "_id" : ObjectId("5b371e120d6160b73a9fcee6"), "test" : true }
{ "_id" : ObjectId("5b371e6d0d6160b73a9fcee7"), "test" : true }
{ "_id" : ObjectId("5b373202d0b208b7386e9c20"), "not_test" : false }
[10.240.129.36:30001_primary@dba]> db.coll_2.find()
{ "_id" : ObjectId("5b373202d0b208b7386e9c21"), "not_test" : false }

第四次嘗試（測試回滾）：

[10.240.129.36:30001_primary@admin]> session=db.getMongo().startSession()
session { "id" : UUID("e7935985-160d-4969-adfe-3bae401e155f") }
[10.240.129.36:30001_primary@admin]> session.startTransaction()
[10.240.129.36:30001_primary@admin]> coll_1=session.getDatabase(‘dba‘).coll_1
dba.coll_1
[10.240.129.36:30001_primary@admin]> coll_2=session.getDatabase(‘dba‘).coll_2;
dba.coll_2
[10.240.129.36:30001_primary@admin]> coll_1.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b373202d0b208b7386e9c20")
}
[10.240.129.36:30001_primary@admin]> coll_2.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b373202d0b208b7386e9c21")
}
[10.240.129.36:30001_primary@admin]> session.commitTransaction()
[10.240.129.36:30001_primary@admin]> use dba
switched to db dba
[10.240.129.36:30001_primary@dba]> db.coll_1.find()
{ "_id" : ObjectId("5b371e120d6160b73a9fcee6"), "test" : true }
{ "_id" : ObjectId("5b371e6d0d6160b73a9fcee7"), "test" : true }
{ "_id" : ObjectId("5b373202d0b208b7386e9c20"), "not_test" : false }
[10.240.129.36:30001_primary@dba]> db.coll_2.find()
{ "_id" : ObjectId("5b373202d0b208b7386e9c21"), "not_test" : false }
[10.240.129.36:30001_primary@dba]> session=db.getMongo().startSession()
session { "id" : UUID("cc0e2d23-1766-4ea5-87a5-957efcae28ad") }
[10.240.129.36:30001_primary@dba]> session.startTransaction()
[10.240.129.36:30001_primary@dba]> coll_1=session.getDatabase(‘dba‘).coll_1
dba.coll_1
[10.240.129.36:30001_primary@dba]> coll_2=session.getDatabase(‘dba‘).coll_2;
dba.coll_2
[10.240.129.36:30001_primary@dba]> coll_1.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b3732f0d0b208b7386e9c22")
}
[10.240.129.36:30001_primary@dba]> coll_2.insertOne({‘not_test‘:false})
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5b3732f1d0b208b7386e9c23")
}
[10.240.129.36:30001_primary@dba]> session.abortTransaction()
[10.240.129.36:30001_primary@dba]> db.coll_2.find()
{ "_id" : ObjectId("5b373202d0b208b7386e9c21"), "not_test" : false }
[10.240.129.36:30001_primary@dba]> db.coll_1.find()
{ "_id" : ObjectId("5b371e120d6160b73a9fcee6"), "test" : true }
{ "_id" : ObjectId("5b371e6d0d6160b73a9fcee7"), "test" : true }
{ "_id" : ObjectId("5b373202d0b208b7386e9c20"), "not_test" : false }

註意

默認事務超時時間有點短，1分鐘
默認鎖等待時間短，5毫秒
事務的操作有些繁瑣，不如RDS的 begin commit rollback方便（指SHELL操作）
一個事務的對應的oplog不能超過16M（指BSON格式的文件大小)
顯式事務功能的開啟對WT緩存提出了新的要求。類似於IBP事務不按時提交，類似undo用於存放快照或者舊版本的東西肯定會占用大量WT的空間。

【MongoDB】4.0版本事務上手測試

相關推薦

【MongoDB】4.0版本事務上手測試

進行 ted back edi 單文檔 .get -m javascrip 多行 事務上手測試 基礎： 原來3版本的只能叫單文檔事務，即針對行的事務。所以沒必要顯式提供調用，多文檔事務由於有損耗，照顧到性能的需求，提供了事務開啟關閉的接口。多行，多集合，多庫之間讀肯定會牽扯

【Unity3D】5.0版本之後的AssetBundle資源的打包和解析載入

一、前言 這幾天在研究AssetBundle資源打包盒解析載入，也踩過很多坑，參考過很多人的文章 發現很多人關於AssetBundle的文章不是API過時了不能用，就是有點亂 也不是有點亂，就是摸不著頭腦，讓人不能快速的get到這個東西如何使用 所以我特意在踩

【mongodb】centos7 yum方式安裝Mongodb 4.0

1. 建立使用者 （當前操作使用者: root） [root]# adduser mongo #新增使用者 [root]# passwd mongo #為使用者設定密碼 2. 賦予sudo許可權

【JMeter】關於測試計劃 - 4.0 版本

文章目錄 一、測試計劃 1、Test Plan (測試計劃) 2、各配置項 2.1 測試計劃名稱和註釋 2.2 使用者定義的變數 2.3 獨立執行每個執行緒組 2.4 Run tearDown

【JMeter】關於執行緒組 - 4.0 版本

文章目錄 1、執行緒組 2、setup thread group 3、teardown thread group 4、thread group (執行緒組) 5、執行緒組基本設定 5.1 取樣器錯誤後要執

MongoDB 4.0版本

dev 機制 ssl 移動互 關系數據庫 能力 環境變量 分享圖片 tex MongoDB 簡介 是一款跨平臺、面向文檔的數據庫。可實實現高性能、高可、可用性、並且能輕松擴展。是一個基於分布式文件存儲開源數據庫系統，在高負載的清苦下添加更多節點。 MongoDB 也是一個

MongoDB 4.0版本的安裝與配置

由於還是學習Python的一枚小白，所以在安裝MongoDB資料庫的時候也遇到了很多問題，安裝完之後一直連線不上埠。 下面分享一下我安裝、配置MongoDB的過程，希望給那些萬一遇到同樣問題的小白提供參考。 一、下載MongoDB資料庫安裝 1、到

opentcs 夜光開發手冊（四）【針對最新4.12版本】

夜光序言： 我是人間惆悵客, 知君何事淚縱橫, 斷腸聲裡憶平生。     正文： 新特性: 為車輛引入一個顯式整合級別屬性，該屬性表示車輛應該整合到系統中的程度。(將整合級別設定為TO_BE_UTILIZED，取代了以前用於整合車輛的手動

【MarketAnalysis總結】4.0使用者登入等賬戶安全訪問的實現

在這部分，我主要實現了使用者賬戶登入的身份校驗，使用者賬戶的註冊，使用者的登出、規避了繞過登入訪問的不合法請求，以及拒絕非法請求的實現。在具體論述每一部分之前，我先來說明使用者安全與許可權部分用到的表結構。這裡用到的具體表結構如圖4.1，他們的邏輯關係圖如圖4.2，E-R圖如

【Ubuntu-opencv3.4.0-Error】對‘cv::Mat::updateContinuityFlag()’未定義的引用

/path/libTrackKcf.a(kcftracker.cpp.o)：在函式‘ot::KCFTracker::KCFTracker(bool, bool, bool, bool)’中： kcftracker.cpp:(.text+0x673)：對‘cv::Mat::up

【筆記】webpack4.0教程_配置詳解_圖文_新手入門_快速上手

前言 這篇筆記會從node安裝開始，到搭建基礎的webpack環境為止。中間每一步的配置和遇到的術語、名詞，我都會做簡單的解釋。 同時，這篇博文是一篇記錄我學習webpack的過程筆記，因為我也在學習過程，如果有記述錯誤之處，歡迎指正。 【注：全程系統環境

【MongoDB】mongodump and mongorestore of mogodb

sso next south stl win amp log avi cti The another tool will be mentioned in this blog, namely mongodump and mongorestore. Genera

Jumpserver v0.4.0 版本安裝詳細過程

sqlite3環境系統: CentOS 6.5 x86_64 miniPython: 版本 3.6 大部分功能兼容 2.7安裝目錄/opt/jumpserver/opt/coco一. 環境準備1.1 安裝基本工具和庫$ yum -y install sqlite-devel git epel-release

【MongoDB】The basic operation of Index in MongoDB

drop desc ould lar text and tracking num ack In the past four blogs, we attached importance to the index, including description and c

【mysql】查看版本的四種方法

span clas latin min days use ble dha pre 1：在終端下：mysql -V。 以下是代碼片段： [[email protected]/* */ ~]$ mysql -V mysql Ver 14.7 Distrib 4.

【電路】4線智能調速風扇

pc機 nbsp 電路 logs cnblogs .cn 引入 http image PC機內4線風扇，參考型號 貓頭鷹NF-A6x25 PWM 4根線分別是：PWM - 測速 - 12V+ - 地線(pin1) PWM拉高/懸空會全速轉，拉低停止，給占空比控速。

【16】vuex2.0 之 getter

this map 多個參數 name not 同時 方便 比較 compute 　有的組件中獲取到 store 中的state, 需要對進行加工才能使用，computed 屬性中就需要寫操作函數，如果有多個組件中都需要進行這個操作，那麽在各個組件中都寫相同的函數，那就非常

【15】vuex2.0 之 modules

his 來看 暴露 方式 ets 我們 spa web space 　　vue 使用的是單一狀態樹對整個應用的狀態進行管理，也就是說，應用中的所有狀態都放到store中，如果是一個大型應用，狀態非常多， store 就會非常龐大，不太好管理。這時vuex 提供了另外一種方式

【Spring】16、註解事務 @Transactional

引用 相關 連接池 每次 one 作用 事務性 簡單 這一 概述 事務管理對於企業應用來說是至關重要的，即使出現異常情況，它也可以保證數據的一致性。Spring Framework對事務管理提供了一致的抽象，其特點如下： 為不同的事務API提供一致的編程模型，

【MongoDB】MongoDB的一些操作命令

更新 use 使用 查看 count 一個 對象 分頁 ins 我們首先應該知道MongoDB的數據結構：MongoDB:庫-->集合-->JSON對象 查看 show dbs //查看有哪些庫 show collections //查看庫中有哪些