diff options
| author | David Storch <david.storch@10gen.com> | 2014-05-06 19:00:56 -0400 |
|---|---|---|
| committer | David Storch <david.storch@10gen.com> | 2014-05-06 19:00:56 -0400 |
| commit | 72380726608df663a85bee24d69a20ed2ca8287d (patch) | |
| tree | 735b7724ddc814fdf385d754bd7921975b5de491 /jstests/sharding/multi_write_target.js | |
| parent | 3061ab54eb2cc642a279becfca0b93f5e17db117 (diff) | |
| download | mongo-72380726608df663a85bee24d69a20ed2ca8287d.tar.gz | |
Revert "SERVER-13741 Migrate remaining tests to use write commands"
This reverts commit 87dc3ae516e1d12a632dc604710661e38ed7b3dd.
Diffstat (limited to 'jstests/sharding/multi_write_target.js')
| -rw-r--r-- | jstests/sharding/multi_write_target.js | 36 |
1 files changed, 24 insertions, 12 deletions
diff --git a/jstests/sharding/multi_write_target.js b/jstests/sharding/multi_write_target.js index 3fc528293c8..52ce36a83e0 100644 --- a/jstests/sharding/multi_write_target.js +++ b/jstests/sharding/multi_write_target.js @@ -25,15 +25,20 @@ st.printShardingStatus(); jsTest.log("Testing multi-update..."); // Put data 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 })); +st.shard0.getCollection(coll.toString()).insert({ _id : 0, skey : -1, x : 1 }); +assert.gleOK(st.shard0.getCollection(coll.toString()).getDB().getLastErrorObj()); +st.shard1.getCollection(coll.toString()).insert({ _id : 1, skey : 1, x : 1 }); +assert.gleOK(st.shard1.getCollection(coll.toString()).getDB().getLastErrorObj()); // Data not in chunks -assert.writeOK(st.shard2.getCollection(coll.toString()).insert({ _id : 0, x : 1 })); +st.shard2.getCollection(coll.toString()).insert({ _id : 0, x : 1 }); +assert.gleOK(st.shard2.getCollection(coll.toString()).getDB().getLastErrorObj()); // Non-multi-update doesn't work without shard key -assert.writeError(coll.update({ x : 1 }, { $set : { updated : true } }, { multi : false })); +coll.update({ x : 1 }, { $set : { updated : true } }, { multi : false }); +assert.gleError(coll.getDB().getLastErrorObj()); -assert.writeOK(coll.update({ x : 1 }, { $set : { updated : true } }, { multi : true })); +coll.update({ x : 1 }, { $set : { updated : true } }, { multi : true }); +assert.gleOK(coll.getDB().getLastErrorObj()); // Ensure update goes to *all* shards assert.neq(null, st.shard0.getCollection(coll.toString()).findOne({ updated : true })); @@ -41,7 +46,8 @@ assert.neq(null, st.shard1.getCollection(coll.toString()).findOne({ updated : tr assert.neq(null, st.shard2.getCollection(coll.toString()).findOne({ updated : true })); // _id update works, and goes to all shards -assert.writeOK(coll.update({ _id : 0 }, { $set : { updatedById : true } }, { multi : false })); +coll.update({ _id : 0 }, { $set : { updatedById : true } }, { multi : false }); +assert.gleOK(coll.getDB().getLastErrorObj()); // Ensure _id update goes to *all* shards assert.neq(null, st.shard0.getCollection(coll.toString()).findOne({ updatedById : true })); @@ -50,9 +56,11 @@ assert.neq(null, st.shard2.getCollection(coll.toString()).findOne({ updatedById jsTest.log("Testing multi-delete..."); // non-multi-delete doesn't work without shard key -assert.writeError(coll.remove({ x : 1 }, { justOne : true })); +coll.remove({ x : 1 }, { justOne : true }); +assert.gleError(coll.getDB().getLastErrorObj()); -assert.writeOK(coll.remove({ x : 1 }, { justOne : false })); +coll.remove({ x : 1 }, { justOne : false }); +assert.gleOK(coll.getDB().getLastErrorObj()); // Ensure delete goes to *all* shards assert.eq(null, st.shard0.getCollection(coll.toString()).findOne({ x : 1 })); @@ -60,12 +68,16 @@ 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 })); +st.shard0.getCollection(coll.toString()).insert({ _id : 0, skey : -1, x : 1 }); +assert.gleOK(st.shard0.getCollection(coll.toString()).getDB().getLastErrorObj()); +st.shard1.getCollection(coll.toString()).insert({ _id : 1, skey : 1, x : 1 }); +assert.gleOK(st.shard1.getCollection(coll.toString()).getDB().getLastErrorObj()); // Data not in chunks -assert.writeOK(st.shard2.getCollection(coll.toString()).insert({ _id : 0, x : 1 })); +st.shard2.getCollection(coll.toString()).insert({ _id : 0, x : 1 }); +assert.gleOK(st.shard2.getCollection(coll.toString()).getDB().getLastErrorObj()); -assert.writeOK(coll.remove({ _id : 0 }, { justOne : true })); +coll.remove({ _id : 0 }, { justOne : true }); +assert.gleOK(coll.getDB().getLastErrorObj()); // Ensure _id delete goes to *all* shards assert.eq(null, st.shard0.getCollection(coll.toString()).findOne({ x : 1 })); |
