(self, query: str, values: list)
| 107 | |
| 108 | @translate_exceptions |
| 109 | async def execute_insert(self, query: str, values: list) -> asyncpg.Record | None: |
| 110 | async with self.acquire_connection() as connection: |
| 111 | self.log.debug("%s: %s", query, values) |
| 112 | # TODO: Cache prepared statement |
| 113 | return await connection.fetchrow(query, *values) |
| 114 | |
| 115 | @translate_exceptions |
| 116 | async def execute_many(self, query: str, values: list) -> None: |
nothing calls this directly
no test coverage detected