✏️ 正在编辑: abstracts.cpython-312.pyc
路径:
/var/opt/nydus/ops/mysql/connector/aio/__pycache__/abstracts.cpython-312.pyc
提示:
您可以编辑任何文件（包括二进制文件），但请注意不当修改可能导致文件损坏。
� ��'j͒ � �v � d Z ddlmZ ddlmZ g d�ZddlZddlZddlZddl Z ddl m Z m Z ddl mZmZ ddlmZ dd lmZ dd lmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z( d d l)m*Z* d d l+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3 d dl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z= d dl>m?Z?m@Z@ d dlAmBZBmCZCmDZDmEZEmFZF d dlGmHZHmIZI d dlmJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZU d dlVmWZWmXZX ddlYmZZZ ddl[m\Z\m[Z[ ddl]m^Z^ erddl_m`Z`maZa ej� dk( Zce G d� d� � Zd G d � d e � Ze G d � d e � Zf G d � d!eW� Zgy)"z+Module gathering all abstract base classes.� )� annotations)�read_option_files)�MySQLConnectionAbstract�MySQLCursorAbstract� ServerInfoN)�ABC�abstractmethod)� dataclass�field)� signature)� TracebackType)� TYPE_CHECKING�Any�AsyncGenerator� Awaitable�BinaryIO�Callable�ClassVar�Deque�Dict� Generator�Iterator�List�Mapping�NoReturn�Optional�Sequence�Tuple�Type�Union�cast� )� deprecated)�DUPLICATED_IN_LIST_ERROR�KRB_SERVICE_PRINCIPAL_ERROR�MYSQL_PY_TYPES�OPENID_TOKEN_FILE_ERROR�TLS_V1_3_SUPPORTED�TLS_VER_NO_SUPPORTED�TLS_VERSION_ERROR� TLS_VERSION_UNACCEPTABLE_ERROR) � CONN_ATTRS_DN�DEFAULT_CONFIGURATION�DEPRECATED_METHOD_WARNING�MYSQL_DEFAULT_CHARSET_ID_57�MYSQL_DEFAULT_CHARSET_ID_80�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�MySQLScriptPartition� OkPacketType�ParamsSequenceType� ResultType�RowType�StatsPacketType� StrOrBytes� WarningType)�GenericWrapper� import_object� )�MySQLAuthenticator)�Charset�charsets)� MySQLProtocol)�MySQLTcpSocket�MySQLUnixSocket�posixc � � e Zd ZU dZded< ded< ed�� Zded < ded < ded < ded < ded < ded< ded< dZded< dd�Zy)r z�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�charset� status_flags� auth_plugin�bytes� auth_data� capabilities�bool�query_attrs_is_supportedc � � t j d� }|j | j � }|s t d� �t d� |j � dd D � � }|dk rt d| j � d�� �|| _ y ) 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})(.*)z Failed parsing MySQL versionc 3 �2 K � | ] }t |� �� � y �w�N)rU )�.0�vs �N/opt/nydus/tmp/pip-target-k0fmikie/lib/python/mysql/connector/aio/abstracts.py� <genexpr>z+ServerInfo.__post_init__.<locals>.<genexpr>� s � �� �<�(;�1��A��(;�s �r � )� rL zMySQL Version 'z' is not supportedN)�re�compile�matchrX r8 �tuple�groupsrZ )�self� version_rero rX s ri � __post_init__zServerInfo.__post_init__� s| � � �Z�Z� G�H� �� � �� � �.��� �!?�@� @��<�� � ��q��(;�<�<�� �V� � �?�4�<�<�.�@R�!S�T� T� $��� N��return�None) �__name__� __module__� __qualname__�__doc__�__annotations__r rZ rc rt � ru ri r r � sT � �� �M� �L�%*��%6�M�?�6��N� �L���������%*� �d�*�%ru r c 0 � � e Zd ZU dZddddddddddddddddi dddddddddded ed dded ed ed dd ddddded dddddd�/ d�d�Zd�d�Z d� d�d�Zd�d�Zd�d�Z d�d�Z d�d�Z e d� d�d�� Z eed�d�� � Zed�d�� Zed�d�� Zed�d �� Zed�d �� Zed�d �� Zej, d�d �� Zed�d �� Zej, d�d!�� Zed�d"�� Zej, d�d#�� Zd�d$�Zd�d%�Zed�d&�� Zej, d�d'�� Zed�d(�� Z e j, d�d)�� Z ed�d*�� Z ed�d+�� Z ed�d,�� Z ed�d-�� Z ed�d.�� Z!ed�d/�� Z"e"j, d�d0�� Z"d�d1�Z#d�d2�Z$ed�d3�� Z%e%j, d�d4�� Z%d�d5�Z&d�d6�Z'ed�d7�� Z(e(j, d�d8�� Z(d�d9�Z)d�d:�Z*ed�d;�� Z+e+j, d�d<�� Z+ed�d=�� Z,e,j, d�d>�� Z,ed�d?�� Z-e-j, d�d@�� Z-ed�dA�� Z.ed�dB�� Z/ed�dC�� Z0ed�dD�� Z1e1j, d�dE�� Z1ed�dF�� Z2ed�dG�� Z3ed�dH�� Z4d�dI�Z5 d� d�dJ�Z6d�dK�Z7d�dL�Z8d�dM�Z9 e: e;jx dN�O� � d�dP�� Z= e: e;jx dQ�O� � d�dR�� Z>ed�dS�� Z?ed�dT�� Z@ed�dU�� ZAed�dV�� ZBe d� d�dW�� ZC e: e;jx d�O� � d�dX�� ZDed�dY�� ZEeEj, d�dZ�� ZE e: e;jx d�O� � d�d[�� ZFed�d\�� ZGeGj, d�d]�� ZGed�d^�� ZHeHj, d�d_�� ZHd�d`�ZId�da�ZJd�db�ZKd�dc�ZLd�dd�ZMd�de�ZNd�df�ZOd�dg�ZPed�dh�� ZQd�d�di�ZRd�dj�ZSed�dk�� ZTeTZUdleVdm< e d� d�dn�� ZWe d� d�do�� ZXe d� d�dp�� ZYed�dq�� ZZed�dr�� Z[ d� d�ds�Z\e d� d�dt�� Z]ed�du�� Z^ed�dv�� Z_e d� d�dw�� Z` d�dx�Zae d� d�dy�� Zbe d�dz�� Zce d� d�d{�� Zde d�d|�� Zeed�d}�� Zfed�d~�� Zg d�d�Zhed�d��� Zied�d�d��� Zjed�d��� Zked�d��� Zled�d��� Zmed�d��� Zne d� d�d��� Zoy)�r z'Defines the MySQL connection interface.N� z 127.0.0.1i� F�allow_local_infile�allow_local_infile_in_path�connect_timeout� read_timeout� write_timeoutT� ssl_disabled)/�user�password�host�port�database� password1� password2� password3r\ � collationr^ � 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�openid_token_file�webauthn_callbackr� r� �converter_class�converter_str_fallback�connection_timeoutr� r� � unix_socket� use_unicode�ssl_ca�ssl_cert�ssl_key�ssl_verify_cert�ssl_verify_identityr� � tls_versions�tls_ciphersuites�loop�oci_config_file�oci_config_profiler� r� c / �z � d | _ || _ || _ || _ || _ || _ || _ || _ || _ |#| _ | | _ |!| _ |"| _ || _ | | _ || _ || _ || _ || _ || _ t) � | _ d | _ | | _ | | _ d| _ |*| _ |%| _ |&| _ |'| _ |(| _ |)| _ |+| _ |,| _! | | _" d | _# d | _$ d | _% |-xs tM jN � | _( | xs tS jT � | _+ d | _, t[ j\ � | _/ i | _0 d| _1 g | _2 tg � | _4 | xs tj | _6 | | _7 || _8 || _9 || _: | | _; | | _< || _= || _> || _? || _@ |$| _A d| _B d| _C d| _D |.| _E |/| _F || _G d | _H d | _I d | _J | j� � y )NF)L�!_MySQLConnectionAbstract__charset�_user� _password�_host�_port� _database� _password1� _password2� _password3� _unix_socket�_connection_timeout� _read_timeout�_write_timeout�_connection_attrs� _compress�_consume_results� _autocommit� _time_zone� _sql_mode� _init_commandrP � _protocol�_socket� _charset_name�_charset_collation� _ssl_active� _ssl_disabled�_ssl_ca� _ssl_cert�_ssl_key�_ssl_verify_cert�_ssl_verify_identity� _tls_versions�_tls_ciphersuites� _auth_plugin�_auth_plugin_class�_pool_config_version� _handshake�asyncio�get_event_loop�_loopr4 � get_default� _client_flags� _server_info�weakref�WeakSet�_cursors� _query_attrs�_query_attrs_supported� _columns_descrM �_authenticatorr5 �_converter_class�_converter_str_fallback�_kerberos_auth_mode�_krb_service_principal�_openid_token_file�_allow_local_infile�_allow_local_infile_in_path� _get_warningsr� � _buffered�_raw� _use_unicode�_have_next_result�_unread_result�_in_transaction�_oci_config_file�_oci_config_profile�_webauthn_callback� converter�_local_infile_filenames�_query� _validate_connection_options)0rr r� r� r� r� r� r� r� r� r\ r� r^ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� s0 ri �__init__z MySQLConnectionAbstract.__init__� s] � �l -1��� � �� � &��� �� � �� � &��� (��� (��� (���!,���(:�� �,8���-:���1;�� � '���&5�� �!+���)2���(0���,8���(5����IM�� �,3���C�1:�� �@�!&���#/���&,�� �(0���'.�� �0?�� �4G��!�2>���6F�� �+6���15�� �)-��!�37��� � ,�G�*�*�,� � � #/�"J�*�2H�2H�2J���26���)0� � �):�� �;=���+0��#�46���2D�2F���6E�6W� �� �-C��$�2D�� �5J��#�1B�� �);�� �:T��(�#/���'8�� � '��� �� �"-���',�� �$)���%*�� �/>�� �-�2D�� �� � � � 48���=A��$� (� (,�� �(� �)�)�+ru c � �b K � | j � s| j � � d { ��� | S 7 ��wrf )�is_socket_connected�connect�rr s ri � __aenter__z"MySQLConnectionAbstract.__aenter__6 s+ � �� ��'�'�)��,�,�.� � �� � !�s �$/�-�/c � �@ K � | j � � d { ��� y 7 ��wrf ��close�rr �exc_type� exc_value� tracebacks ri � __aexit__z!MySQLConnectionAbstract.__aexit__; � � �� � �j�j�l���� � � � c �� � | j r | j j � | _ | j rt j g| _ | j r�t j j | j � }|r>t j j |� r t j j |� r t j j |� r t d� �| j s | j rt j g| _ nt j g| _ | j dk( rt# d| j � d�� �| j$ rt j& dk( rd| _ | j( r4| j d k( r t# d � �| j d k( r t# d � �t+ | j, t. � s t# d � �t1 | j2 | j4 | j6 g� r�t9 | j6 | j4 g� s t d� �| j6 du | j4 du k7 r t d� �| j: �| j= � | j> �| jA � t+ | jB tD � s t# d� �| jB jG � D ]� \ }}|tH v r�t+ |tJ � s t# d|� d| jB � d�� �tM |� dkD rt# d|� d�� �|jO d� r t# d� �t+ |tJ � st# d|� d|� d�� �tM |� dkD s��t# d|� d|� d �� � | jP t jR z r| jU � | jV r�t+ | jV tJ � s t# d � �| jV jY � }|d k( r&t j& d k7 r t# d � �d!| _- n|d"k( rd#| _- n t# d$� �| j\ r�t+ | j\ tJ � s t# t_ j` d%�&� � �| j\ d'k( r t# t_ j` d(�&� � �d)| j\ vr t# t_ j` d*�&� � �| jb r | je d+| jb d,� | jf r�t+ | jf tJ � s t# ti j` d%�&� � �| jf d'k( r t# ti j` d-�&� � �t j j | jf � st# d.| jf � d/�� �| jj �4t+ | jj t. � r| jj d0k r t# d1� �| jl �5t+ | jl t. � r| jl d0k r t# d2� �yy# t $ r}t d� |�d}~ww xY w)3z Validate connection options.z'user' must be a stringNz.allow_local_infile_in_path must be a directory� authentication_webauthn_client�'z5' cannot be used as the default authentication pluginrS T�mysql_clear_passwordzFClear password authentication is not supported over insecure channels�$authentication_openid_connect_clientzEOpenID Connect 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 neitherz conn_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}'z Attribute 'z ' value: 'z' must be a string typei z$' exceeds 1024 characters limit sizez('kerberos_auth_mode' must be of type str�sspi�ntz6'kerberos_auth_mode=SSPI' is only available on Windows�MySQLSSPIKerberosAuthPlugin�gssapi�MySQLKerberosAuthPluginz@Invalid 'kerberos_auth_mode' mode. Please use 'SSPI' or 'GSSAPI'zis not a string)�errorr� zcan not be an empty string�/zis incorrectly formatted�webauth_callbackrL zcannot be an empty stringz The path 'z1' provided via 'openid_token_file' does not existr z.Option read_timeout must be a positive integerz/Option write_timeout must be a positive integer)7r� �strip�AttributeErrorr� r4 �COMPRESSr� r� �os�path�abspath�exists�isdir�islinkr� � LOCAL_FILESr� r8 r� �namer� � isinstancer� rU �anyr� r� r� �allr� �_validate_tls_versionsr� �_validate_tls_ciphersuitesr� �dict�itemsr, rW �len� startswithr� � CONNECT_ARGS�_add_default_conn_attrsr� �lowerr� r� r% �formatr� �_validate_callabler� r' r� r� )rr �err�infile_in_path� attr_name� attr_valuer� s ri r� z4MySQLConnectionAbstract._validate_connection_optionsC s� � � �:�:� I� !�Z�Z� -� -� /�� � �>�>�!+�!4�!4� 5�D� � � +� +� �W�W�_�_�T�-M�-M� N�N� ��G�G�N�N�>�2���� � �n�5��7�7�>�>�.�1�$�%U�V�V� � #� #�t�'G�'G�!+�!7�!7� 8�D� �",�"8�"8�!8� 9�D� � � � � @� @� ��D�%�%�&� '� �� � � � ����G�!3�!%�D� � � � �� � �$:�:�$� �� � � � �$J�J�$�[�� � �$�*�*�c�*� �!J�K� K� �� � �d�n�n�d�m�m�<� =��� � �t�~�~�6�7�$�P�� � � � ��%�4�>�>�T�+A�B�$�J�� � �!�!�-��+�+�-��%�%�1��/�/�1��$�0�0�$�7� �!B�C� C�%)�%;�%;�%A�%A�%C� !�I�z��M�)�� �i��-�$��!�{�&��)?�)?�(@��C�� � �9�~��"�$�&�y�k�1S�T�� � �#�#�C�(�$�0�� � �j�#�.�$�!�)��J�z�l� C'� '�� � �:���%�$�!�)��J�z�l� C9� 9�� �9 &D�B � � � � 7� 7� 7� � (� (� *� � #� #� �d� 6� 6��<�$�%O�P�P�!%�!9�!9�!?�!?�!A� �!�V�+��7�7�d�?�(�P�� � +H��'�#�x�/�*C��'�$�V�� � � &� &� �d� 9� 9�3�?�$�/�6�6�=N�O�� � �*�*�b�0�$�/�6�6� :��� � �$�5�5�5�$�/�6�6�=W�X�� � � "� "� � #� #�$6��8O�8O�QR� S� � "� "� �d� 5� 5�s�;�$�+�2�2�9J�K�� � �&�&�"�,�$�+�2�2�9T�U�� � �7�7�>�>�$�"9�"9�:�$� ��!8�!8� 9� :%� %�� � � � � )� �d� 0� 0�#�6�$�:L�:L�q�:P�$�%U�V�V� � � � *� �d� 1� 1�3�7�4�;N�;N�QR�;R�$�%V�W�W� <S� +��u "� I�$�%>�?�S�H�� I�s � Y � Y+� Y&�&Y+c � � |j � }g d�}|D ] \ }} ||vr|| ||< ||= � t d i |��}|j dd� | _ |j dd� | _ |j dt j � � | _ |j dt � | _ |j � D ]0 \ }} t | d |z } t | ||j � � �2 | j! � y # t $ r Y ��w xY w# t $ r t d|� d�� d �w xY w# t $ r t | ||� Y ��w xY w) an Internal utility to set or update the connection options. Args: **kwargs: For a complete list of possible arguments, see [1]. Raises: AttributeError: When provided unsupported connection arguments. References: [1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html ))�dbr� )�usernamer� )�passwdr� )r� r� )�read_default_file� option_filesr� Fr� r� r� zUnsupported argument 'r Nr r~ )�copy�KeyErrorr �popr� r� r4 r� r� r5 r� r' r- r �setattrr r� ) rr �kwargs�config� compat_map�compat� translate�key�value� attributes ri �_set_connection_optionsz/MySQLConnectionAbstract._set_connection_options� s^ � � ��� �� � � ",� �F�I� � �F�*�(.�v��F�9�%��6�N� ",� #�,�V�,�� #�J�J�~�u� =���!'���,?��!G�� � "�J�J�~�z�7M�7M�7O� P��� %�z�z�*;�^� L�� � !�,�,�.�J�C�� P�%�c�*� �c� �I� 0���i���� �7� )� �)�)�+��3 � �� �� � P�$�'=�c�U�!�%D�E�4�O� P�� "� 0���i��/� 0�s/ �D � D�D,� D � D �D)�,E�Ec � � g }| j }t |t � r�|j d� r|j d� st d|� d�� �|dd j d� }|s t d� �|D ]4 }|j � j � }|s�$|j |� �6 n8t |t t f� r|D �cg c] }|s�|�� }}nt d |� d�� �| j � t d d n| j d d }|j d � � |d }g g g}i }g } t d t j |� dz D ]2 } |j! t" | � | j% t& | � �4 |D ]� } d| v r9| | v r5| t& d v r|d j | � �+|d j | � �@| |v rd|| } | |v r t t) j* d| �� � �| t" d v r|d j || � ��|d j || � ��t d| � d�� � |d s|d s t d� �|d D ]* } | t, d j/ � v s� t1 d| � d�� � |d D ]* } | t, d j/ � v s� t1 d| � d�� � dj3 |d � dj3 |d � g| _ y c c}w )z&Validates the tls_ciphersuites option.�[�]z)tls_ciphersuites must be a list, found: 'r rL ����,z6No valid cipher suite found in 'tls_ciphersuites' listzItls_ciphersuites should be a list with one or more ciphersuites. Found: 'NT)�reverser �-�TLSv1.3r� ��listrC z The 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! rW r) �endswithr �splitr �upper�appendrO �setr� r3 �sort�index�updater2 �extendr1 r$ r- r< �valuesr: �join)rr r� �tls_cs�tls_css�_tls_csr� � newer_tls_ver�translated_names�iani_cipher_suites_names�ossl_cipher_suites_names�tls_verr �translated_name�cipher_as_ossls ri r% z2MySQLConnectionAbstract._validate_tls_ciphersuites sb � � ���'�'�� �f�c� "��%�%�c�*�v���s�/C�$�?��x�q�I�� � �Q�r�l�(�(��-�G��$�L�� � #�� �,�,�.�.�.�0���$�+�+�G�4� #� ���s� � ,�5;� F�V�6�v��V� � F� �)�)/���3�� � $� 1� 1� 9�L��O�t�?Q�?Q�RS�?T� � ���$��'�$�Q�� � .0��H��#%� �.0� � $�$K�l�&8�&8� �&G�!�&K�L�G� $� +� +�,=�g�,F� G� $� +� +�,<�W�,E� F� M� %�D��d�{�t�'?� ?��+�I�6�6�$�Q�'�.�.�t�4�$�Q�'�.�.�t�4��1�1�":�4�"@��"�&6�6�(�0�7�7�!3�?��� � �,�Y�7�7�$�Q�'�.�.�/G��/M�N�$�Q�'�.�.�/G��/M�N�$�!�$�� (#� #�� �' %�. ��"�+;�A�+>� �L�� � /�q� 1�N� �!>�y�!I�!P�!P�!R�R�'� �n� -�-U�V�� � 2� /�q� 1�N� �!>�y�!I�!P�!P�!R�R�'� �n� -�-U�V�� � 2� �H�H�%�a�(� )� �H�H�%�a�(� )�" �� ��G Gs �K� Kc �� � g }| j }t |t � r�|j d� r|j d� st d|� d�� �|dd j d� }|D ]M }|j � }|dk( r�||v r t t j d |� � � �|j |� �O |d gk( r�t s�t t j |t � � �t |t � rJ|s t d � �|D ]7 }||v r t t j d |� � � �|j |� �9 nNt |t � r|D ] }|j |� � n%t d dj! t � � d|� d�� �|s t d� �g }g }g }|D ]F }|t v r|j |� |t" v r|j |� �6|j |� �H |r7|d gk( r)t s#t% t j |t � � �|| _ y|r#t% t' j |t � � �|r#t t) j t � � �y)z"Validates the tls_versions option.rG rH z%tls_versions must be a list, found: 'r rL rI rJ r� r� rN rM zJAt 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! rW r) rQ r rR r r$ r- rT r( r) r3 rO rU r[ r= r: r+ r* )rr r� � tls_version�tls_versrc �use_tls_versions�unacceptable_tls_versions�invalid_tls_versionss ri r$ z.MySQLConnectionAbstract._validate_tls_versionsy s� � �� ��(�(� � �k�3� '� �*�*�3�/�K�4H�4H��4M�$�;�K�=��J�� � #�1�R�(�.�.�s�3�H�#�� %�m�m�o� � �"�$� � �,�.�(�0�7�7�!/�{��� � �#�#�K�0� $� �I�;�&�/A�$�(�/�/� �\�J�� � � �T� *� �$�*�� � '���l�*�(�0�7�7�!/�w��� � �#�#�G�,� '� � �S� )�&�� �#�#�G�,� '� !���i�i� �-�.�j� ��a�I�� � � �C�� � ��$&�!� !� �#�G��,�&� �'�'��0��3�3�)�0�0��9�$�+�+�G�4� $� � �I�;�.�7I�'�(�/�/� �\�J�� � "2�D� � &�#�.�5�5�-�|��� � "� �!2�!9�!9�'�<�!P�Q� Q� "ru c � � t |t � r t |� }t |� st d| � d�� �t t |� j � }||k7 rt d| � d|� d|� �� �y# t $ r}t |� � |�d}~ww xY w)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! rW rK � ValueErrorr; �callabler( r � parameters)� option_name�callback�num_argsr/ � num_paramss ri r. z*MySQLConnectionAbstract._validate_callable� s� � �$ �h�� $� :�(��2�� ��!�"�%>�{�m�1�#M�N� N� ��8�,�7�7�8� � �� !�"��K�=� �H�:� 6)�)3� �6�� � "�� � :�&�#��0�c�9�� :�s � A/ �/ B �8 B�B c � � y)zMySQL connection ID.Nr~ r� s ri � connection_idz%MySQLConnectionAbstract.connection_id� � � ru c � � | j S )z$User used while connecting to MySQL.)r� r� s ri r� z MySQLConnectionAbstract.user� � � � �z�z�ru c � � | j S )z MySQL server IP address or name.)r� r� s ri � server_hostz#MySQLConnectionAbstract.server_host� rx ru c � � | j S )zMySQL server TCP/IP port.)r� r� s ri � server_portz#MySQLConnectionAbstract.server_port� rx ru c � � | j S )z MySQL Unix socket file location.)r� r� s ri r� z#MySQLConnectionAbstract.unix_socket � � � � � � ru c � � t d� �)�Get the current database.zoThe use of async properties are not supported by Python. Use `await get_database()` to get the database instead�r; r� s ri r� z MySQLConnectionAbstract.database s � � � E� � ru c � � t d� �)�Set the current database.zsThe use of async properties are not supported by Python. Use `await set_database(name)` to set the database insteadr� �rr rC s ri r� z MySQLConnectionAbstract.database � � � � I� � ru c � � | j S )a� Gets the connection context's timeout in seconds for each attempt to read any data from the server. `read_timeout` is number of seconds upto which the connector should wait for the server to reply back before raising an ReadTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the read operation is completed or stopped abruptly. �r� r� s ri r� z$MySQLConnectionAbstract.read_timeout � � � �!�!�!ru c �V � |� t |t � r|dk r t d� �|| _ y)a� Sets or updates the connection context's timeout in seconds for each attempt to read any data from the server. `read_timeout` is number of seconds upto which the connector should wait for the server to reply back before raising an ReadTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the read operation is completed or stopped abruptly. Args: timeout: Accepts a non-negative integer which is the timeout to be set in seconds or None. Raises: InterfaceError: If a positive integer or None is not passed via the timeout parameter. Examples: The following will set the read_timeout of the current session to 5 seconds: ``` >>> cnx = await mysql.connector.aio.connect(user='scott') >>> cnx.read_timeout = 5 ``` Nr �6Option read_timeout must be a positive integer or None�r! rU r8 r� �rr �timeouts ri r� z$MySQLConnectionAbstract.read_timeout# s4 � �2 � � �g�s�+�w��{�$�L�� � %��ru c � � | j S )a� Gets the connection context's timeout in seconds for each attempt to send data to the server. `write_timeout` is number of seconds upto which the connector should spend to write to the server before raising an WriteTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the write operation is completed or stopped abruptly. �r� r� s ri r� z%MySQLConnectionAbstract.write_timeoutC � � � �"�"�"ru c �V � |� t |t � r|dk r t d� �|| _ y)a� Sets or updates the connection context's timeout in seconds for each attempt to send data to the server. `write_timeout` is number of seconds upto which the connector should spend to write to the server before raising an WriteTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the write operation is completed or stopped abruptly. Args: timeout: Accepts a non-negative integer which is the timeout to be set in seconds or None. Raises: InterfaceError: If a positive integer or None is not passed via the timeout parameter. Examples: The following will set the write_timeout of the current session to 5 seconds: ``` >>> cnx = await mysql.connector.connect(user='scott') >>> cnx.write_timeout = 5 ``` Nr �7Option write_timeout must be a positive integer or None�r! rU r8 r� r� s ri r� z%MySQLConnectionAbstract.write_timeoutP s4 � �2 � � �g�s�+�w��{�$�M�� � &��ru c � �J K � | j d� � d{ ��� }|d S 7 � �w)r� zSELECT DATABASE()Nr �� info_query)rr �results ri � get_databasez$MySQLConnectionAbstract.get_databasep s' � �� ����':�;�;���a�y�� <�� �#�!� #c � �H K � | j d|� �� � d{ ��� y7 ��w)r� zUSE N)� cmd_queryr� s ri � set_databasez$MySQLConnectionAbstract.set_databaseu s � �� ��n�n�t�E�7�^�,�,�,�s �"� �"c � � | j S )z"Returns whether to consume results)r� r� s ri �can_consume_resultsz+MySQLConnectionAbstract.can_consume_resultsy � � � �$�$�$ru c �6 � t |t � sJ �|| _ y)zSet if can consume results.N)r! rb r� r� s ri r� z+MySQLConnectionAbstract.can_consume_results~ s � � �%��&�&�&� %�� ru c � � | j S )z'Returns the pool configuration version.�r� r� s ri �pool_config_versionz+MySQLConnectionAbstract.pool_config_version� s � � �(�(�(ru c � � || _ y)z#Sets the pool configuration versionNr� r� s ri r� z+MySQLConnectionAbstract.pool_config_version� s � � %*��!ru c � � | j S )z(MySQL session has started a transaction.)r� r� s ri �in_transactionz&MySQLConnectionAbstract.in_transaction� s � � �#�#�#ru c � � | j S )zReturn the event loop.)r� r� s ri r� z MySQLConnectionAbstract.loop� rx ru c �J � | j xs | j duxr t S )z&Return True if is a secure connection.N)r� r� �IS_POSIXr� s ri � is_securez!MySQLConnectionAbstract.is_secure� s% � � � � �O�D�$5�$5�T�$A�$N�h�Oru c �H � t | j j � � S )z Returns query attributes list.)rO r� r' r� s ri � query_attrsz#MySQLConnectionAbstract.query_attrs� s � � �D�%�%�+�+�-�.�.ru c � � | j S )zReturn if have next result.)r� r� s ri �have_next_resultz(MySQLConnectionAbstract.have_next_result� s � � �%�%�%ru c � � t d� �)�$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 insteadr� r� s ri r� z"MySQLConnectionAbstract.autocommit� r� ru c � � t d� �)�Toggle autocommit.zxThe use of async properties are not supported by Python. Use `await set_autocommit(value)` to set the autocommit insteadr� r� s ri r� z"MySQLConnectionAbstract.autocommit� � � � � N� � ru c � �P K � | j d� � d{ ��� }|d dk( S 7 � �w)r� zSELECT @@session.autocommitNr rL r� r� s ri �get_autocommitz&MySQLConnectionAbstract.get_autocommit� s, � �� ��o�o�&C�D�D���Q�x�1�}� � E�s �&�$� &c � �b K � |rdnd}| j d|� �� � d{ ��� || _ y7 � �w)r� �ON�OFFzSET @@session.autocommit = N)r� r� )rr rC �switchs ri �set_autocommitz&MySQLConnectionAbstract.set_autocommit� s7 � �� � ��E���n�n� :�6�(� C�D�D�D� ��� E�s � /�-� /c � � t d� �)�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 insteadr� r� s ri r� z!MySQLConnectionAbstract.time_zone� s � � � G� � ru c � � t d� �)�Sets the time zone.zxThe use of async properties are not supported by Python. Use `await get_autocommit(value)` to get the autocommit insteadr� r� s ri r� z!MySQLConnectionAbstract.time_zone� r� ru c � �J K � | j d� � d{ ��� }|d S 7 � �w)r� zSELECT @@session.time_zoneNr r� r� s ri � get_time_zonez%MySQLConnectionAbstract.get_time_zone� s' � �� ��o�o�&B�C�C���Q�x�� D�r� c � �X K � | j d|� d�� � d{ ��� || _ y7 � �w)r� zSET @@session.time_zone = 'r N)r� r� r� s ri � set_time_zonez%MySQLConnectionAbstract.set_time_zone� s/ � �� ��n�n� :�5�'�� C�D�D�D� ��� E�s �*�(� *c � � K � t d� ��w)�Gets the SQL mode.zoThe use of async properties are not supported by Python. Use `await get_sql_mode()` to get the SQL mode insteadr� r� s ri r� z MySQLConnectionAbstract.sql_mode� s � �� � � E� � �� � c � � K � t d� ��w)� 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 insteadr� r� s ri r� z MySQLConnectionAbstract.sql_mode� s � �� � � J� � �r� c � � K � | j �!| j d� � d{ ��� d | _ | j S 7 ��w)r� NzSELECT @@session.sql_moder )r� r� r� s ri � get_sql_modez$MySQLConnectionAbstract.get_sql_mode� s: � �� � �>�>� !�$(�O�O�4O�$P� P�RS� T�D�N��~�~� � Q�s �!>�<�>c � � K � t |t t f� rdj |� }| j d|� d�� � d{ ��� || _ y7 � �w)r� rJ zSET @@session.sql_mode = 'r N)r! rO rp r[ r� r� r� s ri � set_sql_modez$MySQLConnectionAbstract.set_sql_mode� sL � �� � �e�d�E�]� +��H�H�U�O�E��n�n� 9�%��� B�C�C�C� ��� D�s �A A�A� Ac � � | j S )z�Get whether this connection retrieves warnings automatically. This method returns whether this connection retrieves warnings automatically. )r� r� s ri r� z$MySQLConnectionAbstract.get_warnings s � � �!�!�!ru c �H � t |t � s t d� �|| _ y)a Set 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! rb rm r� r� s ri r� z$MySQLConnectionAbstract.get_warnings s" � � �%��&� � 6�7� 7� "��ru c � � | j S )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� s ri r� z)MySQLConnectionAbstract.raise_on_warnings% s � � �&�&�&ru c �\ � t |t � s t d� �|| _ |r|| _ yy)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! rb rm r� r� r� s ri r� z)MySQLConnectionAbstract.raise_on_warnings. s2 � � �%��&� � 6�7� 7�"'�� � �!&�D� � ru c � � | j S )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� s ri � unread_resultz%MySQLConnectionAbstract.unread_resultC � � � �"�"�"ru c �H � t |t � s t d� �|| _ y)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! rb rm r� r� s ri r� z%MySQLConnectionAbstract.unread_resultL s" � � �%��&� � 6�7� 7� #��ru c �. � | j j S )a Returns the collation for current connection. This property returns the collation name of the current connection. The server is queried when the connection is active. If not connected, the configured collation name is returned. Returns a string. )�_charsetr� r� s ri r� z!MySQLConnectionAbstract.collationZ s � � �}�}�&�&�&ru c �. � | j j S )a Return 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. �r� r r� s ri r\ z MySQLConnectionAbstract.charsetf s � � �}�}�!�!�!ru c �. � | j j S )z�The charset ID utilized during the connection phase. If the charset ID hasn't been set, the default charset ID is returned. )r� � charset_idr� s ri r� z"MySQLConnectionAbstract.charset_idp s � � �}�}�'�'�'ru c � � | j �b| j �t j t � S t j | j j dk rt nt � | _ | j S )�BThe charset object encapsulates charset and collation information.)� r )r� r� rO � get_by_idr/ rZ r0 r� s ri r� z MySQLConnectionAbstract._charsetx sj � � �>�>� !�� � �(� �)�)�*E�F�F� %� /� /� �(�(�6�6��?� 0�4� �D�N� �~�~� ru c � � || _ y)r� N)r� r� s ri r� z MySQLConnectionAbstract._charset� s � � ��ru c �x � | j �| j j dv ry| j j S )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. )�utf8mb4�utf8mb3�binary�utf8r� r� s ri �python_charsetz&MySQLConnectionAbstract.python_charset� s9 � � �=�=� �D�M�M�$6�$6� ; � % � ��}�}�!�!�!ru c � � y)z&Add the default connection attributes.Nr~ r� s ri r+ z/MySQLConnectionAbstract._add_default_conn_attrs� rv ru c � � K � y�w)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~ )rr �querys ri �_execute_queryz&MySQLConnectionAbstract._execute_query� � � �� �� �c � �� K � | j | j j �� � d{ ��� | j | j � � d{ ��� | j r#| j | j � � d{ ��� | j r#| j | j � � d{ ��� | j r$| j | j � � d{ ��� yy7 ��7 ��7 �h7 �;7 ��w)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. )r\ N) �set_charset_collationr� r� r� r� r� r� r� r� r� r� r� s ri �_post_connectionz(MySQLConnectionAbstract._post_connection� s� � �� � �(�(�� � �1I�1I�(�J�J�J��!�!�$�"2�"2�3�3�3� �?�?��$�$�T�_�_�5� 5� 5� �>�>��#�#�D�N�N�3� 3� 3� � � ��%�%�d�&8�&8�9� 9� 9� � K��3�� 5�� 3�� 9�sW �*C-�C#�"C-�C%�.C-�>C'�?.C-�-C)�..C-� C+� C-�%C-�'C-�)C-�+C-c � � K � d}t |t t f� s |�t |j d� � �t |t � s |� t d� �|rO|rMt |t � r t j |� j n|}t j ||� | _ n�|rpt |t � rt j |� | _ n�t |t � rt j |� | _ nZt |j d� � �|rt j |� | _ n#t d }t j |� | _ | j d| j j � d| j j � d�� � d{ ��� | j r0| j j! | j j � yy7 �A�w)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 NoneNr\ z)collation should be either string or Nonez SET NAMES 'z ' COLLATE 'r )r! rU rW rm r- rO r� r �get_by_name_and_collationr� � get_by_name�get_by_collationr- r� r� r� � set_charset)rr r\ r� �err_msg� charset_strs ri r� z-MySQLConnectionAbstract.set_charset_collation� s� � �� �2 @���'�C��:�.�7�3F� �W�^�^�I� 6�7� 7��)�S�)�i�.C� � H�I� I� �y� �g�s�+� �"�"�7�+�0�0� � � %� >� >�{�I� V�D�M� ��'�3�'� (� 2� 2�7� ;�� ��G�S�)� (� 4� 4�W� =�� � �� � � �!:�;�;� � $� 5� 5�i� @�D�M�+�I�6�G� $� 0� 0�� 9�D�M��n�n��$�-�-�,�,�-�[�� � �9P�9P�8Q�QR� S� � � � �>�>� �N�N� &� &�t�}�}�'9�'9� :� � �s �FG �G �AG c �& � | j |z dkD S )z|Checks if a client flag is set. Returns: `True` if the client flag was set, `False` otherwise. r �r� )rr �flags ri �isset_client_flagz)MySQLConnectionAbstract.isset_client_flag� s � � �"�"�T�)�Q�.�.ru c � � || _ y)zySet the path that user can upload files. Args: path (str): Path that user can upload files. N)r� )rr r s ri � set_allow_local_infile_in_pathz6MySQLConnectionAbstract.set_allow_local_infile_in_path s � � ,0��(ru c � � | S )z�Return self for weakref.proxy. This method is used when the original object is needed when using weakref.proxy. r~ r� s ri �get_selfz MySQLConnectionAbstract.get_self s � � � ru �server_version�� property_namec � � | j S )��Gets the MySQL version. Returns: The MySQL server version as a tuple. If not previously connected, it will return `None`. )r� r� s ri �get_server_versionz*MySQLConnectionAbstract.get_server_version s � � �"�"�"ru � server_infoc � � | j S )��Gets the original MySQL version information. Returns: The original MySQL server as text. If not previously connected, it will return `None`. )r r� s ri �get_server_infoz'MySQLConnectionAbstract.get_server_info s � � � � � ru c �H � | j �| j j S y)r N)r� rZ r� s ri r� z&MySQLConnectionAbstract.server_version& s% � � � � � (��$�$�2�2� 2�ru c �L � | j d S # t t f$ r Y yw xY w)r �server_version_originalN)r� � TypeErrorr: r� s ri r z#MySQLConnectionAbstract.server_info2 s. � � ��?�?�#<�=� =���8�$� �� �s � �#�#c � � y)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� s ri r� z+MySQLConnectionAbstract.is_socket_connected? rv ru c � � K � y�w)a Reports 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� s ri � is_connectedz$MySQLConnectionAbstract.is_connectedG r� r� c � � K � y�w)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. Nr~ )rr � reconnect�attempts�delays ri �pingz MySQLConnectionAbstract.pingP r� r� c �( � || _ | j S )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. client_flags = [ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG] Raises: ProgrammingError: When the flags argument is not a set or an integer bigger than 0. )r� )rr �flagss ri �set_client_flagsz(MySQLConnectionAbstract.set_client_flagsc s � � "���� � � ru c � � | j S )z-Gets the client flags of the current session.r� r� s ri r� z$MySQLConnectionAbstract.client_flagst s � � �!�!�!ru c � � t |t � r |dkD r|| _ yt |t t f� rB|D ]< }|dk r | xj t |� z c_ �(| xj |z c_ �> yt d� �)a� Sets 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. client_flags = [ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG] Raises: ProgrammingError: When the flags argument is not a set or an integer bigger than 0. r z.client_flags setter expect integer (>0) or setN)r! rU r� rp rO �absr; )rr r r� s ri r� z$MySQLConnectionAbstract.client_flagsy sq � � �e�S� !�e�a�i�!&�D� � ���t�}� -� ���!�8��&�&�3�t�9�*�4�&��&�&�$�.�&� � #�#S�T� Tru c � � || _ y)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`. N)r� �rr � convclasss ri �set_converter_classz+MySQLConnectionAbstract.set_converter_class� s � � )�� ru c � � | j S )z5Gets the converter class set for the current session.)r� r� s ri r� z'MySQLConnectionAbstract.converter_class� r� ru c �� � |r_t |t � rO|| _ || j j | j � | _ | j | j _ yt d� �)z�Sets 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) � issubclassr6 r� r� r r� r� r� � str_fallbackr r s ri r� z'MySQLConnectionAbstract.converter_class� sY � � ��I�/A�B�$-�D� !� &�t�}�}�'9�'9�4�;K�;K� L�D�N�*.�*F�*F�D�N�N� '��S�� ru c � � | j S )z7Gets whether we return string fields as unicode or not.)r� r� s ri r� z#MySQLConnectionAbstract.use_unicode� r~ ru c �b � || _ | j r | j j |� yy)z�Sets whether we return string fields as unicode or not. Args: value: A boolean - default is `True`. N)r� r� � set_unicoder� s ri r� z#MySQLConnectionAbstract.use_unicode� s* � � "��� �>�>� �N�N� &� &�u� -� ru c �J � |\ }}|| j vr|| j |< yy)a Add 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� )rr rC r1 r2 s ri �query_attrs_appendz*MySQLConnectionAbstract.query_attrs_append� s1 � � !&� � �:� �D� -� -� -�+5�D� � �i� (� .ru c �: � | j 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� r; �rr r s ri �query_attrs_removez*MySQLConnectionAbstract.query_attrs_remove� s � � � � �$�$�T�4�0�0ru c � � i | _ y)z5Clears query attributes list on the connector's side.Nr' r� s ri �query_attrs_clearz)MySQLConnectionAbstract.query_attrs_clear� s � � ��ru c � � K � | j r| j � � d{ ��� y| j r t d� �y7 � �w)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� r9 r� s ri �handle_unread_resultz,MySQLConnectionAbstract.handle_unread_result� sB � �� � � � ��&�&�(� (� (� � � � � 5�6� 6� � )�s � A�A � Ac � �Z K � | j r| j � � d{ ��� yy7 ��w)zConsume pending results.N)r� �get_rowsr� s ri r� z'MySQLConnectionAbstract.consume_results� s& � �� � � � ��-�-�/� !� !� � !�s � +�)�+c � �. K � | j d�� � d{ ��� 4 �d{ ��� }|j t t |� � � d{ ��� |j � � d{ ��� cddd� �d{ ��� S 7 �]7 �V7 �17 �7 � # 1 �d{ ���7 sw Y yxY w�w)z&Send a query which only returns 1 row.T)r� N)�cursor�executer! rW �fetchone)rr r� r3 s ri r� z"MySQLConnectionAbstract.info_query� sl � �� � ���d��3�3�3�3�v��.�.��c�5�!1�2� 2� 2� � � �*�*� 4�3�3��3�� 2��*�� 4��3�3�3�sx �B�A6�B�A8�B�#B �A:� B � A<�!B �$ B�0A>�1B�8B�:B �<B �>B� B�B �B�Bc �: � | j j |� y)z Add cursor to the weakref set.N)r� �add�rr r3 s ri � add_cursorz"MySQLConnectionAbstract.add_cursor� s � � � � ���&�!ru c �: � | j j |� y)z#Remove cursor from the weakref set.N)r� �remover8 s ri � remove_cursorz%MySQLConnectionAbstract.remove_cursor� s � � � � � � �V�$ru c � � K � y�w)z Connect to the MySQL server.Nr~ r� s ri r� z MySQLConnectionAbstract.connect r� r� c � � K � d}||k7 ry|dz } | j � � d{ ��� | j � � d{ ��� | j � � d{ ��� ry |dkD r t j |� � d{ ��� ||k7 r�xyy7 �`7 �J7 �4# t t f$ r#}||k( rd|� d|� �}t |� |�Y d}~�]d}~ww xY w7 �G�w)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. r rL Nz!Can not reconnect to MySQL after z attempt(s): )� disconnectr� r r7 �IOErrorr8 r� �sleep)rr r r �counterr/ �msgs ri r z!MySQLConnectionAbstract.reconnect s� � �� �" ����!� ��k�G� 7��o�o�'�'�'��l�l�n�$�$� �*�*�,�,�,�� -� �q�y� �m�m�E�*�*�*� ��!� (��$��,���7�#� 7��h�&�;�H�:� F'�'*�e�-� � )��-�3�6� '�� 7�� +�sr � C�B �B�B �B�B �B�B � C�7B?�8 C�C�B �B �B � B<�B7�2C�7B<�<Cc � � K � t ��w)ak Shuts 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. )�NotImplementedErrorr� s ri �shutdownz MySQLConnectionAbstract.shutdown( s � �� � "�!�s � c � � K � y�w)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� s ri r� z MySQLConnectionAbstract.close3 r� r� z@ClassVar[Callable[['MySQLConnectionAbstract'], Awaitable[None]]]r? c � � K � y�w)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 a dictionary or a 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 MySQLCursor. ValueError: When cursor is not available. Nr~ )rr r� r� �prepared� cursor_class� dictionaryr� r� s ri r3 z MySQLConnectionAbstract.cursorC r� r� c � � K � y�w)a3 Get 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~ )rr r� �columnsr� r= s ri �get_rowz MySQLConnectionAbstract.get_row_ r� r� c � � K � y�w)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~ )rr �countr� rM r� � prep_stmtr= s ri r1 z MySQLConnectionAbstract.get_rowsn r� r� c � � K � y�w)zCommit current transaction.Nr~ r� s ri �commitz MySQLConnectionAbstract.commit r� r� c � � K � y�w)z Rollback current transaction.Nr~ r� s ri �rollbackz MySQLConnectionAbstract.rollback� r� r� c � �� K � | j r t d� �|ra|j � j dd� j � }g d�}||vrt d|� d�� �| j d|� �� � d{ ��� |�K| j d k rt d | j � d �� �|rd }nd }| j d|� �� � d{ ��� d}|r|dz }| j |� � d{ ��� y7 �t7 �)7 � �w)at Starts a transaction. This method explicitly starts a transaction sending the START TRANSACTION statement to the MySQL server. You can optionally set whether there should be a consistent snapshot, which isolation level you need or which access mode i.e. READ ONLY or READ WRITE. Args: consistent_snapshot: If `True`, Connector/Python sends WITH CONSISTENT SNAPSHOT with the statement. MySQL ignores this for isolation levels for which that option does not apply. isolation_level: Permitted values are 'READ UNCOMMITTED', 'READ COMMITTED', 'REPEATABLE READ', and 'SERIALIZABLE'. If the value is `None`, no isolation level is sent, so the default level applies. readonly: Can be `True` to start the transaction in READ ONLY mode or `False` to start it in READ WRITE mode. If readonly is omitted, the server's default access mode is used. Raises: ProgrammingError: When a transaction is already in progress and when `ValueError` when `isolation_level` specifies an Unknown level. Examples: For example, to start a transaction with isolation level `SERIALIZABLE`, you would do the following: ``` >>> cnx = mysql.connector.aio.connect(...) >>> await cnx.start_transaction(isolation_level='SERIALIZABLE') ``` z Transaction already in progressrL � )zREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READ� SERIALIZABLEzUnknown isolation level "�"z SET TRANSACTION ISOLATION LEVEL N)� � rZ zMySQL server version z does not support this featurez READ ONLYz READ WRITEzSET TRANSACTION zSTART TRANSACTIONz WITH CONSISTENT SNAPSHOT) r� r; r �replacerS rm r� r� r� )rr �consistent_snapshot�isolation_level�readonly�level�levels� access_moder� s ri �start_transactionz)MySQLConnectionAbstract.start_transaction� s% � �� �F � � �"�#D�E� E� �#�)�)�+�3�3�C��=�C�C�E�E��F� �F�"� �#<�_�<M�Q�!O�P�P��%�%�(H���&P�Q� Q� Q� � ��"�"�Y�.� �+�D�,?�,?�+@� A+� +�� � � )� � *� ��%�%�(8�� �&F�G� G� G�#�� � �0� 0�E��n�n�U�#�#�#�% R�� H�� $�s7 �A6C3�8C-�9A C3�C/�!C3�'C1�(C3�/C3�1C3c � � K � y�w)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. Args: user_variables: User variables map. session_variables: System variables map. Raises: OperationalError: If not connected. InternalError: If there are unread results and InterfaceError on errors. Examples: ``` >>> user_variables = {'var1': '1', 'var2': '10'} >>> session_variables = {'wait_timeout': 100000, 'sql_mode': 'TRADITIONAL'} >>> await cnx.reset_session(user_variables, session_variables) ``` Nr~ )rr �user_variables�session_variabless ri � reset_sessionz%MySQLConnectionAbstract.reset_session� r� r� c � � K � y�w)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� s ri �cmd_reset_connectionz,MySQLConnectionAbstract.cmd_reset_connection� r� r� c � � K � y�w)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~ )rr r� s ri � cmd_init_dbz#MySQLConnectionAbstract.cmd_init_db� r� r� c � � K � y�w)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~ )rr r� r� r� � raw_as_stringr= s ri r� z!MySQLConnectionAbstract.cmd_query� r� r� c � � K � y�w)ac Send 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~ )rr � statementsr= s ri �cmd_query_iterz&MySQLConnectionAbstract.cmd_query_iter r� r� c � � K � y�w)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~ )rr � statement_id�rowsr= s ri �cmd_stmt_fetchz&MySQLConnectionAbstract.cmd_stmt_fetch& r� r� c � � K � y�w)z�Prepare a MySQL statement. This method will send the PREPARE command to MySQL together with the given statement. Nr~ )rr � statementr= s ri �cmd_stmt_preparez(MySQLConnectionAbstract.cmd_stmt_prepare0 r� r� c � � K � y�w)z#Execute a prepared MySQL statement.Nr~ )rr rr �dataro r r= s ri �cmd_stmt_executez(MySQLConnectionAbstract.cmd_stmt_execute< r� r� c � � K � y�w)z}Reset data for prepared statement sent as long data. The result is a dictionary with OK packet information. Nr~ �rr rr r= s ri �cmd_stmt_resetz&MySQLConnectionAbstract.cmd_stmt_resetG r� r� c � � K � y�w)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| s ri �cmd_stmt_closez&MySQLConnectionAbstract.cmd_stmt_closeR r� r� c � � K � y�w)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. Typical usage example: ``` RefreshOption = mysql.connector.RefreshOption refresh = RefreshOption.LOG | RefreshOption.INFO await cnx.cmd_refresh(refresh) ``` Args: options: Bitmask value constructed using constants from the `constants.RefreshOption` class. Returns: A dictionary representing the OK packet got as response when executing the command. Raises: ValueError: If an invalid command `refresh options` is provided. DeprecationWarning: If one of the options is deprecated for the server you are connecting to. Nr~ )rr �optionss ri � cmd_refreshz#MySQLConnectionAbstract.cmd_refreshZ r� r� c � � K � y�w)a Send 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~ )rr rr �param_idry r= s ri �cmd_stmt_send_long_dataz/MySQLConnectionAbstract.cmd_stmt_send_long_datav r� r� c � � K � y�w)z�Close the current connection with the server. Send the QUIT command to the MySQL server, closing the current connection. Nr~ r� s ri �cmd_quitz MySQLConnectionAbstract.cmd_quit� r� r� c � � K � y�w)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~ )rr � shutdown_types ri � cmd_shutdownz$MySQLConnectionAbstract.cmd_shutdown� r� r� c � � K � y�w)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� s ri �cmd_statisticsz&MySQLConnectionAbstract.cmd_statistics� r� r� c � � K � y�w)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~ )rr � mysql_pids ri �cmd_process_killz(MySQLConnectionAbstract.cmd_process_kill� r� r� c � � K � y�w)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� s ri � cmd_debugz!MySQLConnectionAbstract.cmd_debug� r� r� c � � K � y�w)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� s ri �cmd_pingz MySQLConnectionAbstract.cmd_ping� r� r� c � � K � y�w)a� Changes the current logged in user. It also causes the specified database to become the default (current) database. It is also possible to change the character set using the charset argument. The character set passed during initial connection is reused if no value of charset is passed via this method. Args: username: New account's username. password: New account's password. database: Database to become the default (current) database. charset: Client charset (see [1]), only the lower 8-bits. password1: New account's password factor 1 - it's used instead of `password` if set (higher precedence). password2: New account's password factor 2. password3: New account's password factor 3. oci_config_file: OCI configuration file location (path-like string). oci_config_profile: OCI configuration profile location (path-like string). openid_token_file: OpenID Connect token file location (path-like string). Returns: ok_packet: Dictionary containing the OK packet information. Examples: ``` >>> cnx.cmd_change_user(username='', password='', database='', charset=33) ``` References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set Nr~ ) rr r5 r� r� r\ r� r� r� r� r� r� s ri �cmd_change_userz'MySQLConnectionAbstract.cmd_change_user� r� r� )^r� � Optional[str]r� rW r� rW r� rU r� r� r� rW r� rW r� rW r\ rW r� rW r^ r� r� � Optional[int]r� rb r� rb r� rb r� r� r� zDict[str, str]r� r� r� r� r� rb r� rb r� rb r� rb r� r� r� r� r� r� r� z+Optional[Union[str, Callable[[str], None]]]r� rb r� r� r� zOptional[MySQLConverter]r� rb r� rU r� r� r� r� r� r� r� �Optional[bool]r� r� r� r� r� r� r� r� r� r� r� r� r� �Optional[List[str]]r� r� r� z#Optional[asyncio.AbstractEventLoop]r� r� r� r� )rw r �NNN�r z Optional[Type[BaseException]]r zOptional[BaseException]r zOptional[TracebackType]rw rx rv )r= r rw rx )r )rp rW rq zUnion[str, Callable]rr rU rw rx �rw r� )rw rW �rw rU �rw r� )rC rW rw rx �r� r� rw rx �rw rb )rC rb rw rx )rw r )rC r rw rx )rw zasyncio.AbstractEventLoop)rw z$List[Tuple[str, BinaryProtocolType]])rC zUnion[str, Sequence[int]]rw rx )rw rN )rC rN rw rx )r� rW rw rE �NN)r\ zOptional[Union[int, str]]r� r� rw rx )r� rU rw rb )r rW rw rx )rw zOptional[Tuple[int, ...]])FrL r )r rb r rU r rU rw rb )r �Union[int, Sequence[int]]rw rU )r r� rw rx )r z Optional[Type[MySQLConverter]]rw rx )rw zType[MySQLConverter])rC z Tuple[str, BinaryProtocolType]rw rx �r rW rw r> )r� rH rw �Optional[RowType])r3 r rw rx )rL r )r rU r rU rw rx )rw r )NNNNNNN)r� r� r� r� rI r� rJ z#Optional[Type[MySQLCursorAbstract]]rK r� r� r� r� r� rw r )FNN) r� rb rM � Optional[List[DescriptionType]]r� r� r= r rw z1Tuple[Optional[RowType], Optional[EofPacketType]])NFNNN)rP r� r� rb rM r� r� r� rQ r r= r rw z-Tuple[List[RowType], Optional[EofPacketType]])r] rb r^ r� r_ r� rw rx )re �Optional[Dict[str, Any]]rf r� rw rx )r� rW rw rC )FFF) r� rH r� rb r� rb rm rb r= r rw rE )ro rH r= r rw z!Generator[ResultType, None, None]�rL )rr rU rs rU r= r rw rx )rv r_ r= r rw z/Mapping[str, Union[int, List[DescriptionType]]])r~ r~ r ) rr zUnion[int, CMySQLPrepStmt]ry z Sequence[BinaryProtocolType]ro r r rU r= r rw z&Optional[Union[Dict[str, Any], Tuple]])rr rU r= r rw rx )r� rU rw rC ) rr rU r� rU ry r r= r rw rU )rw r_ rf )r� r� rw rx )rw rG )r� rU rw rC )rw r@ )rw rC ) r� r� r� Nr� r� r� r� r� r� )r5 rW r� rW r� rW r\ r� r� rW r� rW r� rW r� rW r� rW r� rW rw zOptional[OkPacketType])pry rz r{ r| r- r� r� r r� rE r% r$ � staticmethodr. �propertyr ru r� rz r| r� r� �setterr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r\ r� r� r� r+ r� r� r� r� r� r� r# r. r- r r r� r r� r r r r� r r� r� r( r+ r- r/ r� r� r9 r< r� r rF r� r? r} r3 rN r1 rS rU rc rg ri rk r� rp rt rw rz r} r r� r� r� r� r� r� r� r� r� r~ ru ri r r � s= � �1� #�� ��"&������%)�&*� � %� �#'�%'�"&�&*� "�"'� ��,0�/3�+/�IM�#8�9M�#N�4I� (�5 � 59�',�"7�8I�"J�&;�N�&K�'<�_�'M�%)�&*� $�"&�!%�*/�.3�'<�^�'L�,0�04�48�)-�,0�gM,� �M,� � M,� � M,� � M,� �M,� �M,� �M,� �M,� �M,� �M,� #�M,� $� M,� � M,� �!M,�" �#M,�$ !�%M,�& #�'M,�( �)M,�* $�+M,�, �-M,�. �/M,�0 �1M,�2 �3M,�4 *�5M,�6 -�7M,�8 )�9M,�: G�;M,�< !�=M,�> %2�?M,�D 2�EM,�F !%�GM,�H �IM,�J $�KM,�L %�MM,�N #�OM,�P $�QM,�R �SM,�T �UM,�V �WM,�X (�YM,�Z ,�[M,�\ %�]M,�^ *�_M,�` .�aM,�b 2�cM,�d '�eM,�f *�gM,�^� 37�-1�-1� �/�� +�� +� � � �aX�F4,�l[ �zOR�b �JK� �� �$8� �DG� � � � � �D ��#� � �#� �� �� �� �� �� �� �!� �!� � � � � �_�_� � � � � "� � "� ��� %� � %�> � #� � #� ��� &� � &�>� -� �%� �%� � � �&� �&� �)� �)� � � �*� �*� �$� �$� �� �� �P� �P� �/� �/� �&� �&� � � � � ��� � � � � !� � � � � ��� � � �� � � � � � �_�_� � � �$ � �$ �"� �"� ��� #� � #� �'� �'� � � �'� �'�( �#� �#� ��� $� � $� � '� � '� �"� �"� �(� �(� � � � �& �_�_� � � � �"� �"� �5� �5� � � � �:�" UY�8;�0�8;�DQ�8;� �8;�t/�0�� �0�)�0�0�?O�P�Q�#� R�#� �0�)�0�0�}�M�N� � O� � � � � � � � � � � � � � � � � � �GH� � � �14� �AD� � � � � �$ �0�)�0�0�~�N�O�!� P�!� �"� �"� ���U� �U�0 �0�)�0�0�?P�Q�R� )� S� )� �%� �%� ���� ��$ �!� �!� ���.� �.� 6�1� � 7�"� +� "�%� �+� �+�!+�F "� � � � � TY�J�P�X�� $(� "�#'�<@�%)�&*�'+� � � � � � !� � :� � #� � $� � %� � � � � �6 � �37� "� �� � 1� � � � � � ;� � � � � $� �37� "� � � � � � � 1� � � � � � � � 7� � � � �*� �*� �,� �,� %*�)-�#'� D$� !�D$� '�D$� !� D$� � D$�L � 48�6:� �0� � 4� � � � � �> � � � � � � � � � � � #� �� � � � � � � � � � � � � �( � � � � � +� �( �-.� � � �'*� �:=� � � � � � � �� � � � 9� � � � � .0� !�� 2�0�2� +�2� � 2� � 2� � 2� 0�2� �2� � �� � � � � � � � � � � � � � � �6 �� � � � � � � � � �* � � � � � � � � � � � � � � � � � � � � � � � � � ���!%���� !�"$�!#�, ��, � �, � � , � � , � � , � �, � �, � �, � �, � �, � �, � �, ru r c �� � e Zd ZdZ d( d)d�Zd*d�Z d+ d,d�Zd-d�Zd.d�Ze d/d�� Z e j d0d �� Z e d/d �� Z e j d0d �� Z e d1d �� Z e d2d �� Ze d/d�� Ze d3d�� Z e ej& d�� � d3d�� Ze d2d�� Ze d4d�� Ze d5d�� Ze d6d�� Zed7d�� Ze d8 d9d�� Ze d8 d9d�� Z e d:d�� Z ed;d�� Z ed<d �� Z ed=d>d �� Z d?d �Z!ed@d �� Z"ed6d �� Z# e ej& d!�� � d/d"�� Z$dAdBd#�Z%dCd$�Z&dDd%�Z'dEd&�Z(dFd'�Z)y)Gr z#Defines the MySQL cursor interface.Nc �X � || _ |j | _ d | _ d | _ d | _ d| _ d | _ g | _ g | _ d| _ d| _ d| _ d| _ d| _ d | _ d | _ d| _ || _ || _ | j j) | � y )Nr FrI r� rL )� _connectionr� r� � _description�_last_insert_id� _warnings�_warning_count� _executed�_executed_list�_stored_results�_binaryr� � _rowcount�_nextrow� arraysize�_stmt_partitions�_stmt_partition�_stmt_map_resultsr� r� r9 )rr � connectionr� r� s ri r� z MySQLCursorAbstract.__init__� s� � � 5?���0:���� �=A���.2�� �6:���#$���*.���+-���*,�� � "�� � �� � ���L �� � ��� � � � @D�� �',�� �,8���-:��� ���#�#�D�)ru c � � K � | S �wrf r~ r� s ri r� z MySQLCursorAbstract.__aenter__ s � �� �� �� �c � �@ K � | j � � d { ��� y 7 ��wrf r� r s ri r z MySQLCursorAbstract.__aexit__ r r c � � K � | S �w)z�Iterate over result set. Iteration over the result set which calls self.fetchone() and returns the next row. r~ r� s ri � __aiter__z MySQLCursorAbstract.__aiter__ s � �� � � �r� c � �| K � | j � � d{ ��� }|st �|S 7 �# t $ r t d�w xY w�w)zl Used for iterating over the result set. Calls self.fetchone() to get the next row. N)r5 r8 �StopAsyncIteration)rr �rows ri � __anext__z MySQLCursorAbstract.__anext__& sD � �� � /� � � ��'�C� �$� $�� � (�� � /�$�$� .� /�s �<�( �&�( � <�( �9�<c � � | j S )a� Gets the cursor context's timeout in seconds for each attempt to read any data from the server. `read_timeout` is number of seconds upto which the connector should wait for the server to reply back before raising an ReadTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the read operation is completed or stopped abruptly. r� r� s ri r� z MySQLCursorAbstract.read_timeout3 r� ru c �V � |� t |t � r|dk r t d� �|| _ y)a Sets or updates the cursor context's timeout in seconds for each attempt to read any data from the server. `read_timeout` is number of seconds upto which the connector should wait for the server to reply back before raising an ReadTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the read operation is completed or stopped abruptly. Args: timeout: Accepts a non-negative integer which is the timeout to be set in seconds or None. Raises: InterfaceError: If a positive integer or None is not passed via the timeout parameter. Examples: The following will set the read_timeout of the current session's cursor context to 5 seconds: ``` >>> cnx = await mysql.connector.connect(user='scott') >>> cur = await cnx.cursor() >>> cur.read_timeout = 5 ``` Nr r� r� r� s ri r� z MySQLCursorAbstract.read_timeout@ s4 � �4 � � �g�s�+�w��{�$�L�� � %��ru c � � | j S )a� Gets the cursor context's timeout in seconds for each attempt to send data to the server. `write_timeout` is number of seconds upto which the connector should spend to write to the server before raising an WriteTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the write operation is completed or stopped abruptly. r� r� s ri r� z!MySQLCursorAbstract.write_timeouta r� ru c �V � |� t |t � r|dk r t d� �|| _ y)a Sets or updates the cursor context's timeout in seconds for each attempt to send data to the server. `write_timeout` is number of seconds upto which the connector should spend to write to the server before raising an WriteTimeoutError. We can set this option to None, which would signal the connector to wait indefinitely till the write operation is completed or stopped abruptly. Args: timeout: Accepts a non-negative integer which is the timeout to be set in seconds or None. Raises: InterfaceError: If a positive integer or None is not passed via the timeout parameter. Examples: The following will set the write_timeout of the current session's cursor context to 5 seconds: ``` >>> cnx = await mysql.connector.connect(user='scott') >>> cur = await cnx.cursor() >>> cur.write_timeout = 5 ``` Nr r� r� r� s ri r� z!MySQLCursorAbstract.write_timeoutn s4 � �4 � � �g�s�+�w��{�$�M�� � &��ru c � � | j S )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� s ri � descriptionz MySQLCursorAbstract.description� s � �$ � � � ru c � � | j S )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� s ri �rowcountz MySQLCursorAbstract.rowcount� s � � �~�~� ru c � � | j S )z�Gets 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� s ri � lastrowidz MySQLCursorAbstract.lastrowid� s � � �#�#�#ru c � � | j S )zGets warnings.�r� r� s ri �warningsz MySQLCursorAbstract.warnings� � � � �~�~� ru r� r c � � | j S )zReturns Warnings.r� r� s ri � fetchwarningsz!MySQLCursorAbstract.fetchwarnings� r� ru c � � | j S )z�Return the number of warnings. This property returns the number of warnings generated by the previously executed operation. )r� r� s ri � warning_countz!MySQLCursorAbstract.warning_count� r� ru c �f � | j s t � S t d� | j D � � S )z[Returns column names. This property returns the columns names as a tuple. c 3 �& K � | ] }|d �� � y�w)r Nr~ )rg �ds ri rj z3MySQLCursorAbstract.column_names.<locals>.<genexpr>� s � �� �4�#3�a�Q�q�T�#3�s �)r� rp r� s ri � column_namesz MySQLCursorAbstract.column_names� s+ � � � � ��7�N��4�4�#3�#3�4�4�4ru c �� � | j �y | j j � j d� S # t t f$ r+ t t | j j � � cY S w xY w)a� Returns the latest executed statement. When a multiple statement is executed, the value of `statement` corresponds to the one that caused the current result set, provided the statement-result mapping was enabled. Otherwise, the value of `statement` matches the statement just as provided when calling `execute()` and it does not change as result sets are traversed. Nzutf-8)r� r �decoder �UnicodeDecodeErrorr! rW r� s ri rv z MySQLCursorAbstract.statement� sc � � �>�>� !�� 5��>�>�'�'�)�0�0��9� 9�� � 2�3� 5���T�^�^� 1� 1� 3�4� 4� 5�s �(8 �7A2�1A2c �, � 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. )rb r� r� s ri � with_rowsz MySQLCursorAbstract.with_rows� s � � �D�%�%�&�&ru c � � y)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� s ri �stored_resultsz"MySQLCursorAbstract.stored_results� rv ru c � � K � y�w)a� Executes the given operation (a MySQL script) substituting any markers with the given parameters. For example, getting all rows where id is 5: ``` cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,)) ``` If you want each single statement in the script to be related to its corresponding result set, you should enable the `map_results` switch - see workflow example below. If the given script uses `DELIMITER` statements (which are not recognized by MySQL Server), the connector will parse such statements to remove them from the script and substitute delimiters as needed. This pre-processing may cause a performance hit when using long scripts. Note that when enabling `map_results`, the script is expected to use `DELIMITER` statements in order to split the script into multiple query strings. The following characters are currently not supported by the connector in `DELIMITER` statements: `"`, `'`, #`, `/*` and `*/`. If warnings were generated, and `connection.get_warnings` is `True`, then `self.warnings` will be a list containing these warnings. Args: operation: Operation to be executed - it can be a single or a multi statement. params: The parameters found in the tuple or dictionary params are bound to the variables in the operation. Specify variables using `%s` or `%(name)s` parameter style (that is, using format or pyformat style). map_results: It is `False` by default. If `True`, it allows you to know what statement caused what result set - see workflow example below. Only relevant when working with multi statements. Returns: `None`. Example (basic usage): The following example runs many single statements in a single go and loads the corresponding result sets sequentially: ``` sql_operation = ''' SET @a=1, @b='2024-02-01'; SELECT @a, LENGTH('hello'), @b; SELECT @@version; ''' async with await cnx.cursor() as cur: await cur.execute(sql_operation) result_set = await cur.fetchall() # do something with result set ... while (await cur.nextset()): result_set = await cur.fetchall() # do something with result set ... ``` In case the operation is a single statement, you may skip the looping section as no more result sets are to be expected. Example (statement-result mapping): The following example runs many single statements in a single go and loads the corresponding result sets sequentially. Additionally, each result set gets related to the statement that caused it: ``` sql_operation = ''' SET @a=1, @b='2024-02-01'; SELECT @a, LENGTH('hello'), @b; SELECT @@version; ''' async with await cnx.cursor() as cur: await cur.execute(sql_operation, map_results=True) # statement 1 is `SET @a=1, @b='2024-02-01'`, # result set from statement 1 is `[]` - aka, an empty set. result_set, statement = await cur.fetchall(), cur.statement # do something with result set ... # 1st call to `nextset()` will laod the result set from statement 2, # statement 2 is `SELECT @a, LENGTH('hello'), @b`, # result set from statement 2 is `[(1, 5, '2024-02-01')]`. # # 2nd call to `nextset()` will laod the result set from statement 3, # statement 3 is `SELECT @@version`, # result set from statement 3 is `[('9.0.0-labs-mrs-8',)]`. # # 3rd call to `nextset()` will return `None` as there are no more sets, # leading to the end of the consumption process of result sets. while (await cur.nextset()): result_set, statement = await cur.fetchall(), cur.statement # do something with result set ... ``` In case the mapping is disabled (`map_results=False`), all result sets get related to the same statement, which is the one provided when calling `execute()`. In other words, the property `statement` will not change as result sets are consumed, which contrasts with the case in which the mapping is enabled. Note that we offer a new fetch-related API command which can be leveraged as a shortcut for consuming result sets - it is equivalent to the previous workflow. ``` sql_operation = ''' SET @a=1, @b='2024-02-01'; SELECT @a, LENGTH('hello'), @b; SELECT @@version; ''' async with await cnx.cursor() as cur: await cur.execute(sql_operation, map_results=True) async for statement, result_set in cur.fetchsets(): # do something with result set ``` Nr~ �rr � operation�params� map_resultss ri r4 zMySQLCursorAbstract.execute� r� r� c � � K � y�w)a� Executes the given operation (it can be a multi statement or a MySQL script) substituting any markers with the given parameters. **NOTE: `executemulti()` is deprecated and will be removed in a future release. Use `execute()` instead.** If you want each single statement in the script to be related to its corresponding result set, you should enable the `map_results` switch - see workflow example below. This capability reduces performance. **Unexpected behavior might happen if your script includes the following symbols as delimiters `"`, `'`, `#`, `/*` and `*/`. The use of these should be avoided for now**. Refer to the documentation of `execute()` to see the multi statement execution workflow. Args: operation: Operation to be executed - it can be a single or a multi statement. params: The parameters found in the tuple or dictionary params are bound to the variables in the operation. Specify variables using `%s` or `%(name)s` parameter style (that is, using format or pyformat style). map_results: It is `False` by default. If `True`, it allows you to know what statement caused what result set - see workflow example below. Only relevant when working with multi statements. Returns: `None`. Nr~ r� s ri � executemultiz MySQLCursorAbstract.executemultiz r� r� c � � K � y�w)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~ )rr r� � seq_paramss ri � executemanyz MySQLCursorAbstract.executemany� r� r� c � � K � y�w)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� s ri r5 z MySQLCursorAbstract.fetchone� r� r� c � � K � y�w)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� s ri �fetchallz MySQLCursorAbstract.fetchall� r� r� c � � K � y�w)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~ )rr �sizes ri � fetchmanyz MySQLCursorAbstract.fetchmany� r� r� c �� K � d}| j s | j } | j � � d{ ��� }| j r | j n||f��� | j � � d{ ��� rR | j � � d{ ��� }| j r | j n||f��� | j � � d{ ��� r�Qyy7 ��# t $ r g }Y ��w xY w7 �j7 �S# t $ r g }Y �^w xY w7 �/�w)a� Generates the result sets stream caused by the last `execute*()`. Returns: A 2-tuple; the first element is the statement that caused the result set, and the second is the result set itself. Example: Consider the following example where multiple statements are executed in one go: ``` sql_operation = ''' SET @a=1, @b='2024-02-01'; SELECT @a, LENGTH('hello'), @b; SELECT @@version; ''' async with await cnx.cursor() as cur: await cur.execute(sql_operation, map_results=True) result_set, statement = await cur.fetchall(), cur.statement # do something with result set ... while (await cur.nextset()): result_set, statement = await cur.fetchall(), cur.statement # do something with result set ... ``` In this case, as an alternative to loading the result sets with `nextset()` in combination with a `while` loop, you can use `fetchsets()` which is equivalent to the previous approach: ``` sql_operation = ''' SET @a=1, @b='2024-02-01'; SELECT @a, LENGTH('hello'), @b; SELECT @@version; ''' async with await cnx.cursor() as cur: await cur.execute(sql_operation, map_results=True) async for statement, result_set in cur.fetchsets(): # do something with result set ``` N)r� rv r� r8 �nextset)rr �statement_cached� result_sets ri � fetchsetsz MySQLCursorAbstract.fetchsets� s� � �� �h ���%�%� #�~�~� � � #�}�}��.�J� #� 4� 4�D�N�N�:J� �� � �L�L�N�"�"� �#'�=�=�?� 2� � #'�"8�"8����>N��� � �L�L�N�"�"� /�� � ��J� �� #�� 2��!� � � � �� #�s� �C*�C �C �C �2C*�(C�)C*�.C �C�C �2C*�8C(�9C*�>C*� C � C� C*�C�C*�C � C%�"C*�$C%�%C*c � � K � y�w)aK Makes the cursor skip to the next available set, discarding any remaining rows from the current set. This method should be used as part of the multi statement execution workflow - see example below. Returns: It returns `None` if there are no more sets. Otherwise, it returns `True` and subsequent calls to the `fetch*()` methods will return rows from the next result set. Example: The following example runs many single statements in a single go and loads the corresponding result sets sequentially: ``` sql_operation = ''' SET @a=1, @b='2024-02-01'; SELECT @a, LENGTH('hello'), @b; SELECT @@version; ''' async with await cnx.cursor() as cur: await cur.execute(sql_operation) result_set = await cur.fetchall() # do something with result set ... while (await cur.nextset()): result_set = await cur.fetchall() # do something with result set ... ``` In case the operation is a single statement, you may skip the looping section as no more result sets are to be expected. Nr~ r� s ri r� zMySQLCursorAbstract.nextset r� r� c � � K � y�w)zClose the cursor.Nr~ r� s ri r� zMySQLCursorAbstract.closeC r� r� r� c � � | j S )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� s ri � getlastrowidz MySQLCursorAbstract.getlastrowidG s � � �#�#�#ru c � � K � y�w)z Reset the cursor to default.Nr~ )rr �frees ri �resetzMySQLCursorAbstract.resetP r� r� c �H � t | d� r| j j S y)z�Gets a list of query attributes from the connector's side. Returns: List of existing query attributes. r� N)�hasattrr� r� r� s ri �get_attributesz"MySQLCursorAbstract.get_attributesS s# � � �4� � '��#�#�/�/� /�ru c � � t |t � s t d� �|� t |t � st d|� d�� �| j j ||f� y)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! rW r; r& r� r( )rr r rC s ri � add_attributez!MySQLCursorAbstract.add_attribute] s] � � �$��$�"�#K�L� L� � �Z��~�%F�"��%�� D�E�� � ���+�+�T�5�M�:ru c �n � t |t � s t d� �| j 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! rW r; r� r+ r* s ri �remove_attributez$MySQLCursorAbstract.remove_attributes s1 � � �$��$�"�#K�L� L�� � �2�2�4�8�8ru c �8 � | j j � y)z<Clears the list of query attributes on the connector's side.N)r� r- r� s ri �clear_attributesz$MySQLCursorAbstract.clear_attributes� s � � ���*�*�,ru r� )r� r r� r� r� r� )rw r r� r� )rw zIterator[RowType])rw rF r� r� )rw r� r� )rw zOptional[List[WarningType]])rw zTuple[str, ...]r� r� )rw z Iterator[MySQLCursorAbstract])r~ F)r� rW r� z$Union[Sequence[Any], Dict[str, Any]]r� rb rw rx )r� rW r� z Sequence[ParamsSequenceType]rw rx )rw r� )rw z List[RowType]r� )r� rU rw zList[Sequence[Any]])rw z9AsyncGenerator[tuple[Optional[str], list[RowType]], None])rw r� )T)r� rb rw r )rw z.Optional[List[Tuple[str, BinaryProtocolType]]])r rW rC r> rw rx r� rv )*ry rz r{ r| r� r� r r� r� r� r� r� r� r� r� r� r� r# r. r- r� r� r� rv r� r r� r4 r� r� r5 r� r� r� r� r� r� r� r r r r r~ ru ri r r � s" � �-� '+�'+� !*�+�!*� $�!*� %� !*�F� 37�-1�-1� �/�� +�� +� � � �� � � "� � "� ��� %� � %�@ � #� � #� ��� &� � &�@ �!� �!�& � � � � �$� �$� � � � � �0�)�0�0�z�J�K� � L� � �#� �#� �5� �5� �5� �5� �'� �'� � � � � � 8:� !� A ��A � 5�A � � A � � A � �A �F � 8:� !� # ��# � 5�# � � # � � # � �# �J � �� � 1� � � � � � � � � � � � � � � � � �F� B�F�P �& � �& �P � � � � �0�)�0�0�{�K�L�$� M�$�+��;�, 9� -ru r c � � e Zd ZdZy)�CMySQLPrepStmtaP Structure 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)ry rz r{ r| r~ ru ri r r � s � �ru r )hr| � __future__r �mysql.connector.optionfilesr �__all__r� r rm r� �abcr r � dataclassesr r �inspectr �typesr �typingr r r r r r r r r r r r r r r r r r r r! � _decoratingr# � abstractsr$ r% r& r' r( r) r* r+ � constantsr, r- r. r/ r0 r1 r2 r3 r4 � conversionr5 r6 �errorsr7 r8 r9 r: r; � tls_ciphersr< r= r> r? r@ rA rB rC rD rE rF rG rH rI �utilsrJ rK �authenticationrM rO rN rV rP �networkrQ rR r r� r r r r r~ ru ri �<module>r s ��@ 2� "� 9� J�� � � � � #� (� � �� � � � � �. %� � � � � � � <�� � S� � � � � 2� .� '� #��8� �7�7�g� �� � %� %� � %�DF �c� F �R:W -�#� W -�t�^� ru
💾 保存文件
← 返回文件管理器