openTransaction method

Future openTransaction(
  1. Future queryBlock(
    1. PostgreSQLConnectionTransactionWrapper connection
    ), {
  2. 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,
      ),
    ),
  );
}