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
|
// auto1.js
s = new ShardingTest( "auto1" , 2 , 1 , 1 );
s.adminCommand( { enablesharding : "test" } );
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;
for ( ; i<100; i++ ){
coll.save( { num : i , s : bigString } );
}
db.getLastError();
primary = s.getServer( "test" ).getDB( "test" );
counts = []
s.printChunks();
counts.push( s.config.chunks.count() );
assert.eq( 100 , primary.foo.count() );
print( "datasize: " + tojson( s.getServer( "test" ).getDB( "admin" ).runCommand( { datasize : "test.foo" } ) ) );
for ( ; i<200; i++ ){
coll.save( { num : i , s : bigString } );
}
db.getLastError();
s.printChunks()
s.printChangeLog()
counts.push( s.config.chunks.count() );
for ( ; i<400; i++ ){
coll.save( { num : i , s : bigString } );
}
db.getLastError();
s.printChunks();
s.printChangeLog()
counts.push( s.config.chunks.count() );
for ( ; i<700; i++ ){
coll.save( { num : i , s : bigString } );
}
db.getLastError();
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();
|