summaryrefslogtreecommitdiff
path: root/jstests/slow1/sharding_multiple_collections.js
blob: 6577e0050fa9ce5409561988d76c7b9f7cb4453d (plain)
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
// multcollections.js

s = new ShardingTest( "multcollections" , 2 , 1 , 1 , { chunksize : 1, enableBalancer : true }  );

s.adminCommand( { enablesharding : "test" } );

db = s.getDB( "test" )

N = 100000

S = ""
while ( S.length < 500 )
    S += "123123312312";

var bulk = db.foo.initializeUnorderedBulkOp();
var bulk2 = db.bar.initializeUnorderedBulkOp();
for ( i=0; i<N; i++ ){
    bulk.insert({ _id: i, s: S });
    bulk2.insert({ _id: i, s: S, s2: S });
}
assert.writeOK(bulk.execute());
assert.writeOK(bulk2.execute());

db.printShardingStatus()

function mytest( coll , i , loopNumber ){
    x = coll.find( { _id : i } ).explain();
    if ( x )
        return;
    throw Error( "can't find " + i + " in " + coll.getName() + " on loopNumber: " + loopNumber +  " explain: " + tojson( x ) );
}

loopNumber = 0
while ( 1 ){
    for ( i=0; i<N; i++ ){
        mytest( db.foo , i , loopNumber );
        mytest( db.bar , i , loopNumber );
        if ( i % 1000 == 0 )
            print( i )
    }
    db.printShardingStatus()
    loopNumber++;

    if ( loopNumber == 1 ){
        s.adminCommand( { shardcollection : "test.foo" , key : { _id : 1 } } );
        s.adminCommand( { shardcollection : "test.bar" , key : { _id : 1 } } );
    }
        
    assert( loopNumber < 1000 , "taking too long" );

    if ( s.chunkDiff( "foo" ) < 12 && s.chunkDiff( "bar" ) < 12 )
        break
}

s.stop()