blob: ac528c66c36cd85de4de5e563a608ccfea860338 (
plain)
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
|
var toInsert = [];
for (var j = 0; j < 10000; j++) {
toInsert.push({
x: j
});
}
for (var i = 0; i < 100; i++) {
db.test.insert(toInsert);
}
db1 = (new Mongo()).getDB("mongoreplay");
var c = db1.runCommand({
aggregate: "test",
cursor: {
batchSize: 5
}
});
cursorId = c.cursor.id;
print("got cursor fron cxn1: ", cursorId);
var cursor1 = db1.getMongo().cursorFromId("mongoreplay.test", cursorId);
while (c.hasNext()) {
printjson(c.next());
}
for (var i = 0; i < 100; i++) {
db1.test.insert({
y: i
});
sleep(50);
}
var cursor2 = db1.test.find();
printjson(cursor2.next());
|