async def close(self) -> None:
        """Complete queued queries/cursors and close the connection."""
        await self._execute(self._conn.close)
        self._running = False
        self._connection = None
Complete queued queries/cursors and close the connection.