summaryrefslogtreecommitdiff
path: root/jstests/sharding/auto1.js
blob: 70249c85c8dfe73af59440d7b2c143a92fe68ca6 (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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
// auto1.js

s = new ShardingTest( "auto1" , 2 , 1 , 1, { enableBalancer : 1 } );

s.adminCommand( { enablesharding : "test" } );
s.ensurePrimaryShard('test', 'shard0001');
s.adminCommand( { shardcollection : "test.foo" , key : { num : 1 } } );

bigString = "";
while ( bigString.length < 1024 * 50 )
    bigString += "asocsancdnsjfnsdnfsjdhfasdfasdfasdfnsadofnsadlkfnsaldknfsad";

db = s.getDB( "test" )
coll = db.foo;

var i=0;

var bulk = coll.initializeUnorderedBulkOp();
for ( ; i<100; i++ ){
    bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );

primary = s.getServer( "test" ).getDB( "test" );

counts = []

s.printChunks();
counts.push( s.config.chunks.count() );
assert.eq(100, db.foo.find().itcount());

print( "datasize: " + tojson( s.getServer( "test" ).getDB( "admin" ).runCommand( { datasize : "test.foo" } ) ) );

bulk = coll.initializeUnorderedBulkOp();
for ( ; i<200; i++ ){
    bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );

s.printChunks()
s.printChangeLog()
counts.push( s.config.chunks.count() );

bulk = coll.initializeUnorderedBulkOp();
for ( ; i<400; i++ ){
    bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );

s.printChunks();
s.printChangeLog()
counts.push( s.config.chunks.count() );

bulk = coll.initializeUnorderedBulkOp();
for ( ; i<700; i++ ){
    bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );

s.printChunks();
s.printChangeLog()
counts.push( s.config.chunks.count() );

assert( counts[counts.length-1] > counts[0] , "counts 1 : " + tojson( counts ) )
sorted = counts.slice(0)
// Sort doesn't sort numbers correctly by default, resulting in fail
sorted.sort( function(a, b){ return a - b } )
assert.eq( counts , sorted , "counts 2 : " + tojson( counts ) )

print( counts )

printjson( db.stats() )

s.stop();