mirror of https://github.com/mongodb/mongo
32 lines
845 B
JavaScript
32 lines
845 B
JavaScript
// test $out in a replicated environment
|
|
import {ReplSetTest} from "jstests/libs/replsettest.js";
|
|
|
|
let name = "pipelineout";
|
|
let replTest = new ReplSetTest({name: name, nodes: 2});
|
|
let nodes = replTest.nodeList();
|
|
|
|
replTest.startSet();
|
|
replTest.initiate({
|
|
"_id": name,
|
|
"members": [
|
|
{"_id": 0, "host": nodes[0]},
|
|
{"_id": 1, "host": nodes[1]},
|
|
],
|
|
});
|
|
|
|
let primary = replTest.getPrimary().getDB(name);
|
|
let secondary = replTest.getSecondary().getDB(name);
|
|
|
|
// populate the collection
|
|
for (let i = 0; i < 5; i++) {
|
|
primary.coll.insert({x: i});
|
|
}
|
|
replTest.awaitReplication();
|
|
|
|
// run one and check for proper replication
|
|
primary.coll.aggregate({$out: "out"}).itcount();
|
|
replTest.awaitReplication();
|
|
assert.eq(primary.out.find().sort({x: 1}).toArray(), secondary.out.find().sort({x: 1}).toArray());
|
|
|
|
replTest.stopSet();
|