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
|
// features1.js
s = new ShardingTest( "features1" , 2 , 1 , 1 );
s.adminCommand( { enablesharding : "test" } );
// ---- can't shard system namespaces ----
assert( ! s.admin.runCommand( { shardcollection : "test.system.blah" , key : { num : 1 } } ).ok , "shard system namespace" );
// ---- setup test.foo -----
s.adminCommand( { shardcollection : "test.foo" , key : { num : 1 } } );
db = s.getDB( "test" );
a = s._connections[0].getDB( "test" );
b = s._connections[1].getDB( "test" );
s.adminCommand( { split : "test.foo" , middle : { num : 10 } } );
s.adminCommand( { movechunk : "test.foo" , find : { num : 20 } , to : s.getOther( s.getServer( "test" ) ).name } );
db.foo.save( { num : 5 } );
db.foo.save( { num : 15 } );
s.sync();
// ---- make sure shard key index is everywhere ----
assert.eq( 2 , a.foo.getIndexKeys().length , "a index 1" );
assert.eq( 2 , b.foo.getIndexKeys().length , "b index 1" );
// ---- make sure if you add an index it goes everywhere ------
db.foo.ensureIndex( { x : 1 } );
//assert.eq( 3 , a.foo.getIndexKeys().length , "a index 2" );
//assert.eq( 3 , b.foo.getIndexKeys().length , "b index 2" );
s.stop()
|
