Generator to start the processing of a query. It is implemented as generator because it may send additional queries, such as `begin`.
(self, query: Query | None = None)
| 372 | return self._raise_for_result(res) |
| 373 | |
| 374 | def _start_query(self, query: Query | None = None) -> PQGen[None]: |
| 375 | """Generator to start the processing of a query. |
| 376 | |
| 377 | It is implemented as generator because it may send additional queries, |
| 378 | such as `begin`. |
| 379 | """ |
| 380 | if self.closed: |
| 381 | raise e.InterfaceError("the cursor is closed") |
| 382 | |
| 383 | self._reset() |
| 384 | if not self._last_query or (self._last_query is not query): |
| 385 | self._last_query = None |
| 386 | self._tx = adapt.Transformer(self) |
| 387 | yield from self._conn._start_query() |
| 388 | |
| 389 | def _start_copy_gen( |
| 390 | self, statement: Query, params: Params | None = None |
no test coverage detected