transaction2 method

  1. @override
Future transaction2(
  1. Future queryBlock(
    1. QueryExecutor
    ), {
  2. 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;
}