transaction<T> method
Run query in a transaction.
Implementation
@override
Future<T> transaction<T>(FutureOr<T> Function(Database) f) async {
return _pool.runTx((pgContext) async {
var exec = PostgreSqlDatabase(pgContext, logger: logger);
return await f(exec);
});
}