diff options
author | Pavi Vetriselvan <pavithra.vetriselvan@mongodb.com> | 2021-02-10 12:43:50 -0500 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-02-11 23:25:16 +0000 |
commit | 5d2dbc60a46022118830638eceda06807bdd5a6a (patch) | |
tree | 88c1f4d97bd55658db275256e100092aa33c8989 /src/mongo/db/pipeline/document_source_graph_lookup_test.cpp | |
parent | f577e86bec434f1b47c670714d6901c2e16b0440 (diff) | |
download | mongo-5d2dbc60a46022118830638eceda06807bdd5a6a.tar.gz |
SERVER-54439 Allow lookup/graphLookup into kTenantMigrationOplogView
Diffstat (limited to 'src/mongo/db/pipeline/document_source_graph_lookup_test.cpp')
-rw-r--r-- | src/mongo/db/pipeline/document_source_graph_lookup_test.cpp | 43 |
1 files changed, 22 insertions, 21 deletions
diff --git a/src/mongo/db/pipeline/document_source_graph_lookup_test.cpp b/src/mongo/db/pipeline/document_source_graph_lookup_test.cpp index 4b438d38386..d22ee4b60bc 100644 --- a/src/mongo/db/pipeline/document_source_graph_lookup_test.cpp +++ b/src/mongo/db/pipeline/document_source_graph_lookup_test.cpp @@ -77,25 +77,26 @@ private: }; // Tests that $graphLookup with special 'from' syntax from: {db: local, coll: -// oplog.rs} can be round tripped. +// system.tenantMigration.oplogView} can be round tripped. TEST_F(DocumentSourceGraphLookUpTest, LookupReParseSerializedStageWithFromDBAndColl) { auto expCtx = getExpCtx(); - NamespaceString fromNs("local", "oplog.rs"); + NamespaceString fromNs("local", "system.tenantMigration.oplogView"); expCtx->setResolvedNamespaces(StringMap<ExpressionContext::ResolvedNamespace>{ {fromNs.coll().toString(), {fromNs, std::vector<BSONObj>()}}}); - auto originalBSON = BSON("$graphLookup" << BSON("from" << BSON("db" - << "local" - << "coll" - << "oplog.rs") - << "startWith" - << "$x" - << "connectFromField" - << "id" - << "connectToField" - << "id" - << "as" - << "connections")); + auto originalBSON = + BSON("$graphLookup" << BSON("from" << BSON("db" + << "local" + << "coll" + << "system.tenantMigration.oplogView") + << "startWith" + << "$x" + << "connectFromField" + << "id" + << "connectToField" + << "id" + << "as" + << "connections")); auto graphLookupStage = DocumentSourceGraphLookUp::createFromBson(originalBSON.firstElement(), expCtx); @@ -119,8 +120,8 @@ TEST_F(DocumentSourceGraphLookUpTest, LookupReParseSerializedStageWithFromDBAndC } // $graphLookup : {from : {db: <>, coll: <>}} syntax doesn't work for a namespace that isn't -// local.oplog.rs. -TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotLocalDBOrRsOplogColl) { +// local.system.tenantMigration.oplogView. +TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotLocalDBOrRsOplogView) { auto expCtx = getExpCtx(); NamespaceString fromNs("test", "coll"); expCtx->setResolvedNamespaces(StringMap<ExpressionContext::ResolvedNamespace>{ @@ -137,8 +138,8 @@ TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotLocalDBOrRs } // $graphLookup : {from : {db: <>, coll: <>}} syntax fails when "db" is local but "coll" is -// not "oplog.rs". -TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotRsOplogColl) { +// not "system.tenantMigration.oplogView". +TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotRsOplogView) { auto expCtx = getExpCtx(); NamespaceString fromNs("local", "coll"); expCtx->setResolvedNamespaces(StringMap<ExpressionContext::ResolvedNamespace>{ @@ -155,17 +156,17 @@ TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotRsOplogColl } // $lookup : {from : {db: <>, coll: <>}} syntax doesn't work for a namespace when "coll" is -// "oplog.rs" but "db" is not "local". +// "system.tenantMigration.oplogView" but "db" is not "local". TEST_F(DocumentSourceGraphLookUpTest, RejectsPipelineFromDBAndCollNotLocalDB) { auto expCtx = getExpCtx(); - NamespaceString fromNs("test", "oplog.rs"); + NamespaceString fromNs("test", "system.tenantMigration.oplogView"); expCtx->setResolvedNamespaces(StringMap<ExpressionContext::ResolvedNamespace>{ {fromNs.coll().toString(), {fromNs, std::vector<BSONObj>()}}}); ASSERT_THROWS_CODE( DocumentSourceGraphLookUp::createFromBson( fromjson("{$graphLookup: {from: {db: 'test', coll: " - "'oplog.rs'}, startWith: '$x', " + "'system.tenantMigration.oplogView'}, startWith: '$x', " "connectFromField: 'id', connectionToField: 'id', as: 'connections'}}") .firstElement(), expCtx), |