mirror of https://github.com/mongodb/mongo
50 lines
1.7 KiB
JavaScript
50 lines
1.7 KiB
JavaScript
/**
|
|
* Confirms that the aggregate command accepts writeConcern and that a read-only aggregation will
|
|
* not wait for the writeConcern specified to be satisfied.
|
|
*/
|
|
import {ReplSetTest} from "jstests/libs/replsettest.js";
|
|
import {restartReplicationOnSecondaries, stopReplicationOnSecondaries} from "jstests/libs/write_concern_util.js";
|
|
|
|
const name = "aggregation_write_concern";
|
|
|
|
const replTest = new ReplSetTest({nodes: [{}, {rsConfig: {priority: 0}}]});
|
|
|
|
replTest.startSet();
|
|
replTest.initiate();
|
|
|
|
const testDB = replTest.getPrimary().getDB(name);
|
|
const collectionName = "test";
|
|
|
|
// Stop replication and perform a w: 1 write. This will block subsequent 'writeConcern:
|
|
// majority' reads if the read command waits on writeConcern.
|
|
|
|
stopReplicationOnSecondaries(replTest);
|
|
assert.commandWorked(testDB.runCommand({insert: collectionName, documents: [{_id: 1}], writeConcern: {w: 1}}));
|
|
|
|
// A read-only aggregation accepts the writeConcern option but does not wait for it.
|
|
let res = assert.commandWorked(
|
|
testDB.runCommand({
|
|
aggregate: collectionName,
|
|
pipeline: [{$match: {_id: 1}}],
|
|
cursor: {},
|
|
writeConcern: {w: "majority"},
|
|
}),
|
|
);
|
|
assert(res.cursor.firstBatch.length);
|
|
assert.eq(res.cursor.firstBatch[0], {_id: 1});
|
|
|
|
// An aggregation pipeline that writes will block on writeConcern.
|
|
assert.commandFailedWithCode(
|
|
testDB.runCommand({
|
|
aggregate: collectionName,
|
|
pipeline: [{$match: {_id: 1}}, {$out: collectionName + "_out"}],
|
|
cursor: {},
|
|
writeConcern: {w: "majority", wtimeout: 1000},
|
|
}),
|
|
ErrorCodes.WriteConcernTimeout,
|
|
);
|
|
|
|
restartReplicationOnSecondaries(replTest);
|
|
replTest.awaitLastOpCommitted();
|
|
replTest.stopSet();
|