startTransaction method

  1. @override
Future<Transaction> startTransaction([
  1. IsolationLevel? isolationLevel
])
override

Start a new database transaction

Implementation

@override
Future<Transaction> startTransaction([IsolationLevel? isolationLevel]) async {
  final pool = _pool;
  if (pool != null) {
    // Pin a dedicated pool connection for the transaction's lifetime.
    return PostgresTransaction._startPooled(pool, isolationLevel);
  }
  return PostgresTransaction._start(_connection!, isolationLevel);
}