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
|
// Tests that each change in the stream will include the cluster time at which it happened.
(function() {
"use strict";
load("jstests/libs/collection_drop_recreate.js"); // For assertDropAndRecreateCollection.
// Drop and recreate the collections to be used in this set of tests.
const coll = assertDropAndRecreateCollection(db, "include_cluster_time");
const changeStream = coll.watch();
const insertClusterTime =
assert.commandWorked(coll.runCommand("insert", {documents: [{_id: 0}]}))
.$clusterTime.clusterTime;
const updateClusterTime =
assert
.commandWorked(
coll.runCommand("update", {updates: [{q: {_id: 0}, u: {$set: {updated: true}}}]}))
.$clusterTime.clusterTime;
const deleteClusterTime =
assert.commandWorked(coll.runCommand("delete", {deletes: [{q: {_id: 0}, limit: 1}]}))
.$clusterTime.clusterTime;
const dropClusterTime =
assert.commandWorked(db.runCommand({drop: coll.getName()})).$clusterTime.clusterTime;
// Make sure each operation has a reasonable cluster time. Note that we should not assert
// that the cluster times are equal, because the cluster time returned from the command is
// generated by a second, independent read of the logical clock than the one used to
// generate the oplog entry. It's possible that the system did something to advance the time
// between the two reads of the clock.
assert.soon(() => changeStream.hasNext());
let next = changeStream.next();
assert.eq(next.operationType, "insert");
assert.lte(next.clusterTime, insertClusterTime);
assert.soon(() => changeStream.hasNext());
next = changeStream.next();
assert.eq(next.operationType, "update");
assert.lte(next.clusterTime, updateClusterTime);
assert.soon(() => changeStream.hasNext());
next = changeStream.next();
assert.eq(next.operationType, "delete");
assert.lte(next.clusterTime, deleteClusterTime);
assert.soon(() => changeStream.hasNext());
next = changeStream.next();
assert.eq(next.operationType, "invalidate");
assert.lte(next.clusterTime, dropClusterTime);
changeStream.close();
}());
|
