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
|
/**
* Test that split/move chunk update the dbhash on the config server
*/
st = new ShardingTest({ name: "dbhash", shards : 2, mongos : 2, verbose : 2, sync: true });
st.stopBalancer();
var mongos = st.s0;
var shards = mongos.getCollection( "config.shards" ).find().toArray();
var admin = mongos.getDB( "admin" );
var configs = st._configServers;
assert(admin.runCommand({ enablesharding : "test" }).ok);
printjson(admin.runCommand({ movePrimary : "test", to : shards[0]._id }));
assert(admin.runCommand({ shardcollection : "test.foo" , key : { x : 1 } }).ok);
mongos.getCollection("test.foo").insert({x:1});
assert.eq(1, st.config.chunks.count(), "there should only be 1 chunk");
var dbhash1 = configs[0].getDB("config").runCommand( "dbhash");
printjson("dbhash before split and move is " + dbhash1.collections.chunks);
// split the chunk and move one chunk to the non-primary shard
assert(admin.runCommand({ split : "test.foo", middle : { x : 0 } }).ok);
assert( admin.runCommand({ moveChunk : "test.foo",
find : { x : 0 },
to : shards[1]._id,
_waitForDelete : true }).ok );
st.printShardingStatus();
assert.eq(2, st.config.chunks.count(), "there should be 2 chunks");
var dbhash2 = configs[0].getDB("config").runCommand("dbhash");
printjson("dbhash after split and move is " + dbhash2.collections.chunks);
assert.neq(dbhash1.collections.chunks, dbhash2.collections.chunks, "The hash should be different after split and move." );
st.stop();
|
