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
|
// Cannot implicitly shard accessed collections because unsupported use of sharded collection
// for output collection of aggregation pipeline.
//
// @tags: [
// assumes_unsharded_collection,
// assumes_write_concern_unchanged,
// does_not_support_stepdowns,
// requires_non_retryable_commands,
// ]
/**
* Tests related to the aggregate commands behavior with writeConcern and writeConcern + explain.
*/
(function() {
"use strict";
const collName = "explain_agg_write_concern";
let coll = db[collName];
let outColl = db[collName + "_out"];
coll.drop();
outColl.drop();
assert.commandWorked(coll.insert({_id: 1}));
// Agg should accept write concern if the last stage is a $out.
assert.commandWorked(db.runCommand({
aggregate: coll.getName(),
pipeline: [{$out: outColl.getName()}],
cursor: {},
writeConcern: {w: 1}
}));
assert.eq(1, outColl.find().itcount());
outColl.drop();
// Agg should accept writeConcern even if read-only.
assert.commandWorked(
db.runCommand({aggregate: coll.getName(), pipeline: [], cursor: {}, writeConcern: {w: 1}}));
// Agg should succeed if the last stage is an $out and the explain flag is set.
assert.commandWorked(db.runCommand({
aggregate: coll.getName(),
pipeline: [{$out: outColl.getName()}],
explain: true,
}));
assert.eq(0, outColl.find().itcount());
outColl.drop();
// Agg should fail if the last stage is an $out and both the explain flag and writeConcern are
// set.
assert.commandFailed(db.runCommand({
aggregate: coll.getName(),
pipeline: [{$out: outColl.getName()}],
explain: true,
writeConcern: {w: 1}
}));
// Agg explain helpers with all verbosities (or verbosity omitted) should fail if the last stage
// is an $out and writeConcern is set.
assert.throws(function() {
coll.explain().aggregate([{$out: outColl.getName()}], {writeConcern: {w: 1}});
});
assert.throws(function() {
coll.explain("queryPlanner").aggregate([{$out: outColl.getName()}], {writeConcern: {w: 1}});
});
assert.throws(function() {
coll.explain("executionStats").aggregate([{$out: outColl.getName()}], {writeConcern: {w: 1}});
});
assert.throws(function() {
coll.explain("allPlansExecution").aggregate([{$out: outColl.getName()}], {
writeConcern: {w: 1}
});
});
}());
|
