U ڲg'@s0dZddlmZddlmZmZddlmZddlm Z m Z m Z m Z ddl mZddl mZdd lmZdd lmZmZmZmZdd lmZmZdd lmZmZmZmZe rdd lm Z ddl!m"Z"ddl#m$Z$ej%j&Z&ej%j'Z'ej(j)Z)GdddedZ*GdddeZ+Gddde+Z,Gddde,Z-dS)z7 Objects to support the COPY protocol (async version). ) annotations)ABCabstractmethod) TracebackType)Any AsyncIteratorSequence TYPE_CHECKING)pq)errors)Self)BaseCopyMAX_BUFFER_SIZE QUEUE_SIZE PREFER_FLUSH)copy_tocopy_end)aspawnagatherAQueueAWorker)Buffer) AsyncCursor)AsyncConnectioncseZdZUdZdZded<dddddd d fd d Zd dddZdddddddZddddZddddZ dddd Z d!dd"d#Z d$dd%d&d'Z d(dd)d*d+Z ddd,d-d.ZZS)/ AsyncCopyajManage an asynchronous :sql:`COPY` operation. :param cursor: the cursor where the operation is performed. :param binary: if `!True`, write binary format. :param writer: the object to write to destination. If not specified, write to the `!cursor` connection. Choosing `!binary` is not necessary if the cursor has executed a :sql:`COPY` operation, because the operation result describes the format too. The parameter is useful when a `!Copy` object is created manually and no operation is performed on the cursor, such as when using ``writer=``\ `~psycopg.copy.FileWriter`. Zpsycopg AsyncWriterwriterN)binaryrAsyncCursor[Any]z bool | NonezAsyncWriter | None)cursorrrcs.tj||d|st|}||_|j|_dS)N)r)super__init__AsyncLibpqWriterrwrite_write)selfr rr __class__7/tmp/pip-unpacked-wheel-b_ea6rx_/psycopg/_copy_async.pyr"2s zAsyncCopy.__init__r returncs ||SN)_enterr&r)r)r* __aenter__@szAsyncCopy.__aenter__ztype[BaseException] | NoneBaseException | NonezTracebackType | NoneNone)exc_typeexc_valexc_tbr,cs||IdHdSr-)finish)r&r3r4r5r)r)r* __aexit__DszAsyncCopy.__aexit__zAsyncIterator[Buffer]cCs |IdH}|sq|VqdS)z5Implement block-by-block iteration on :sql:`COPY TO`.N)readr&datar)r)r* __aiter__NszAsyncCopy.__aiter__rcs|j|IdHS)z Read an unparsed row after a :sql:`COPY TO` operation. Return an empty string when the data is finished. N) connectionwaitZ _read_genr/r)r)r*r8VszAsyncCopy.readzAsyncIterator[tuple[Any, ...]]cCs$|IdH}|dkrq |VqdS)z Iterate on the result of a :sql:`COPY TO` operation record by record. Note that the records returned will be tuples of unparsed strings or bytes, unless data types are specified using `set_types()`. N)read_row)r&recordr)r)r*rows^szAsyncCopy.rowsztuple[Any, ...] | Nonecs|j|IdHS)a Read a parsed row of data from a table after a :sql:`COPY TO` operation. Return `!None` when the data is finished. Note that the records returned will be tuples of unparsed strings or bytes, unless data types are specified using `set_types()`. N)r<r=Z _read_row_genr/r)r)r*r>ks zAsyncCopy.read_rowz Buffer | str)bufferr,cs$|j|}|r ||IdHdS)z Write a block of data to a table after a :sql:`COPY FROM` operation. If the :sql:`COPY` is in binary format `!buffer` must be `!bytes`. In text mode it can be either `!bytes` or `!str`. N) formatterr$r%)r&rAr:r)r)r*r$vs zAsyncCopy.writez Sequence[Any])rowr,cs$|j|}|r ||IdHdS)z=Write a record to a table after a :sql:`COPY FROM` operation.N)rB write_rowr%)r&rCr:r)r)r*rDs zAsyncCopy.write_rowexcr,cs|jtkrB|j}|r(||IdH|j|IdHd|_n>|sJdS|jj t krZdS|j IdH|j |IdHdS)aTerminate the copy operation and free the resources allocated. You shouldn't need to call this function yourself: it is usually called by exit. It is available if, despite what is documented, you end up using the `Copy` object outside a block. NT)Z _directionCOPY_INrBendr%rr6 _finished_pgconnZtransaction_statusACTIVEr<Z _try_cancelr=Z_end_copy_out_gen)r&rFr:r)r)r*r6s   zAsyncCopy.finish)__name__ __module__ __qualname____doc____annotations__r"r0r7r;r8r@r>r$rDr6 __classcell__r)r)r'r*rs     rzAsyncConnection[Any]c@s6eZdZdZedddddZd ddd d d ZdS) rzG A class to write copy data somewhere (for async connections). rr2r:r,csdS)zWrite some data to destination.Nr)r9r)r)r*r$szAsyncWriter.writeNr1rEcsdS)z Called when write operations are finished. If operations finished with an error, it will be passed to ``exc``. Nr)r&rFr)r)r*r6szAsyncWriter.finish)N)rLrMrNrOrr$r6r)r)r)r*rsrc@sDeZdZdZdZddddZddd d d Zdd ddddZd S)r#zE An `AsyncWriter` to write copy data to a Postgres database. psycopg.copyrr cCs||_|j|_|jj|_dSr-)r r<ZpgconnrJr&r r)r)r*r"szAsyncLibpqWriter.__init__rr2rRc spt|tkr,|jt|j|tdIdHn@tdt|tD].}|jt|j|||ttdIdHq|j|IdHn4tdt|tD]"}|j|||tIdHqNdS)Nr) rgrrlrhrYrrfputrZr[r)r)r*r$ s  zAsyncQueuedLibpqWriter.writeNr1rEcsP|jdIdH|jr.t|jIdHd|_|jr:|jt|IdHdS)N)rfrmrgrrhr!r6rSr'r)r*r6 szAsyncQueuedLibpqWriter.finish)N) rLrMrNrOr"rlr$r6rQr)r)r'r*rds rdN).rO __future__rabcrrtypesrtypingrrrr r r ra_compatr Z _copy_baserrrr generatorsrrZ_acompatrrrrrZ cursor_asyncrZconnection_asyncrZ ExecStatusrGZCOPY_OUTZTransactionStatusrKrrr#rdr)r)r)r*s,        /