ۇeh&XddlZddlmZddlmZddlmZGddejZdS)N) connresource)cursor) exceptionsceZdZdZdZfdZejdefdZ ejdefdZ ejdefdZ ejdZ ejd Z ejd d d dejfd Zejd ddZejd ddZejdd ddZejd ddZejd ddZejd ddefdZdZdZdZfdZdZxZS)PreparedStatementz)A representation of a prepared statement.)_state_query _last_statusct|||_||_|d|_dSN)super__init__r r attachr )self connectionquerystate __class__s G/var/www/api/venv/lib/python3.11/site-packages/asyncpg/prepared_stmt.pyrzPreparedStatement.__init__sD $$$    returnc|jjS)zVReturn the name of this prepared statement. .. versionadded:: 0.25.0 )r namers rget_namezPreparedStatement.get_names {rc|jS)zReturn the text of the query for this prepared statement. Example:: stmt = await connection.prepare('SELECT $1::int') assert stmt.get_query() == "SELECT $1::int" )r rs r get_queryzPreparedStatement.get_query#s {rcP|j|jS|jS)zReturn the status of the executed command. Example:: stmt = await connection.prepare('CREATE TABLE mytab (a int)') await stmt.fetch() assert stmt.get_statusmsg() == "CREATE TABLE" )r decoders r get_statusmsgzPreparedStatement.get_statusmsg.s+   $$ $ '')))rc4|jS)aReturn a description of statement parameters types. :return: A tuple of :class:`asyncpg.types.Type`. Example:: stmt = await connection.prepare('SELECT ($1::int, $2::text)') print(stmt.get_parameters()) # Will print: # (Type(oid=23, name='int4', kind='scalar', schema='pg_catalog'), # Type(oid=25, name='text', kind='scalar', schema='pg_catalog')) )r _get_parametersrs rget_parametersz PreparedStatement.get_parameters<s{**,,,rc4|jS)aReturn a description of relation attributes (columns). :return: A tuple of :class:`asyncpg.types.Attribute`. Example:: st = await self.con.prepare(''' SELECT typname, typnamespace FROM pg_type ''') print(st.get_attributes()) # Will print: # (Attribute( # name='typname', # type=Type(oid=19, name='name', kind='scalar', # schema='pg_catalog')), # Attribute( # name='typnamespace', # type=Type(oid=26, name='oid', kind='scalar', # schema='pg_catalog'))) )r _get_attributesrs rget_attributesz PreparedStatement.get_attributesMs.{**,,,rN)prefetchtimeoutc htj|j|j|j||||jjS)abReturn a *cursor factory* for the prepared statement. :param args: Query arguments. :param int prefetch: The number of rows the *cursor iterator* will prefetch (defaults to ``50``.) :param float timeout: Optional timeout in seconds. :return: A :class:`~cursor.CursorFactory` object. )r CursorFactory _connectionr r record_class)rr(r)argss rrzPreparedStatement.cursorfs:#   K K    K $   rF)analyzecKd}|r|dz }n|dz }||jjz }|r|j}|d{V |jj|g|Rd{V}|d{Vn8#|d{VwxYw|jj|g|Rd{V}tj|S)aReturn the execution plan of the statement. :param args: Query arguments. :param analyze: If ``True``, the statement will be executed and the run time statitics added to the return value. :return: An object representing the execution plan. This value is actually a deserialized JSON output of the SQL ``EXPLAIN`` command. zEXPLAIN (FORMAT JSON, VERBOSEz , ANALYZE) z) N) r rr, transactionstartfetchvalrollbackjsonloads)rr/r.rtrdatas rexplainzPreparedStatement.explain|s40   ] "EE TME ""  A!--//B((**        $6T-6uDtDDDDDDDDDkkmm########bkkmm########2)25@4@@@@@@@@@Dz$s B B')r)cDK||d|d{V}|S)aExecute the statement and return a list of :class:`Record` objects. :param str query: Query text :param args: Query arguments :param float timeout: Optional timeout value in seconds. :return: A list of :class:`Record` instances. rN _PreparedStatement__bind_executerr)r.r8s rfetchzPreparedStatement.fetchs6((q':::::::: rr)columnr)cdK||d|d{V}|sdS|d|S)a:Execute the statement and return a value in the first row. :param args: Query arguments. :param int column: Numeric index within the record of the value to return (defaults to 0). :param float timeout: Optional timeout value in seconds. If not specified, defaults to the value of ``command_timeout`` argument to the ``Connection`` instance constructor. :return: The value of the specified column of the first record. rNrr;)rr?r)r.r8s rr3zPreparedStatement.fetchvalsL((q':::::::: 4AwvrcXK||d|d{V}|sdS|dS)aExecute the statement and return the first row. :param str query: Query text :param args: Query arguments :param float timeout: Optional timeout value in seconds. :return: The first row as a :class:`Record` instance. rNrr;r=s rfetchrowzPreparedStatement.fetchrowsG((q':::::::: 4AwrcLKfdd{VS)a Execute the statement and return a list of :class:`Record` objects. :param args: Query arguments. :param float timeout: Optional timeout value in seconds. :return: A list of :class:`Record` instances. .. versionadded:: 0.30.0 cB|jddS)NT portal_namer) return_rowsbind_execute_manyr protocolr.rr)s rz-PreparedStatement.fetchmany..s-X77  8rN_PreparedStatement__do_executerr.r)s```r fetchmanyzPreparedStatement.fetchmanys_&&               rr)cLKfdd{VS)a:Execute the statement for each sequence of arguments in *args*. :param args: An iterable containing sequences of arguments. :param float timeout: Optional timeout value in seconds. :return None: This method discards the results of the operations. .. versionadded:: 0.22.0 cB|jddS)NrEFrFrIrKs rrMz/PreparedStatement.executemany..s-X77 ! 8rNrNrPs```r executemanyzPreparedStatement.executemanys_&&       rcK|jj} ||d{VS#tj$r:|jd{V|jwxYwr )r, _protocolrOutdatedSchemaCacheErrorreload_schema_stater mark_closed)rexecutorrLs r __do_executezPreparedStatement.__do_executes#- !(++++++++ +2   "6688 8 8 8 8 8 8 8 K # # % % %  s !A A*cjKfdd{V\}}}|_|S)NcB|jddS)NrET) bind_executer )rLr.limitrr)s rrMz2PreparedStatement.__bind_execute.. s&X22 T2udG==r)rOr )rr.r_r)r8status_s```` r__bind_executez PreparedStatement.__bind_execute su $ 1 1 = = = = = = =!>!>>>>>>>fa# rcl|jjr'tjd|dS)Nz?cannot call PreparedStmt.{}(): the prepared statement is closed)r closedrInterfaceErrorformat)r meth_names r _check_openzPreparedStatement._check_opensF ;  F+3396)3D3DFF F F Frct||t|dSr )rhr_check_conn_validity)rrgrs rrjz&PreparedStatement._check_conn_validitys5 ### $$Y/////rcv|j|j|jdSr )r detachr,_maybe_gc_stmtrs r__del__zPreparedStatement.__del__s5  '' 44444r)__name__ __module__ __qualname____doc__ __slots__rrguardedstrrrr!r$r'rr+r9r>r3rBrQfloatrTrOr<rhrjrn __classcell__)rs@rrrs334I!!!!! #    3 *s * * * *--- ---0%)   & 4    *+0' ' ' ' ' R)-     +,d$,0     /3     (8<%$   FFF 000005555555rr)r5rErrrConnectionResourcerrrrzs N5N5N5N5N5 7N5N5N5N5N5r