HEX

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

�,�h��@sUdZddlmZgd�ZddlZddlZddlZddlZddlm	Z	m
Z
ddlmZm
Z
ddlmZddlmZdd	lmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"d
dl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*d
dl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1d
d
l2m3Z3m4Z4d
dl5m6Z6m7Z7m8Z8m9Z9m:Z:d
dl;m<Z<m=Z=d
dlm>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHd
dlImJZJmKZKddlLmMZMddlNmOZOmNZNddlPmQZQe�r�ddlRmSZSmTZTejUdkZVe�W�ZXdeYd<eGdd�d��ZZGdd�de	�Z[Gdd�de	�Z\Gd d!�d!eJ�Z]dS)"z+Module gathering all abstract base classes.�)�annotations)�MySQLConnectionAbstract�MySQLCursorAbstract�
ServerInfoN)�ABC�abstractmethod)�	dataclass�field)�	signature)�
TracebackType)�
TYPE_CHECKING�Any�AsyncGenerator�BinaryIO�Callable�Dict�	Generator�Iterator�List�Mapping�NoReturn�Optional�Sequence�Tuple�Type�Union�)�DUPLICATED_IN_LIST_ERROR�KRB_SERVICE_PINCIPAL_ERROR�MYSQL_PY_TYPES�TLS_V1_3_SUPPORTED�TLS_VER_NO_SUPPORTED�TLS_VERSION_ERROR�TLS_VERSION_UNACCEPTABLE_ERROR)�
CONN_ATTRS_DN�DEFAULT_CONFIGURATION�OPENSSL_CS_NAMES�TLS_CIPHER_SUITES�TLS_VERSIONS�
ClientFlag)�MySQLConverter�MySQLConverterBase)�Error�InterfaceError�
InternalError�NotSupportedError�ProgrammingError)�UNACCEPTABLE_TLS_CIPHERSUITES�UNACCEPTABLE_TLS_VERSIONS)�BinaryProtocolType�DescriptionType�
EofPacketType�
HandShakeType�OkPacketType�ParamsSequenceType�
ResultType�RowType�StatsPacketType�
StrOrBytes�WarningType)�GenericWrapper�
import_object�)�MySQLAuthenticator)�Charset�charsets)�
MySQLProtocol)�MySQLTcpSocket�MySQLUnixSocket�posixz%weakref.WeakValueDictionary[Any, Any]�NAMED_TUPLE_CACHEc@s~eZdZUdZded<ded<edd�Zded	<ded
<ded<ded<ded
<ded<ded<dZded<dd�dd�ZdS)rz�Stores the server information retrieved on the handshake.

    Also parses and validates the server version, storing it as a tuple.
    �int�protocol�str�versionF)�initzTuple[int, ...]�
version_tuple�	thread_id�charsetZstatus_flags�auth_plugin�bytesZ	auth_dataZcapabilities�bool�query_attrs_is_supported�None��returncCsdt�d�}|�|j�}|s"td��tdd�|��dd�D��}|dkrZtd|j�d	���||_d
S)z�Parse and validate server version.

        Raises:
            InterfaceError: If parsing fails or MySQL version is not supported.
        z$^(\d{1,2})\.(\d{1,2})\.(\d{1,3})(.*)zFailed parsing MySQL versioncss|]}t|�VqdS�N)rI)�.0�v�r[�P/opt/nydus/tmp/pip-target-wkfpz8uv/lib64/python/mysql/connector/aio/abstracts.py�	<genexpr>��z+ServerInfo.__post_init__.<locals>.<genexpr>r�)�r@zMySQL Version 'z' is not supportedN)�re�compile�matchrLr-�tuple�groupsrN)�selfZ
version_rercrLr[r[r\�
__post_init__�s
zServerInfo.__post_init__N)	�__name__�
__module__�__qualname__�__doc__�__annotations__r	rNrTrgr[r[r[r\rvs
rc+@s�eZdZUdZddddddddddddddddidddddddddededdded	dddddded
dddd�)dd
d
ddd
d
d
d
d
dddddddddddddddddddddddddddddddd�)dd�Zdd�dd�Z�d	ddddd �d!d"�Zdd�d#d$�Zdd�d%d&�Z	dd�d'd(�Z
e�d
d
d*ddd+�d,d-��Ze
edd�d.d/���Ze
d
d�d0d1��Ze
d
d�d2d3��Ze
dd�d4d5��Ze
dd�d6d7��Ze
d
d�d8d9��Zejd
dd:�d;d9��Zd
d�d<d=�Zd
dd:�d>d?�Ze
dd�d@dA��Zejddd:�dBdA��Ze
dd�dCdD��Ze
dEd�dFdG��Ze
dd�dHdI��Ze
dJd�dKdL��Ze
dd�dMdN��Ze
dd�dOdP��Zejddd:�dQdP��Zdd�dRdS�Zddd:�dTdU�Z e
d
d�dVdW��Z!e!jd
dd:�dXdW��Z!d
d�dYdZ�Z"d
dd:�d[d\�Z#e
d
d�d]d^��Z$e$jd_dd:�d`d^��Z$d
d�dadb�Z%d_dd:�dcdd�Z&e
dd�dedf��Z'e'jddd:�dgdf��Z'e
dd�dhdi��Z(e(jddd:�djdi��Z(e
dd�dkdl��Z)e)jddd:�dmdl��Z)e
d
d�dndo��Z*e
d
d�dpdq��Z+edd�drds��Z,ed
dtdu�dvdw��Z-dd�dxdy�Z.�ddzddd{�d|d}�Z/ddd~�dd��Z0d
dd��d�d��Z1dd�d�d��Z2d�d�d�d��Z3dd�d�d��Z4edd�d�d���Z5edd�d�d���Z6e�dddddd��d�d���Z7d�dd��d�d��Z8d�dd��d�d��Z9d�dd:�d�d��Z:d
d�d��d�d��Z;dd�d�d��Z<dd�d�d��Z=dd�d�d��Z>d�d�du�d�d��Z?d�dd��d�d��Z@d�dd��d�d��ZAedd�d�d���ZB�d
dddd��d�d��ZCd�d�d�d��ZDedd�d�d���ZEeEZFd�eGd�<e�ddddd�ddd�d��d�d���ZHe�ddd�dd�dĜd�dƄ�ZIe�dddd�dd�d�dɜd�d˄�ZJedd�d�d̈́�ZKedd�d�dτ�ZLedd�d�dф�ZMed
d�dӜd�dՄ�ZNe�dd�ddddtd֜d�d؄�ZOd�d�dڜd�d܄ZPe�dddddݜd�d߄�ZQed�d�d�d�d��ZRe�dd�d�d�dd�d�d�d��ZSeddd�d�d��ZTeddd�d�d��ZUedd�d�d�d��ZVddd�dd��d�d��ZWed�d�d�d���ZXe�dddd��d�d���ZYed�d�d��d��ZZeddҐd��d�d��Z[e�dd��d�d��Z\ed�d��d�d��Z]dS(rz'Defines the MySQL connection interface.N�z	127.0.0.1i�F�allow_local_infile�allow_local_infile_in_path�connect_timeout�ssl_disabled))�user�password�host�port�database�	password1�	password2�	password3rP�	collationrQ�client_flags�compress�consume_results�
autocommit�	time_zone�
conn_attrs�sql_mode�init_command�get_warnings�raise_on_warnings�buffered�raw�kerberos_auth_mode�krb_service_principal�webauthn_callbackrnro�converter_class�converter_str_fallback�connection_timeout�unix_socket�ssl_ca�ssl_cert�ssl_key�ssl_verify_cert�ssl_verify_identityrq�tls_versions�tls_ciphersuites�loop�
Optional[str]rKrI�
Optional[int]rSzDict[str, str]z+Optional[Union[str, Callable[[str], None]]]zOptional[MySQLConverter]zOptional[bool]zOptional[List[str]]z#Optional[asyncio.AbstractEventLoop]c)*Cs�||_||_||_||_||_||_||_||_| |_||_	||_
|
|_||_||_
||_||_||_t�|_d|_d|_|	|_|
|_d|_|&|_|!|_|"|_|#|_|$|_|%|_|'|_|(|_||_ d|_!d|_"|)p�t#�$�|_%|p�t&�'�|_(|t)�*�|_+i|_,d|_-g|_.t/�|_0|�pt1|_2||_3||_4||_5||_6||_7||_8||_9||_:||_;d|_<d|_=d|_>d|_?d|_@d|_A||_Bd|_C|�D�dS)NFT)E�_userZ	_password�_host�_portZ	_databaseZ
_password1Z
_password2Z
_password3�_unix_socketZ_connection_timeout�_connection_attrs�	_compress�_consume_results�_autocommit�
_time_zone�	_sql_mode�
_init_commandrD�	_protocol�_socket�_charset�
_charset_name�_charset_collation�_ssl_active�
_ssl_disabled�_ssl_ca�	_ssl_cert�_ssl_keyZ_ssl_verify_certZ_ssl_verify_identity�
_tls_versions�_tls_ciphersuites�_auth_plugin�_auth_plugin_class�
_handshake�asyncio�get_event_loop�_loopr)�get_default�
_client_flags�weakref�WeakSet�_cursors�_query_attrsZ_query_attrs_supportedZ
_columns_descrAZ_authenticatorr*�_converter_class�_converter_str_fallback�_kerberos_auth_mode�_krb_service_principal�_allow_local_infile�_allow_local_infile_in_path�
_get_warningsr�Z	_buffered�_raw�_have_next_result�_unread_result�_use_unicode�_in_transactionZ_oci_config_fileZ_oci_config_profile�_webauthn_callback�	converter�_validate_connection_options)*rfrrrsrtrurvrwrxryrPrzrQr{r|r}r~rr�r�r�r�r�r�r�r�r�r�rnror�r�r�r�r�r�r�r�r�rqr�r�r�r[r[r\�__init__�s~/
�
�z MySQLConnectionAbstract.__init__rVc�s|��s|��IdH|SrX)�is_socket_connected�connect�rfr[r[r\�
__aenter__sz"MySQLConnectionAbstract.__aenter__�Optional[Type[BaseException]]�Optional[BaseException]�Optional[TracebackType]rU��exc_type�	exc_value�	tracebackrWc�s|��IdHdSrX��close�rfr�r�r�r[r[r\�	__aexit__sz!MySQLConnectionAbstract.__aexit__c
Csr|jrFz|j��|_Wn.tyD}ztd�|�WYd}~n
d}~00|jrZ|�tjg�|jr�tj	�
|j�}|r�tj	�|�r�tj	�|�r�tj	�
|�r�td��|js�|jr�|�tjg�n|�tjg�|jdkr�td|j�d���|jr�tjdkr�d|_|j�r|jd	k�rtd
��t|jt��s.td��t|j|j|jg��r�t|j|jg��s^td��|jdu|jduk�r|td
��|jdu�r�|��|jdu�r�|� �t|j!t"��s�td��|j!�#�D]�\}}|t$v�rڐq�t|t%��s�td|�d|j!�d���t&|�dk�rtd|�d���|�'d��r0td��t|t%��sRtd|�d|�d���t&|�dk�r�td|�d|�d����q�|j(tj)@�r�|�*�|j+�r�t|j+t%��s�td��|j+�,�}|dk�r�tjdk�r�td��d|_-n|d k�r�d!|_-ntd"��|j.�rVt|j.t%��stt/j0d#d$���|j.d%k�r:tt/j0d&d$���d'|j.v�rVtt/j0d(d$���|j1�rn|�2d)|j1d*�dS)+zValidate connection options.z'user' must be a stringNz.allow_local_infile_in_path must be a directoryZauthentication_webauthn_client�'z5' cannot be used as the default authentication pluginrGTZmysql_clear_passwordzFClear password authentication is not supported over insecure  channelsz'TCP/IP port number should be an integerz:ssl_key and ssl_cert need to be both specified, or neitherz4ssl_key and ssl_cert need to be both set, or neitherzconn_attrs must be of type dictz+Attribute name should be a string, found: 'z' in '� zAttribute name 'z"' exceeds 32 characters limit size�_zNKey names in connection attributes cannot start with '_', found: '{attr_name}'zAttribute 'z
' value: 'z' must be a string typeiz$' exceeds 1024 characters limit sizez('kerberos_auth_mode' must be of type strZsspi�ntz6'kerberos_auth_mode=SSPI' is only available on WindowsZMySQLSSPIKerberosAuthPluginZgssapiZMySQLKerberosAuthPluginz@Invalid 'kerberos_auth_mode' mode. Please use 'SSPI' or 'GSSAPI'zis not a string)�errorrmzcan not be an empty string�/zis incorrectly formattedZwebauth_callbackr@)3r��strip�AttributeErrorr��set_client_flagsr)ZCOMPRESSr��os�path�abspath�exists�isdir�islinkr�ZLOCAL_FILESr�r-r��namer��
isinstancer�rI�anyr�r�r��allr��_validate_tls_versionsr��_validate_tls_ciphersuitesr��dict�itemsr$rK�len�
startswithr�ZCONNECT_ARGS�_add_default_conn_attrsr��lowerr�r�r�formatr��_validate_callable)rf�errZinfile_in_path�	attr_name�
attr_valuer�r[r[r\r�s� �
�
�
�
����
���
����

�
�
���
�z4MySQLConnectionAbstract._validate_connection_optionscCs�g}|j}t|t�r||�d�r(|�d�s8td|�d���|dd��d�}|sVtd��|D]}|����}|rZ|�	|�qZn.t|t
tf�r�d	d
�|D�}ntd|�d���|jdur�t
dd�n|jdd�}|jd
d�|d}ggg}i}g}	t
dt
�|�d�D]"}
|�t|
�|	�t|
��q|D]�}d|v�rv||	v�rv|tdv�rf|d�	|�n|d�	|�nt||v�r�||}||v�r�ttjd|d���|tdv�r�|d�	||�n|d�	||�ntd|�d����q0|d�s
|d�s
td��|dD](}
|
td��v�rtd|
�d����q|dD](}
|
td��v�rDtd|
�d����qDd�|d�d�|d�g|_dS)z&Validates the tls_ciphersuites option.�[�]z)tls_ciphersuites must be a list, found: 'r�r@����,z6No valid cipher suite found in 'tls_ciphersuites' listcSsg|]}|r|�qSr[r[)rY�tls_csr[r[r\�
<listcomp>�r^zFMySQLConnectionAbstract._validate_tls_ciphersuites.<locals>.<listcomp>zItls_ciphersuites should be a list with one or more ciphersuites. Found: 'NT)�reverser�-�TLSv1.3r���list�valuezThe value 'z1' in tls_ciphersuites is not a valid cipher suitez:No valid cipher suite found in the 'tls_ciphersuites' listzTLSv1.2zCipher z( when used with TLSv1.2 is unacceptable.z( when used with TLSv1.3 is unacceptable.�:)r�r�rKr��endswithr��splitr��upper�appendr�setr�r(�sort�index�updater'�extendr&rr�r1�valuesr/�join)rfr�r�Ztls_cssZ_tls_csr�Z
newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_names�tls_verr�Ztranslated_nameZcipher_as_osslr[r[r\r��s�

����"�

��
��
�
��z2MySQLConnectionAbstract._validate_tls_ciphersuitescCs�g}|j}t|t�r�|�d�r(|�d�s8td|�d���|dd��d�}|D]:}|��}|dkrdqN||vr~ttj	d	|d
���|�
|�qN|dgkr�ts�tt�	|t
���n�t|t�r�|s�td��|D](}||vr�ttj	d	|d
���|�
|�q�n@t|t��r|D]}|�
|��qntd
d�t
��d|�d���|�s>td��g}g}g}|D]:}|t
v�rf|�
|�|tv�r||�
|�n
|�
|��qN|�r�|dgk�r�t�s�tt�	|t
���||_n.|�r�tt�	|t
���n|�r�tt�	|t
���dS)z"Validates the tls_versions option.r�r�z%tls_versions must be a list, found: 'r�r@r�r�rmr�rrzJAt least one TLS protocol version must be specified in 'tls_versions' listz>tls_versions should be a list with one or more of versions in z, z
. found: 'zdAt least one TLS protocol version must be specified in 'tls_versions' list when this option is givenN)r�r�rKr�rr�rr�rr�r
r r!r(rrrr2r/r#r")rfr�Ztls_versionZtls_versrZuse_tls_versionsZunacceptable_tls_versionsZinvalid_tls_versionsr[r[r\r�s�

���
�
�������



���z.MySQLConnectionAbstract._validate_tls_versionsrzUnion[str, Callable])�option_name�callback�num_argsrWc
Cs�t|t�rHzt|�}Wn0tyF}zt|��|�WYd}~n
d}~00t|�s`td|�d���tt|�j�}||kr�td|�d|�d|����dS)a�Validates if it's a Python callable.

         Args:
             option_name (str): Connection option name.
             callback (str or callable): The fully qualified path to the callable or
                                         a callable.
             num_args (int): Number of positional arguments allowed.

        Raises:
             ProgrammingError: If `callback` is not valid or wrong number of positional
                               arguments.

        .. versionadded:: 8.2.0
        NzExpected a callable for 'r�z' requires z4 positional argument, but the callback provided has )	r�rKr?�
ValueErrorr0�callabler�r
�
parameters)rrrr�Z
num_paramsr[r[r\r�Ss
"��z*MySQLConnectionAbstract._validate_callablecCsdS)zMySQL connection ID.Nr[r�r[r[r\�
connection_idvsz%MySQLConnectionAbstract.connection_idcCs|jS)z$User used while connecting to MySQL.)r�r�r[r[r\rr{szMySQLConnectionAbstract.usercCs|jS)z MySQL server IP address or name.)r�r�r[r[r\�server_host�sz#MySQLConnectionAbstract.server_hostcCs|jS)zMySQL server TCP/IP port.)r�r�r[r[r\�server_port�sz#MySQLConnectionAbstract.server_portcCs|jS)z MySQL Unix socket file location.)r�r�r[r[r\r��sz#MySQLConnectionAbstract.unix_socketcCstd��dS)�Get the current database.zoThe use of async properties are not supported by Python. Use `await get_database()` to get the database insteadN�r0r�r[r[r\rv�s�z MySQLConnectionAbstract.database)rrWcCstd��dS)�Set the current database.zsThe use of async properties are not supported by Python. Use `await set_database(name)` to set the database insteadNr�rfrr[r[r\rv�s�c�s|�d�IdH}|dS)rzSELECT DATABASE()Nr��
info_query)rf�resultr[r[r\�get_database�sz$MySQLConnectionAbstract.get_databasec�s|�d|���IdHdS)rzUSE N)�	cmd_queryrr[r[r\�set_database�sz$MySQLConnectionAbstract.set_databasecCs|jS)z"Returns whether to consume results)r�r�r[r[r\�can_consume_results�sz+MySQLConnectionAbstract.can_consume_resultscCst|t�sJ�||_dS)zSet if can consume results.N)r�rSr�rr[r[r\r&�scCs|jS)z(MySQL session has started a transaction.)r�r�r[r[r\�in_transaction�sz&MySQLConnectionAbstract.in_transactionzasyncio.AbstractEventLoopcCs|jS)zReturn the event loop.)r�r�r[r[r\r��szMySQLConnectionAbstract.loopcCs|jp|jduotS)z&Return True if is a secure connection.N)r�r��IS_POSIXr�r[r[r\�	is_secure�sz!MySQLConnectionAbstract.is_securez$List[Tuple[str, BinaryProtocolType]]cCst|j���S)zReturns query attributes list.)rr�r�r�r[r[r\�query_attrs�sz#MySQLConnectionAbstract.query_attrscCs|jS)zReturn if have next result.)r�r�r[r[r\�have_next_result�sz(MySQLConnectionAbstract.have_next_resultcCstd��dS)�$Get whether autocommit is on or off.zsThe use of async properties are not supported by Python. Use `await get_autocommit()` to get the autocommit insteadNrr�r[r[r\r~�s�z"MySQLConnectionAbstract.autocommitcCstd��dS)�Toggle autocommit.zxThe use of async properties are not supported by Python. Use `await set_autocommit(value)` to set the autocommit insteadNrrr[r[r\r~�s�c�s|�d�IdH}|ddkS)r,zSELECT @@session.autocommitNrr@r rr[r[r\�get_autocommit�sz&MySQLConnectionAbstract.get_autocommitc�s,|rdnd}|�d|���IdH||_dS)r-�ONZOFFzSET @@session.autocommit = N)r$r�)rfr�switchr[r[r\�set_autocommit�sz&MySQLConnectionAbstract.set_autocommitcCstd��dS)�Gets the current time zone.zqThe use of async properties are not supported by Python. Use `await get_time_zone()` to get the time zone insteadNrr�r[r[r\r�s�z!MySQLConnectionAbstract.time_zonecCstd��dS)�Sets the time zone.zxThe use of async properties are not supported by Python. Use `await get_autocommit(value)` to get the autocommit insteadNrrr[r[r\r�s�c�s|�d�IdH}|dS)r2zSELECT @@session.time_zoneNrr rr[r[r\�
get_time_zone�sz%MySQLConnectionAbstract.get_time_zonec�s"|�d|�d��IdH||_dS)r3zSET @@session.time_zone = 'r�N)r$r�rr[r[r\�
set_time_zone�sz%MySQLConnectionAbstract.set_time_zonec�std��dS)�Gets the SQL mode.zoThe use of async properties are not supported by Python. Use `await get_sql_mode()` to get the SQL mode insteadNrr�r[r[r\r�s�z MySQLConnectionAbstract.sql_modezUnion[str, Sequence[int]]c�std��dS)�Sets the SQL mode.

        This method sets the SQL Mode for the current connection. The value
        argument can be either a string with comma separate mode names, or
        a sequence of mode names.

        It is good practice to use the constants class `SQLMode`:
        ```
        >>> from mysql.connector.constants import SQLMode
        >>> cnx.sql_mode = [SQLMode.NO_ZERO_DATE, SQLMode.REAL_AS_FLOAT]
        ```
        ztThe use of async properties are not supported by Python. Use `await set_sql_mode(value)` to set the SQL mode insteadNrrr[r[r\r�	s�c�s&|jdur |�d�IdHd|_|jS)r6NzSELECT @@session.sql_moder)r�r!r�r[r[r\�get_sql_modes
z$MySQLConnectionAbstract.get_sql_modec�s:t|ttf�rd�|�}|�d|�d��IdH||_dS)r7r�zSET @@session.sql_mode = 'r�N)r�rrdrr$r�rr[r[r\�set_sql_mode"s

z$MySQLConnectionAbstract.set_sql_modecCs|jS)z�Get whether this connection retrieves warnings automatically.

        This method returns whether this connection retrieves warnings automatically.
        )r�r�r[r[r\r�4sz$MySQLConnectionAbstract.get_warningscCst|t�std��||_dS)aSet whether warnings should be automatically retrieved.

        The toggle-argument must be a boolean. When True, cursors for this connection
        will retrieve information about warnings (if any).

        Raises:
            ValueError: When the value is not a bool type.
        �Expected a boolean typeN)r�rSrr�rr[r[r\r�<s

cCs|jS)z�Get whether this connection raises an error on warnings.

        This method returns whether this connection will raise errors when MySQL
        reports warnings.
        )�_raise_on_warningsr�r[r[r\r�Jsz)MySQLConnectionAbstract.raise_on_warningscCs&t|t�std��||_|r"||_dS)a�Set whether warnings raise an error.

        The toggle-argument must be a boolean. When True, cursors for this connection
        will raise an error when MySQL reports warnings.

        Raising on warnings implies retrieving warnings automatically.
        In other words: warnings will be set to True. If set to False, warnings will
        be also set to False.

        Raises:
            ValueError: When the value is not a bool type.
        r:N)r�rSrr;r�rr[r[r\r�Ss

cCs|jS)z�Get whether there is an unread result.

        This method is used by cursors to check whether another cursor still needs to
        retrieve its result set.
        )r�r�r[r[r\�
unread_resulthsz%MySQLConnectionAbstract.unread_resultcCst|t�std��||_dS)z�Set whether there is an unread result.

        This method is used by cursors to let other cursors know there is still a
        result set that needs to be retrieved.

        Raises:
            ValueError: When the value is not a bool type.
        r:N)r�rSrr�rr[r[r\r<qs

cCs|jr|jjSdS)aReturn the character set for current connection.

        This property returns the character set name of the current connection.
        The server is queried when the connection is active.
        If not connected, the configured character set name is returned.
        �utf8�r�r�r�r[r[r\rPszMySQLConnectionAbstract.charsetcCs"|jdus|jjdvrdS|jjS)a^Return the Python character set for current connection.

        This property returns the character set name of the current connection.
        Note that, unlike property charset, this checks if the previously set
        character set is supported by Python and if not, it returns the equivalent
        character set that Python supports.
        N)Zutf8mb4Zutf8mb3�binaryr=r>r�r[r[r\�python_charset�s	z&MySQLConnectionAbstract.python_charsetcCsdS)z&Add the default connection attributes.Nr[r�r[r[r\r��sz/MySQLConnectionAbstract._add_default_conn_attrsr9)�queryrWc�sdS)z�Execute a query.

        This method simply calls cmd_query() after checking for unread result. If there
        are still unread result, an InterfaceError is raised. Otherwise whatever
        cmd_query() returns is returned.
        Nr[)rfrAr[r[r\�_execute_query�sz&MySQLConnectionAbstract._execute_queryc�sr|�|jj�IdH|�|j�IdH|jr>|�|j�IdH|jrV|�|j�IdH|j	rn|�
|j	�IdHdS)z�Executes commands after connection has been established.

        This method executes commands after the connection has been established.
        Some setting like autocommit, character set, and SQL mode are set using this
        method.
        N)�set_charset_collationr�Z
charset_idr1r�r�r5r�r9r�rBr�r[r[r\�_post_connection�sz(MySQLConnectionAbstract._post_connectionzOptional[Union[int, str]])rPrzrWc�s\d}t|ttf�s(|dur(t|�d���t|t�sB|durBtd��|rt|rtt|t�r`t�|�jn|}t�||�|_	nj|r�t|t�r�t�|�|_	q�t|t�r�t�
|�|_	q�t|�d���n&|r�t�|�|_	ntd}t�
|�|_	|j	j|_
|j	j|_|�d|j	j�d|j	j�d��IdHz|�|j	j�Wnt�y>Yn0|j�rX|j�|j	j�dS)a�Set the character set and collation for the current connection.

        This method sets the character set and collation to be used for the current
        connection. The charset argument can be either the name of a character set as
        a string, or the numerical equivalent as defined in constants.CharacterSet.

        When the collation is not given, the default will be looked up and used.

        Args:
            charset: Can be either the name of a character set, or the numerical
                     equivalent as defined in `constants.CharacterSet`.
            collation: When collation is `None`, the default collation for the
                       character set is used.

        Examples:
            The following will set the collation for the latin1 character set to
            `latin1_general_ci`:
            ```
            >>> cnx = mysql.connector.connect(user='scott')
            >>> cnx.set_charset_collation('latin1', 'latin1_general_ci')
            ```
        z+{} should be either integer, string or NoneNrPz)collation should be either string or NonezSET NAMES 'z' COLLATE 'r�)r�rIrKrr�rCZ	get_by_idr�Zget_by_name_and_collationr�Zget_by_nameZget_by_collationr%r�rzr�r$Zset_character_set_namer�r��set_charset)rfrPrz�err_msgZcharset_strr[r[r\rC�s@��



�
z-MySQLConnectionAbstract.set_charset_collation)�flagrWcCs|j|@dkS)z|Checks if a client flag is set.

        Returns:
            `True` if the client flag was set, `False` otherwise.
        r)r�)rfrGr[r[r\�isset_client_flag�sz)MySQLConnectionAbstract.isset_client_flag)r�rWcCs
||_dS)zySet the path that user can upload files.

        Args:
            path (str): Path that user can upload files.
        N)r�)rfr�r[r[r\�set_allow_local_infile_in_pathsz6MySQLConnectionAbstract.set_allow_local_infile_in_pathcCs|S)z�Return self for weakref.proxy.

        This method is used when the original object is needed when using
        weakref.proxy.
        r[r�r[r[r\�get_selfsz MySQLConnectionAbstract.get_selfzOptional[Tuple[int, ...]]cCs|jjS)z�Gets the MySQL version.

        Returns:
            The MySQL server version as a tuple. If not previously connected, it will
            return `None`.
        )Z_server_inforLr�r[r[r\�get_server_versionsz*MySQLConnectionAbstract.get_server_versionc	Cs*z|jdWSttfy$YdS0dS)z�Gets the original MySQL version information.

        Returns:
            The original MySQL server as text. If not previously connected, it will
            return `None`.
        Zserver_version_originalN)r��	TypeError�KeyErrorr�r[r[r\�get_server_infosz'MySQLConnectionAbstract.get_server_infocCsdS)z�Reports whether the socket is connected.

        Instead of ping the server like ``is_connected()``, it only checks if the
        socket connection flag is set.
        Nr[r�r[r[r\r�(sz+MySQLConnectionAbstract.is_socket_connectedc�sdS)aReports whether the connection to MySQL Server is available.

        This method checks whether the connection to MySQL is available.
        It is similar to ``ping()``, but unlike the ``ping()`` method, either `True`
        or `False` is returned and no exception is raised.
        Nr[r�r[r[r\�is_connected0sz$MySQLConnectionAbstract.is_connectedr@)�	reconnect�attempts�delayrWc�sdS)aCheck 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.
        Nr[)rfrPrQrRr[r[r\�ping9szMySQLConnectionAbstract.pingzUnion[int, Sequence[int]])�flagsrWcCsnt|t�r|dkr||_nNt|ttf�r`|D]0}|dkrN|jt|�M_q,|j|O_q,ntd��|jS)a�Set the client flags.

        The flags-argument can be either an int or a list (or tuple) of ClientFlag
        values. If it is an integer, it will set client_flags to flags as is.
        If flags is a list or tuple, each flag will be set or unset when it's negative.

        set_client_flags([ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG])

        Raises:
            ProgrammingError: When the flags argument is not a set or an integer bigger
                              than 0.
        rz+set_client_flags expect integer (>0) or set)r�rIr�rdr�absr0)rfrTrGr[r[r\r�Ls
z(MySQLConnectionAbstract.set_client_flagszOptional[Type[MySQLConverter]])�	convclassrWcCs>|r2t|t�r2||_||jj|j�|_|j|j_nt	d��dS)z�Set the converter class to be used.

        This should be a class overloading methods and members of
        conversion.MySQLConverter.

        Raises:
            TypeError: When the class is not a subclass of `conversion.MySQLConverter`.
        zAConverter class should be a subclass of conversion.MySQLConverterN)
�
issubclassr+r�r�r�r�r�r�Zstr_fallbackrL)rfrVr[r[r\�set_converter_classes	�z+MySQLConnectionAbstract.set_converter_classzTuple[str, BinaryProtocolType]cCs |\}}||jvr||j|<dS)aAdd element to the query attributes list on the connector's side.

        If an element in the query attributes list already matches
        the attribute name provided, the new element will NOT be added.

        Args:
            value: key-value as a 2-tuple.
        N�r�)rfrr�r�r[r[r\�query_attrs_appendws	
z*MySQLConnectionAbstract.query_attrs_appendr3�r�rWcCs|j�|d�S)z�Remove element by name from the query attributes list.

        If no match, `None` is returned, else the corresponding value is returned.

        Args:
            name: key name.
        N)r��pop�rfr�r[r[r\�query_attrs_remove�sz*MySQLConnectionAbstract.query_attrs_removecCs
i|_dS)z5Clears query attributes list on the connector's side.NrYr�r[r[r\�query_attrs_clear�sz)MySQLConnectionAbstract.query_attrs_clearc�s(|jr|��IdHn|jr$td��dS)z�Handle unread result.

        Consume pending results if is configured for it.

        Raises:
            InternalError: When there are pending results and they were not consumed.
        NzUnread result found)r�r}r<r.r�r[r[r\�handle_unread_result�sz,MySQLConnectionAbstract.handle_unread_resultc�s|jr|��IdHdS)zConsume pending results.N)r<�get_rowsr�r[r[r\r}�sz'MySQLConnectionAbstract.consume_resultsr<�Optional[RowType]c	�sh|jdd�IdH4IdH�4}|�|�IdH|��IdHWd�IdHS1IdHsZ0YdS)z&Send a query which only returns 1 row.T)r�N)�cursor�execute�fetchone)rfrArcr[r[r\r!�sz"MySQLConnectionAbstract.info_queryr)rcrWcCs|j�|�dS)zAdd cursor to the weakref set.N)r��add�rfrcr[r[r\�
add_cursor�sz"MySQLConnectionAbstract.add_cursorcCs|j�|�dS)z#Remove cursor from the weakref set.N)r��removergr[r[r\�
remove_cursor�sz%MySQLConnectionAbstract.remove_cursorc�sdS)zConnect to the MySQL server.Nr[r�r[r[r\r��szMySQLConnectionAbstract.connect)rQrRrWc
�s�d}||kr�|d}z2|��IdH|��IdH|��IdHrDWq�WnJttfy�}z.||kr|d|�d|��}t|�|�WYd}~n
d}~00|dkrt�|�IdHqdS)a�Attempts to reconnect to the MySQL server.

        The argument `attempts` should be the number of times a reconnect is tried.
        The `delay` argument is the number of seconds to wait between each retry.

        You may want to set the number of attempts higher and use delay when you expect
        the MySQL server to be down for maintenance or when you expect the network to
        be temporary unavailable.

        Args:
            attempts: Number of attempts to make when reconnecting.
            delay: Use it (defined in seconds) if you want to wait between each retry.

        Raises:
            InterfaceError: When reconnection fails.
        rr@Nz!Can not reconnect to MySQL after z
 attempt(s): )�
disconnectr�rOr,�IOErrorr-r��sleep)rfrQrR�counterr��msgr[r[r\rP�s"�� z!MySQLConnectionAbstract.reconnectrc�st�dS)akShuts down connection to MySQL Server.

        This method closes the socket. It raises no exceptions.

        Unlike `disconnect()`, `shutdown()` closes the client connection without
        attempting to send a `QUIT` command to the server first. Thus, it will not
        block if the connection is disrupted for some reason such as network failure.
        N)�NotImplementedErrorr�r[r[r\�shutdown�s	z MySQLConnectionAbstract.shutdownc�sdS)a�Close the connection.

        It closes any opened cursor associated to this connection, and closes the
        underling socket connection.

        `MySQLConnection.close()` is a synonymous for `MySQLConnection.disconnect()`
        method name and more commonly used.

        This method tries to send a `QUIT` command and close the socket. It raises
        no exceptions.
        Nr[r�r[r[r\r��szMySQLConnectionAbstract.closezCallable[[], Any]rkz#Optional[Type[MySQLCursorAbstract]])r�r��prepared�cursor_class�
dictionary�named_tuplerWc�sdS)a�Instantiate and return a cursor.

        By default, MySQLCursor 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.

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

        Raises:
            ProgrammingError: When cursor_class is not a subclass of
                              CursorBase.
            ValueError: When cursor is not available.
        Nr[)rfr�r�rrrsrtrur[r[r\rc�s
zMySQLConnectionAbstract.cursor�Optional[List[DescriptionType]]z1Tuple[Optional[RowType], Optional[EofPacketType]])r?�columnsr�rWc�sdS)a3Get the next rows returned by the MySQL server.

        This method gets one row from the result set after sending, for example, the
        query command. The result is a tuple consisting of the row and the EOF packet.
        If no row was available in the result set, the row data will be None.
        Nr[)rfr?rwr�r[r[r\�get_rowszMySQLConnectionAbstract.get_rowr
z-Tuple[List[RowType], Optional[EofPacketType]])�countr?rwr��	prep_stmtrWc�sdS)z�Get all rows returned by the MySQL server.

        This method gets all rows returned by the MySQL server after sending, for
        example, the query command. The result is a tuple consisting of a list of rows
        and the EOF packet.
        Nr[)rfryr?rwr�rzr[r[r\ras	z MySQLConnectionAbstract.get_rowsc�sdS)zCommit current transaction.Nr[r�r[r[r\�commit-szMySQLConnectionAbstract.commitc�sdS)zRollback current transaction.Nr[r�r[r[r\�rollback1sz MySQLConnectionAbstract.rollbackc�sdS)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.
        Nr[r�r[r[r\�cmd_reset_connection5sz,MySQLConnectionAbstract.cmd_reset_connectionr7)rvrWc�sdS)z�Change the current database.

        This method changes the current (default) database by sending the INIT_DB
        command. The result is a dictionary containing the OK packet infawaitormation.
        Nr[)rfrvr[r[r\�cmd_init_db=sz#MySQLConnectionAbstract.cmd_init_db)rAr�r��
raw_as_stringrWc�sdS)a�Send a query to the MySQL server.

        This method send the query to the MySQL server and returns the result.

        If there was a text result, a tuple will be returned consisting of the number
        of columns and a list containing information about these columns.

        When the query doesn't return a text result, the OK or EOF packet information
        as dictionary will be returned. In case the result was an error, exception
        Error will be raised.
        Nr[)rfrAr�r�rr[r[r\r$Esz!MySQLConnectionAbstract.cmd_queryz!Generator[ResultType, None, None])�
statementsrWc�sdS)acSend one or more statements to the MySQL server.

        Similar to the cmd_query method, but instead returns a generator
        object to iterate through results. It sends the statements to the
        MySQL server and through the iterator you can get the results.

        statement = 'SELECT 1; INSERT INTO t1 VALUES (); SELECT 2'
        for result in await cnx.cmd_query(statement, iterate=True):
            if 'columns' in result:
                columns = result['columns']
                rows = await cnx.get_rows()
            else:
                # do something useful with INSERT result
        Nr[)rfr�r[r[r\�cmd_query_iterYsz&MySQLConnectionAbstract.cmd_query_iter)�statement_id�rowsrWc�sdS)z�Fetch a MySQL statement Result Set.

        This method will send the FETCH command to MySQL together with the given
        statement id and the number of rows to fetch.
        Nr[)rfr�r�r[r[r\�cmd_stmt_fetchksz&MySQLConnectionAbstract.cmd_stmt_fetchrRz/Mapping[str, Union[int, List[DescriptionType]]])�	statementrWc�sdS)z�Prepare a MySQL statement.

        This method will send the PREPARE command to MySQL together with the given
        statement.
        Nr[)rfr�r[r[r\�cmd_stmt_preparessz(MySQLConnectionAbstract.cmd_stmt_preparer[zUnion[int, CMySQLPrepStmt]zSequence[BinaryProtocolType]rz&Optional[Union[Dict[str, Any], Tuple]])r��datarrTrWc�sdS)z#Execute a prepared MySQL statement.Nr[)rfr�r�rrTr[r[r\�cmd_stmt_execute}sz(MySQLConnectionAbstract.cmd_stmt_execute)r�rWc�sdS)z}Reset data for prepared statement sent as long data.

        The result is a dictionary with OK packet information.
        Nr[�rfr�r[r[r\�cmd_stmt_reset�sz&MySQLConnectionAbstract.cmd_stmt_resetc�sdS)z�Deallocate a prepared MySQL statement.

        This method deallocates the prepared statement using the statement_id.
        Note that the MySQL server does not return anything.
        Nr[r�r[r[r\�cmd_stmt_close�sz&MySQLConnectionAbstract.cmd_stmt_close)�optionsrWc�sdS)a�Send the Refresh command to the MySQL server.

        This method sends the Refresh command to the MySQL server. The options
        argument should be a bitwise value using constants.RefreshOption.

        Usage example:
           RefreshOption = mysql.connector.RefreshOption
           refresh = RefreshOption.LOG | RefreshOption.INFO
           cnx.cmd_refresh(refresh)
        Nr[)rfr�r[r[r\�cmd_refresh�sz#MySQLConnectionAbstract.cmd_refreshr)r��param_idr�rWc�sdS)aSend data for a column.

        This methods send data for a column (for example BLOB) for statement identified
        by statement_id. The param_id indicate which parameter the data belongs too.
        The data argument should be a file-like object.

        Since MySQL does not send anything back, no error is raised. When the MySQL
        server is not reachable, an OperationalError is raised.

        cmd_stmt_send_long_data should be called before cmd_stmt_execute.

        The total bytes send is returned.
        Nr[)rfr�r�r�r[r[r\�cmd_stmt_send_long_data�sz/MySQLConnectionAbstract.cmd_stmt_send_long_datac�sdS)z�Close the current connection with the server.

        Send the QUIT command to the MySQL server, closing the current connection.
        Nr[r�r[r[r\�cmd_quit�sz MySQLConnectionAbstract.cmd_quit)�
shutdown_typerWc�sdS)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.
        Nr[)rfr�r[r[r\�cmd_shutdown�sz$MySQLConnectionAbstract.cmd_shutdownr;c�sdS)z�Send the statistics command to the MySQL Server.

        This method sends the STATISTICS command to the MySQL server. The result is a
        dictionary with various statistical information.
        Nr[r�r[r[r\�cmd_statistics�sz&MySQLConnectionAbstract.cmd_statistics)�	mysql_pidrWc�sdS)z�Kill a MySQL process.

        This method send the PROCESS_KILL command to the server along with the
        process ID. The result is a dictionary with the OK packet information.
        Nr[)rfr�r[r[r\�cmd_process_kill�sz(MySQLConnectionAbstract.cmd_process_killr5c�sdS)a-Send the DEBUG command.

        This method sends the DEBUG command to the MySQL server, which requires the
        MySQL user to have SUPER privilege. The output will go to the MySQL server
        error log and the result of this method is a dictionary with EOF packet
        information.
        Nr[r�r[r[r\�	cmd_debug�sz!MySQLConnectionAbstract.cmd_debugc�sdS)z�Send the PING command.

        This method sends the PING command to the MySQL server. It is used to check
        if the the connection is still valid. The result of this method is dictionary
        with OK packet information.
        Nr[r�r[r[r\�cmd_ping�sz MySQLConnectionAbstract.cmd_ping)NNN)r)NN)Fr@r)r@r)NNNNNN)FNN)NFNNN)FFF)r@)r[r[r)N)^rhrirjrkr%r�r�r�r�r�r��staticmethodr��propertyrrrrrrr�rv�setterr#r%r&r'r�r)r*r+r~r.r1rr4r5r�r8r9r�r�r<rPr@r�rBrDrCrHrIrJrKrNr�rOrSr�rXrZr^r_r`r}r!rhrjr�rPrqr�rkrlrcrxrar{r|r}r~r$r�r�r�r�r�r�r�r�r�r�r�r�r�r�r[r[r[r\r�s�
��bs�
]Q�"

	�C		�


#
��
��	�		rc@s�eZdZdZdd�dd�Zdd�dd�Zdcd
ddd
d�dd�Zdd�dd�Zdd�dd�Ze	dd�dd��Z
e	dd�dd��Ze	dd�dd��Ze	d d�d!d"��Z
d d�d#d$�Ze	dd�d%d&��Ze	d'd�d(d)��Ze	d*d�d+d,��Ze	d-d�d.d/��Zed0d�d1d2��Zeddd5d6d-d
d7�d8d9��Zded5d6d:d;�d<d=�Zed>d?d
d@�dAdB��ZedCd�dDdE��ZedFd�dGdH��ZedfddJdK�dLdM��Zed-d�dNdO��Zdd�dPdQ�Zdgd-dSdT�dUdV�ZdWd�dXdY�Zd>dZd
d[�d\d]�Zd>dZd^�d_d`�Z d
d�dadb�Z!d	S)hrz#Defines the MySQL cursor interface.r)�
connectioncCsf||_|j|_d|_d|_d|_d|_d|_g|_g|_	d|_
d|_d|_d|_
d|_|j�|�dS)NrFr�)NNr@)�_connectionr�r��_description�_last_insert_id�	_warnings�_warning_count�	_executedZ_executed_listZ_stored_results�_binaryr��	_rowcountZ_nextrowZ	arraysizerh)rfr�r[r[r\r��szMySQLCursorAbstract.__init__rVc�s|SrXr[r�r[r[r\r��szMySQLCursorAbstract.__aenter__Nr�r�r�rUr�c�s|��IdHdSrXr�r�r[r[r\r�szMySQLCursorAbstract.__aexit__zIterator[RowType]c�s|S)z�Iterate over result set.

        Iteration over the result set which calls self.fetchone()
        and returns the next row.
        r[r�r[r[r\�	__aiter__	szMySQLCursorAbstract.__aiter__r:c�s8z|��IdH}Wnty*td�Yn0|s4t�|S)zm
        Used for iterating over the result set. Calles self.fetchone()
        to get the next row.
        N)rer-�StopAsyncIteration)rf�rowr[r[r\�__next__szMySQLCursorAbstract.__next__rvcCs|jS)a�Return description of columns in a result.

        This property returns a list of tuples describing the columns in in a result
        set. A tuple is described as follows:

                (column_name,
                 type,
                 None,
                 None,
                 None,
                 None,
                 null_ok,
                 column_flags)  # Addition to PEP-249 specs

        Returns a list of tuples.
        )r�r�r[r[r\�descriptionszMySQLCursorAbstract.descriptionrIcCs|jS)a�Return the number of rows produced or affected.

        This property returns the number of rows produced by queries such as a
        SELECT, or affected rows when executing DML statements like INSERT or UPDATE.

        Note that for non-buffered cursors it is impossible to know the number of rows
        produced before having fetched them all. For those, the number of rows will
        be -1 right after execution, and incremented when fetching rows.
        )r�r�r[r[r\�rowcount2szMySQLCursorAbstract.rowcountr�cCs|jS)z�Return the value generated for an AUTO_INCREMENT column.

        Returns the value generated for an AUTO_INCREMENT column by the previous
        INSERT or UPDATE statement or None when there is no such value available.
        �r�r�r[r[r\�	lastrowid?szMySQLCursorAbstract.lastrowidzOptional[List[WarningType]]cCs|jS)zReturn warnings.�r�r�r[r[r\�warningsHszMySQLCursorAbstract.warningscCs|jS)zReturns Warnings.r�r�r[r[r\�
fetchwarningsMsz!MySQLCursorAbstract.fetchwarningscCs|jS)z�Return the number of warnings.

        This property returns the number of warnings generated by the previously
        executed operation.
        )r�r�r[r[r\�
warning_countQsz!MySQLCursorAbstract.warning_countzTuple[str, ...]cCs |jst�Stdd�|jD��S)z[Returns column names.

        This property returns the columns names as a tuple.
        css|]}|dVqdS)rNr[)rY�dr[r[r\r]br^z3MySQLCursorAbstract.column_names.<locals>.<genexpr>)r�rdr�r[r[r\�column_namesZsz MySQLCursorAbstract.column_namesr�c	CsD|jdurdSz|j����WSttfy>|j��YS0dS)z�Returns the executed statement

        This property returns the executed statement.
        When multiple statements were executed, the current statement in the iterator
        will be returned.
        N)r�r��decoder��UnicodeDecodeErrorr�r[r[r\r�ds
zMySQLCursorAbstract.statementrScCs
t|j�S)z�Returns whether the cursor could have rows returned.

        This property returns True when column descriptions are available and possibly
        also rows, which will need to be fetched.
        )rSr�r�r[r[r\�	with_rowssszMySQLCursorAbstract.with_rowszIterator[MySQLCursorAbstract]cCsdS)z�Returns an iterator for stored results.

        This method returns an iterator over results which are stored when callproc()
        is called. The iterator will provide MySQLCursorBuffered instances.
        Nr[r�r[r[r\�stored_results|sz"MySQLCursorAbstract.stored_resultsr[Fr<z$Union[Sequence[Any], Dict[str, Any]])�	operation�params�multirWc�sdS)auExecutes the given operation.

        Executes the given operation substituting any markers with the given
        parameters.

        For example, getting all rows where id is 5:
          await cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,))

        If the `multi`` parameter is used a `ProgrammingError` is raised. The method for
        executing multiple statements is `executemulti()`.

        If warnings where generated, and connection.get_warnings is True, then
        self._warnings will be a list containing these warnings.

        Raises:
            ProgramingError: If multi parameter is used.
        Nr[)rfr�r�r�r[r[r\rd�szMySQLCursorAbstract.executez)AsyncGenerator[MySQLCursorAbstract, None])r�r�rWc�sdS)z�Execute multiple statements.

        Executes the given operation substituting any markers with the given
        parameters.
        Nr[)rfr�r�r[r[r\�executemulti�sz MySQLCursorAbstract.executemultirKzSequence[ParamsSequenceType])r��
seq_paramsrWc�sdS)a=Prepare and execute a MySQL Prepared Statement many times.

        This method will prepare the given operation and execute with each tuple found
        the list seq_params.

        If the cursor instance already had a prepared statement, it is first closed.

        executemany() simply calls execute().
        Nr[)rfr�r�r[r[r\�executemany�szMySQLCursorAbstract.executemanyrbc�sdS)z�Return next row of a query result set.

        Raises:
            InterfaceError: If there is no result to fetch.

        Returns:
            tuple or None: A row from query result set.
        Nr[r�r[r[r\re�szMySQLCursorAbstract.fetchonez
List[RowType]c�sdS)z�Return all rows of a query result set.

        Raises:
            InterfaceError: If there is no result to fetch.

        Returns:
            list: A list of tuples with all rows of a query result set.
        Nr[r�r[r[r\�fetchall�szMySQLCursorAbstract.fetchallr@zList[Sequence[Any]])�sizerWc�sdS)a<Return the next set of rows of a query result set.

        When no more rows are available, it returns an empty list.
        The number of rows returned can be specified using the size argument, which
        defaults to one.

        Returns:
            list: The next set of rows of a query result set.
        Nr[)rfr�r[r[r\�	fetchmany�szMySQLCursorAbstract.fetchmanyc�sdS)zClose the cursor.Nr[r�r[r[r\r��szMySQLCursorAbstract.closecCs|jS)z�Return the value generated for an AUTO_INCREMENT column.

        Returns the value generated for an AUTO_INCREMENT column by the previous
        INSERT or UPDATE statement.
        r�r�r[r[r\�getlastrowid�sz MySQLCursorAbstract.getlastrowidTr
)�freerWc�sdS)zReset the cursor to default.Nr[)rfr�r[r[r\�reset�szMySQLCursorAbstract.resetz.Optional[List[Tuple[str, BinaryProtocolType]]]cCs(t|d�r|jjSt|d�r$|jjSdS)z�Gets a list of query attributes from the connector's side.

        Returns:
            List of existing query attributes.
        �_cnxr�N)�hasattrr�r*r�r�r[r[r\�get_attributes�s


z"MySQLCursorAbstract.get_attributesr3)r�rrWcCsHt|t�std��|dur4t|t�s4td|�d���|j�||f�dS)a�Add a query attribute and its value into the connector's query attributes.

        Query attributes must be enabled on the server - they are disabled by default. A
        warning is logged when setting query attributes for a server connection
        that does not support them.

        Args:
            name: Key name used to identify the attribute.
            value: A value converted to the MySQL Binary Protocol.

        Raises:
            ProgrammingError: If the value's conversion fails.
        �&Parameter `name` must be a string typeNzObject z$ cannot be converted to a MySQL type)r�rKr0rr�rZ)rfr�rr[r[r\�
add_attribute�s

�z!MySQLCursorAbstract.add_attributer[cCst|t�std��|j�|�S)a'Removes a query attribute by name from the connector's query attributes.

        If no match, `None` is returned, else the corresponding value is returned.

        Args:
            name: Key name used to identify the attribute.

        Returns:
            value: Attribute's value.
        r�)r�rKr0r�r^r]r[r[r\�remove_attributes
z$MySQLCursorAbstract.remove_attributecCs|j��dS)z<Clears the list of query attributes on the connector's side.N)r�r_r�r[r[r\�clear_attributessz$MySQLCursorAbstract.clear_attributes)NNN)r[F)r[)r@)T)"rhrirjrkr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rr�rdr�r�rer�r�r�r�r�r�r�r�r�r[r[r[r\r�sd�
	��

rc@seZdZdZdS)�CMySQLPrepStmtaPStructure to represent a result from `CMySQLConnection.cmd_stmt_prepare`.
    It can be used consistently as a type hint.

    `_mysql_connector.MySQLPrepStmt` isn't available when the C-ext isn't built.

    In this regard, `CmdStmtPrepareResult` acts as a proxy/wrapper entity for a
    `_mysql_connector.MySQLPrepStmt` instance.
    N)rhrirjrkr[r[r[r\r�sr�)^rk�
__future__r�__all__r�r�rar��abcrr�dataclassesrr	�inspectr
�typesr�typingrr
rrrrrrrrrrrrrrZ	abstractsrrrr r!r"r#�	constantsr$r%r&r'r(r)�
conversionr*r+�errorsr,r-r.r/r0Ztls_ciphersr1r2r3r4r5r6r7r8r9r:r;r<r=�utilsr>r?ZauthenticationrArCrBrJrD�networkrErFr�r(�WeakValueDictionaryrHrlrrrr�r[r[r[r\�<module> sTH$	 4

"X: