diff options
author | clang-format-7.0.1 <adam.martin@10gen.com> | 2019-07-26 18:42:24 -0400 |
---|---|---|
committer | ADAM David Alan Martin <adam.martin@10gen.com> | 2019-07-26 18:42:24 -0400 |
commit | c1a45ebbb0530e3d0201321d725527f1eb83ffce (patch) | |
tree | f523079dc5ded3052eefbdcaae424b7502df5b25 /jstests/sharding/multi_write_target.js | |
parent | c9599d8610c3da0b7c3da65667aff821063cf5b9 (diff) | |
download | mongo-c1a45ebbb0530e3d0201321d725527f1eb83ffce.tar.gz |
Apply formatting per `clang-format-7.0.1`
Diffstat (limited to 'jstests/sharding/multi_write_target.js')
-rw-r--r-- | jstests/sharding/multi_write_target.js | 99 |
1 files changed, 49 insertions, 50 deletions
diff --git a/jstests/sharding/multi_write_target.js b/jstests/sharding/multi_write_target.js index 9c4f37430da..90330f43cc0 100644 --- a/jstests/sharding/multi_write_target.js +++ b/jstests/sharding/multi_write_target.js @@ -2,72 +2,71 @@ // Tests that multi-writes (update/delete) target *all* shards and not just shards in the collection // (function() { - 'use strict'; +'use strict'; - var st = new ShardingTest({shards: 3, mongos: 2}); +var st = new ShardingTest({shards: 3, mongos: 2}); - var admin = st.s0.getDB("admin"); - var coll = st.s0.getCollection("foo.bar"); +var admin = st.s0.getDB("admin"); +var coll = st.s0.getCollection("foo.bar"); - assert.commandWorked(admin.runCommand({enableSharding: coll.getDB() + ""})); - st.ensurePrimaryShard(coll.getDB() + "", st.shard0.shardName); - assert.commandWorked(admin.runCommand({shardCollection: coll + "", key: {skey: 1}})); +assert.commandWorked(admin.runCommand({enableSharding: coll.getDB() + ""})); +st.ensurePrimaryShard(coll.getDB() + "", st.shard0.shardName); +assert.commandWorked(admin.runCommand({shardCollection: coll + "", key: {skey: 1}})); - assert.commandWorked(admin.runCommand({split: coll + "", middle: {skey: 0}})); - assert.commandWorked(admin.runCommand({split: coll + "", middle: {skey: 100}})); - assert.commandWorked( - admin.runCommand({moveChunk: coll + "", find: {skey: 0}, to: st.shard1.shardName})); - assert.commandWorked( - admin.runCommand({moveChunk: coll + "", find: {skey: 100}, to: st.shard2.shardName})); +assert.commandWorked(admin.runCommand({split: coll + "", middle: {skey: 0}})); +assert.commandWorked(admin.runCommand({split: coll + "", middle: {skey: 100}})); +assert.commandWorked( + admin.runCommand({moveChunk: coll + "", find: {skey: 0}, to: st.shard1.shardName})); +assert.commandWorked( + admin.runCommand({moveChunk: coll + "", find: {skey: 100}, to: st.shard2.shardName})); - jsTest.log("Testing multi-update..."); +jsTest.log("Testing multi-update..."); - // Put data on all shards - assert.writeOK(st.s0.getCollection(coll.toString()).insert({_id: 0, skey: -1, x: 1})); - assert.writeOK(st.s0.getCollection(coll.toString()).insert({_id: 1, skey: 1, x: 1})); - assert.writeOK(st.s0.getCollection(coll.toString()).insert({_id: 0, skey: 100, x: 1})); +// Put data on all shards +assert.writeOK(st.s0.getCollection(coll.toString()).insert({_id: 0, skey: -1, x: 1})); +assert.writeOK(st.s0.getCollection(coll.toString()).insert({_id: 1, skey: 1, x: 1})); +assert.writeOK(st.s0.getCollection(coll.toString()).insert({_id: 0, skey: 100, x: 1})); - // Non-multi-update doesn't work without shard key - assert.writeError(coll.update({x: 1}, {$set: {updated: true}}, {multi: false})); - assert.writeOK(coll.update({x: 1}, {$set: {updated: true}}, {multi: true})); +// Non-multi-update doesn't work without shard key +assert.writeError(coll.update({x: 1}, {$set: {updated: true}}, {multi: false})); +assert.writeOK(coll.update({x: 1}, {$set: {updated: true}}, {multi: true})); - // Ensure update goes to *all* shards - assert.neq(null, st.shard0.getCollection(coll.toString()).findOne({updated: true})); - assert.neq(null, st.shard1.getCollection(coll.toString()).findOne({updated: true})); - assert.neq(null, st.shard2.getCollection(coll.toString()).findOne({updated: true})); +// Ensure update goes to *all* shards +assert.neq(null, st.shard0.getCollection(coll.toString()).findOne({updated: true})); +assert.neq(null, st.shard1.getCollection(coll.toString()).findOne({updated: true})); +assert.neq(null, st.shard2.getCollection(coll.toString()).findOne({updated: true})); - // _id update works, and goes to all shards even on the stale mongos - var staleColl = st.s1.getCollection('foo.bar'); - assert.writeOK(staleColl.update({_id: 0}, {$set: {updatedById: true}}, {multi: false})); +// _id update works, and goes to all shards even on the stale mongos +var staleColl = st.s1.getCollection('foo.bar'); +assert.writeOK(staleColl.update({_id: 0}, {$set: {updatedById: true}}, {multi: false})); - // Ensure _id update goes to *all* shards - assert.neq(null, st.shard0.getCollection(coll.toString()).findOne({updatedById: true})); - assert.neq(null, st.shard2.getCollection(coll.toString()).findOne({updatedById: true})); +// Ensure _id update goes to *all* shards +assert.neq(null, st.shard0.getCollection(coll.toString()).findOne({updatedById: true})); +assert.neq(null, st.shard2.getCollection(coll.toString()).findOne({updatedById: true})); - jsTest.log("Testing multi-delete..."); +jsTest.log("Testing multi-delete..."); - // non-multi-delete doesn't work without shard key - assert.writeError(coll.remove({x: 1}, {justOne: true})); +// non-multi-delete doesn't work without shard key +assert.writeError(coll.remove({x: 1}, {justOne: true})); - assert.writeOK(coll.remove({x: 1}, {justOne: false})); +assert.writeOK(coll.remove({x: 1}, {justOne: false})); - // Ensure delete goes to *all* shards - assert.eq(null, st.shard0.getCollection(coll.toString()).findOne({x: 1})); - assert.eq(null, st.shard1.getCollection(coll.toString()).findOne({x: 1})); - assert.eq(null, st.shard2.getCollection(coll.toString()).findOne({x: 1})); +// Ensure delete goes to *all* shards +assert.eq(null, st.shard0.getCollection(coll.toString()).findOne({x: 1})); +assert.eq(null, st.shard1.getCollection(coll.toString()).findOne({x: 1})); +assert.eq(null, st.shard2.getCollection(coll.toString()).findOne({x: 1})); - // Put more on all shards - assert.writeOK(st.shard0.getCollection(coll.toString()).insert({_id: 0, skey: -1, x: 1})); - assert.writeOK(st.shard1.getCollection(coll.toString()).insert({_id: 1, skey: 1, x: 1})); - // Data not in chunks - assert.writeOK(st.shard2.getCollection(coll.toString()).insert({_id: 0, x: 1})); +// Put more on all shards +assert.writeOK(st.shard0.getCollection(coll.toString()).insert({_id: 0, skey: -1, x: 1})); +assert.writeOK(st.shard1.getCollection(coll.toString()).insert({_id: 1, skey: 1, x: 1})); +// Data not in chunks +assert.writeOK(st.shard2.getCollection(coll.toString()).insert({_id: 0, x: 1})); - assert.writeOK(coll.remove({_id: 0}, {justOne: true})); +assert.writeOK(coll.remove({_id: 0}, {justOne: true})); - // Ensure _id delete goes to *all* shards - assert.eq(null, st.shard0.getCollection(coll.toString()).findOne({x: 1})); - assert.eq(null, st.shard2.getCollection(coll.toString()).findOne({x: 1})); - - st.stop(); +// Ensure _id delete goes to *all* shards +assert.eq(null, st.shard0.getCollection(coll.toString()).findOne({x: 1})); +assert.eq(null, st.shard2.getCollection(coll.toString()).findOne({x: 1})); +st.stop(); })(); |