Begins a transaction
@override Future<DSTransaction> beginTransaction() async { final connection = _requireConnection(); await connection.execute('BEGIN'); return _PostgresTransaction(this); }