diff options
Diffstat (limited to 'jstests/sharding/moveprimary_ignore_sharded.js')
| -rw-r--r-- | jstests/sharding/moveprimary_ignore_sharded.js | 97 |
1 files changed, 48 insertions, 49 deletions
diff --git a/jstests/sharding/moveprimary_ignore_sharded.js b/jstests/sharding/moveprimary_ignore_sharded.js index 9b608279c77..f73f50939cc 100644 --- a/jstests/sharding/moveprimary_ignore_sharded.js +++ b/jstests/sharding/moveprimary_ignore_sharded.js @@ -1,5 +1,5 @@ // Checks that movePrimary doesn't move collections detected as sharded when it begins moving -var st = new ShardingTest({ shards : 2, mongos : 2, verbose : 1 }); +var st = new ShardingTest({shards: 2, mongos: 2, verbose: 1}); // Stop balancer, otherwise mongosB may load information about the database non-deterministically st.stopBalancer(); @@ -7,51 +7,51 @@ st.stopBalancer(); var mongosA = st.s0; var mongosB = st.s1; -var adminA = mongosA.getDB( "admin" ); -var adminB = mongosB.getDB( "admin" ); +var adminA = mongosA.getDB("admin"); +var adminB = mongosB.getDB("admin"); -var configA = mongosA.getDB( "config" ); -var configB = mongosB.getDB( "config" ); +var configA = mongosA.getDB("config"); +var configB = mongosB.getDB("config"); // Populate some data -assert.writeOK(mongosA.getCollection("foo.coll0").insert({ hello : "world" })); -assert.writeOK(mongosA.getCollection("bar.coll0").insert({ hello : "world" })); -assert.writeOK(mongosA.getCollection("foo.coll1").insert({ hello : "world" })); -assert.writeOK(mongosA.getCollection("bar.coll1").insert({ hello : "world" })); -assert.writeOK(mongosA.getCollection("foo.coll2").insert({ hello : "world" })); -assert.writeOK(mongosA.getCollection("bar.coll2").insert({ hello : "world" })); +assert.writeOK(mongosA.getCollection("foo.coll0").insert({hello: "world"})); +assert.writeOK(mongosA.getCollection("bar.coll0").insert({hello: "world"})); +assert.writeOK(mongosA.getCollection("foo.coll1").insert({hello: "world"})); +assert.writeOK(mongosA.getCollection("bar.coll1").insert({hello: "world"})); +assert.writeOK(mongosA.getCollection("foo.coll2").insert({hello: "world"})); +assert.writeOK(mongosA.getCollection("bar.coll2").insert({hello: "world"})); // Enable sharding -printjson( adminA.runCommand({ enableSharding : "foo" }) ); +printjson(adminA.runCommand({enableSharding: "foo"})); st.ensurePrimaryShard('foo', 'shard0001'); -printjson( adminA.runCommand({ enableSharding : "bar" }) ); +printjson(adminA.runCommand({enableSharding: "bar"})); st.ensurePrimaryShard('bar', 'shard0000'); // Setup three collections per-db // 0 : not sharded // 1 : sharded // 2 : sharded but not seen as sharded by mongosB -printjson( adminA.runCommand({ shardCollection : "foo.coll1", key : { _id : 1 } }) ); -printjson( adminA.runCommand({ shardCollection : "foo.coll2", key : { _id : 1 } }) ); -printjson( adminA.runCommand({ shardCollection : "bar.coll1", key : { _id : 1 } }) ); -printjson( adminA.runCommand({ shardCollection : "bar.coll2", key : { _id : 1 } }) ); +printjson(adminA.runCommand({shardCollection: "foo.coll1", key: {_id: 1}})); +printjson(adminA.runCommand({shardCollection: "foo.coll2", key: {_id: 1}})); +printjson(adminA.runCommand({shardCollection: "bar.coll1", key: {_id: 1}})); +printjson(adminA.runCommand({shardCollection: "bar.coll2", key: {_id: 1}})); // All collections are now on primary shard -var fooPrimaryShard = configA.databases.findOne({ _id : "foo" }).primary; -var barPrimaryShard = configA.databases.findOne({ _id : "bar" }).primary; +var fooPrimaryShard = configA.databases.findOne({_id: "foo"}).primary; +var barPrimaryShard = configA.databases.findOne({_id: "bar"}).primary; var shards = configA.shards.find().toArray(); -var fooPrimaryShard = fooPrimaryShard == shards[0]._id ? shards[0] : shards[1]; -var fooOtherShard = fooPrimaryShard._id == shards[0]._id ? shards[1] : shards[0]; -var barPrimaryShard = barPrimaryShard == shards[0]._id ? shards[0] : shards[1]; -var barOtherShard = barPrimaryShard._id == shards[0]._id ? shards[1] : shards[0]; +var fooPrimaryShard = fooPrimaryShard == shards[0]._id ? shards[0] : shards[1]; +var fooOtherShard = fooPrimaryShard._id == shards[0]._id ? shards[1] : shards[0]; +var barPrimaryShard = barPrimaryShard == shards[0]._id ? shards[0] : shards[1]; +var barOtherShard = barPrimaryShard._id == shards[0]._id ? shards[1] : shards[0]; st.printShardingStatus(); -jsTest.log( "Running movePrimary for foo through mongosA ..." ); +jsTest.log("Running movePrimary for foo through mongosA ..."); // MongosA should already know about all the collection states -printjson( adminA.runCommand({ movePrimary : "foo", to : fooOtherShard._id }) ); +printjson(adminA.runCommand({movePrimary: "foo", to: fooOtherShard._id})); if (st.configRS) { // If we are in CSRS mode need to make sure that mongosB will actually get the most recent @@ -59,31 +59,30 @@ if (st.configRS) { st.configRS.awaitLastOpCommitted(); } - // All collections still correctly sharded / unsharded -assert.neq( null, mongosA.getCollection("foo.coll0").findOne() ); -assert.neq( null, mongosA.getCollection("foo.coll1").findOne() ); -assert.neq( null, mongosA.getCollection("foo.coll2").findOne() ); +assert.neq(null, mongosA.getCollection("foo.coll0").findOne()); +assert.neq(null, mongosA.getCollection("foo.coll1").findOne()); +assert.neq(null, mongosA.getCollection("foo.coll2").findOne()); -assert.neq( null, mongosB.getCollection("foo.coll0").findOne() ); -assert.neq( null, mongosB.getCollection("foo.coll1").findOne() ); -assert.neq( null, mongosB.getCollection("foo.coll2").findOne() ); +assert.neq(null, mongosB.getCollection("foo.coll0").findOne()); +assert.neq(null, mongosB.getCollection("foo.coll1").findOne()); +assert.neq(null, mongosB.getCollection("foo.coll2").findOne()); -function realCollectionCount( mydb ) { +function realCollectionCount(mydb) { var num = 0; - mydb.getCollectionNames().forEach( function(z) { - if ( z.startsWith( "coll" ) ) + mydb.getCollectionNames().forEach(function(z) { + if (z.startsWith("coll")) num++; - } ); + }); return num; } // All collections sane -assert.eq( 2, realCollectionCount( new Mongo( fooPrimaryShard.host ).getDB( "foo" ) ) ); -assert.eq( 1, realCollectionCount( new Mongo( fooOtherShard.host ).getDB( "foo" ) ) ); +assert.eq(2, realCollectionCount(new Mongo(fooPrimaryShard.host).getDB("foo"))); +assert.eq(1, realCollectionCount(new Mongo(fooOtherShard.host).getDB("foo"))); -jsTest.log( "Running movePrimary for bar through mongosB ..." ); -printjson( adminB.runCommand({ movePrimary : "bar", to : barOtherShard._id }) ); +jsTest.log("Running movePrimary for bar through mongosB ..."); +printjson(adminB.runCommand({movePrimary: "bar", to: barOtherShard._id})); // We need to flush the cluster config on mongosA, so it can discover that database 'bar' got // moved. Otherwise since the collections are not sharded, we have no way of discovering this. @@ -93,19 +92,19 @@ if (st.configRS) { // the most recent config data. st.configRS.awaitLastOpCommitted(); } -assert.commandWorked(adminA.runCommand({ flushRouterConfig : 1 })); +assert.commandWorked(adminA.runCommand({flushRouterConfig: 1})); // All collections still correctly sharded / unsharded -assert.neq( null, mongosA.getCollection("bar.coll0").findOne() ); -assert.neq( null, mongosA.getCollection("bar.coll1").findOne() ); -assert.neq( null, mongosA.getCollection("bar.coll2").findOne() ); +assert.neq(null, mongosA.getCollection("bar.coll0").findOne()); +assert.neq(null, mongosA.getCollection("bar.coll1").findOne()); +assert.neq(null, mongosA.getCollection("bar.coll2").findOne()); -assert.neq( null, mongosB.getCollection("bar.coll0").findOne() ); -assert.neq( null, mongosB.getCollection("bar.coll1").findOne() ); -assert.neq( null, mongosB.getCollection("bar.coll2").findOne() ); +assert.neq(null, mongosB.getCollection("bar.coll0").findOne()); +assert.neq(null, mongosB.getCollection("bar.coll1").findOne()); +assert.neq(null, mongosB.getCollection("bar.coll2").findOne()); // All collections sane -assert.eq( 2, realCollectionCount( new Mongo( barPrimaryShard.host ).getDB( "bar" ) ) ); -assert.eq( 1, realCollectionCount( new Mongo( barOtherShard.host ).getDB( "bar" ) ) ); +assert.eq(2, realCollectionCount(new Mongo(barPrimaryShard.host).getDB("bar"))); +assert.eq(1, realCollectionCount(new Mongo(barOtherShard.host).getDB("bar"))); st.stop(); |