summaryrefslogtreecommitdiff
path: root/jstests/sharding/multi_mongos2.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/multi_mongos2.js')
-rw-r--r--jstests/sharding/multi_mongos2.js97
1 files changed, 51 insertions, 46 deletions
diff --git a/jstests/sharding/multi_mongos2.js b/jstests/sharding/multi_mongos2.js
index 43be2ecd9da..9184ce9e807 100644
--- a/jstests/sharding/multi_mongos2.js
+++ b/jstests/sharding/multi_mongos2.js
@@ -1,73 +1,78 @@
// This tests sharding an existing collection that both shards are aware of (SERVER-2828)
(function() {
-var s1 = new ShardingTest({ name: "multi_mongos1", shards: 2, mongos: 2 });
-s2 = s1._mongos[1];
+ var s1 = new ShardingTest({name: "multi_mongos1", shards: 2, mongos: 2});
+ s2 = s1._mongos[1];
-s1.adminCommand( { enablesharding : "test" } );
-s1.ensurePrimaryShard('test', 'shard0001');
-s1.adminCommand( { shardcollection : "test.foo" , key : { num : 1 } } );
+ s1.adminCommand({enablesharding: "test"});
+ s1.ensurePrimaryShard('test', 'shard0001');
+ s1.adminCommand({shardcollection: "test.foo", key: {num: 1}});
-s1.config.databases.find().forEach( printjson );
+ s1.config.databases.find().forEach(printjson);
-// test queries
+ // test queries
-s1.getDB('test').existing.insert({_id:1});
-assert.eq(1, s1.getDB('test').existing.count({_id:1}));
-assert.eq(1, s2.getDB('test').existing.count({_id:1}));
+ s1.getDB('test').existing.insert({_id: 1});
+ assert.eq(1, s1.getDB('test').existing.count({_id: 1}));
+ assert.eq(1, s2.getDB('test').existing.count({_id: 1}));
-// Balancer is by default stopped, thus it will not interfere with manual chunk moves.
+ // Balancer is by default stopped, thus it will not interfere with manual chunk moves.
-s2.adminCommand( { shardcollection : "test.existing" , key : { _id : 1 } } );
-assert.commandWorked(s2.adminCommand({ split: "test.existing", middle: { _id: 5 }}));
+ s2.adminCommand({shardcollection: "test.existing", key: {_id: 1}});
+ assert.commandWorked(s2.adminCommand({split: "test.existing", middle: {_id: 5}}));
-res = s2.getDB( "admin" ).runCommand( { moveChunk: "test.existing" ,
- find : { _id : 1 } ,
- to : s1.getOther( s1.getPrimaryShard( "test" ) ).name } );
+ res = s2.getDB("admin").runCommand({
+ moveChunk: "test.existing",
+ find: {_id: 1},
+ to: s1.getOther(s1.getPrimaryShard("test")).name
+ });
-assert.eq(1 , res.ok, tojson(res));
+ assert.eq(1, res.ok, tojson(res));
-s1.startBalancer();
+ s1.startBalancer();
-printjson( s2.adminCommand( {"getShardVersion" : "test.existing" } ) );
-printjson( new Mongo(s1.getPrimaryShard( "test" ).name).getDB( "admin" )
- .adminCommand( {"getShardVersion" : "test.existing" } ) );
+ printjson(s2.adminCommand({"getShardVersion": "test.existing"}));
+ printjson(new Mongo(s1.getPrimaryShard("test").name)
+ .getDB("admin")
+ .adminCommand({"getShardVersion": "test.existing"}));
-assert.eq(1, s1.getDB('test').existing.count({_id:1})); // SERVER-2828
-assert.eq(1, s2.getDB('test').existing.count({_id:1}));
+ assert.eq(1, s1.getDB('test').existing.count({_id: 1})); // SERVER-2828
+ assert.eq(1, s2.getDB('test').existing.count({_id: 1}));
-// test stats
+ // test stats
-s1.getDB('test').existing2.insert({_id:1});
-assert.eq(1, s1.getDB('test').existing2.count({_id:1}));
-assert.eq(1, s2.getDB('test').existing2.count({_id:1}));
+ s1.getDB('test').existing2.insert({_id: 1});
+ assert.eq(1, s1.getDB('test').existing2.count({_id: 1}));
+ assert.eq(1, s2.getDB('test').existing2.count({_id: 1}));
-s2.adminCommand( { shardcollection : "test.existing2" , key : { _id : 1 } } );
-assert.commandWorked(s2.adminCommand({ split: "test.existing2", middle: { _id: 5 }}));
+ s2.adminCommand({shardcollection: "test.existing2", key: {_id: 1}});
+ assert.commandWorked(s2.adminCommand({split: "test.existing2", middle: {_id: 5}}));
-var res = s1.getDB('test').existing2.stats();
-printjson( res );
-assert.eq(true, res.sharded); //SERVER-2828
-assert.eq(true, s2.getDB('test').existing2.stats().sharded);
+ var res = s1.getDB('test').existing2.stats();
+ printjson(res);
+ assert.eq(true, res.sharded); // SERVER-2828
+ assert.eq(true, s2.getDB('test').existing2.stats().sharded);
-// test admin commands
+ // test admin commands
-s1.getDB('test').existing3.insert({_id:1});
-assert.eq(1, s1.getDB('test').existing3.count({_id:1}));
-assert.eq(1, s2.getDB('test').existing3.count({_id:1}));
+ s1.getDB('test').existing3.insert({_id: 1});
+ assert.eq(1, s1.getDB('test').existing3.count({_id: 1}));
+ assert.eq(1, s2.getDB('test').existing3.count({_id: 1}));
-s1.stopBalancer();
+ s1.stopBalancer();
-s2.adminCommand( { shardcollection : "test.existing3" , key : { _id : 1 } } );
-assert.commandWorked(s2.adminCommand({ split: "test.existing3", middle: { _id: 5 }}));
+ s2.adminCommand({shardcollection: "test.existing3", key: {_id: 1}});
+ assert.commandWorked(s2.adminCommand({split: "test.existing3", middle: {_id: 5}}));
-res = s1.getDB( "admin" ).runCommand( { moveChunk: "test.existing3",
- find : { _id : 1 },
- to : s1.getOther( s1.getPrimaryShard( "test" ) ).name } );
-assert.eq(1 , res.ok, tojson(res));
+ res = s1.getDB("admin").runCommand({
+ moveChunk: "test.existing3",
+ find: {_id: 1},
+ to: s1.getOther(s1.getPrimaryShard("test")).name
+ });
+ assert.eq(1, res.ok, tojson(res));
-s1.startBalancer();
+ s1.startBalancer();
-s1.stop();
+ s1.stop();
})();