summaryrefslogtreecommitdiff
path: root/src/mongo/shell/session.js
diff options
context:
space:
mode:
authorPavi Vetriselvan <pvselvan@umich.edu>2018-04-04 15:22:31 -0400
committerPavi Vetriselvan <pvselvan@umich.edu>2018-04-04 15:25:11 -0400
commita893a7ca52f16645339ebd75bc521ddd0b95050d (patch)
tree96a8c1b21d015e7d05f3d765357862661ea8b872 /src/mongo/shell/session.js
parentff56c556ebb8dab6a9dccd2a7d416ed41c3bf1fc (diff)
downloadmongo-a893a7ca52f16645339ebd75bc521ddd0b95050d.tar.gz
SERVER-34287 only add writeConcern on abort and commit
Diffstat (limited to 'src/mongo/shell/session.js')
-rw-r--r--src/mongo/shell/session.js9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mongo/shell/session.js b/src/mongo/shell/session.js
index 0a2701742c8..3b65fd32ce5 100644
--- a/src/mongo/shell/session.js
+++ b/src/mongo/shell/session.js
@@ -664,9 +664,6 @@ var {
if (_txnOptions.getTxnReadConcern() !== undefined) {
cmdObjUnwrapped.readConcern = _txnOptions.getTxnReadConcern();
}
- if (_txnOptions.getTxnWriteConcern() !== undefined) {
- cmdObjUnwrapped.writeConcern = _txnOptions.getTxnWriteConcern();
- }
_firstStatement = false;
}
@@ -694,7 +691,11 @@ var {
};
const endTransaction = (commandName, driverSession) => {
- const cmd = {[commandName]: 1, txnNumber: NumberLong(_txnNumber)};
+ let cmd = {[commandName]: 1, txnNumber: NumberLong(_txnNumber)};
+ // writeConcern should only be specified on commit or abort
+ if (_txnOptions.getTxnWriteConcern() !== undefined) {
+ cmd.writeConcern = _txnOptions.getTxnWriteConcern();
+ }
// run command against the admin database.
const res = this.client.runCommand(driverSession, "admin", cmd, 0);
_txnState = ServerSession.TransactionStates.kInactive;