Method _prepare

asyncpg/connection.py:645–664

(
        self,
        query,
        *,
        name: typing.Union[str, bool, None] = None,
        timeout=None,
        use_cache: bool=False,
        record_class=None
    )

        )

    async def _prepare(
        self,
        query,
        *,
        name: typing.Union[str, bool, None] = None,
        timeout=None,
        use_cache: bool=False,
        record_class=None
    ):
        self._check_open()
        if name is None:
            name = self._stmt_cache_enabled
        stmt = await self._get_statement(
            query,
            timeout,
            named=name,
            use_cache=use_cache,
            record_class=record_class,
        )
        return prepared_stmt.PreparedStatement(self, query, stmt)

    async def fetch(
        self,