openTransaction method

Future openTransaction(Future queryBlock(PostgreSQLConnectionTransactionWrapper connection), { int? commitTimeoutInSeconds, })

Implementation

Future openTransaction(
  Future Function(PostgreSQLConnectionTransactionWrapper connection)
      queryBlock, {
  int? commitTimeoutInSeconds,
}) {
  var conn = nativeConnection as Connection;
  updateLastAccessTime();

  return conn.runTx(
    (tx) => queryBlock(
      PostgreSQLConnectionTransactionWrapper(
          this, tx, username, host, port, database, secure),
    ),
  );
}