summaryrefslogtreecommitdiff
path: root/jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js')
-rw-r--r--jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js12
1 files changed, 8 insertions, 4 deletions
diff --git a/jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js b/jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js
index 18ff70c8fdf..ad3f197f644 100644
--- a/jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js
+++ b/jstests/concurrency/fsm_workloads/multi_statement_transaction_simple.js
@@ -15,6 +15,7 @@ var $config = (function() {
filter: {},
readConcern: {level: "snapshot"},
txnNumber: NumberLong(txnNumber),
+ startTransaction: true,
autocommit: false
});
assertWhenOwnColl.commandWorked(res);
@@ -26,6 +27,7 @@ var $config = (function() {
getMore: cursorId,
collection: collName,
txnNumber: NumberLong(txnNumber),
+ autocommit: false
});
assertWhenOwnColl.commandWorked(res);
res.cursor.nextBatch.forEach(function(account) {
@@ -34,8 +36,8 @@ var $config = (function() {
cursorId = res.cursor.id;
}
// commitTransaction can only be called on the admin database.
- assertWhenOwnColl.commandWorked(
- sessionDb.adminCommand({commitTransaction: 1, txnNumber: NumberLong(txnNumber)}));
+ assertWhenOwnColl.commandWorked(sessionDb.adminCommand(
+ {commitTransaction: 1, txnNumber: NumberLong(txnNumber), autocommit: false}));
return total;
}
@@ -65,13 +67,15 @@ var $config = (function() {
update: collName,
updates: [{q: {_id: transferFrom}, u: {$inc: {balance: -transferAmount}}}],
readConcern: {level: "snapshot"},
+ startTransaction: true,
autocommit: false
},
{
update: collName,
- updates: [{q: {_id: transferTo}, u: {$inc: {balance: transferAmount}}}]
+ updates: [{q: {_id: transferTo}, u: {$inc: {balance: transferAmount}}}],
+ autocommit: false
},
- {commitTransaction: 1}
+ {commitTransaction: 1, autocommit: false}
];
let hasWriteConflict;