Function rollback

packages/sql/src/AbstractSqlConnection.ts:250–265

Rolls back the transaction or rolls back to the savepoint.

(
    ctx: ControlledTransaction<any, any>,
    eventBroadcaster?: TransactionEventBroadcaster,
    loggerContext?: LogContext,
  )

  /** Rolls back the transaction or rolls back to the savepoint. */
  override async rollback(
    ctx: ControlledTransaction<any, any>,
    eventBroadcaster?: TransactionEventBroadcaster,
    loggerContext?: LogContext,
  ): Promise<void> {
    await eventBroadcaster?.dispatchEvent(EventType.beforeTransactionRollback, ctx);
    if ('savepointName' in ctx) {
      await ctx.rollbackToSavepoint(ctx.savepointName).execute();
      this.logQuery(this.platform.getRollbackToSavepointSQL(ctx.savepointName as string), loggerContext);
    } else {
      await ctx.rollback().execute();
      this.logQuery(this.platform.getRollbackTransactionSQL(), loggerContext);
    }

    await eventBroadcaster?.dispatchEvent(EventType.afterTransactionRollback, ctx);
  }

  private prepareQuery(
    query: string | NativeQueryBuilder | RawQueryFragment,