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
|
/**
* Test that explained aggregation commands behave correctly with the readConcern option.
*/
(function() {
"use strict";
load("jstests/multiVersion/libs/causal_consistency_helpers.js");
if (!supportsMajorityReadConcern()) {
jsTestLog("Skipping test since storage engine doesn't support majority read concern.");
return;
}
const rst = new ReplSetTest(
{name: "aggExplainReadConcernSet", nodes: 1, nodeOptions: {enableMajorityReadConcern: ""}});
rst.startSet();
rst.initiate();
let primary = rst.getPrimary();
let testDB = primary.getDB("test");
let coll = testDB.agg_explain_read_concern;
// Test that explain is legal with readConcern "local".
assert.commandWorked(coll.explain().aggregate([], {readConcern: {level: "local"}}));
assert.commandWorked(testDB.runCommand(
{aggregate: coll.getName(), pipeline: [], explain: true, readConcern: {level: "local"}}));
assert.commandWorked(testDB.runCommand({
explain: {aggregate: coll.getName(), pipeline: [], cursor: {}},
readConcern: {level: "local"}
}));
// Test that explain is illegal with other readConcern levels.
let nonLocalReadConcerns = ["majority", "available", "linearizable"];
nonLocalReadConcerns.forEach(function(readConcernLevel) {
assert.throws(() => coll.explain().aggregate([], {readConcern: {level: readConcernLevel}}));
let cmdRes = testDB.runCommand({
aggregate: coll.getName(),
pipeline: [],
explain: true,
readConcern: {level: readConcernLevel}
});
assert.commandFailedWithCode(cmdRes, ErrorCodes.InvalidOptions, tojson(cmdRes));
let expectedErrStr = "aggregate command does not support non-local readConcern";
assert.neq(cmdRes.errmsg.indexOf(expectedErrStr), -1, tojson(cmdRes));
cmdRes = testDB.runCommand({
explain: {aggregate: coll.getName(), pipeline: [], cursor: {}},
readConcern: {level: readConcernLevel}
});
assert.commandFailedWithCode(cmdRes, ErrorCodes.InvalidOptions, tojson(cmdRes));
expectedErrStr = "Command does not support non local";
assert.neq(cmdRes.errmsg.indexOf(expectedErrStr), -1, tojson(cmdRes));
});
rst.stopSet();
}());
|
