diff options
Diffstat (limited to 'jstests/sharding/multi_mongos2.js')
-rw-r--r-- | jstests/sharding/multi_mongos2.js | 97 |
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(); })(); |