1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
function debug(str) {
print("---\n" + str + "\n-----");
}
var name = "badNonUpdate";
debug("Starting sharded cluster test stuff");
var s = new ShardingTest({name: name, shards: 2, mongos: 2});
var mongosA = s.s0;
var mongosB = s.s1;
ns = "test.coll";
ns2 = "test.coll2";
adminSA = mongosA.getDB("admin");
adminSA.runCommand({enableSharding: "test"});
adminSA.runCommand({moveprimary: "test", to: "s.shard0.shardName"});
adminSA.runCommand({moveprimary: "test2", to: "s.shard1.shardName"});
adminSA.runCommand({shardCollection: ns, key: {_id: 1}});
try {
s.stopBalancer();
} catch (e) {
print("coundn't stop balancer via command");
}
adminSA.settings.update({_id: 'balancer'}, {$set: {stopped: true}});
var db = mongosA.getDB("test");
var coll = db.coll;
var coll2 = db.coll2;
numDocs = 10;
for (var i = 1; i < numDocs; i++) {
coll.insert({_id: i, control: 0});
coll2.insert({_id: i, control: 0});
}
debug("Inserted docs, now split chunks");
adminSA.runCommand({split: ns, find: {_id: 3}});
adminSA.runCommand({movechunk: ns, find: {_id: 10}, to: "s.shard1.shardName"});
var command = 'printjson(db.coll.update({ _id: 9 }, { $set: { a: "9" }}, true));';
// without this first query through mongo, the second time doesn't "fail"
debug("Try query first time");
runMongoProgram("mongo", "--quiet", "--port", "" + s._mongos[1].port, "--eval", command);
var res = mongosB.getDB("test").coll2.update({_id: 0}, {$set: {c: "333"}});
assert.eq(0, res.nModified);
s.stop();
|
