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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
// Checks that movePrimary doesn't move collections detected as sharded when it begins moving
var st = new ShardingTest({shards: 2, mongos: 2, verbose: 1});
// Stop balancer, otherwise mongosB may load information about the database non-deterministically
st.stopBalancer();
var mongosA = st.s0;
var mongosB = st.s1;
var adminA = mongosA.getDB("admin");
var adminB = mongosB.getDB("admin");
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"}));
// Enable sharding
printjson(adminA.runCommand({enableSharding: "foo"}));
st.ensurePrimaryShard('foo', 'shard0001');
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}}));
// All collections are now on primary shard
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];
st.printShardingStatus();
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}));
if (st.configRS) {
// If we are in CSRS mode need to make sure that mongosB will actually get the most recent
// config data.
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, mongosB.getCollection("foo.coll0").findOne());
assert.neq(null, mongosB.getCollection("foo.coll1").findOne());
assert.neq(null, mongosB.getCollection("foo.coll2").findOne());
function realCollectionCount(mydb) {
var num = 0;
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")));
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.
// See SERVER-8059.
if (st.configRS) {
// If we are in CSRS mode need to make sure that after we flushRouterConfig we'll actually get
// the most recent config data.
st.configRS.awaitLastOpCommitted();
}
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, 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")));
st.stop();
|
