diff --git a/packages/db-mongodb/src/connect.ts b/packages/db-mongodb/src/connect.ts index c499cb369a..8f227a4c9b 100644 --- a/packages/db-mongodb/src/connect.ts +++ b/packages/db-mongodb/src/connect.ts @@ -50,7 +50,7 @@ export const connect: Connect = async function connect(this: MongooseAdapter, pa const client = this.connection.getClient() - if (!client.options.replicaSet || this.transactionOptions === false) { + if (!client.options.replicaSet) { this.transactionOptions = false this.beginTransaction = undefined } diff --git a/packages/db-mongodb/src/index.ts b/packages/db-mongodb/src/index.ts index f801d26b84..2119ef2345 100644 --- a/packages/db-mongodb/src/index.ts +++ b/packages/db-mongodb/src/index.ts @@ -93,18 +93,13 @@ export function mongooseAdapter({ connectOptions, disableIndexHints = false, migrationDir: migrationDirArg, - transactionOptions, + transactionOptions = {}, url, }: Args): MongooseAdapterResult { function adapter({ payload }: { payload: Payload }) { const migrationDir = findMigrationDir(migrationDirArg) - let beginTransactionFunction = beginTransaction mongoose.set('strictQuery', false) - if (transactionOptions === false) { - beginTransactionFunction = () => null - } - return createDatabaseAdapter({ name: 'mongoose', @@ -122,7 +117,7 @@ export function mongooseAdapter({ versions: {}, // DatabaseAdapter - beginTransaction: beginTransactionFunction, + beginTransaction: transactionOptions ? beginTransaction : undefined, commitTransaction, connect, create,