(self, name: bytes, query: PostgresQuery)
| 567 | self._pos = pos |
| 568 | |
| 569 | def _send_prepare(self, name: bytes, query: PostgresQuery) -> None: |
| 570 | if self._conn._pipeline: |
| 571 | self._conn._pipeline.command_queue.append( |
| 572 | partial( |
| 573 | self._pgconn.send_prepare, |
| 574 | name, |
| 575 | query.query, |
| 576 | param_types=query.types, |
| 577 | ) |
| 578 | ) |
| 579 | self._conn._pipeline.result_queue.append(None) |
| 580 | else: |
| 581 | self._pgconn.send_prepare(name, query.query, param_types=query.types) |
| 582 | |
| 583 | def _send_query_prepared( |
| 584 | self, name: bytes, pgq: PostgresQuery, *, binary: bool | None = None |
no test coverage detected