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
|
(function() {
"use strict";
var name = "dumprestore7";
var step = (function() {
var n = 0;
return function(msg) {
msg = msg || "";
print('\n' + name + ".js step " + (++n) + ' ' + msg);
};
})();
step("starting the replset test");
var replTest = new ReplSetTest({name: name, nodes: 1});
var nodes = replTest.startSet();
replTest.initiate();
step("inserting first chunk of data");
var foo = replTest.getPrimary().getDB("foo");
for (var i = 0; i < 20; i++) {
foo.bar.insert({x: i, y: "abc"});
}
step("waiting for replication");
replTest.awaitReplication();
assert.eq(foo.bar.count(), 20, "should have inserted 20 documents");
// The time of the last oplog entry.
var time = replTest.getPrimary()
.getDB("local")
.getCollection("oplog.rs")
.find()
.limit(1)
.sort({$natural: -1})
.next()
.ts;
step("got time of last oplog entry: " + time);
step("inserting second chunk of data");
for (var i = 30; i < 50; i++) {
foo.bar.insert({x: i, y: "abc"});
}
assert.eq(foo.bar.count(), 40, "should have inserted 40 total documents");
step("try mongodump with $timestamp");
var data = MongoRunner.dataDir + "/dumprestore7-dump1/";
var query = {ts: {$gt: time}};
print("mongodump query: " + tojson(query));
var testQueryCount =
replTest.getPrimary().getDB("local").getCollection("oplog.rs").find(query).itcount();
assert.eq(testQueryCount, 20, "the query should match 20 documents");
var exitCode = MongoRunner.runMongoTool("mongodump", {
host: "127.0.0.1:" + replTest.ports[0],
db: "local",
collection: "oplog.rs",
query: tojson(query),
out: data,
});
assert.eq(0, exitCode, "monogdump failed to dump the oplog");
step("try mongorestore from $timestamp");
var restoreMongod = MongoRunner.runMongod({});
exitCode = MongoRunner.runMongoTool("mongorestore", {
host: "127.0.0.1:" + restoreMongod.port,
dir: data,
writeConcern: 1,
});
assert.eq(0, exitCode, "mongorestore failed to restore the oplog");
var count = restoreMongod.getDB("local").getCollection("oplog.rs").count();
if (count != 20) {
print("mongorestore restored too many documents");
restoreMongod.getDB("local").getCollection("oplog.rs").find().pretty().shellPrint();
assert.eq(count, 20, "mongorestore should only have inserted the latter 20 entries");
}
step("stopping replset test");
replTest.stopSet();
})();
|
