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
|
// Tests sharding with a key file
myTestName = "sharding_with_keyfile"
keyFile = "jstests/sharding/" + myTestName + ".key";
run( "chmod" , "600" , keyFile );
var st = new ShardingTest({ name : myTestName ,
shards : 2,
mongos : 1,
keyFile : keyFile })
// Make sure all our instances got the key
var configs = st._configServers
var shards = st._connections
var mongoses = st._mongos
for( var i = 0; i < configs.length; i++ ){
printjson( new Mongo( "localhost:" + configs[i].port ).getDB("admin").runCommand({ getCmdLineOpts : 1 }) )
assert.eq( new Mongo( "localhost:" + configs[i].port ).getDB("admin").runCommand({ getCmdLineOpts : 1 }).parsed.security.keyFile, keyFile )
}
for( var i = 0; i < shards.length; i++ ){
printjson( new Mongo( "localhost:" + shards[i].port ).getDB("admin").runCommand({ getCmdLineOpts : 1 }) )
assert.eq( new Mongo( "localhost:" + shards[i].port ).getDB("admin").runCommand({ getCmdLineOpts : 1 }).parsed.security.keyFile, keyFile )
}
for( var i = 0; i < mongoses.length; i++ ){
printjson( new Mongo( "localhost:" + mongoses[i].port ).getDB("admin").runCommand({ getCmdLineOpts : 1 }) )
assert.eq( new Mongo( "localhost:" + mongoses[i].port ).getDB("admin").runCommand({ getCmdLineOpts : 1 }).parsed.security.keyFile, keyFile )
}
var mongos = new Mongo( "localhost:" + st.s0.port )
var coll = mongos.getCollection( "test.foo" )
st.shardColl( coll, { _id : 1 }, false )
// Create an index so we can find by num later
coll.ensureIndex({ insert : 1 })
// For more logging
// mongos.getDB("admin").runCommand({ setParameter : 1, logLevel : 3 })
print( "INSERT!" )
// Insert a bunch of data
var toInsert = 2000;
var bulk = coll.initializeUnorderedBulkOp();
for( var i = 0; i < toInsert; i++ ){
bulk.insert({ my : "test", data : "to", insert : i });
}
assert.writeOK(bulk.execute());
print( "UPDATE!" )
// Update a bunch of data
var toUpdate = toInsert;
bulk = coll.initializeUnorderedBulkOp();
for( var i = 0; i < toUpdate; i++ ){
var id = coll.findOne({ insert : i })._id;
bulk.find({ insert : i, _id : id }).updateOne({ $inc : { counter : 1 } });
}
assert.writeOK(bulk.execute());
print( "DELETE" )
// Remove a bunch of data
var toDelete = toInsert / 2;
bulk = coll.initializeUnorderedBulkOp();
for( var i = 0; i < toDelete; i++ ){
bulk.find({ insert : i }).remove();
}
assert.writeOK(bulk.execute());
// Make sure the right amount of data is there
assert.eq( coll.find().count(), toInsert / 2 )
// Finish
st.stop()
|
