diff options
Diffstat (limited to 'jstests/sharding/multi_shard_transaction_without_majority_reads.js')
-rw-r--r-- | jstests/sharding/multi_shard_transaction_without_majority_reads.js | 42 |
1 files changed, 21 insertions, 21 deletions
diff --git a/jstests/sharding/multi_shard_transaction_without_majority_reads.js b/jstests/sharding/multi_shard_transaction_without_majority_reads.js index dafdf503f84..8ddb69a665d 100644 --- a/jstests/sharding/multi_shard_transaction_without_majority_reads.js +++ b/jstests/sharding/multi_shard_transaction_without_majority_reads.js @@ -6,34 +6,34 @@ */ (function() { - 'use strict'; +'use strict'; - const st = new ShardingTest({shards: 2, rs: {nodes: 1, enableMajorityReadConcern: 'false'}}); +const st = new ShardingTest({shards: 2, rs: {nodes: 1, enableMajorityReadConcern: 'false'}}); - assert.commandWorked(st.s0.adminCommand({enableSharding: 'TestDB'})); - st.ensurePrimaryShard('TestDB', st.shard0.shardName); - assert.commandWorked(st.s0.adminCommand({shardCollection: 'TestDB.TestColl', key: {_id: 1}})); +assert.commandWorked(st.s0.adminCommand({enableSharding: 'TestDB'})); +st.ensurePrimaryShard('TestDB', st.shard0.shardName); +assert.commandWorked(st.s0.adminCommand({shardCollection: 'TestDB.TestColl', key: {_id: 1}})); - const coll = st.s0.getDB('TestDB').TestColl; - assert.writeOK(coll.insert({_id: -1, x: 0})); - assert.writeOK(coll.insert({_id: 1, x: 0})); - assert.commandWorked(st.s0.adminCommand({split: 'TestDB.TestColl', middle: {_id: 1}})); - assert.commandWorked(st.s0.adminCommand( - {moveChunk: 'TestDB.TestColl', find: {_id: 1}, to: st.shard1.shardName})); +const coll = st.s0.getDB('TestDB').TestColl; +assert.writeOK(coll.insert({_id: -1, x: 0})); +assert.writeOK(coll.insert({_id: 1, x: 0})); +assert.commandWorked(st.s0.adminCommand({split: 'TestDB.TestColl', middle: {_id: 1}})); +assert.commandWorked( + st.s0.adminCommand({moveChunk: 'TestDB.TestColl', find: {_id: 1}, to: st.shard1.shardName})); - assert.writeOK(coll.update({_id: -1}, {$inc: {x: 1}})); - assert.writeOK(coll.update({_id: 1}, {$inc: {x: 1}})); +assert.writeOK(coll.update({_id: -1}, {$inc: {x: 1}})); +assert.writeOK(coll.update({_id: 1}, {$inc: {x: 1}})); - const session = st.s0.startSession(); - const sessionColl = session.getDatabase('TestDB').TestColl; +const session = st.s0.startSession(); +const sessionColl = session.getDatabase('TestDB').TestColl; - session.startTransaction(); +session.startTransaction(); - assert.writeOK(sessionColl.update({_id: -1}, {$inc: {x: 1}})); - assert.writeOK(sessionColl.update({_id: 1}, {$inc: {x: 1}})); +assert.writeOK(sessionColl.update({_id: -1}, {$inc: {x: 1}})); +assert.writeOK(sessionColl.update({_id: 1}, {$inc: {x: 1}})); - assert.commandFailedWithCode(session.commitTransaction_forTesting(), - ErrorCodes.ReadConcernMajorityNotEnabled); +assert.commandFailedWithCode(session.commitTransaction_forTesting(), + ErrorCodes.ReadConcernMajorityNotEnabled); - st.stop(); +st.stop(); })(); |