transaction<T> method

  1. @override
Future<T> transaction<T>(
  1. FutureOr<T> f(
    1. QueryExecutor
    )
)

Run query in a transaction.

Implementation

@override
Future<T> transaction<T>(FutureOr<T> Function(QueryExecutor) f) async {
  return _pool.runTx((session) async {
    var exec = PostgreSqlExecutor(session, logger: logger);
    return await f(exec);
  });
}