HEX

File: //var/opt/nydus/ops/mysql/connector/__pycache__/connection_cext.cpython-39.pyc
a

�,�h��
@s�dZddlZddlZddlZddlZddlmZmZmZm	Z	m
Z
mZmZm
Z
mZmZddlmZddlmZmZddlmZmZmZmZmZddlmZdd	lmZmZm Z m!Z!m"Z"dd
l#m$Z$ddl%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0d
Z1zTddl2Z2ddl2m3Z3ddl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@dZ1Wn8eA�y�ZBzeAdeB�d��eB�WYdZB[Bn
dZB[B00ddlCmDZDddlEmFZFeD�r�ddlGmHZHmIZIGdd�de�ZJdS)z'Connection class using the C Extension.�N)
�Any�BinaryIO�Dict�List�NoReturn�Optional�Sequence�Tuple�Type�Union�)�version)�CMySQLPrepStmt�MySQLConnectionAbstract)�
ClientFlag�	FieldFlag�	FieldType�
ServerFlag�ShutdownType)�MySQLConverter)�InterfaceError�
InternalError�OperationalError�ProgrammingError�get_mysql_exception)�
MySQLProtocol)�CextEofPacketType�CextResultType�DescriptionType�ParamsSequenceOrDictType�RowType�StatsPacketType�
StrOrBytes)�
import_object�warn_ciphersuites_deprecated�warn_tls_version_deprecatedF)�MySQLInterfaceError)�CMySQLCursor�CMySQLCursorBuffered�CMySQLCursorBufferedDict�CMySQLCursorBufferedNamedTuple�CMySQLCursorBufferedRaw�CMySQLCursorDict�CMySQLCursorNamedTuple�CMySQLCursorPrepared�CMySQLCursorPreparedDict�CMySQLCursorPreparedNamedTuple�CMySQLCursorPreparedRaw�CMySQLCursorRawTz2MySQL Connector/Python C Extension not available (�))�OTEL_ENABLED)�with_context_propagation)�end_span�record_exception_eventcs�eZdZdZedd��fdd�Zdd�dd�Zdd�d	d
�Zee	d�dd��Z
edd
�dd�Zd�e
dd�dd�Zee
d�dd��Zeje
dd�dd��Zeed�dd��Zejedd�dd��Zee
d�dd��Zdd�dd�Zdd�dd�ZeZe
d�d d!�Ze
d�d"d#�Zd�e
e	e	dd'�d(d)�Zedd*�d+d,�Zeeed-�d.d/�Zeee	d�d0d1��Zd�ee	e
eee ee
ee!e"eeee#fd2�d3d4�Z$d�e
eee ee
ee!e"eeee#fd5�d6d7�Z%ee
d�d8d9�Z&dd�d:d;�Z'dd�d<d=�Z(dd�d>d?�Z)edd@�dAdB�Z*d�ee!e+dC�dDdE�Z,ee#d�dFdG�Z-e.e!dH�dIdJ�Z/e0e!eee1e#e+fdK�dLdM��Z2e!ddN�dOdP�Z3e!ddN�dQdR�Z4e0d�eee
e
e
ee1e#e+fdS�dTdU��Z5e5Z6d�ee
ee
ee
ee7e8ee
ee
e8dV�dWdX�Z9ee	d�dYdZ��Z:ee	d�d[d\��Z;ee
d�d]d^��Z<ee
d�d_d`��Z=ee
d�dadb��Z>e?e1e@e.eAee.ffdc�ddde�ZBdd�dfdg�ZCd�eeee	eeeeeeeddj�
dkdl�ZDe
d�dmdn�ZEe	ee#do�dpdq�ZFdd�drds�ZGd�ee	ddt�dudv�ZHeId�dwdx�ZJe	ddy�dzd{�ZKeLd�d|d}�ZMeLd�d~d�ZNeeLd��d�d��ZOe!e	ePeLd��d�d��ZQd�e
dd��d�d��ZRd�eeAeefeeAeefdd��d�d��ZS�ZTS)��CMySQLConnectionz6Class initiating a MySQL Connection using Connector/C.N)�kwargs�returncs�tstd��d|_g|_tj�tj�tj�t	j
��ddd�|_t�
�dkrntj�|j�sntj�d�rhdnd|_d|_t���|r�z|jfi|��Wnty�|���Yn0dS)	ZInitializationz0MySQL Connector/Python C Extension not availableNZmysql�vendorZplugin�Linuxz/usr/lib64/mysql/pluginz/usr/lib/mysql/plugin)�HAVE_CMYSQL�RuntimeError�_cmysql�_columns�os�path�join�dirname�abspath�_mysql_connector�__file__�_plugin_dir�platform�system�exists�	converter�super�__init__�connect�	Exception�close)�selfr9��	__class__��R/opt/nydus/tmp/pip-target-wkfpz8uv/lib64/python/mysql/connector/connection_cext.pyrNts2��
��
zCMySQLConnection.__init__)r:c
CsZtj�d�}|ddkrd}nd}|j�d|d�dd	�tjdd
�D��t��d��dS)
z!Add default connection attributes� rZGPLv2zGPL-2.0Z
Commercialzmysql-connector-python�.cSsg|]}t|��qSrU)�str)�.0�xrUrUrV�
<listcomp>��z<CMySQLConnection._add_default_conn_attrs.<locals>.<listcomp>�)Z_connector_nameZ_connector_licenseZ_connector_versionZ_source_hostN)	r
ZLICENSE�split�_conn_attrs�updaterC�VERSION�socket�gethostname)rRZlicense_chunksZclient_licenserUrUrV�_add_default_conn_attrs�s��z(CMySQLConnection._add_default_conn_attrsc	CsT|j��|j��|j��dddd|j��d�|_|�|jd�|_|j�	|j�dS)z<Gather information of the MySQL server before authenticationN)�protocol�server_version_originalZserver_threadid�charset�
server_status�auth_pluginZ	auth_dataZcapabilitiesrg)
r?Zget_proto_infoZget_server_info�	thread_idZst_server_capabilitiesZ
_handshakeZ_check_server_versionZ_server_version�_character_setZset_mysql_version�rRrUrUrV�
_do_handshake�s��zCMySQLConnection._do_handshakecCs
|j��S)z6Returns the server status attribute of MYSQL structure)r?Zst_server_statusrmrUrUrV�_server_status�szCMySQLConnection._server_status)rBr:cCs|jr|j�|�dS)zJset local_infile_in_path

        Set allow_local_infile_in_path.
        N)r?Z!set_load_data_local_infile_option)rRrBrUrUrV�set_allow_local_infile_in_path�sz/CMySQLConnection.set_allow_local_infile_in_pathT)�valuer:cCs.||_|jr|j�|�|jr*|j�|�dS)zuToggle unicode mode

        Set whether we return string fields as unicode or not.
        Default is True.
        N)�_use_unicoder?�use_unicoderL�set_unicode�rRrqrUrUrVrt�s
zCMySQLConnection.set_unicodecCs|�d�d}|dkS)z#Get whether autocommit is on or offzSELECT @@session.autocommitrr��
info_queryrurUrUrV�
autocommit�szCMySQLConnection.autocommitc
CsVz|j�|�||_Wn:tyP}z"t|j|j|jd�|�WYd}~n
d}~00dS)zToggle autocommit��msg�errno�sqlstateN)r?rxZ_autocommitr&rrzr{r|�rRrq�errrUrUrVrx�s
��cCs|�d�dS)zGet the current databasezSELECT DATABASE()rrvrmrUrUrV�database�szCMySQLConnection.databasec
CsPz|j�|�Wn:tyJ}z"t|j|j|jd�|�WYd}~n
d}~00dS)zSet the current databaseryN�r?Z	select_dbr&rrzr{r|r}rUrUrVr�s��cCst|jtj@�S)z'MySQL session has started a transaction)�boolrorZSTATUS_IN_TRANSrmrUrUrV�in_transaction�szCMySQLConnection.in_transactionc	Cs�|j�|j�d}tj|j|j||jp(d|j|j	|j
d�|_|�t
j�sNi|_|j|j|j|j|j|j|j|j|j|j|jd|j|j|j|j|jt|j t!�r�t"|j �n|j d�}|j#�$d�}|dur�|j%dd�d�&|�}|j#�$d�du�r|j#�$d�d}|j#�$d�d	}nd}d}|du�r4d
|v�r4|�s4d}|j'�s�|�(|j#�$d�|j#�$d
�|j#�$d�||||j#�$d��ptd|j#�$d��p�d|j'd�	�t)j*dk�r�|j+dk�r�d|d<z2|jj,fi|��|j-|j_.|j/�r�|j-|j/_0Wn<t1�y}z"t2|j3|j4|j5d�|�WYd}~n
d}~00|�6�|j'�s�t7|jd��r�t8|jj9��r�|j�9�}t:|j#�$dg��D]}t;|�t<||��qhdS)Nr)�buffered�raw�charset_nameZconnection_timeoutrsrjZ
plugin_dirT)�host�user�password�	password1�	password2�	password3r�portZclient_flagsZunix_socket�compress�ssl_disabledZ
conn_attrsZlocal_infileZload_data_local_dir�oci_config_file�oci_config_profileZwebauthn_callback�tls_versions)�reverse�,�tls_ciphersuitesrzTLSv1.3ZTLS_AES_256_GCM_SHA384�ca�cert�keyZverify_certFZverify_identity)	Zssl_caZssl_certZssl_keyZssl_cipher_suitesr�Ztls_cipher_suitesZssl_verify_certZssl_verify_identityr��ntZMySQLKerberosAuthPluginZuse_kerberos_gssapiry�get_ssl_cipher)=rl�get_info�_charset_idrFZMySQL�	_buffered�_rawZ_connection_timeoutrrZ_auth_pluginrHr?Zisset_client_flagrZCONNECT_ARGSr`�_host�_user�	_password�
_password1�
_password2�
_password3�	_database�_portZ
_client_flags�_unix_socketZ	_compressZ_allow_local_infileZ_allow_local_infile_in_path�_oci_config_file�_oci_config_profile�
isinstanceZ_webauthn_callbackrYr#�_ssl�get�sortrCZ
_ssl_disabledrarA�nameZ_auth_plugin_classrO�_converter_str_fallback�converter_str_fallbackrLZstr_fallbackr&rrzr{r|rn�hasattr�callabler��setr%r$)	rRr�Z
cnx_kwargsr�Zssl_ciphersuitesr�r~�cipherZtls_versionrUrUrV�_open_connection�s��

��

�
����


��
���
�
�	
z!CMySQLConnection._open_connectionc
Cs�|jr$|j��r$t|jt��d�|js.dSztz|��|j��WnJty�}z2t	rft|j|�t
|j|j|j
d�|�WYd}~n
d}~00Wt	r�t|j�nt	r�t|j�0dS)z Disconnect from the MySQL serverrNry)Z_spanZis_recordingr7�sys�exc_infor?�free_resultrQr&r4rrzr{r|r6)rRr~rUrUrVrQ`s&���zCMySQLConnection.closecCs|j��S)z8Return True if the connection to MySQL Server is closed.)r?�	connectedrmrUrUrV�	is_closedwszCMySQLConnection.is_closedcCs|jr|��|j��SdS)z;Reports whether the connection to MySQL Server is availableF)r?�handle_unread_result�pingrmrUrUrV�is_connected{s
zCMySQLConnection.is_connectedFrr)�	reconnect�attempts�delayr:cCsR|��z|j��}Wnty(Yn
0|r2dS|rF|j||d�ntd��dS)a�Check availability of the MySQL server

        When reconnect is set to True, one or more attempts are made to try
        to reconnect to the MySQL server using the reconnect()-method.

        delay is the number of seconds to wait between each retry.

        When the connection is not available, an InterfaceError is raised. Use
        the is_connected()-method if you just want to check the connection
        without raising an error.

        Raises InterfaceError on errors.
        N)r�r�z$Connection to MySQL is not available)r�r?r��AttributeErrorr�r)rRr�r�r�r�rUrUrVr��szCMySQLConnection.ping)rhr:cCs|j�|�dS)z;Sets the default character set name for current connection.N)r?Zset_character_set)rRrhrUrUrV�set_character_set_name�sz'CMySQLConnection.set_character_set_name)�queryr:c
Cs�d}zH|j�|�|jjr@|j��}|j��r@|j��td��|j��Wn:ty�}z"t|j|j	|j
d�|�WYd}~n
d}~00|S)z%Send a query which only returns 1 rowrUz'Query should not return more than 1 rowryN)r?r��have_result_set�	fetch_rowr�rr&rrzr{r|)rRr�Z	first_rowr~rUrUrVrw�s 


��zCMySQLConnection.info_querycCs$z|j��WStyYn0dS)zMySQL connection IDN)r?rkr&rmrUrUrV�
connection_id�s
zCMySQLConnection.connection_id)�count�binary�columnsr��	prep_stmtr:c
Cs�|r
|jn|j}|jr|s"td��|dur0|j}g}|durL|dkrLtd��d}�z*|r^|jn|jj}	|jrx|j�d�|	�}
|
�rBt	|
�}
|j��s�|s�t
|j�D](\}}|dtj
kr�t�|
|�|
|<q�|j�s|j�rt
|
�D](\}}
|s�|j�|j||
|�|
|<q�|�t|
��|d7}|�r:||k�r:�qB|	�}
q~|
�sv|�|�d}|�rl|��d|_n|��nd}Wn`t�y�}zF|�r�|��tt|��|�|��t|j|j|jd	�|�WYd}~n
d}~00||fS)
z8Get all or a subset of rows returned by the MySQL serverzNo result set availableNrz$count should be 1 or higher, or NoneTr�eofFry)r��
unread_resultr?rr�r�r�rLr��list�	enumerater@rZVECTORrZ_vector_to_pythonZ	to_python�append�tuple�fetch_eof_columnsr��_unread_resultr&rrYrrzr{r|)rRr�r�r�r�r�r��rows�counterr��row�iZdsc�_�_eofr~rUrUrV�get_rows�sb	

�
��zCMySQLConnection.get_rows)r�r�r�r�r:cCsNz4|jd||||d�\}}|r,|d|fWSd|fWStyHYdS0dS)z.Get the next rows returned by the MySQL serverr)r�r�r�r�r�rN)NN)r��
IndexError)rRr�r�r�r�r�r�rUrUrV�get_rows�

zCMySQLConnection.get_rowcCs|jr|j��|j��SdS)zReads the next resultN)r?�consume_result�next_resultrmrUrUrVr�(s

zCMySQLConnection.next_resultcCs|jr|j��dS)zFrees the resultN)r?r�rmrUrUrVr�/szCMySQLConnection.free_resultcCs|jr|��|j��dS)zCommit current transactionN)r?r��commitrmrUrUrVr�4szCMySQLConnection.commitcCs|jr|j��|j��dS)zRollback current transactionN)r?r��rollbackrmrUrUrVr�:s
zCMySQLConnection.rollback)rr:c
CsPz|j�|�Wn:tyJ}z"t|j|j|jd�|�WYd}~n
d}~00dS)zChange the current databaseryNr�)rRrr~rUrUrV�cmd_init_db@s��zCMySQLConnection.cmd_init_db)r�r:cCs�|r
|jn|jj}|std��|r*|��n|j��}g|_|D]N}|j�|dt|d�ddddt|d�tj@t|d�t|d�f	�q>|j	|j�
�d�|jd�S)	z Fetch EOF and column information�
No result set��N�	�)Zstatus_flag�
warning_count)r�r�)r�r?rZfetch_fieldsr@r��intrZNOT_NULLro�st_warning_count)rRr�r��fields�colrUrUrVr�Is0�


����z"CMySQLConnection.fetch_eof_columnscCs4|jr0|j��|j��|j��|j��|jd�SdS)z Fetch EOF and status information)r�Zfield_count�	insert_id�
affected_rowsriN)r?r�Zst_field_countr�r�rormrUrUrV�fetch_eof_statusls�z!CMySQLConnection.fetch_eof_status)�	statementr:c
Csd|jstd��z|j�|�}|j|_t|�WSty^}ztt|��|�WYd}~n
d}~00dS)zPrepares the SQL statement�MySQL Connection not availableN)	r?rZstmt_preparer�r�rr&rrY)rRr��stmtr~rUrUrV�cmd_stmt_prepareys
z!CMySQLConnection.cmd_stmt_prepare)�statement_id�argsr:c
Gstz|j|d|ji�Wn2tyH}ztt|��|�WYd}~n
d}~00g|_|jsdd|_|��Sd|_|�	|�S)zExecutes the prepared statement�query_attrsNFT)
Zstmt_executer�r&rrYr@r�r�r�r�)rRr�r�r~rUrUrV�cmd_stmt_execute�s$z!CMySQLConnection.cmd_stmt_execute)r�r:cCs|jrtd��|��dS)zCloses the prepared statement�Unread result foundN)r�rZ
stmt_close�rRr�rUrUrV�cmd_stmt_close�szCMySQLConnection.cmd_stmt_closecCs|jrtd��|��dS)zResets the prepared statementr�N)r�rZ
stmt_resetr�rUrUrV�cmd_stmt_reset�szCMySQLConnection.cmd_stmt_reset)r�r�r��
raw_as_stringr:c
Cs�|��|dur|j}z0t|t�s,|�d�}|jj|||||jd�Wn�ty�}z"t	|j
|j|jd�|�WYd}~n\d}~0t
y�}z<|jr�|jn|j�d|j��}td|dfd�|�WYd}~n
d}~00g|_|jjs�|��S|��S)	z Send a query to the MySQL serverNzutf-8)r�r�r�r�)rzr|�:izConnection not available.)r{�values)r�r�r��bytes�encoder?r�r�r&rr{rzr|r�r�r�r�rr@r�r�r�)rRr�r�r�r�r~�addrrUrUrV�	cmd_query�s>	

�
�����zCMySQLConnection.cmd_query)r�r��prepared�cursor_class�
dictionary�named_tupler:c
s|�|�|��std��|dur<t|t�s4td��||�S|pD|j}|pN|j}d�|durd�dO�|durt�dO�|dur��dO�|dur��d	O�|dur��d
O�ttt	t
ttt
tttttd�}z|�|�WSt�yd�td
d���fdd�td�D���d�Yn0dS)a�Instantiates and returns a cursor using C Extension

        By default, CMySQLCursor is returned. Depending on the options
        while connecting, a buffered and/or raw cursor is instantiated
        instead. Also depending upon the cursor options, rows can be
        returned as dictionary or named tuple.

        Dictionary and namedtuple based cursors are available with buffered
        output but not raw.

        It is possible to also give a custom cursor through the
        cursor_class parameter, but it needs to be a subclass of
        mysql.connector.cursor_cext.CMySQLCursor.

        Raises ProgrammingError when cursor_class is not a subclass of
        CursorBase. Raises ValueError when cursor is not available.

        Returns instance of CMySQLCursor or subclass.

        :param buffered: Return a buffering cursor
        :param raw: Return a raw cursor
        :param prepared: Return a cursor which uses prepared statements
        :param cursor_class: Use a custom cursor class
        :param dictionary: Rows are returned as dictionary
        :param named_tuple: Rows are returned as named tuple
        :return: Subclass of CMySQLCursor
        :rtype: CMySQLCursor or subclass
        �MySQL Connection not available.Nz=Cursor class needs be to subclass of cursor_cext.CMySQLCursorrTr�r�r��)rrrr^r��r�r�r���)r�r�rrrz*Cursor not available with given criteria: z, cs$g|]}�d|>@dkr�|�qS)rrrU)rZr��r�Zcursor_typerUrVr\'r]z+CMySQLConnection.cursor.<locals>.<listcomp>r)r�r�r�
issubclassr'rr�r�r(r2r+r,r)r-r*r.r1r/r0�KeyError�
ValueErrorrC�range)rRr�r�rrrr�typesrUrrV�cursor�s\%

�

����zCMySQLConnection.cursorcCs|jjstd��|j��S)z,Returns number of rows of current result setr�)r?r�r�num_rowsrmrUrUrVr*szCMySQLConnection.num_rowscCs|js
dS|j��S)zReturns number of warningsr)r?r�rmrUrUrVr�2szCMySQLConnection.warning_countcCs|js
dS|jjS)z"Check if a result set is availableF)r?r�rmrUrUrV�result_set_available:sz%CMySQLConnection.result_set_availablecCs|jS)z)Check if there are unread results or rows)rrmrUrUrVr�BszCMySQLConnection.unread_resultcCs
|j��S)zCheck if there are more results)r?�more_resultsrmrUrUrVrGszCMySQLConnection.more_results)�paramsr:cs�g}t|ttf�r:�jr,�fdd�|D�}qʈjj|�}n�t|t�r�i}�jr�|��D],\}}�j��j�	�j�
|��j��||<qVq�|��D]\}}�j�|�d||<q�ntdt
|�j�d|�d���|S)z�Prepare parameters for statements

        This method is use by cursors to prepared parameters found in the
        list (or tuple) params.

        Returns dict.
        c	s,g|]$}�j��j��j�|��j���qSrU)rL�quote�escape�to_mysql�	_sql_mode)rZrqrmrUrVr\Ys���z6CMySQLConnection.prepare_for_mysql.<locals>.<listcomp>rzCould not process parameters: �(z)), it must be of type list, tuple or dict)r�r�r�rLr?Zconvert_to_mysql�dict�itemsrrrrr�type�__name__)rRr�resultr�rqrUrmrV�prepare_for_mysqlLs,

�	
���z"CMySQLConnection.prepare_for_mysqlcCs|j��dS)zlConsume the current result

        This method consume the result by reading (consuming) all rows.
        N)r?r�rmrUrUrV�consume_resultswsz CMySQLConnection.consume_results��-)
�usernamer�rrhr�r�r�r�r�r:c

Csrz|j�||||||||	�Wn:tyX}
z"t|
j|
j|
jd�|
�WYd}
~
n
d}
~
00||_||_|�	�dS)z!Change the current logged in userryN)
r?Zchange_userr&rrzr{r|r�r��_post_connection)rRr$r�rrhr�r�r�r�r�r~rUrUrV�cmd_change_user~s(
���z CMySQLConnection.cmd_change_usercCs|j��}|r|��|S)z�Resets the session state without re-authenticating

        Reset command only works on MySQL server 5.7.3 or later.
        The result is True for a successful reset otherwise False.

        Returns bool
        )r?Zreset_connectionr%)rR�resrUrUrV�cmd_reset_connection�s
z%CMySQLConnection.cmd_reset_connection)�optionsr:c
Cs\z|��|j�|�Wn:tyR}z"t|j|j|jd�|�WYd}~n
d}~00|��S)z,Send the Refresh command to the MySQL serverryN)	r�r?Zrefreshr&rrzr{r|r�)rRr)r~rUrUrV�cmd_refresh�s��zCMySQLConnection.cmd_refreshcCs|��dS)z,Close the current connection with the serverN)rQrmrUrUrV�cmd_quit�szCMySQLConnection.cmd_quit)�
shutdown_typer:c
Cs�|jstd��|r*t�|�s$td��|}ntj}z|j�|�Wn:tyz}z"t|j	|j
|jd�|�WYd}~n
d}~00|��dS)z�Shut down the MySQL Server

        This method sends the SHUTDOWN command to the MySQL server.
        The `shutdown_type` is not used, and it's kept for backward compatibility.
        r�zInvalid shutdown typeryN)
r?rrr�rZSHUTDOWN_DEFAULT�shutdownr&rrzr{r|rQ)rRr,�levelr~rUrUrV�cmd_shutdown�s 
��zCMySQLConnection.cmd_shutdownc
Csh|��z|j��}t�j|dd�WSttfyb}z"t|j|j	|j
d�|�WYd}~n
d}~00dS)z'Return statistics from the MySQL serverF)Zwith_headerryN)r�r?�statrZparse_statisticsr&rrrzr{r|)rRr0r~rUrUrV�cmd_statistics�s
��zCMySQLConnection.cmd_statistics)�	mysql_pidr:cCs&t|t�std��|�d|���dS)zKill a MySQL processzMySQL PID must be intzKILL N)r�r�rr�)rRr2rUrUrV�cmd_process_kill�s
z!CMySQLConnection.cmd_process_killcCst�dS)zSend the DEBUG commandN��NotImplementedErrorrmrUrUrV�	cmd_debug�szCMySQLConnection.cmd_debugcCst�dS)zSend the PING commandNr4rmrUrUrV�cmd_ping�szCMySQLConnection.cmd_ping)�
statementsr:cCst�dS)z/Send one or more statements to the MySQL serverNr4)rRr8rUrUrV�cmd_query_iter�szCMySQLConnection.cmd_query_iter)r��param_id�datar:cCst�dS)zSend data for a columnNr4)rRr�r:r;rUrUrV�cmd_stmt_send_long_data�sz(CMySQLConnection.cmd_stmt_send_long_data)rr:cCs4|dur|jn|j}|jr$|��n|r0td��dS)z'Check whether there is an unread resultTr�N)r�r�Zcan_consume_resultsr!r)rRrr�rUrUrVr��s

z%CMySQLConnection.handle_unread_result)�user_variables�session_variablesr:cCs�|��std��|��sdz0|�|j|j|j|j|j|j	|j
|j|j�	Wnt
yb|��Yn0|sl|r�|��}|r�|��D]\}}|�d|�d�|f�q�|r�|��D]\}}|�d|�d�|f�q�|��dS)a�Clears the current active session

        This method resets the session state, if the MySQL server is 5.7.3
        or later active session will be reset without re-authenticating.
        For other server versions session will be reset by re-authenticating.

        It is possible to provide a sequence of variables and their values to
        be set after clearing the session. This is possible for both user
        defined variables and session variables.
        This method takes two arguments user_variables and session_variables
        which are dictionaries.

        Raises OperationalError if not connected, InternalError if there are
        unread results and InterfaceError on errors.
        rzSET @`z` = %sz
SET SESSION `N)r�rr(r&r�r�r�r�r�r�r�r�r�rr�rr�executerQ)rRr=r>�curr�rqrUrUrV�
reset_sessions4�zCMySQLConnection.reset_session)T)Frr)NFNNN)FNNN)N)NFF)NNNNNN)	r"r"r"r#r"r"r"NN)N)F)NN)Ur�
__module__�__qualname__�__doc__rrNrern�propertyr�rorYrpr�rtrx�setterrr�r�rQZ
disconnectr�r�r�r�r"rr rwr�rrrr	rr�r�r�r�r�r�r�rr�r�r�r�r5rr�r�r�r�Z_execute_queryr
r'rrr�rr�rrrrr r!r&r(r*r+r/r!r1r3rr6r7r9rr<r�rA�
__classcell__rUrUrSrVr8qs<!	
	i�
�S�
�
��#
���	��(�
�U�+	��"
�	
��r8)KrDrArIrcr��typingrrrrrrrr	r
rr"r
Z	abstractsrr�	constantsrrrrr�
conversionr�errorsrrrrrrfrrrrrrr r!r"�utilsr#r$r%r=rFr&Zcursor_cextr'r(r)r*r+r,r-r.r/r0r1r2�ImportError�excZopentelemetry.constantsr4Z!opentelemetry.context_propagationr5Zopentelemetry.instrumentationr6r7r8rUrUrUrV�<module>s<0
$	8
��