blob: 7d42d8b41a25659df32880c3e6b288ff9f8ac508 (
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
75
76
77
78
79
80
81
|
// Test bulk inserts with sharding
(function() {
// Setup randomized test
var seed = new Date().getTime();
// seed = 0
Random.srand( seed );
print( "Seeded with " + seed );
var st = new ShardingTest({ name : jsTestName(), shards : 4, chunkSize: 1 });
// Setup sharded collection
var mongos = st.s0;
var db = mongos.getDB( jsTestName() );
var coll = db.coll;
st.shardColl( coll, { _id : 1 }, false );
// Insert lots of bulk documents
var numDocs = 1000000;
var bulkSize = Math.floor( Random.rand() * 1000 ) + 2;
bulkSize = 4000;
var docSize = 128; /* bytes */
print( "\n\n\nBulk size is " + bulkSize );
var data = "x";
while( Object.bsonsize({ x : data }) < docSize ){
data += data;
}
print( "\n\n\nDocument size is " + Object.bsonsize({ x : data }) );
var docsInserted = 0;
var balancerOn = false;
while (docsInserted < numDocs) {
var currBulkSize = ( numDocs - docsInserted > bulkSize ) ? bulkSize : ( numDocs - docsInserted );
var bulk = [];
for( var i = 0; i < currBulkSize; i++ ){
bulk.push({hi: "there", at: docsInserted, i: i, x: data});
}
assert.writeOK(coll.insert( bulk ));
if( Math.floor( docsInserted / 10000 ) != Math.floor( ( docsInserted + currBulkSize ) / 10000 ) ){
print( "Inserted " + (docsInserted + currBulkSize) + " documents." );
st.printShardingStatus();
}
docsInserted += currBulkSize;
if( docsInserted > numDocs / 2 && ! balancerOn ){
print( "Turning on balancer after half documents inserted." );
st.startBalancer();
balancerOn = true;
}
}
// Check we inserted all the documents
st.printShardingStatus();
var count = coll.find().count();
var itcount = count; //coll.find().itcount()
print("Inserted " + docsInserted + " count : " + count + " itcount : " + itcount);
st.startBalancer();
var count = coll.find().count();
var itcount = coll.find().itcount();
print( "Inserted " + docsInserted + " count : " + count + " itcount : " + itcount );
// SERVER-3645
// assert.eq( docsInserted, count )
assert.eq(docsInserted, itcount);
})();
|
