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
|
'use strict';
/**
* create_and_drop_collection.js
*
* Repeatedly creates and drops a collection.
*
* @tags: [requires_sharding]
*/
var $config = (function() {
var data = {};
var states = (function() {
function init(db, collName) {
this.docNum = 0;
}
function checkForDocument(coll, docNum) {
let docs = coll.find({}).toArray();
assert.eq(docs.length, 1);
assert.eq(docs[0]._id, docNum);
}
function createShardedCollection(db, collName) {
assertAlways.commandWorked(db.adminCommand({enableSharding: db.getName()}));
assertAlways.commandWorked(
db.adminCommand({shardCollection: db[collName].getFullName(), key: {_id: 1}}));
assertAlways.commandWorked(db[collName].insertOne({_id: this.docNum}));
checkForDocument(db[collName], this.docNum);
}
function createUnshardedCollection(db, collName) {
assertAlways.commandWorked(db[collName].insertOne({_id: this.docNum}));
checkForDocument(db[collName], this.docNum);
}
function dropCollection(db, collName) {
checkForDocument(db[collName], this.docNum++);
assertAlways(db[collName].drop());
}
function dropDatabase(db, collName) {
checkForDocument(db[collName], this.docNum++);
assertAlways.commandWorked(db.dropDatabase());
}
return {
init: init,
createShardedCollection: createShardedCollection,
createUnshardedCollection: createUnshardedCollection,
dropCollection: dropCollection,
dropDatabase: dropDatabase
};
})();
var transitions = {
init: {createShardedCollection: 0.5, createUnshardedCollection: 0.5},
createShardedCollection: {dropCollection: 0.5, dropDatabase: 0.5},
createUnshardedCollection: {dropCollection: 0.5, dropDatabase: 0.5},
dropCollection: {createShardedCollection: 0.5, createUnshardedCollection: 0.5},
dropDatabase: {createShardedCollection: 0.5, createUnshardedCollection: 0.5}
};
// This test in in the concurrency suite because it requires shard stepdowns to properly test
// that no documents from a newly created collection are dropped from a previous drop
// collection. There is only one thread because only one collection is being dropped and
// created.
return {threadCount: 1, iterations: 50, data: data, states: states, transitions: transitions};
})();
|
