⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.166
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
var
/
opt
/
nydus
/
ops
/
mysql
/
connector
/
__pycache__
/
View File Name :
connection_cext.cpython-39.pyc
a ��Rh� � @ s� d Z ddlZddlZddlZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZ ddlmZ ddlmZmZ ddlmZmZmZmZmZ ddlm Z dd l m Z m Z m Z m!Z!m"Z" dd l#m$Z$ dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z, dd l-m.Z.m/Z/m0Z0 d Z1zTddl2Z2ddl2m3Z3 ddl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ dZ1W n8 eA�y� ZB z eAdeB� d��eB�W Y dZB[Bn dZB[B0 0 ddlCmDZD ddlEmFZF eD�r�ddlGmHZHmIZI G dd� 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_eventc s� e Zd ZdZedd�� fdd� Zdd�dd�Zdd�d d �Zee d�d d ��Z e dd �dd�Z d�e dd�dd�Zee d�dd��Zeje dd�dd��Zee d�dd��Zeje dd�dd��Zee d�dd��Zdd�d d �Zdd�d d �ZeZe d�d d!�Ze d�d"d#�Zd�e e e dd'�d(d)�Ze dd*�d+d,�Zeee d-�d.d/�Z eee d�d0d1��Z d�ee e ee e ee ee! e"e e ee# f d2�d3d4�Z$d�e ee e ee ee! e"ee ee# f d5�d6d7�Z%ee d�d8d9�Z&dd�d:d;�Z'dd�d<d=�Z(dd�d>d?�Z)e dd@�dAdB�Z*d�ee! e+dC�dDdE�Z,ee# d�dFdG�Z-e.e!dH�dIdJ�Z/e0e!eee1e#e+f dK�dLdM��Z2e!ddN�dOdP�Z3e!ddN�dQdR�Z4e0d�eee e e ee1e#e+f dS�dTdU��Z5e5Z6d�ee ee ee ee7e8 ee 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. eAe e.f f dc�ddde�ZBdd�dfdg�ZCd�e e e e e e e ee ee ddj� 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�ZNe eLd��d�d��ZOe!e ePeLd��d�d��ZQd�e dd��d�d��ZRd�eeAe ef eeAe ef dd��d�d��ZS� ZTS )��CMySQLConnectionz6Class initiating a MySQL Connection using Connector/C.N)�kwargs�returnc s� t s td��d| _g | _tj�tj�tj�t j ��ddd�| _ t � � dkrntj�| j �sntj�d�rhdnd| _ d| _t� �� |r�z| jf i |�� W n ty� | �� � Y n0 dS ) 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-o2llkf2b/lib64/python/mysql/connector/connection_cext.pyrN t s2 �� �� zCMySQLConnection.__init__)r: c C sZ t j�d�}|d dkr d}nd}| j�d|d�dd � t jdd � D ��t�� d �� d S ) z!Add default connection attributes� r ZGPLv2zGPL-2.0Z Commercialzmysql-connector-python�.c S s g | ] }t |��qS rU )�str)�.0�xrU rU rV � <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)rR Zlicense_chunksZclient_licenserU rU rV �_add_default_conn_attrs� s ��z(CMySQLConnection._add_default_conn_attrsc C sT | 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_dataZ capabilitiesrg ) r? Zget_proto_infoZget_server_info� thread_idZst_server_capabilitiesZ _handshakeZ_check_server_versionZ_server_version�_character_setZset_mysql_version�rR rU rU rV � _do_handshake� s � �z CMySQLConnection._do_handshakec C s | j �� S )z6Returns the server status attribute of MYSQL structure)r? Zst_server_statusrm rU rU rV �_server_status� s z CMySQLConnection._server_status)rB r: c C s | j r| j �|� dS )zJset local_infile_in_path Set allow_local_infile_in_path. N)r? Z!set_load_data_local_infile_option)rR rB rU rU rV � set_allow_local_infile_in_path� s z/CMySQLConnection.set_allow_local_infile_in_pathT)�valuer: c C s. || _ | 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�rR rq rU rU rV rt � s z CMySQLConnection.set_unicodec C s | � d�d }|dkS )z#Get whether autocommit is on or offzSELECT @@session.autocommitr r �� info_queryru rU rU rV � autocommit� s zCMySQLConnection.autocommitc C sV z| j �|� || _W n: tyP } z"t|j|j|jd�|�W Y d}~n d}~0 0 dS )zToggle autocommit��msg�errno�sqlstateN)r? rx Z _autocommitr& r rz r{ r| �rR rq �errrU rU rV rx � s ��c C s | � d�d S )zGet the current databasezSELECT DATABASE()r rv rm rU rU rV �database� s zCMySQLConnection.databasec C sP z| j �|� W n: tyJ } z"t|j|j|jd�|�W Y d}~n d}~0 0 dS )zSet the current databasery N�r? Z select_dbr& r rz r{ r| r} rU rU rV r � s ��c C s t | jtj@ �S )z'MySQL session has started a transaction)�boolro r ZSTATUS_IN_TRANSrm rU rU rV �in_transaction� s z CMySQLConnection.in_transactionc C s� | 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 | j t | j t!�r�t"| j �n| j d�}| j#�$d�}|d ur�|j%dd� d�&|�}| j#�$d�d u�r| j#�$d�d }| j#�$d�d }nd }d }|d u�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| j j,f i |�� | j-| j _.| j/�r�| j-| j/_0W n< t1�y } z"t2|j3|j4|j5d�|�W Y d }~n d }~0 0 | �6� | j'�s�t7| j d��r�t8| j j9��r�| j �9� }t:| j#�$dg ��D ]}t;|� t<||� �qhd S )Nr )�buffered�raw� charset_nameZconnection_timeoutrs rj Z plugin_dirT)�host�user�password� password1� password2� password3r �portZ client_flagsZ unix_socket�compress� ssl_disabledZ conn_attrsZ local_infileZload_data_local_dir�oci_config_file�oci_config_profileZwebauthn_callback� tls_versions)�reverse�,�tls_ciphersuitesr zTLSv1.3ZTLS_AES_256_GCM_SHA384�ca�cert�keyZ verify_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_idrF ZMySQL� _buffered�_rawZ_connection_timeoutrr Z _auth_pluginrH r? Zisset_client_flagr Z CONNECT_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_callbackrY r# �_ssl�get�sortrC Z _ssl_disabledra rA �nameZ_auth_plugin_classrO �_converter_str_fallback�converter_str_fallbackrL Z str_fallbackr& r rz r{ r| rn �hasattr�callabler� �setr% r$ ) rR r� Z cnx_kwargsr� Zssl_ciphersuitesr� r~ �cipherZ tls_versionrU rU rV �_open_connection� s� � � � � ���� �� ��� � � z!CMySQLConnection._open_connectionc C s� | j r$| j �� r$t| j t�� d � | js.dS ztz| �� | j�� W nJ ty� } z2t rft| j |� t |j |j |j d�|�W Y d}~n d}~0 0 W t r�t| j � nt r�t| j � 0 dS )z Disconnect from the MySQL serverr Nry )Z_spanZ is_recordingr7 �sys�exc_infor? � free_resultrQ r& r4 r rz r{ r| r6 )rR r~ rU rU rV rQ ` s& �� �zCMySQLConnection.closec C s | j �� S )z8Return True if the connection to MySQL Server is closed.)r? � connectedrm rU rU rV � is_closedw s zCMySQLConnection.is_closedc C s | j r| �� | j �� S dS )z;Reports whether the connection to MySQL Server is availableF)r? �handle_unread_result�pingrm rU rU rV � is_connected{ s z CMySQLConnection.is_connectedFr r )� reconnect�attempts�delayr: c C sR | � � z| j�� }W n ty( Y n 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 )rR r� r� r� r� rU rU rV r� � s zCMySQLConnection.ping)rh r: c C s | j �|� dS )z;Sets the default character set name for current connection.N)r? Zset_character_set)rR rh rU rU rV �set_character_set_name� s z'CMySQLConnection.set_character_set_name)�queryr: c C s� d}zH| j �|� | j jr@| j �� }| j �� r@| j �� td��| j �� W n: ty� } z"t|j|j |j d�|�W Y d}~n d}~0 0 |S )z%Send a query which only returns 1 rowrU z'Query should not return more than 1 rowry N) r? r� �have_result_set� fetch_rowr� r r& r rz r{ r| )rR r� Z first_rowr~ rU rU rV rw � s ��zCMySQLConnection.info_queryc C s$ z | j �� W S ty Y n0 dS )zMySQL connection IDN)r? rk r& rm rU rU rV � connection_id� s z CMySQLConnection.connection_id)�count�binary�columnsr� � prep_stmtr: c C s� |r |j n| j}| jr|s"td��|du r0| j}g }|durL|dkrLtd��d}�z*|r^|jn| jj} | jrx| j�d� | � } | �rBt | �} | j�� s�|s�t | j �D ](\} } | d t j 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}W n` t�y� } zF|�r�|�� tt|��|�| �� t|j|j|j d �|�W Y d}~n d}~0 0 ||fS ) z8Get all or a subset of rows returned by the MySQL serverzNo result set availableNr z$count should be 1 or higher, or NoneTr �eofFry ) r� � unread_resultr? r r� r� r� rL r� �list� enumerater@ r ZVECTORr Z_vector_to_pythonZ to_python�append�tuple�fetch_eof_columnsr� �_unread_resultr& r rY r rz r{ r| )rR r� r� r� r� r� r� �rows�counterr� �row�iZdsc�_�_eofr~ rU rU rV �get_rows� sb � ��zCMySQLConnection.get_rows)r� r� r� r� r: c C sN z4| j d||||d�\}}|r,|d |fW S d|fW S tyH Y dS 0 dS )z.Get the next rows returned by the MySQL serverr )r� r� r� r� r� r N)NN)r� � IndexError)rR r� r� r� r� r� r� rU rU rV �get_row s � zCMySQLConnection.get_rowc C s | j r| j �� | j �� S dS )zReads the next resultN)r? �consume_result� next_resultrm rU rU rV r� ( s z CMySQLConnection.next_resultc C s | j r| j �� dS )zFrees the resultN)r? r� rm rU rU rV r� / s z CMySQLConnection.free_resultc C s | j r| �� | j �� dS )zCommit current transactionN)r? r� �commitrm rU rU rV r� 4 s zCMySQLConnection.commitc C s | j r| j �� | j �� dS )z Rollback current transactionN)r? r� �rollbackrm rU rU rV r� : s zCMySQLConnection.rollback)r r: c C sP z| j �|� W n: tyJ } z"t|j|j|jd�|�W Y d}~n d}~0 0 dS )zChange the current databasery Nr� )rR r r~ rU rU rV � cmd_init_db@ s ��z CMySQLConnection.cmd_init_db)r� r: c C s� |r |j n| jj }|s td��|r*|�� n| j�� }g | _|D ]N}| j�|d t|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� � )Z status_flag� warning_count)r� r� ) r� r? r Z fetch_fieldsr@ r� �intr ZNOT_NULLro �st_warning_count)rR r� r� �fields�colrU rU rV r� I s0 � ����z"CMySQLConnection.fetch_eof_columnsc C s4 | j r0| j �� | j �� | j �� | j �� | jd�S dS )z Fetch EOF and status information)r� Z field_count� insert_id� affected_rowsri N)r? r� Zst_field_countr� r� ro rm rU rU rV �fetch_eof_statusl s �z!CMySQLConnection.fetch_eof_status)� statementr: c C sd | j std��z | j �|�}| j|_t|�W S ty^ } ztt|��|�W Y d}~n d}~0 0 dS )zPrepares the SQL statement� MySQL Connection not availableN) r? r Z stmt_preparer� r� r r& r rY )rR r� �stmtr~ rU rU rV �cmd_stmt_preparey s z!CMySQLConnection.cmd_stmt_prepare)� statement_id�argsr: c G st z|j |d| ji� W n2 tyH } ztt|��|�W Y d}~n d}~0 0 g | _|jsdd| _| �� S d| _| � |�S )z Executes the prepared statement� query_attrsNFT) Z stmt_executer� r& r rY r@ r� r� r� r� )rR r� r� r~ rU rU rV �cmd_stmt_execute� s $z!CMySQLConnection.cmd_stmt_execute)r� r: c C s | j rtd��|�� dS )z Closes the prepared statement�Unread result foundN)r� r Z stmt_close�rR r� rU rU rV �cmd_stmt_close� s z CMySQLConnection.cmd_stmt_closec C s | j rtd��|�� dS )z Resets the prepared statementr� N)r� r Z stmt_resetr� rU rU rV �cmd_stmt_reset� s z CMySQLConnection.cmd_stmt_reset)r� r� r� � raw_as_stringr: c C s� | � � |du r| j}z0t|t�s,|�d�}| jj||||| jd� W n� ty� } z"t |j |j |j d�|�W Y d}~n\d}~0 t y� } z<| jr�| jn| j� d| j� �}td|dfd�|�W Y d}~n d}~0 0 g | _| jjs�| �� S | �� S ) z Send a query to the MySQL serverNzutf-8)r� r� r� r� )rz r| �:i zConnection not available.)r{ �values)r� r� r� �bytes�encoder? r� r� r& r r{ rz r| r� r� r� r� r r@ r� r� r� )rR r� r� r� r� r~ �addrrU rU rV � 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�|du rd�dO �|du rt�dO �|du r��dO �|du r��d O �|du r��d O �ttt t t t t tttttd � }z|� | �W S t�y d � td d�� �fdd�td�D �� �d�Y n0 dS )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.CMySQLCursorr Tr � r� r� � ) r r r r^ r� � r� r� r � � � )r� r� r r r z*Cursor not available with given criteria: z, c s$ g | ] }�d |> @ dkr� | �qS )r r rU )rZ r� �r� Z cursor_typerU rV r\ ' r] z+CMySQLConnection.cursor.<locals>.<listcomp>r )r� r� r � issubclassr' r r� r� r( r2 r+ r, r) r- r* r. r1 r/ r0 �KeyError� ValueErrorrC �range)rR r� r� r r r r �typesrU r rV �cursor� s\ % � � ���zCMySQLConnection.cursorc C s | j jstd��| j �� S )z,Returns number of rows of current result setr� )r? r� r �num_rowsrm rU rU rV r * s zCMySQLConnection.num_rowsc C s | j s dS | j �� S )zReturns number of warningsr )r? r� rm rU rU rV r� 2 s z CMySQLConnection.warning_countc C s | j s dS | j jS )z"Check if a result set is availableF)r? r� rm rU rU rV �result_set_available: s z%CMySQLConnection.result_set_availablec C s | j S )z)Check if there are unread results or rows)r rm rU rU rV r� B s z CMySQLConnection.unread_resultc C s | j �� S )z Check if there are more results)r? � more_resultsrm rU rU rV r G s z CMySQLConnection.more_results)�paramsr: c s� 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�n t dt |�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���qS rU )rL �quote�escape�to_mysql� _sql_mode)rZ rq rm rU rV r\ Y s ���z6CMySQLConnection.prepare_for_mysql.<locals>.<listcomp>r z Could not process parameters: �(z)), it must be of type list, tuple or dict)r� r� r� rL r? Zconvert_to_mysql�dict�itemsr r r r r �type�__name__)rR r �resultr� rq rU rm rV �prepare_for_mysqlL s, � �� �z"CMySQLConnection.prepare_for_mysqlc C s | j �� dS )zlConsume the current result This method consume the result by reading (consuming) all rows. N)r? r� rm rU rU rV �consume_resultsw s z CMySQLConnection.consume_results� �- ) �usernamer� r rh r� r� r� r� r� r: c C sr z | j �|||||||| � W n: tyX } z"t| j| j| jd�| �W Y d} ~ n d} ~ 0 0 || _|| _| � � dS )z!Change the current logged in userry N) r? Z change_userr& r rz r{ r| r� r� �_post_connection) rR r$ r� r rh r� r� r� r� r� r~ rU rU rV �cmd_change_user~ s( � ��z CMySQLConnection.cmd_change_userc C s | 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 �resrU rU rV �cmd_reset_connection� s z%CMySQLConnection.cmd_reset_connection)�optionsr: c C s\ z| � � | j�|� W n: tyR } z"t|j|j|jd�|�W Y d}~n d}~0 0 | �� S )z,Send the Refresh command to the MySQL serverry N) r� r? Zrefreshr& r rz r{ r| r� )rR r) r~ rU rU rV � cmd_refresh� s ��z CMySQLConnection.cmd_refreshc C s | � � dS )z,Close the current connection with the serverN)rQ rm rU rU rV �cmd_quit� s zCMySQLConnection.cmd_quit)� shutdown_typer: c C s� | j std��|r*t�|�s$td��|}ntj}z| j �|� W n: tyz } z"t|j |j |j d�|�W Y d}~n d}~0 0 | � � 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 typery N) r? r r r� r ZSHUTDOWN_DEFAULT�shutdownr& r rz r{ r| rQ )rR r, �levelr~ rU rU rV � cmd_shutdown� s ��z CMySQLConnection.cmd_shutdownc C sh | � � z | j�� }t� j|dd�W S ttfyb } z"t|j|j |j d�|�W Y d}~n d}~0 0 dS )z'Return statistics from the MySQL serverF)Z with_headerry N) r� r? �statr Zparse_statisticsr& r r rz r{ r| )rR r0 r~ rU rU rV �cmd_statistics� s ��z CMySQLConnection.cmd_statistics)� mysql_pidr: c C s& t |t�std��| �d|� �� dS )zKill a MySQL processzMySQL PID must be intzKILL N)r� r� r r� )rR r2 rU rU rV �cmd_process_kill� s z!CMySQLConnection.cmd_process_killc C s t �dS )zSend the DEBUG commandN��NotImplementedErrorrm rU rU rV � cmd_debug� s zCMySQLConnection.cmd_debugc C s t �dS )zSend the PING commandNr4 rm rU rU rV �cmd_ping� s zCMySQLConnection.cmd_ping)� statementsr: c C s t �dS )z/Send one or more statements to the MySQL serverNr4 )rR r8 rU rU rV �cmd_query_iter� s z CMySQLConnection.cmd_query_iter)r� �param_id�datar: c C s t �dS )zSend data for a columnNr4 )rR r� r: r; rU rU rV �cmd_stmt_send_long_data� s z(CMySQLConnection.cmd_stmt_send_long_data)r r: c C s4 |du r| j n| j}| jr$| �� n |r0td��dS )z'Check whether there is an unread resultTr� N)r� r� Zcan_consume_resultsr! r )rR r r� rU rU rV r� � s z%CMySQLConnection.handle_unread_result)�user_variables�session_variablesr: c C s� | � � std��| �� sdz0| �| j| j| j| j| j| j | j | j | j � W n t yb | �� Y n0 |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. r zSET @`z` = %sz SET SESSION `N)r� r r( r& r� r� r� r� r� r� r� r� r� r r� r r �executerQ )rR r= r> �curr� rq rU rU rV � reset_session s4 � z CMySQLConnection.reset_session)T)Fr r )NFNNN)FNNN)N)NFF)NNNNNN) r" r" r" r# r" r" r" NN)N)F)NN)Ur � __module__� __qualname__�__doc__r rN re rn �propertyr� ro rY rp r� rt rx �setterr r� r� rQ Z disconnectr� r� r� r� r" r r rw r� r r r r r r� r� r� r� r� r� r� r r� r� r� r� r5 r r� r� r� r� Z_execute_queryr r' r r r� r r� r r r r r r! r& r( r* r+ r/ r! r1 r3 r r6 r7 r9 r r< r� rA � __classcell__rU rU rS rV r8 q s< ! i � � S � � �� # �� � ��( � � U� + �� " � ��r8 )KrD rA rI rc r� �typingr r r r r r r r r r r" r Z abstractsr r � constantsr r r r r � conversionr �errorsr r r r r rf r r r r r r r r! r" �utilsr# r$ r% r= rF r& Z cursor_cextr' r( r) r* r+ r, r- r. r/ r0 r1 r2 � ImportError�excZopentelemetry.constantsr4 Z!opentelemetry.context_propagationr5 Z opentelemetry.instrumentationr6 r7 r8 rU rU rU rV �<module> s< 0 $ 8 ��