runInTransactionFor<T extends Object> method

Future<Result<T>> runInTransactionFor<T extends Object>(
  1. Connection conn,
  2. Future<Result<T>> action(
    1. int txnId
    ), {
  3. IsolationLevel? isolationLevel,
  4. SavepointDialect? savepointDialect,
  5. TransactionAccessMode? accessMode,
  6. Duration? lockTimeout,
})

runInTransaction overload that accepts a Connection.

Implementation

Future<Result<T>> runInTransactionFor<T extends Object>(
  Connection conn,
  Future<Result<T>> Function(int txnId) action, {
  IsolationLevel? isolationLevel,
  SavepointDialect? savepointDialect,
  TransactionAccessMode? accessMode,
  Duration? lockTimeout,
}) =>
    OdbcErrorBoundary.run(
      'runInTransactionFor',
      () => runInTransaction(
        conn.id,
        action,
        isolationLevel: isolationLevel,
        savepointDialect: savepointDialect,
        accessMode: accessMode,
        lockTimeout: lockTimeout,
      ),
    );