(self)
| 235 | await connection.executemany(query, values) |
| 236 | |
| 237 | async def begin(self) -> None: |
| 238 | try: |
| 239 | await self._connection.commit() |
| 240 | await self._connection.execute("BEGIN") |
| 241 | except sqlite3.OperationalError as exc: # pragma: nocoverage |
| 242 | raise TransactionManagementError(exc) |
| 243 | |
| 244 | async def rollback(self) -> None: |
| 245 | if self._finalized: |
no test coverage detected