diff options
author | Pavi Vetriselvan <pvselvan@umich.edu> | 2018-04-04 15:22:31 -0400 |
---|---|---|
committer | Pavi Vetriselvan <pvselvan@umich.edu> | 2018-04-04 15:25:11 -0400 |
commit | a893a7ca52f16645339ebd75bc521ddd0b95050d (patch) | |
tree | 96a8c1b21d015e7d05f3d765357862661ea8b872 /src/mongo/shell/session.js | |
parent | ff56c556ebb8dab6a9dccd2a7d416ed41c3bf1fc (diff) | |
download | mongo-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.js | 9 |
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; |