transaction2 method
Future
transaction2(
- Future queryBlock(
- QueryExecutor
), {
- int? commitTimeoutInSeconds,
})
Implementation
@override
Future<dynamic> transaction2(
Future<dynamic> Function(QueryExecutor) queryBlock,
{int? commitTimeoutInSeconds}) async {
var conn = connection as PostgreSQLConnection;
var re = await conn.transaction((ctx) async {
var tx =
PostgreSqlExecutor(connectionInfo, logger: logger, connection: ctx);
await queryBlock(tx);
}, commitTimeoutInSeconds: commitTimeoutInSeconds);
return re;
}