o h&@sBddlZddlmZddlmZddlmZGdddejZdS)N) connresource)cursor) exceptionscsFeZdZdZdZfddZejdefddZ ejdefdd Z ejdefd d Z ejd d Z ejddZ ejddddejfddZejddddZejddddZejdddddZejdddd Zejddd!d"Zejddd#efd$d%Zd&d'Zd(d)Zd*d+Zfd,d-Zd.d/ZZS)0PreparedStatementz)A representation of a prepared statement.)_state_query _last_statuscs*t|||_||_|d|_dSN)super__init__rrattachr )self connectionquerystate __class__i/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/asyncpg/prepared_stmt.pyr s  zPreparedStatement.__init__returncCs|jjS)zVReturn the name of this prepared statement. .. versionadded:: 0.25.0 )rnamerrrrget_nameszPreparedStatement.get_namecCs|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" )rrrrr get_query#s zPreparedStatement.get_querycCs|jdur|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" N)r decoderrrr get_statusmsg.s  zPreparedStatement.get_statusmsgcC |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_parametersrrrrget_parameters<s z PreparedStatement.get_parameterscCr)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_attributesrrrrget_attributesMs z PreparedStatement.get_attributesN)prefetchtimeoutc Gs t|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 _connectionrr record_class)rr"r#argsrrrrfs zPreparedStatement.cursorF)analyzecsd}|r |d7}n|d7}||jj7}|rA|j}|IdHz|jj|g|RIdH}W|IdHn|IdHw|jj|g|RIdH}t|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) rrr% transactionstartfetchvalrollbackjsonloads)rr(r'rtrdatarrrexplain|s      zPreparedStatement.explain)r#cs||d|IdH}|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'r0rrrfetchs zPreparedStatement.fetchr)columnr#cs*||d|IdH}|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. rNrr2)rr6r#r'r0rrrr+s  zPreparedStatement.fetchvalcs&||d|IdH}|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. rNrr2r4rrrfetchrows  zPreparedStatement.fetchrowcfddIdHS)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 c|jjdddS)NT portal_namer# return_rowsbind_execute_manyrprotocolr'rr#rrz-PreparedStatement.fetchmany..N_PreparedStatement__do_executerr'r#rrBr fetchmanys  zPreparedStatement.fetchmanyr#cr8)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 cr9)Nr:Fr;r>r@rBrrrCrDz/PreparedStatement.executemany..NrErGrrBr executemanys  zPreparedStatement.executemanycsH|jj}z||IdHWStjy#|jIdH|jwr )r% _protocolrOutdatedSchemaCacheErrorreload_schema_stater mark_closed)rexecutorrArrr __do_executes zPreparedStatement.__do_executecs0fddIdH\}}}|_|S)Ncs|jddS)Nr:T) bind_executerr@r'limitrr#rrrC sz2PreparedStatement.__bind_execute..)rFr )rr'rRr#r0status_rrQr__bind_execute s z PreparedStatement.__bind_executecCs|jjr td|dS)Nz?cannot call PreparedStmt.{}(): the prepared statement is closed)rclosedrInterfaceErrorformatr meth_namerrr _check_opens zPreparedStatement._check_opencs||t|dSr )r[r _check_conn_validityrYrrrr\s z&PreparedStatement._check_conn_validitycCs|j|j|jdSr )rdetachr%_maybe_gc_stmtrrrr__del__s zPreparedStatement.__del__)__name__ __module__ __qualname____doc__ __slots__r rguardedstrrrrrr!rr$r1r5r+r7rHfloatrIrFr3r[r\r_ __classcell__rrrrrsJ     )   r)r-r:rrrConnectionResourcerrrrrs