Method copy

psycopg/psycopg/cursor.py:313–334

Initiate a :sql:`COPY` operation and return an object to manage it.

(
        self,
        statement: Query,
        params: Params | None = None,
        *,
        writer: Writer | None = None,
    )

    @contextmanager
    def copy(
        self,
        statement: Query,
        params: Params | None = None,
        *,
        writer: Writer | None = None,
    ) -> Iterator[Copy]:
        """
        Initiate a :sql:`COPY` operation and return an object to manage it.
        """
        try:
            with self._conn.lock:
                self._conn.wait(self._start_copy_gen(statement, params))

                with Copy(self, writer=writer) as copy:
                    yield copy
        except e._NO_TRACEBACK as ex:
            raise ex.with_traceback(None)

        # If a fresher result has been set on the cursor by the Copy object,
        # read its properties (especially rowcount).
        self._select_current_result(0)

    def _fetch_pipeline(self) -> None:
        if (