transaction<T> method

  1. @override
Future<T> transaction<T>(
  1. Future<T> callback(
    1. DatabaseExecutor tx
    )
)
override

Executes multiple queries within a single transaction.

Implementation

@override
Future<T> transaction<T>(Future<T> Function(DatabaseExecutor tx) callback) async {
  return await _pool.run((session) async {
    final executor = PostgresExecutor(session);
    return await callback(executor);
  });
}