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
|
var name = "dumprestore7";
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: 1});
var nodes = replTest.startSet();
replTest.initiate();
var master = replTest.getPrimary();
{
step("first chunk of data");
var foo = master.getDB("foo");
for (i = 0; i < 20; i++) {
foo.bar.insert({x: i, y: "abc"});
}
}
{
step("wait");
replTest.awaitReplication();
var time = replTest.getPrimary()
.getDB("local")
.getCollection("oplog.rs")
.find()
.limit(1)
.sort({$natural: -1})
.next();
step(time.ts.t);
}
{
step("second chunk of data");
var foo = master.getDB("foo");
for (i = 30; i < 50; i++) {
foo.bar.insert({x: i, y: "abc"});
}
}
{ var conn = MongoRunner.runMongod({}); }
step("try mongodump with $timestamp");
var data = MongoRunner.dataDir + "/dumprestore7-dump1/";
var query = "{\"ts\":{\"$gt\":{\"$timestamp\":{\"t\":" + time.ts.t + ",\"i\":" + time.ts.i + "}}}}";
MongoRunner.runMongoTool("mongodump",
{
"host": "127.0.0.1:" + replTest.ports[0],
"db": "local",
"collection": "oplog.rs",
"query": query,
"out": data
});
step("try mongorestore from $timestamp");
runMongoProgram(
"mongorestore", "--host", "127.0.0.1:" + conn.port, "--dir", data, "--writeConcern", 1);
var x = 9;
x = conn.getDB("local").getCollection("oplog.rs").count();
assert.eq(x, 20, "mongorestore should only have the latter 20 entries");
step("stopSet");
replTest.stopSet();
step("SUCCESS");
|
