summaryrefslogtreecommitdiff
path: root/jstests/sharding/multi_write_target.js
diff options
context:
space:
mode:
authorclang-format-7.0.1 <adam.martin@10gen.com>2019-07-26 18:42:24 -0400
committerADAM David Alan Martin <adam.martin@10gen.com>2019-07-26 18:42:24 -0400
commitc1a45ebbb0530e3d0201321d725527f1eb83ffce (patch)
treef523079dc5ded3052eefbdcaae424b7502df5b25 /jstests/sharding/multi_write_target.js
parentc9599d8610c3da0b7c3da65667aff821063cf5b9 (diff)
downloadmongo-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.js99
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();
})();