【MongoDB】4.0版本事务上手测试
> session=db.getMongo().startSession() session { "id" : UUID("b82d71b0-b698-4909-b5b8-a7845dba98b2") }>session.startTransaction()
> coll_1=session.getDatabase('dba').coll_1
dba.coll_1
> coll_2=session.getDatabase('dba').coll_2;
dba.coll_2
> coll_1.insertOne({'not_test':false})
{
"acknowledged" : true,
"insertedId" : ObjectId("5b37270429c5c0c486b4b17b")
}
> coll_2.insertOne({'not_test':false})
// 这里的事务回滚可能是因为超时引起的，默认事务生命周期最大值为1分钟
2018-06-30T15:00:50.629+0800 E QUERY 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
> coll_2.insertOne({'not_test':false})
2018-06-30T15:00:59.308+0800 E QUERY 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
// 事务超时回滚之后，应该还可以重开新的事务才对，这里老是报错
> session.startTransaction()
2018-06-30T15:01:04.932+0800 E QUERY 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
// 内部已经回滚掉了，结果竟然需要我手动回滚才行，晕
> session.abortTransaction()
> session.startTransaction()
> coll_1.insertOne({'not_test':false})
{
"acknowledged" : true,
"insertedId" : ObjectId("5b372ac229c5c0c486b4b17e")
}
> coll_2.insertOne({'not_test':false})
{
"acknowledged" : true,
"insertedId" : ObjectId("5b372ac529c5c0c486b4b17f")
}
// 试试能不能进行explain操作
> coll_1.explain().find({'test_explain':1})
2018-06-30T15:03:09.375+0800 E QUERY 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
// 尝试提交时报错
> session.commitTransaction()
2018-06-30T15:04:21.985+0800 E QUERY 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
> db.coll_1.find()
{ "_id" : ObjectId("5b371e120d6160b73a9fcee6"), "test" : true }
{ "_id" : ObjectId("5b371e6d0d6160b73a9fcee7"), "test" : true }
> db.coll_2.find()
// 这边可以看到，插入语句并没有真正被执行
> session.commitTransaction()
2018-06-30T15:05:46.288+0800 E QUERY 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
// 这儿又抽风了，内部回滚之后禁止提交操作，尝试进行回滚，结果说已经提交了，不能回滚，真是晕死
> session.abortTransaction()
2018-06-30T15:06:04.162+0800 E QUERY 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
页:
[1]