summaryrefslogtreecommitdiff
path: root/jstests/aggregation/sources
diff options
context:
space:
mode:
authorLouis Williams <louis.williams@mongodb.com>2020-02-27 14:07:37 -0500
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-02-27 19:38:41 +0000
commita3135f9d40d6a571405ad3edcc1864c53f98218d (patch)
tree80b8a18e171d163df50d66eceb52ec0a9aa36b28 /jstests/aggregation/sources
parentff724b466d7bc7ead68eacd5524cc1185b8b4523 (diff)
downloadmongo-a3135f9d40d6a571405ad3edcc1864c53f98218d.tar.gz
Revert "SERVER-46110 Expose $internalOutToDifferentDB functionality"
This reverts commit 835e125ff9cf933ff9804d8f7ca22cca1e3a04f2.
Diffstat (limited to 'jstests/aggregation/sources')
-rw-r--r--jstests/aggregation/sources/out/replace_collection.js11
1 files changed, 8 insertions, 3 deletions
diff --git a/jstests/aggregation/sources/out/replace_collection.js b/jstests/aggregation/sources/out/replace_collection.js
index 81a83bbdb4f..1544c398822 100644
--- a/jstests/aggregation/sources/out/replace_collection.js
+++ b/jstests/aggregation/sources/out/replace_collection.js
@@ -26,7 +26,7 @@ assert.commandWorked(coll.insert({_id: 0}));
coll.aggregate(pipeline);
assert.eq(1, targetColl.find().itcount());
-// Test $out with a non-existent database. This is only expected to work in a
+// Test $internalOutToDifferentDB with a non-existent database. This is only expected to work in a
// non-sharded environment.
const destDB = db.getSiblingDB("outDifferentDB");
destDB.dropDatabase();
@@ -34,11 +34,16 @@ if (FixtureHelpers.isMongos(db)) {
assert.commandFailedWithCode(db.runCommand({
aggregate: coll.getName(),
cursor: {},
- pipeline: [{$out: {db: destDB.getName(), coll: destDB.outDifferentColl.getName()}}]
+ pipeline: [{
+ $internalOutToDifferentDB:
+ {db: destDB.getName(), coll: destDB.outDifferentColl.getName()}
+ }]
}),
ErrorCodes.NamespaceNotFound);
} else {
- coll.aggregate({$out: {db: destDB.getName(), coll: destDB.outDifferentColl.getName()}});
+ coll.aggregate({
+ $internalOutToDifferentDB: {db: destDB.getName(), coll: destDB.outDifferentColl.getName()}
+ });
assert.eq(1, destDB.outDifferentColl.find().itcount());
}