diff options
author | Jack Mulrow <jack.mulrow@mongodb.com> | 2022-05-25 15:43:58 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-05-25 16:18:08 +0000 |
commit | 80e519f931ee0339b34e2546d274e21499e437b6 (patch) | |
tree | 4faab13bb94c6d37ff84467cbf81ce5050d7ec0c /src/mongo/db/s/resharding | |
parent | 982ba2296ba7e5a9f53e8f36d14310f0f45b7b70 (diff) | |
download | mongo-80e519f931ee0339b34e2546d274e21499e437b6.tar.gz |
SERVER-66565 Use hint with config.transactions partial index and allow creating it
Diffstat (limited to 'src/mongo/db/s/resharding')
4 files changed, 10 insertions, 0 deletions
diff --git a/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp b/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp index f890ca53ca2..7f57851d8e2 100644 --- a/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp +++ b/src/mongo/db/s/resharding/resharding_coordinator_service_test.cpp @@ -48,6 +48,7 @@ #include "mongo/db/s/resharding/resharding_service_test_helpers.h" #include "mongo/db/s/resharding/resharding_util.h" #include "mongo/db/s/transaction_coordinator_service.h" +#include "mongo/db/session_catalog_mongod.h" #include "mongo/idl/server_parameter_test_util.h" #include "mongo/logv2/log.h" #include "mongo/s/catalog/type_collection.h" @@ -147,6 +148,8 @@ public: auto opCtx = operationContext(); DBDirectClient client(opCtx); client.createCollection(NamespaceString::kSessionTransactionsTableNamespace.ns()); + client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(), + {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()}); client.createCollection(NamespaceString::kConfigReshardingOperationsNamespace.ns()); client.createCollection(CollectionType::ConfigNS.ns()); diff --git a/src/mongo/db/s/resharding/resharding_coordinator_test.cpp b/src/mongo/db/s/resharding/resharding_coordinator_test.cpp index 6d69dd99f28..1fcb1fe7dd1 100644 --- a/src/mongo/db/s/resharding/resharding_coordinator_test.cpp +++ b/src/mongo/db/s/resharding/resharding_coordinator_test.cpp @@ -75,6 +75,8 @@ protected: auto opCtx = operationContext(); DBDirectClient client(opCtx); client.createCollection(NamespaceString::kSessionTransactionsTableNamespace.ns()); + client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(), + {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()}); client.createCollection(NamespaceString::kConfigReshardingOperationsNamespace.ns()); client.createCollection(CollectionType::ConfigNS.ns()); client.createIndex(TagsType::ConfigNS.ns(), BSON("ns" << 1 << "min" << 1)); diff --git a/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp b/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp index ed5d6b1cf42..d95f0fdc23e 100644 --- a/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp +++ b/src/mongo/db/s/resharding/resharding_destined_recipient_test.cpp @@ -186,6 +186,8 @@ protected: ReshardingEnv setupReshardingEnv(OperationContext* opCtx, bool refreshTempNss) { DBDirectClient client(opCtx); ASSERT(client.createCollection(NamespaceString::kSessionTransactionsTableNamespace.ns())); + client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(), + {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()}); OperationShardingState::ScopedAllowImplicitCollectionCreate_UNSAFE unsafeCreateCollection( opCtx); diff --git a/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp b/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp index e6e80179440..c6772c93d0b 100644 --- a/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp +++ b/src/mongo/db/s/resharding/resharding_oplog_applier_test.cpp @@ -142,6 +142,9 @@ public: operationContext(), NamespaceString::kSessionTransactionsTableNamespace.db().toString(), BSON("create" << NamespaceString::kSessionTransactionsTableNamespace.coll()))); + DBDirectClient client(operationContext()); + client.createIndexes(NamespaceString::kSessionTransactionsTableNamespace.ns(), + {MongoDSessionCatalog::getConfigTxnPartialIndexSpec()}); OperationShardingState::ScopedAllowImplicitCollectionCreate_UNSAFE unsafeCreateCollection( operationContext()); |