(ctx: ClientSession, eventBroadcaster?: TransactionEventBroadcaster)
| 431 | } |
| 432 | |
| 433 | override async commit(ctx: ClientSession, eventBroadcaster?: TransactionEventBroadcaster): Promise<void> { |
| 434 | await this.ensureConnection(); |
| 435 | await eventBroadcaster?.dispatchEvent(EventType.beforeTransactionCommit, ctx); |
| 436 | await ctx.commitTransaction(); |
| 437 | this.logQuery('db.commit();'); |
| 438 | await eventBroadcaster?.dispatchEvent(EventType.afterTransactionCommit, ctx); |
| 439 | } |
| 440 | |
| 441 | override async rollback(ctx: ClientSession, eventBroadcaster?: TransactionEventBroadcaster): Promise<void> { |
| 442 | await this.ensureConnection(); |
no test coverage detected