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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
// Test cloning a database from a replica set (as full replica set uri, just the PRIMARY, or just a
// SECONDARY) to a standalone server and viceversa (SERVER-1643)
(function() {
"use strict";
if (jsTest.options().keyFile) {
jsTest.log("Skipping test because clone command doesn't work with authentication enabled:" +
" SERVER-4245");
} else {
var numDocs = 2000;
// 1kb string
var str = new Array(1000).toString();
var replsetDBName = 'cloneDBreplset';
var standaloneDBName = 'cloneDBstandalone';
var testColName = 'foo';
var testViewName = 'view';
jsTest.log("Create replica set");
var replTest = new ReplSetTest({name: 'testSet', nodes: 3});
replTest.startSet();
replTest.initiate();
var master = replTest.getPrimary();
var secondary = replTest._slaves[0];
var masterDB = master.getDB(replsetDBName);
masterDB.dropDatabase();
jsTest.log("Create standalone server");
var standalone = MongoRunner.runMongod();
standalone.getDB("admin").runCommand({setParameter: 1, logLevel: 5});
var standaloneDB = standalone.getDB(replsetDBName);
standaloneDB.dropDatabase();
jsTest.log("Insert data into replica set");
var bulk = masterDB[testColName].initializeUnorderedBulkOp();
for (var i = 0; i < numDocs; i++) {
bulk.insert({x: i, text: str});
}
assert.writeOK(bulk.execute({w: 3}));
jsTest.log("Create view on replica set");
assert.commandWorked(masterDB.runCommand({create: testViewName, viewOn: testColName}));
// Make sure all writes have replicated to secondary.
replTest.awaitReplication();
jsTest.log("Clone db from replica set to standalone server");
standaloneDB.cloneDatabase(replTest.getURL());
assert.eq(numDocs,
standaloneDB[testColName].find().itcount(),
'cloneDatabase from replset to standalone failed (document counts do not match)');
assert.eq(numDocs,
standaloneDB[testViewName].find().itcount(),
'cloneDatabase from replset to standalone failed (count on view incorrect)');
jsTest.log("Clone db from replica set PRIMARY to standalone server");
standaloneDB.dropDatabase();
standaloneDB.cloneDatabase(master.host);
assert.eq(numDocs,
standaloneDB[testColName].find().itcount(),
'cloneDatabase from PRIMARY to standalone failed (document counts do not match)');
assert.eq(numDocs,
standaloneDB[testViewName].find().itcount(),
'cloneDatabase from PRIMARY to standalone failed (count on view incorrect)');
jsTest.log("Clone db from replica set SECONDARY to standalone server (should not copy)");
standaloneDB.dropDatabase();
standaloneDB.cloneDatabase(secondary.host);
assert.eq(
0,
standaloneDB[testColName].find().itcount(),
'cloneDatabase from SECONDARY to standalone copied documents without slaveOk: true');
jsTest.log("Clone db from replica set SECONDARY to standalone server using slaveOk");
standaloneDB.dropDatabase();
standaloneDB.runCommand({clone: secondary.host, slaveOk: true});
assert.eq(
numDocs,
standaloneDB[testColName].find().itcount(),
'cloneDatabase from SECONDARY to standalone failed (document counts do not match)');
assert.eq(numDocs,
standaloneDB[testViewName].find().itcount(),
'cloneDatabase from SECONDARY to standalone failed (count on view incorrect)');
jsTest.log("Switch db and insert data into standalone server");
masterDB = master.getDB(standaloneDBName);
var secondaryDB = secondary.getDB(standaloneDBName);
standaloneDB = standalone.getDB(standaloneDBName);
masterDB.dropDatabase();
secondaryDB.dropDatabase();
standaloneDB.dropDatabase();
bulk = standaloneDB[testColName].initializeUnorderedBulkOp();
for (var i = 0; i < numDocs; i++) {
bulk.insert({x: i, text: str});
}
assert.writeOK(bulk.execute());
assert.commandWorked(standaloneDB.runCommand({create: testViewName, viewOn: testColName}));
jsTest.log("Clone db from standalone server to replica set PRIMARY");
masterDB.cloneDatabase(standalone.host);
replTest.awaitReplication();
assert.eq(numDocs,
masterDB[testColName].find().itcount(),
'cloneDatabase from standalone to PRIMARY failed (document counts do not match)');
assert.eq(numDocs,
masterDB[testViewName].find().itcount(),
'cloneDatabase from standalone to PRIMARY failed (count on view incorrect)');
jsTest.log("Clone db from standalone server to replica set SECONDARY");
masterDB.dropDatabase();
replTest.awaitReplication();
secondaryDB.cloneDatabase(standalone.host);
assert.eq(
0,
secondaryDB[testColName].find().itcount(),
'cloneDatabase from standalone to SECONDARY succeeded and should not accept writes');
jsTest.log("Shut down replica set and standalone server");
MongoRunner.stopMongod(standalone);
replTest.stopSet();
}
})();
|
