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
|
// simple test to ensure write concern functions as expected
(function() {
// Skip this test if running with --nojournal and WiredTiger.
if (jsTest.options().noJournal &&
(!jsTest.options().storageEngine || jsTest.options().storageEngine === "wiredTiger")) {
print("Skipping test because running WiredTiger without journaling isn't a valid" +
" replica set configuration");
return;
}
var name = "dumprestore10";
function step(msg) {
msg = msg || "";
this.x = (this.x || 0) + 1;
print('\n' + name + ".js step " + this.x + ' ' + msg);
}
step();
var replTest = new ReplSetTest({name: name, nodes: 2});
var nodes = replTest.startSet();
replTest.initiate();
var master = replTest.getPrimary();
var total = 1000;
{
step("store data");
var foo = master.getDB("foo");
for (i = 0; i < total; i++) {
foo.bar.insert({x: i, y: "abc"});
}
}
{
step("wait");
replTest.awaitReplication();
}
step("mongodump from replset");
var data = MongoRunner.dataDir + "/dumprestore10-dump1/";
var exitCode = MongoRunner.runMongoTool("mongodump", {
host: "127.0.0.1:" + master.port,
out: data,
});
assert.eq(0, exitCode, "mongodump failed to dump data from the replica set");
{
step("remove data after dumping");
master.getDB("foo").getCollection("bar").drop();
}
{
step("wait");
replTest.awaitReplication();
}
step("try mongorestore with write concern");
exitCode = MongoRunner.runMongoTool("mongorestore", {
writeConcern: "2",
host: "127.0.0.1:" + master.port,
dir: data,
});
assert.eq(0,
exitCode,
"mongorestore failed to restore the data to a replica set while using w=2 writes");
var x = 0;
// no waiting for replication
x = master.getDB("foo").getCollection("bar").count();
assert.eq(x, total, "mongorestore should have successfully restored the collection");
step("stopSet");
replTest.stopSet();
step("SUCCESS");
}());
|
