【MongoDB】4.0版本事务上手测试

zgdy

[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