diff options
Diffstat (limited to 'jstests/sharding/mongos_validate_writes.js')
| -rw-r--r-- | jstests/sharding/mongos_validate_writes.js | 80 |
1 files changed, 40 insertions, 40 deletions
diff --git a/jstests/sharding/mongos_validate_writes.js b/jstests/sharding/mongos_validate_writes.js index d54349f8d6c..b0843cd5cdb 100644 --- a/jstests/sharding/mongos_validate_writes.js +++ b/jstests/sharding/mongos_validate_writes.js @@ -5,38 +5,38 @@ // var st = new ShardingTest({ shards : 2, mongos : 3, other : { shardOptions : { verbose : 2 } } }); -st.stopBalancer() +st.stopBalancer(); -var mongos = st.s0 -var staleMongosA = st.s1 -var staleMongosB = st.s2 +var mongos = st.s0; +var staleMongosA = st.s1; +var staleMongosB = st.s2; // Additional logging -printjson( mongos.getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ) -printjson( staleMongosA.getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ) -printjson( staleMongosB.getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ) -printjson( st._connections[0].getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ) -printjson( st._connections[1].getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ) - -var admin = mongos.getDB( "admin" ) -var config = mongos.getDB( "config" ) -var coll = mongos.getCollection( "foo.bar" ) -var staleCollA = staleMongosA.getCollection( coll + "" ) -var staleCollB = staleMongosB.getCollection( coll + "" ) - -printjson( admin.runCommand({ enableSharding : coll.getDB() + "" }) ) +printjson( mongos.getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ); +printjson( staleMongosA.getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ); +printjson( staleMongosB.getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ); +printjson( st._connections[0].getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ); +printjson( st._connections[1].getDB( "admin" ).runCommand({ setParameter : 1, logLevel : 2 }) ); + +var admin = mongos.getDB( "admin" ); +var config = mongos.getDB( "config" ); +var coll = mongos.getCollection( "foo.bar" ); +var staleCollA = staleMongosA.getCollection( coll + "" ); +var staleCollB = staleMongosB.getCollection( coll + "" ); + +printjson( admin.runCommand({ enableSharding : coll.getDB() + "" }) ); st.ensurePrimaryShard(coll.getDB().getName(), 'shard0001'); -coll.ensureIndex({ a : 1 }) -printjson( admin.runCommand({ shardCollection : coll + "", key : { a : 1 } }) ) +coll.ensureIndex({ a : 1 }); +printjson( admin.runCommand({ shardCollection : coll + "", key : { a : 1 } }) ); // Let the stale mongos see the collection state -staleCollA.findOne() -staleCollB.findOne() +staleCollA.findOne(); +staleCollB.findOne(); // Change the collection sharding state -coll.drop() -coll.ensureIndex({ b : 1 }) -printjson( admin.runCommand({ shardCollection : coll + "", key : { b : 1 } }) ) +coll.drop(); +coll.ensureIndex({ b : 1 }); +printjson( admin.runCommand({ shardCollection : coll + "", key : { b : 1 } }) ); // Make sure that we can successfully insert, even though we have stale state assert.writeOK(staleCollA.insert({ b : "b" })); @@ -45,9 +45,9 @@ assert.writeOK(staleCollA.insert({ b : "b" })); assert.writeError(staleCollB.insert({ a : "a" })); // Change the collection sharding state -coll.drop() -coll.ensureIndex({ c : 1 }) -printjson( admin.runCommand({ shardCollection : coll + "", key : { c : 1 } }) ) +coll.drop(); +coll.ensureIndex({ c : 1 }); +printjson( admin.runCommand({ shardCollection : coll + "", key : { c : 1 } }) ); // Make sure we can successfully upsert, even though we have stale state assert.writeOK(staleCollA.update({ c : "c" }, { c : "c" }, true )); @@ -56,36 +56,36 @@ assert.writeOK(staleCollA.update({ c : "c" }, { c : "c" }, true )); assert.writeError(staleCollB.update({ b : "b" }, { b : "b" }, true )); // Change the collection sharding state -coll.drop() -coll.ensureIndex({ d : 1 }) -printjson( admin.runCommand({ shardCollection : coll + "", key : { d : 1 } }) ) +coll.drop(); +coll.ensureIndex({ d : 1 }); +printjson( admin.runCommand({ shardCollection : coll + "", key : { d : 1 } }) ); // Make sure we can successfully update, even though we have stale state assert.writeOK(coll.insert({ d : "d" })); assert.writeOK(staleCollA.update({ d : "d" }, { $set : { x : "x" } }, false, false )); -assert.eq( staleCollA.findOne().x, "x" ) +assert.eq( staleCollA.findOne().x, "x" ); // Make sure we unsuccessfully update with old info assert.writeError(staleCollB.update({ c : "c" }, { $set : { x : "y" } }, false, false )); -assert.eq( staleCollB.findOne().x, "x" ) +assert.eq( staleCollB.findOne().x, "x" ); // Change the collection sharding state -coll.drop() -coll.ensureIndex({ e : 1 }) +coll.drop(); +coll.ensureIndex({ e : 1 }); // Deletes need to be across two shards to trigger an error - this is probably an exceptional case -printjson( admin.runCommand({ movePrimary : coll.getDB() + "", to : "shard0000" }) ) -printjson( admin.runCommand({ shardCollection : coll + "", key : { e : 1 } }) ) -printjson( admin.runCommand({ split : coll + "", middle : { e : 0 } }) ) -printjson( admin.runCommand({ moveChunk : coll + "", find : { e : 0 }, to : "shard0001" }) ) +printjson( admin.runCommand({ movePrimary : coll.getDB() + "", to : "shard0000" }) ); +printjson( admin.runCommand({ shardCollection : coll + "", key : { e : 1 } }) ); +printjson( admin.runCommand({ split : coll + "", middle : { e : 0 } }) ); +printjson( admin.runCommand({ moveChunk : coll + "", find : { e : 0 }, to : "shard0001" }) ); // Make sure we can successfully remove, even though we have stale state assert.writeOK(coll.insert({ e : "e" })); assert.writeOK(staleCollA.remove({ e : "e" }, true)); -assert.eq( null, staleCollA.findOne() ) +assert.eq( null, staleCollA.findOne() ); // Make sure we unsuccessfully remove with old info assert.writeError(staleCollB.remove({ d : "d" }, true )); -st.stop() +st.stop(); |