diff --git a/packages/core/database/lib/index.js b/packages/core/database/lib/index.js index 733f9ff526..34a13930a5 100644 --- a/packages/core/database/lib/index.js +++ b/packages/core/database/lib/index.js @@ -51,6 +51,10 @@ class Database { return this.entityManager.getRepository(uid); } + inTransaction() { + return !!transactionCtx.get(); + } + async transaction(cb) { const notNestedTransaction = !transactionCtx.get(); const trx = notNestedTransaction ? await this.connection.transaction() : transactionCtx.get();