?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/__pycache__/connection_cext.cpython-39.pyc
???????
a ��Jhȡ � @ s� d Z ddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZ ddlmZ ddlmZ ddlmZmZ ddlmZmZmZm Z m Z dd l m 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 l0m1Z1m2Z2m3Z3 dZ4zDddl5Z5ddl5m6Z6 ddl7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z? dZ4W n8 e@�y� ZA z e@deA� d��eA�W Y dZA[An dZA[A0 0 ddlBmCZC ddlDmEZE eC�r�ddlFmGZGmHZH G dd� de�ZIdS )z'Connection class using the C Extension.� N) �Any�BinaryIO�Dict�List�NoReturn�Optional�Sequence�Tuple�Type�Union� )�version)�cmd_refresh_verify_options)�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�CMySQLCursorBufferedRaw�CMySQLCursorDict�CMySQLCursorPrepared�CMySQLCursorPreparedDict�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 e jjedd�dd��Zeed�dd��Zejedd�dd��Zeee d�dd��Zeje dd�dd��Zeee d�dd��Zeje dd�d d��Zee d�d d ��Zeje dd�d d ��Zeed�d d!��Zdd�d"d#�Zdd�d$d%�ZeZed�d&d'�Zed�d(d)�Zd�ee e dd-�d.d/�Z e dd0�d1d2�Z e ee d3�d4d5�Z eee d�d6d7��Z!d�ee eee"e# ee ee$ ee%e"e ee& f d8�d9d:�Z'd�eee"e# ee ee$ ee%ee ee& f d;�d<d=�Z(ee d�d>d?�Z)dd�d@dA�Z*dd�dBdC�Z+dd�dDdE�Z,e ddF�dGdH�Z-d�ee$ e.dI�dJdK�Z/ee& d�dLdM�Z0e1ee$dN�dOdP�Z2e3e$eeee4e&e.f dQ�dRdS��Z5e$eddT�dUdV�Z6e$eddT�dWdX�Z7e3d�e ee eeeee4e&e.f dY�dZd[��Z8e8Z9d�ee ee ee ee:e; ee ee ee e;d\�d]d^�Z<ee d�d_d`��Z=ee d�dadb��Z>eed�dcdd��Z?eed�dedf��Z@eed�dgdh��ZAeBe4eCe1 eDe1e1f f di�djdk�ZEdd�dldm�ZFd�e e e ee e e e ee ee ee ddo� dpdq�ZGed�drds�ZHeI� e ee& dt�dudv��ZJdd�dwdx�ZKd�ee ddy�dzd{�ZLeMd�d|d}�ZNe dd~�dd��ZOePd�d�d��ZQePd�d�d��ZRe eePd��d�d��ZSe$e eTeePd��d�d��ZUd�edd��d�d��ZVd�eeDe ef eeDe ef dd��d�d��ZW� ZXS )��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)�selfr6 �� __class__� �T/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/connection_cext.pyrK r s2 �� �� zCMySQLConnection.__init__)r7 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 rR )�str)�.0�xrR rR rS � <listcomp>� � z<CMySQLConnection._add_default_conn_attrs.<locals>.<listcomp>� )Z_connector_nameZ_connector_licenseZ_connector_versionZ _source_hostN) r �LICENSE�split� _conn_attrs�updater@ �VERSION�socket� gethostname)rO Zlicense_chunksZclient_licenserR rR rS �_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 capabilitiesre ) r< Zget_proto_infoZget_server_info� thread_idZst_server_capabilitiesZ _handshakeZ_check_server_versionZ_server_version�_character_setZset_mysql_version�rO rR rR rS � _do_handshake� s � �z CMySQLConnection._do_handshakec C s | j �� S )z6Returns the server status attribute of MYSQL structure)r< Zst_server_statusrk rR rR rS �_server_status� s z CMySQLConnection._server_status)r? r7 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)rO r? rR rR rS � set_allow_local_infile_in_path� s z/CMySQLConnection.set_allow_local_infile_in_path)�valuer7 c C s. || _ | jr| j�|� | jr*| j�|� d S �N)Z _use_unicoder< � use_unicoderI Z set_unicode�rO ro rR rR rS rq � s z CMySQLConnection.use_unicodec C s | � d�d }|dkS )z#Get whether autocommit is on or offzSELECT @@session.autocommitr r �� info_queryrr rR rR rS � autocommit� s zCMySQLConnection.autocommitc C sn z| j �|� || _W nR tyh } z:t|d�rFt|j|j|jd�|�t t |��|�W Y d}~n d}~0 0 dS )zToggle autocommit�errno��msg�sqlstateN) r< ru Z _autocommitr' �hasattrr rv rx ry r rV �rO ro �errrR rR rS ru � s ��c C s | j S rp )� _read_timeoutrk rR rR rS � read_timeout� s z CMySQLConnection.read_timeout)�timeoutr7 c C s t d��d S )Nz� The use of read_timeout after the connection has been established is unsupported in the C-Extension �r �rO r rR rR rS r~ � s �c C s | j S rp )�_write_timeoutrk rR rR rS � write_timeout� s z CMySQLConnection.write_timeoutc C s t d��d S )Nz� Changes in write_timeout after the connection has been established is unsupported in the C-Extension r� r� rR rR rS r� � s �c C s | � d�d S )zGet the current databasezSELECT DATABASE()r rs rk rR rR rS �database� s zCMySQLConnection.databasec C sh z| j �|� W nR tyb } z:t|d�r@t|j|j|jd�|�tt |��|�W Y d}~n d}~0 0 dS )zSet the current databaserv rw N� r< Z select_dbr' rz r rv rx ry r rV r{ rR rR rS r� � s ��c C s t | jtj@ �S )z'MySQL session has started a transaction)�boolrm r ZSTATUS_IN_TRANSrk rR rR rS �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 | j#| j$r�| j$nd| j%r�| j%ndd�}| j&�'d�}|d ur�|j(dd� d�)|�}| j&�'d�d u�r4| j&�'d�d �p d }| j&�'d�d }nd }d }|d u�rZd |v �rZ|�sZd }| j*�s�|�+| j&�'d �| j&�'d �| j&�'d�|||| j&�'d��p�d| j&�'d��p�d| j*d� � t,j-dk�r�| j.dk�r�d|d< z2| j j/f i |�� | j0| j _1| j2�r| j0| j2_3W nV t4�y^ } z<t5|d��r<t6|j7|j8|j9d�|�t:t!|��|�W Y d }~n d }~0 0 | �;� | j*�s�t5| j d��r�t<| j j=��r�| j �=� }t>| j&�'dg ��D ]}t?|� t@||� �q�d S )Nr )�buffered�raw� charset_nameZconnection_timeoutrq rh Z plugin_dirT)�host�user�password� password1� password2� password3r� �port� client_flagsZ unix_socket�compress� ssl_disabledZ conn_attrsZ local_infileZload_data_local_dir�oci_config_file�oci_config_profileZwebauthn_callback�openid_token_filer~ r� � 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_gssapirv rw �get_ssl_cipher)Arj �get_info� _charset_idrC ZMySQL� _buffered�_rawZ_connection_timeoutrq Z _auth_pluginrE r< Zisset_client_flagr Z CONNECT_ARGSr^ �_host�_user� _password� _password1� _password2� _password3� _database�_portr� � _unix_socketZ _compressZ_allow_local_infileZ_allow_local_infile_in_path�_oci_config_file�_oci_config_profile� isinstanceZ_webauthn_callbackrV r$ Z_openid_token_filer} r� �_ssl�get�sortr@ Z _ssl_disabledr_ r> �nameZ_auth_plugin_classrL �_converter_str_fallback�converter_str_fallbackrI Z str_fallbackr' rz r rv rx ry r rl �callabler� �setr& r% ) rO r� Z cnx_kwargsr� Zssl_ciphersuitesr� r| �cipherZ tls_versionrR rR rS �_open_connection s� � � � � ���� �� ��$� � � z!CMySQLConnection._open_connectionc C s� | j r$| j �� r$t| j t�� d � | js.d S z�z| �� | j�� W nb ty� } zJt rft| j |� t |d�r�t |j |j |jd�|�tt|��|�W Y d }~n d }~0 0 W t r�t| j � nt r�t| j � 0 d S )Nr rv rw )Z_spanZ is_recordingr4 �sys�exc_infor< � free_resultrN r' r1 rz r rv rx ry r rV r3 )rO r| rR rR rS rN } s* ��& �zCMySQLConnection.closec C s | j �� S )z8Return True if the connection to MySQL Server is closed.)r< � connectedrk rR rR rS � is_closed� 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�pingrk rR rR rS � is_connected� s z CMySQLConnection.is_connectedFr r )� reconnect�attempts�delayr7 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 )rO r� r� r� r� rR rR rS r� � s zCMySQLConnection.ping)rf r7 c C s | j �|� dS )z;Sets the default character set name for current connection.N)r< Zset_character_set)rO rf rR rR rS �set_character_set_name� s z'CMySQLConnection.set_character_set_name)�queryr7 c C s� d}zH| j �|� | j jr@| j �� }| j �� r@| j �� td��| j �� W nR ty� } z:t|d�r|t|j |j |j d�|�tt |��|�W Y d}~n d}~0 0 |S )z%Send a query which only returns 1 rowrR z'Query should not return more than 1 rowrv rw N) r< r� �have_result_set� fetch_rowr� r r' rz r rv rx ry rV )rO r� Z first_rowr| rR rR rS rt � s$ ��$zCMySQLConnection.info_queryc C s$ z | j �� W S ty Y n0 dS )zMySQL connection IDN)r< ri r' rk rR rR rS � connection_id� s z CMySQLConnection.connection_id)�count�binary�columnsr� � prep_stmtr6 r7 c K s� |r |j n| j}| jr|s"td��|du r0| j}g }|durL|dkrLtd��d} �z.|r^|jn| jj} | jsp|r|| j�d� | � } | �rFt | �} | 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>�qF| � } q�| �sz| �|�d }|�rp|�� d| _n| �� nd}W nn t�y� } zT|�r�|�� n| �� t|d ��r�t|j|j|jd �|�t t |��|�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 �eofFrv rw ) r� � unread_resultr< r r� r� r� rI r� �list� enumerater= r ZVECTORr Z_vector_to_pythonZ to_python�append�tuple�fetch_eof_columnsr� �_unread_resultr' rz r rv rx ry r rV )rO r� r� r� r� r� r6 r� �rows�counterr� �row�iZdsc�_�_eofr| rR rR rS �get_rows� sd � ��$zCMySQLConnection.get_rows)r� r� r� r� r6 r7 c K 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)rO r� r� r� r� r6 r� r� rR rR rS �get_row5 s � zCMySQLConnection.get_rowc C s | j r| j �� | j �� S dS )zReads the next resultN)r< �consume_result� next_resultrk rR rR rS r� M s z CMySQLConnection.next_resultc C s | j r| j �� dS )zFrees the resultN)r< r� rk rR rR rS r� T s z CMySQLConnection.free_resultc C s | j r| �� | j �� dS )zCommit current transactionN)r< r� �commitrk rR rR rS r� Y s zCMySQLConnection.commitc C s | j r| j �� | j �� dS )z Rollback current transactionN)r< r� �rollbackrk rR rR rS r� _ s zCMySQLConnection.rollback)r� r7 c C sh z| j �|� W nR tyb } z:t|d�r@t|j|j|jd�|�tt |��|�W Y d}~n d}~0 0 dS )zChange the current databaserv rw Nr� )rO r� r| rR rR rS � cmd_init_dbe s ��z CMySQLConnection.cmd_init_db)r� r7 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_NULLrm �st_warning_count)rO r� r� �fields�colrR rR rS r� p 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_rowsrg N)r< r� Zst_field_countr� r� rm rk rR rR rS �fetch_eof_status� s �z!CMySQLConnection.fetch_eof_status)� statementr6 r7 c K s� | j std��z | j �|�}| j|_t|�W S ty~ } z:t|d�r\t|j |j |j d�|�t t |��|�W Y d}~n d}~0 0 dS )zPrepares the SQL statement� MySQL Connection not availablerv rw N)r< r Z stmt_preparer� r� r r' rz r rv rx ry r rV )rO r� r6 �stmtr| rR rR rS �cmd_stmt_prepare� s ��z!CMySQLConnection.cmd_stmt_prepare)� statement_id�argsr6 r7 c O s� z|j |d| ji� W nR tyh } z:t|d�rFt|j|j|jd�|�tt |��|�W Y d}~n d}~0 0 g | _ |j s�d| _ | � � S d| _ | �|�S )z Executes the prepared statement� query_attrsrv rw NFT)Z stmt_executer� r' rz r rv rx ry r rV r= r� r� r� r� )rO r� r� r6 r| rR rR rS �cmd_stmt_execute� s ��$z!CMySQLConnection.cmd_stmt_execute)r� r6 r7 c K sr | j rtd��z |�� W nR tyl } z:t|d�rJt|j|j|jd�|�t t |��|�W Y d}~n d}~0 0 dS )z Closes the prepared statement�Unread result foundrv rw N) r� r Z stmt_closer' rz r rv rx ry r rV �rO r� r6 r| rR rR rS �cmd_stmt_close� s ��z CMySQLConnection.cmd_stmt_closec K sr | j rtd��z |�� W nR tyl } z:t|d�rJt|j|j|jd�|�t t |��|�W Y d}~n d}~0 0 dS )z Resets the prepared statementr� rv rw N) r� r Z stmt_resetr' rz r rv rx ry r rV r� rR rR rS �cmd_stmt_reset� s ��z CMySQLConnection.cmd_stmt_reset)r� r� r� � raw_as_stringr6 r7 c K s | � � |d u r| j}z<t|t�s,|�d�}|| _d | _| jj||||| j d� W n� t y� } z:t |d�r�t |j |j|jd�|�tt|��|�W Y d }~n\d }~0 ty� } z<| jr�| jn| j� d| j� �}td|dfd�|�W Y d }~n d }~0 0 g | _| jj�s| �� S | �� S ) Nzutf-8)r� r� r� r� rv rw �:i zConnection not available.)rv �values)r� r� r� �bytes�encodeZ_queryZ_local_infile_filenamesr< r� r� r' rz r rv rx ry r rV r� r� r� r� r r= r� r� r� )rO r� r� r� r� r6 r| �addrrR rR rS � cmd_query� sF � ��" ��� zCMySQLConnection.cmd_query)r� r� �prepared� cursor_class� dictionaryr~ r� r7 c s | � |� | �� std��|s"|r0tjdtd� |durRt|t�sJtd��|| �S |pZ| j }|pd| j }d�|du rz�dO �|du r��d O �|du r��d O �|du r��d O �tt t t ttttd �}z|� | �W S t�y d � tdd�� �fdd�td �D �� �d�Y n0 dS )ay 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 a dictionary or a tuple. Dictionary 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 CMySQLCursor. 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 :return: Subclass of CMySQLCursor :rtype: CMySQLCursor or subclass � MySQL Connection not available.zsThe use of read_timeout after the connection has been established is unsupported in the C-Extension)�categoryNz=Cursor class needs be to subclass of cursor_cext.CMySQLCursorr Tr � 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 rR )rW r� �r� Z cursor_typerR rS rY t rZ z+CMySQLConnection.cursor.<locals>.<listcomp>)r� r� r �warnings�warn�Warning� issubclassr( r r� r� r) r/ r+ r, r* r- r. �KeyError� ValueErrorr@ �range) rO r� r� r r r r~ r� �typesrR r rS �cursor" sZ % � � � ���zCMySQLConnection.cursorc C s | j jstd��| j �� S )z,Returns number of rows of current result setr� )r< r� r �num_rowsrk rR rR rS r w s zCMySQLConnection.num_rowsc C s | j s dS | j �� S )zReturns number of warningsr )r< r� rk rR rR rS r� s z CMySQLConnection.warning_countc C s | j s dS | j jS )z"Check if a result set is availableF)r< r� rk rR rR rS �result_set_available� s z%CMySQLConnection.result_set_availablec C s | j S )z)Check if there are unread results or rows)r rk rR rR rS r� � s z CMySQLConnection.unread_resultc C s | j �� S )z Check if there are more results)r< � more_resultsrk rR rR rS r � s z CMySQLConnection.more_results)�paramsr7 c s� g }t |ttf�r:� jr,� fdd�|D �}q҈ jj|� }n�t |t�r�i }� jr�|�� D ]0\}}� 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 rR )rI �quote�escape�to_mysql� _sql_mode)rW ro rk rR rS rY � 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� rI r< Zconvert_to_mysql�dict�itemsr r r r r r �type�__name__)rO r �resultr� ro rR rk rS �prepare_for_mysql� 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� rk rR rR rS �consume_results� s z CMySQLConnection.consume_results� ) �usernamer� r� rf r� r� r� r� r� r� r7 c C s� z | j �|||||||| | � W nR tyr } z:t| d�rPt| j| j| jd�| �tt | ��| �W Y d} ~ n d} ~ 0 0 |dur�t |t �s�t d��|dk r�t d��|| _ || _| �� dS )z!Change the current logged in userrv rw Nzcharset must be an integerr z2charset should be either zero or a postive integer)r< Z change_userr' rz r rv rx ry r rV r� r� r r� r� �_post_connection) rO r* r� r� rf r� r� r� r� r� r� r| rR rR rS �cmd_change_user� s8 � ��$ 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+ )rO �resrR rR rS �cmd_reset_connection� s z%CMySQLConnection.cmd_reset_connection)�optionsr7 c C st z| � � | j�|� W nR tyj } z:t|d�rHt|j|j|jd�|�t t |��|�W Y d }~n d }~0 0 | � � S )Nrv rw ) r� r< Zrefreshr' rz r rv rx ry r rV r� )rO r/ r| rR rR rS � cmd_refresh s ��$z CMySQLConnection.cmd_refreshc C s | � � dS )z,Close the current connection with the serverN)rN rk rR rR rS �cmd_quit s zCMySQLConnection.cmd_quit)� shutdown_typer7 c C s� | j std��|r*t�|�s$td��|}ntj}z| j �|� W nR ty� } z:t|d�rpt |j |j |j d�|�tt |��|�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 typerv rw N)r< r r r� r ZSHUTDOWN_DEFAULT�shutdownr' rz r rv rx ry rV rN )rO r2 �levelr| rR rR rS � cmd_shutdown s$ ��$z CMySQLConnection.cmd_shutdownc C s� | � � z | j�� }t� j|dd�W S ttfyz } z:t|d�rXt|j |j |j d�|�tt |��|�W Y d}~n d}~0 0 dS )z'Return statistics from the MySQL serverF)Z with_headerrv rw N) r� r< �statr Zparse_statisticsr' r rz r rv rx ry rV )rO r6 r| rR rR rS �cmd_statistics1 s ��z CMySQLConnection.cmd_statistics)� mysql_pidr7 c C s& t |t�std��| �d|� �� dS )zKill a MySQL processzMySQL PID must be intzKILL N)r� r� r r )rO r8 rR rR rS �cmd_process_kill? s z!CMySQLConnection.cmd_process_killc C s t �dS )zSend the DEBUG commandN��NotImplementedErrorrk rR rR rS � cmd_debugE s zCMySQLConnection.cmd_debugc C s t �dS )zSend the PING commandNr: rk rR rR rS �cmd_pingI s zCMySQLConnection.cmd_ping)� statementsr6 r7 c K s t �dS )z/Send one or more statements to the MySQL serverNr: )rO r> r6 rR rR rS �cmd_query_iterM s z CMySQLConnection.cmd_query_iter)r� �param_id�datar6 r7 c K s t �dS )zSend data for a columnNr: )rO r� r@ rA r6 rR rR rS �cmd_stmt_send_long_dataQ s z(CMySQLConnection.cmd_stmt_send_long_data)r r7 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 )rO r r� rR rR rS r� [ s z%CMySQLConnection.handle_unread_result)�user_variables�session_variablesr7 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# �executerN )rO rC rD �curr� ro rR rR rS � reset_sessionc s4 � z CMySQLConnection.reset_session)Fr r )NFNNN)FNNN)N)NFF)NNNNNNN) r) r) r) Nr) r) r) NNN)N)F)NN)Yr% � __module__� __qualname__�__doc__r rK rc rl �propertyr� rm rV rn r rq �setterr� ru r r~ r� r� r� r� rN Z disconnectr� r� r� r� r# r! rt r� r r r r r r� r� r� r� r� r� r� r r� r� r r� r2 r r� r� r� r Z_execute_queryr r( r r r� r r� r r r r r' r( r, r. r r0 r1 r5 r" r7 r9 r r< r= r? r rB r� rG � __classcell__rR rR rP rS r5 o sn ! n � � V � � �� #� �� � ��/ � � U� + �� - � ��r5 )JrJ r> rF ra r� r �typingr r r r r r r r r r r) r Z _decoratingr Z abstractsr r � constantsr r r r r � conversionr �errorsr r r r r rd r r r r r r r! r" r# �utilsr$ r% r& r: rC r' Z cursor_cextr( r) r* r+ r, r- r. r/ � ImportError�excZopentelemetry.constantsr1 Z!opentelemetry.context_propagationr2 Z opentelemetry.instrumentationr3 r4 r5 rR rR rR rS �<module> s@ 0 $ ( ��
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????