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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
// Test parsing of readConcern option 'atClusterTime'.
//
// Only run this test with the WiredTiger storage engine, since we expect other storage engines to
// return early because they do not support snapshot read concern.
// @tags: [requires_wiredtiger]
(function() {
"use strict";
// 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;
}
const dbName = "test";
const collName = "coll";
const rst = new ReplSetTest({nodes: 1});
rst.startSet();
rst.initiate();
const testDB = rst.getPrimary().getDB(dbName);
if (!testDB.serverStatus().storageEngine.supportsSnapshotReadConcern) {
rst.stopSet();
return;
}
const session = testDB.getMongo().startSession({causalConsistency: false});
const sessionDb = session.getDatabase(dbName);
const pingRes = assert.commandWorked(rst.getPrimary().adminCommand({ping: 1}));
assert(pingRes.hasOwnProperty("$clusterTime"), tojson(pingRes));
assert(pingRes.$clusterTime.hasOwnProperty("clusterTime"), tojson(pingRes));
const clusterTime = pingRes.$clusterTime.clusterTime;
let txnNumber = 0;
// 'atClusterTime' can be used with readConcern level 'snapshot'.
assert.commandWorked(sessionDb.runCommand({
find: collName,
readConcern: {level: "snapshot", atClusterTime: clusterTime},
txnNumber: NumberLong(txnNumber++)
}));
// 'atClusterTime' cannot be greater than the current cluster time.
const futureClusterTime = new Timestamp(clusterTime.getTime() + 1000, 1);
assert.commandFailedWithCode(sessionDb.runCommand({
find: collName,
readConcern: {level: "snapshot", atClusterTime: futureClusterTime},
txnNumber: NumberLong(txnNumber++)
}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' must have type Timestamp.
assert.commandFailedWithCode(sessionDb.runCommand({
find: collName,
readConcern: {level: "snapshot", atClusterTime: "bad"},
txnNumber: NumberLong(txnNumber++)
}),
ErrorCodes.TypeMismatch);
// 'atClusterTime' cannot be used with readConcern level 'majority'.
assert.commandFailedWithCode(
sessionDb.runCommand(
{find: collName, readConcern: {level: "majority", atClusterTime: clusterTime}}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used with readConcern level 'local'.
assert.commandFailedWithCode(
sessionDb.runCommand(
{find: collName, readConcern: {level: "local", atClusterTime: clusterTime}}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used with readConcern level 'available'.
assert.commandFailedWithCode(
sessionDb.runCommand(
{find: collName, readConcern: {level: "available", atClusterTime: clusterTime}}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used with readConcern level 'linearizable'.
assert.commandFailedWithCode(
sessionDb.runCommand(
{find: collName, readConcern: {level: "linearizable", atClusterTime: clusterTime}}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used without readConcern level (level is 'local' by default).
assert.commandFailedWithCode(
sessionDb.runCommand({find: collName, readConcern: {atClusterTime: clusterTime}}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used with 'afterOpTime'.
assert.commandFailedWithCode(sessionDb.runCommand({
find: collName,
readConcern: {
level: "snapshot",
atClusterTime: clusterTime,
afterOpTime: {ts: Timestamp(1, 2), t: 1}
},
txnNumber: NumberLong(txnNumber++)
}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used outside of a session.
assert.commandFailedWithCode(
testDB.runCommand(
{find: collName, readConcern: {level: "snapshot", atClusterTime: clusterTime}}),
ErrorCodes.InvalidOptions);
// 'atClusterTime' cannot be used with 'afterClusterTime'.
assert.commandFailedWithCode(sessionDb.runCommand({
find: collName,
readConcern: {level: "snapshot", atClusterTime: clusterTime, afterClusterTime: clusterTime},
txnNumber: NumberLong(txnNumber++)
}),
ErrorCodes.InvalidOptions);
session.endSession();
rst.stopSet();
}());
|
