�
Z��g�� � �� � d Z ddlmZmZmZ ddlZddlZddlmZm Z ddl
m Z ddl m
Z
mZmZ ddlmZ dd lmZ ee� G d
� d e� � Z ee� G d � d
e� � Zy)z*Module gathering all abstract base classes� )�ABCMeta�abstractmethod�abstractpropertyN� )�make_abc�
BYTE_TYPES)�MySQLConverterBase)�
ClientFlag� CharacterSet�DEFAULT_CONFIGURATION)�MySQLOptionsParser)�errorsc � � e Zd ZdZd� Zd� Zd� Zed� � Zed� � Z ed� � Z
ed� � Z e d � � Z
e
j d
� � Z
ed � � Zd � Zd
� Zd� Zd� Ze d� � Zd� Zd� Zed� � Zej d� � Zed� � Zej d� � Zed� � ZdId�ZdJd�Z ed� � Z e j d � � Z ed � � Z e j d � � Z ed � � Z e j d � � Z ed!� � Z e j d"� � Z ed#� � Z!ed$� � Z"dId%�Z#ed&� � Z$ed'� � Z%ed(� � Z&d)� Z'ed*� � Z(e(Z)d+� Z*dKd,�Z+ed-� � Z,edLd.�� Z-ed/� � Z.e dMd0�� Z/ed1� � Z0ed2� � Z1 dNd3�Z2dId4�Z3d5� Z4edOd6�� Z5d7� Z6dPd8�Z7d9� Z8d:� Z9d;� Z:dQd<�Z;d=� Z<d>� Z=d?� Z>d@� Z?dA� Z@ dRdB�ZAdC� ZBdSdD�ZCdE� ZDdF� ZEdG� ZFdH� ZGy)T�MySQLConnectionAbstractz7Abstract class for classes connecting to a MySQL serverc � � t j � | _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _
d| _ d| _ d| _
d| _ d| _ d| _ i | _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _! d| _" d| _# y) �
Initialize�! NF� z 127.0.0.1i� r T)$r
� get_default�
_client_flags� _charset_id� _sql_mode�
_time_zone� _autocommit�_server_version�
_handshake�_user� _password� _database�_host�_port� _unix_socket� _client_host� _client_port�_ssl� _force_ipv6� _use_unicode�
_get_warnings�_raise_on_warnings�_connection_timeout� _buffered�_unread_result�_have_next_result�_raw�_in_transaction�_prepared_statements� _ssl_active� _auth_plugin�_pool_config_version� converter�_converter_class� _compress�_consume_results��self�kwargss �p/opt/hc_python/lib64/python3.12/site-packages/../../../lib/python3.12/site-packages/mysql/connector/abstracts.py�__init__z MySQLConnectionAbstract.__init__) s � � '� 3� 3� 5��� ��� ��� ��� ��� #�� � �����
������� ��
���
� ��� ��� ����� � ��� ��� "���"'�� �#'�� � ��� #���!&�� ��� � $�� �$(��!� ��� ���$(��!� ��� $�� � ��� %�� � c � � | S )z�Return self for weakref.proxy
This method is used when the original object is needed when using
weakref.proxy.
� �r9 s r; � _get_selfz!MySQLConnectionAbstract._get_selfS s � � � r= c � � d|v r� t |d t � r |d g|d< |d }|d= t |d t � r |d g|d< t t |d � d�� }|d= |j
|� }i }|D ]F } || j
� D ]- \ }} |dk( rd}t | ||vs|| d |d k r|||< �/ �H |j
� D ] \ }}||vs� t |d � ||< � |S # t $ r ddg}Y ��w xY w# t $ r! |du rt d
j |� � �Y ��w xY w# t $ r Y ��w xY w# t t f$ r |d ||< Y ��w xY w) z�
Read option files for connection parameters.
Checks if connection arguments contain option file arguments, and then
reads option files accordingly.
� option_files�
option_groups�client�connector_pythonF)� keep_dashes�socket� unix_socketr �Unsupported argument '{0}'r )
�
isinstance�str�KeyErrorr
�list� get_groups_as_dict_with_priority�itemsr �AttributeError�format�eval� NameError� SyntaxError) r9 �config�groups�
option_parser�config_from_file�config_options�group�option�values r; �_read_option_filesz*MySQLConnectionAbstract._read_option_files[ s� � � �V� #�
8� �f�_� 5�s�;�/5�o�/F�.G�F�?�+� ��0���?�+� �&� �0�#�6�*0� �*@�)A��~�&� .�t�F�>�4J�/K�;@� B�M��~�&� M�}� M� M�� � � �N� �� �)9�%�)@�)F�)F�)H�
���
M� %�� 1�)6�� 1�&� 9� !'�n� <�$2�6�$:�1�$=��q��$I�9>��v� 6�� *I� �( "0�!5�!5�!7�
�����'�2�)-�e�A�h� ��v�� "8� �
��M �
8�"�$6�7��
8��2 (� M� $�(:� :�&4� 6=�=C�V�F�^�'M� !M� ;�M�� � � � �� &�{�3� 2�).�q���v��2�sY �$C/ �9D/�'D�:D/�D>�/
C?�>C?�'D,�)D/�+D,�,D/�/ D;�:D;�>E�Ec � � | j S )z#User used while connecting to MySQL)r r@ s r; �userz MySQLConnectionAbstract.user� � � � �z�z�r= c � � | j S )z MySQL server IP address or name)r r@ s r; � server_hostz#MySQLConnectionAbstract.server_host� ra r= c � � | j S )zMySQL server TCP/IP port)r! r@ s r; � server_portz#MySQLConnectionAbstract.server_port� ra r= c � � | j S )z MySQL Unix socket file location)r" r@ s r; rI z#MySQLConnectionAbstract.unix_socket� s � � � � � r= c � � y)zGet the current databaseNr? r@ s r; �databasez MySQLConnectionAbstract.database� � � �
r= c �, � | j d|z � y)zSet the current databasezUSE %sN)� cmd_query�r9 r] s r; rh z MySQLConnectionAbstract.database� s � �
���x�%�'�(r= c � � | j S )z"Returns whether to consume results)r7 r@ s r; �can_consume_resultsz+MySQLConnectionAbstract.can_consume_results� s � � �$�$�$r= c �H � |j � }d|v rt j d� �| j |� |d | _ |d= |d | _ |d= t j � }| j |d xs |� |d= |d r'd| _
| j t j g� |d s!| j t j g� |d sd
| _
nd| _
d |v sd |v r0 |d }|d = |d }|d = t j ||� d | _ | j# |d � g d�}|D ] \ }} ||vr|| ||< ||= � d|v sd|v r$ |d } |d= |d }
|d= | j- | |
� t/ |d � | _ |d= d
} |j7 � D ]q \ } }
t8 | | j= d� r0d} | j> jA | jC dd� |
i� �Qd| z } tE | ||
jG � � �s | �rd| j> vrt8 d | j> d< d | j> vs| j> d � t' d � �tI d | j> v � tI d | j> v � k7 r t' d � �tK d!� tK | j> � k s d
| j> d < d
| j> d < n.| j> d d
u | j> d d
u k7 r t' d"� �| j t jL g� y
y
# t
$ r Y �� w xY w# t
$ r Y ��w xY w# t
$ r Y ���w xY w# t
$ r Y ���w xY w# t
$ r Y ���w xY w# t
$ r d
| _
Y ���w xY w# t
$ r d
}Y ���w xY w# t
$ r d
}Y ���w xY w# t
$ r Y ���t$ $ r t' d� �w xY w# t
$ r Y ���w xY w# t
$ r | j( } Y ���w xY w# t
$ r | j* }
Y ���w xY w# t
$ r Y ���t2 $ r t j4 d� �w xY w# t
$ r t' dj; | � � �w xY w# t& $ r tE | ||
� Y ���w xY w)#z�Configure the MySQL Connection
This method allows you to configure the MySQLConnection instance.
Raises on errors.
�dsnz!Data source name is not supported� get_warnings�raise_on_warnings� client_flags�compressT�allow_local_infile�consume_resultsF�charset� collationNr �converter_class�FConverter class should be a subclass of conversion.MySQLConverterBase.))�dbrh )�passwd�password)�connect_timeout�connection_timeoutr` r} �portz'TCP/IP port number should be an integerrJ �ssl_r �_� verify_cert�ssl_verify_cert�cazMissing ssl_ca argument.�key�certz;ssl_key and ssl_cert need to be both specified, or neither.)r� r� z5ssl_key and ssl_cert need to be both set, or neither.)'�copyr �NotSupportedErrorr^ rq rM rr r
r �set_client_flagsr6 �COMPRESS� LOCAL_FILESr7 r �get_charset_infor �set_converter_class� TypeErrorrQ r r � set_login�intr! �
ValueError�InterfaceErrorrP r rR �
startswithr% �update�replace�setattr�strip�bool�set�SSL)r9 r: rV �defaultrw rx �
compat_map�compat� translater` r} � set_ssl_flagr� r] � attributes r; rV z MySQLConnectionAbstract.config� sN � � ��� �� �F�?��*�*�+N�O� O�
� � ��'� � &�~� 6�D� ��~�&� �%+�,?�%@�D� "��*�+�
� �,�,�.�G� � !� !�&� �"8�"C�G� D��~�&� ��j�!�!%����%�%�z�':�':�&;�<� ��.�/��%�%�
�(>�(>�'>�&?�@� *��+�,�(-��%�(,��%�
�� �+��"7�
� ��+���9�%�
!� "�;� /� ��;�'� ,� <� <�W�=F� H�HI� K�D� � F� � $� $�V�,=�%>� ?�
�
� ",� �F�I�
� �F�*�(.�v��F�9�%��6�N� ",� �V� �z�V� 3�
"� �f�~���6�N�
*�!�*�-���:�&�
�N�N�4�� *� ;� �V�F�^�,�D�J��v�� � � �,�,�.�J�C��
O�%�c�*� �~�~�f�%� #� �� � � � �#�+�+�f�b�"9�5�!A�B� �#�I� �4��D�)�U�[�[�]�;� )� � �D�I�I�-�)�*;�<� � � �-�(� �4�9�9�$�� � �$��(?�$�.�0� 0��E�T�Y�Y�&�'�4��$�)�)�0C�+D�D�$�-�� �
� �)�S����^�;�#'�� � �%� �$(�� � �&�!��)�)�E�"�d�*�� � �&�0A�T�0I�J�$�'�� �
� !� !�:�>�>�"2� 3�- ��m � � � ��
� � � �� � � � �� � � � �� � � � �� � *�$)�D� !� *�� �
� ��
��
�
!� � �
!�� � � �� F� � "E� F�
F� F�� �
��
�� �
"��z�z��
"��
�
*� �>�>��
*�� � � �� ;��'�'�9�;�
;� ;�� �
O�$�%A�%H�%H��%M�N�N�
O�� &� 4��D�)�U�3�4�s �
L= �
M
�/M �,M- �5&M= � N
�9N$ �N6 �)O �
O+�$O; �-P �P3 �7 Q �R�= M
� M
�
M�M� M*�)M*�- M:�9M:�= N
� N
�
N!� N!�$ N3�2N3�6 O�O� O(�O(�+ O8�7O8�;P�P�P0�/P0�3 Q �? Q � $R�R!� R!c � � t |t � r|j � }t j d� }|j |� }|st
j d� �t |j � dd D �cg c]
}t |� �� c}� }d|j d� j � v r+|dk r$t
j dj |� � �|S |d k r$t
j d
j |� � �|S c c}w ) a7 Check the MySQL version
This method will check the MySQL version and raise an InterfaceError
when it is not supported or invalid. It will return the version
as a tuple with major, minor and patch.
Raises InterfaceError if invalid server version.
Returns tuple
z$^(\d{1,2})\.(\d{1,2})\.(\d{1,3})(.*)z Failed parsing MySQL versionr � �fabric� )r � z#MySQL Fabric '{0}' is not supported)r� r z%MySQL Version '{0}' is not supported.)rK r �decode�re�compile�matchr r� �tuplerW r� r[ �lowerrR )r9 �server_version� regex_verr� �v�versions r; �_check_server_versionz-MySQLConnectionAbstract._check_server_versionS s � � �n�j� 1� +� 2� 2� 4�N� �J�J� F�G� �����/����'�'�(F�G� G��� � � ��!�)<�=�)<�A��Q��)<�=�>�� �u�{�{�1�~�+�+�-� -��� � �+�+�9�@�@�&�(�)� )� �� �v�
��'�'�7�>�>�~�N�P�
P� ��� >s �8Dc � � | j S )z�Get the MySQL version
This method returns the MySQL server version as a tuple. If not
previously connected, it will return None.
Returns a tuple or None.
)r r@ s r; �get_server_versionz*MySQLConnectionAbstract.get_server_versiont s � � �#�#�#r= c �L � | j d S # t t f$ r Y yw xY w)z�Get the original MySQL version information
This method returns the original MySQL server as text. If not
previously connected, it will return None.
Returns a string or None.
�server_version_originalN)r r� rM r@ s r; �get_server_infoz'MySQLConnectionAbstract.get_server_info~ s. � � ��?�?�#<�=� =���8�$� �� �s � �#�#c � � y)z'MySQL session has started a transactionNr? r@ s r; �in_transactionz&MySQLConnectionAbstract.in_transaction� ri r= c �B � t |t � r|dkD r|| _ | j S t |t t f� rM|D ]< }|dk r | xj t |� z c_ �(| xj |z c_ �> | j S t
j d� �)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.
Returns self.client_flags
r z+set_client_flags expect integer (>0) or set)rK r� r r� rN �absr �ProgrammingError)r9 �flags�flags r; r� z(MySQLConnectionAbstract.set_client_flags� s� � � �e�S� !�e�a�i�!&�D� � �!�!�!� ���t�}�
-� ���!�8��&�&�3�t�9�*�4�&��&�&�$�.�&� � �!�!�!� �)�)�=�?�
?r= c �* � | j |z dkD ryy)z Check if a client flag is setr TF)r )r9 r� s r; �isset_client_flagz)MySQLConnectionAbstract.isset_client_flag� s � � � � �� %�� *��r= c �* � | j d� d S )zGet the current time zonezSELECT @@session.time_zoner ��
info_queryr@ s r; � time_zonez!MySQLConnectionAbstract.time_zone� s � � ��� ;�<�Q�?�?r= c �R � | j dj |� � || _ y)zSet the time zonez SET @@session.time_zone = '{0}'N)rk rR r rl s r; r� z!MySQLConnectionAbstract.time_zone� s# � �
���8�?�?��F�G� ��r= c �* � | j d� d S )zGet the SQL modezSELECT @@session.sql_moder r� r@ s r; �sql_modez MySQLConnectionAbstract.sql_mode� s � � ��� :�;�A�>�>r= c � � t |t t f� rdj |� }| j dj |� � || _ y)a� Set 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]
�,z SET @@session.sql_mode = '{0}'N)rK rN r� �joinrk rR r rl s r; r� z MySQLConnectionAbstract.sql_mode� s> � � �e�d�E�]� +��H�H�U�O�E� ���7�>�>�u�E�F� ��r= c � � y)z%Send a query which only returns 1 rowNr? �r9 �querys r; r� z"MySQLConnectionAbstract.info_query� ri r= Nc �d � |�|j � | _ nd| _ |�|| _ yd| _ y)z�Set login information for MySQL
Set the username and/or password for the user connecting to
the MySQL Server.
Nr )r� r r )r9 �usernamer} s r; r� z!MySQLConnectionAbstract.set_login� s3 � � � �!� � �)�D�J��D�J� � � %�D�N� �D�Nr= c �b � || _ | j r | j j |� yy)zuToggle unicode mode
Set whether we return string fields as unicode or not.
Default is True.
N)r' r4 � set_unicoderl s r; r� z#MySQLConnectionAbstract.set_unicode� s* � � "��� �>�>� �N�N� &� &�u� -� r= c �< � | j d� d }|dk( rdS dS )z#Get whether autocommit is on or offzSELECT @@session.autocommitr r TFr� rl s r; �
autocommitz"MySQLConnectionAbstract.autocommit� s) � � ��� =�>�q�A�� ��z�t�,�u�,r= c �^ � |rdnd}| j dj |� � || _ y)zToggle autocommit�ON�OFFz SET @@session.autocommit = {0}N)rk rR r )r9 r] �switchs r; r� z"MySQLConnectionAbstract.autocommit� s- � � ��E�� ���7�>�>�v�F�G� ��r= c � � | j S )z�Get whether this connection retrieves warnings automatically
This method returns whether this connection retrieves warnings
automatically.
Returns True, or False when warnings are not retrieved.
)r( r@ s r; rq z$MySQLConnectionAbstract.get_warnings� s � � �!�!�!r= c �H � t |t � s t d� �|| _ y)z�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 on error.
�Expected a boolean typeN)rK r� r� r( rl s r; rq z$MySQLConnectionAbstract.get_warnings
s" � � �%��&� � 6�7� 7� "��r= 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.
Returns True or False.
)r) r@ s r; rr z)MySQLConnectionAbstract.raise_on_warnings s � � �&�&�&r= c �V � t |t � s t d� �|| _ || _ y)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 on error.
r� N)rK r� r� r) r( rl s r; rr z)MySQLConnectionAbstract.raise_on_warnings" s* � � �%��&� � 6�7� 7�"'�� � "��r= 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.
Returns True, or False when there is no unread result.
)r, r@ s r; �
unread_resultz%MySQLConnectionAbstract.unread_result5 s � � �"�"�"r= 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 on errors.
r� N)rK r� r� r, rl s r; r� z%MySQLConnectionAbstract.unread_result@ s" � � �%��&� � 6�7� 7� #��r= c �F � t j | j � d S )a+ Returns 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.
Returns a string.
r �r �get_infor r@ s r; rw z MySQLConnectionAbstract.charsetM s � � �$�$�T�%5�%5�6�q�9�9r= c �T � t j | j � d }|dv ry|S )ay Returns 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.
Returns a string.
r )�utf8mb4�binary�utf8r� )r9 �encodings r; �python_charsetz&MySQLConnectionAbstract.python_charsetY s0 � � �(�(��)9�)9�:�1�=�� �,� ,���Or= c � � |rqt |t � r&|| _ t j |� \ | _ }}n\t |t
� r t j ||� \ | _ }}n,t
d� �|r t j |�� \ | _ }}| j dj � � | j |� | j r | j j |� yy# t $ r Y �4w xY w)aV Sets 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.
For example, the following will set the collation for the latin1
character set to latin1_general_ci:
set_charset('latin1','latin1_general_ci')
z0charset should be either integer, string or None)rx z SET NAMES '{0}' COLLATE '{1}'N)
rK r� r r r� rL r� �_execute_queryrR �set_character_set_namerQ r4 � set_charset)r9 rw rx � charset_name�collation_names r; �set_charset_collationz-MySQLConnectionAbstract.set_charset_collationj s� � �" ��'�3�'�#*�� � �1�1�'�:� A��!�<� ��G�S�)� �1�1�'�9�E� A��!�<� � !�F�H� H�
� �1�1�I�F�
=�T�
�|�^�
��� ;� B� B� �.� *� +� � � '� '� � 5�
�>�>� �N�N� &� &�|� 4� �� � � � �s �7C1 �1 C=�<C=c �F � t j | j � d 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.
� )r r� r r@ s r; rx z!MySQLConnectionAbstract.collation� s � � �,�,�T�-=�-=�>�q�A�Ar= c � � y)z<Gather information of the MySQL server before authenticationNr? r@ s r; �
_do_handshakez%MySQLConnectionAbstract._do_handshake� ri r= c � � y)z'Open the connection to the MySQL serverNr? r@ s r; �_open_connectionz(MySQLConnectionAbstract._open_connection� ri r= c �� � | j | j � | j | _ | j r| j | _ | j r| j | _ yy)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)r� r r r� r r� r r� r@ s r; �_post_connectionz(MySQLConnectionAbstract._post_connection� sN � �
�"�"�4�#3�#3�4� �*�*��� �?�?� !�_�_�D�N� �>�>� �N�N�D�M� r= c � � y)z Disconnect from the MySQL serverNr? r@ s r; �
disconnectz"MySQLConnectionAbstract.disconnect� ri r= c � � t |� dkD r | j di |�� | j � | j � | j � y)z�Connect to the MySQL server
This method sets up the connection to the MySQL server. If no
arguments are given, it will use the already configured or default
values.
r Nr? )�lenrV r� r� r� r8 s r; �connectz MySQLConnectionAbstract.connect� sB � � �v�;��?� �D�K�K� !�&� !� ���� � � � � � � � r= c �Z � d}||k7 rY|dz } | j � | j � | j � ry |dkD rt j |� ||k7 r�Xyy# t $ r?}||k( r0dj |t |� � }t
j |� �Y d}~�ed}~ww xY w)a� Attempt 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.
Raises InterfaceError on errors.
r r z4Can not reconnect to MySQL after {0} attempt(s): {1}N)
r� r� � is_connected� ExceptionrR rL r r� �time�sleep)r9 �attempts�delay�counter�err�msgs r; � reconnectz!MySQLConnectionAbstract.reconnect� s� � � ����!� ��k�G�
5����!�� � ���$�$�&�� '� �q�y��
�
�5�!� ��!�� �
5��h�&�,�,2�F�8�S��X�,F� � �/�/��4�4� '��
5�s �0A" �" B*�+5B%�%B*c � � y)z;Reports whether the connection to MySQL Server is availableNr? r@ s r; r� z$MySQLConnectionAbstract.is_connected� ri r= c � � y)z&Check availability of the MySQL serverNr? )r9 r r r s r; �pingz MySQLConnectionAbstract.ping� ri r= c � � y)zCommit current transactionNr? r@ s r; �commitz MySQLConnectionAbstract.commit� ri r= c � � y)z!Instantiates and returns a cursorNr? )r9 �buffered�raw�prepared� cursor_class�
dictionary� named_tuples r; �cursorz MySQLConnectionAbstract.cursor� s � �
r= c � � y)zExecute a queryNr? r� s r; r� z&MySQLConnectionAbstract._execute_query ri r= c � � y)z Rollback current transactionNr? r@ s r; �rollbackz MySQLConnectionAbstract.rollback ri r= c � � | j rt j d� �|rp|j � j dd� j � }g d�}||vrt
dj |� � �| j dj |� � |�Z| j dk r$t
d j | j � � �|rd
}nd }| j d j |� � d
}|r|dz
}| j |� y)a� Start 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.
For example, to start a transaction with isolation level SERIALIZABLE,
you would do the following:
>>> cnx = mysql.connector.connect(..)
>>> cnx.start_transaction(isolation_level='SERIALIZABLE')
Raises ProgrammingError when a transaction is already in progress
and when ValueError when isolation_level specifies an Unknown
level.
z Transaction already in progress�-� )zREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READ� SERIALIZABLEz Unknown isolation level "{0}"z#SET TRANSACTION ISOLATION LEVEL {0}N)r� � r� z6MySQL server version {0} does not support this featurez READ ONLYz
READ WRITEzSET TRANSACTION {0}zSTART TRANSACTIONz WITH CONSISTENT SNAPSHOT) r� r r� r� r� �upperr� rR r� r rk )r9 �consistent_snapshot�isolation_level�readonly�level�levels� access_moder� s r; �start_transactionz)MySQLConnectionAbstract.start_transaction s � �& � � ��)�)�*K�L� L� �#�)�)�+�3�3�C��=�C�C�E�E�&�F� �F�"� �3�:�:�?�K�M� M�
� � �5�<�<�U�C�
E� � ��#�#�i�/� �#�#)�6�$�*>�*>�#?�A� A� � )� � *� � � � �%�,�,�[�9�
;� $�� � �0� 0�E� ���u� r= c � � | j � st j d� � | j � |s|r�| j � }|r:|j � D ]' \ }}|j dj |� |f� �) |r:|j � D ]' \ }}|j dj |� |f� �) |j! � yy# t j t
f$ ra | j rt j d� �| j | j | j | j | j � Y ��w xY 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.
This method takes two arguments user_variables and session_variables
which are dictionaries.
Raises OperationalError if not connected, InternalError if there are
unread results and InterfaceError on errors.
z MySQL Connection not available.zZReset session is not supported with compression for MySQL server version 5.7.2 or earlier.zSET @`{0}` = %szSET SESSION `{0}` = %sN)r� r �OperationalError�cmd_reset_connectionr� �NotImplementedErrorr6 �cmd_change_userr r r r r rP �executerR �close)r9 �user_variables�session_variables�curr� r] s r; �
reset_sessionz%MySQLConnectionAbstract.reset_session? s+ � � � � �"��)�)�*K�L� L� G� � %� %� '� � .��+�+�-�C� �"0�"6�"6�"8�J�C���K�K� 1� 8� 8�� =��x�H� #9� �"3�"9�"9�";�J�C���K�K� 8� ?� ?�� D�u�h�O� #<� �I�I�K� /�� �(�(�*=�>� G��~�~� �.�.�=�>� >� �$�$�T�Z�Z�� � �%)�^�^�T�5E�5E�G�
G�s �C �A6E�Ec � � |rRt |t � rBt j | j � d }|| _ ||| j � | _ yt d� �)z�
Set the converter class to be used. This should be a class overloading
methods and members of conversion.MySQLConverter.
r rz N) �
issubclassr r r� r r5 r' r4 r� )r9 � convclassr� s r; r� z+MySQLConnectionAbstract.set_converter_classg s] � �
��I�/A�B�'�0�0��1A�1A�B�1�E�L�$-�D� !� &�|�T�5F�5F� G�D�N�� @� A�
Ar= c � � y)z)Get all rows returned by the MySQL serverNr? )r9 �countr� �columnss r; �get_rowsz MySQLConnectionAbstract.get_rowst ri r= c � � t �)zChange the current database�r' )r9 rh s r; � cmd_init_dbz#MySQLConnectionAbstract.cmd_init_dby � � �!�!r= c � � t �)z Send a query to the MySQL serverr7 )r9 r� r r
�
raw_as_strings r; rk z!MySQLConnectionAbstract.cmd_query} r9 r= c � � t �)z/Send one or more statements to the MySQL serverr7 )r9 �
statementss r; �cmd_query_iterz&MySQLConnectionAbstract.cmd_query_iter� r9 r= c � � t �)z,Send the Refresh command to the MySQL serverr7 )r9 �optionss r; � cmd_refreshz#MySQLConnectionAbstract.cmd_refresh� r9 r= c � � t �)z,Close the current connection with the serverr7 r@ s r; �cmd_quitz MySQLConnectionAbstract.cmd_quit� r9 r= c � � t �)zShut down the MySQL Serverr7 )r9 �
shutdown_types r; � cmd_shutdownz$MySQLConnectionAbstract.cmd_shutdown� r9 r= c � � t �)z/Send the statistics command to the MySQL Serverr7 r@ s r; �cmd_statisticsz&MySQLConnectionAbstract.cmd_statistics� r9 r= c �, � t j d� �)ak Get the process list of the MySQL Server
This method is a placeholder to notify that the PROCESS_INFO command
is not supported by raising the NotSupportedError. The command
"SHOW PROCESSLIST" should be send using the cmd_query()-method or
using the INFORMATION_SCHEMA database.
Raises NotSupportedError exception
z;Not implemented. Use SHOW PROCESSLIST or INFORMATION_SCHEMA)r r� r@ s r; �cmd_process_infoz(MySQLConnectionAbstract.cmd_process_info� s � � �&�&� I�K� Kr= c � � t �)zKill a MySQL processr7 )r9 � mysql_pids r; �cmd_process_killz(MySQLConnectionAbstract.cmd_process_kill� r9 r= c � � t �)zSend the DEBUG commandr7 r@ s r; � cmd_debugz!MySQLConnectionAbstract.cmd_debug� r9 r= c � � t �)zSend the PING commandr7 r@ s r; �cmd_pingz MySQLConnectionAbstract.cmd_ping� r9 r= c � � t �)z!Change the current logged in userr7 )r9 r� r} rh rw s r; r( z'MySQLConnectionAbstract.cmd_change_user� s
� � "�!r= c � � t �)zPrepare a MySQL statementr7 )r9 � statements r; �cmd_stmt_preparez(MySQLConnectionAbstract.cmd_stmt_prepare� r9 r= c � � t �)z"Execute a prepared MySQL statementr7 )r9 � statement_id�data�
parametersr� s r; �cmd_stmt_executez(MySQLConnectionAbstract.cmd_stmt_execute� r9 r= c � � t �)z%Deallocate a prepared MySQL statementr7 �r9 rW s r; �cmd_stmt_closez&MySQLConnectionAbstract.cmd_stmt_close� r9 r= c � � t �)zSend data for a columnr7 )r9 rW �param_idrX s r; �cmd_stmt_send_long_dataz/MySQLConnectionAbstract.cmd_stmt_send_long_data� r9 r= c � � t �)z3Reset data for prepared statement sent as long datar7 r\ s r; �cmd_stmt_resetz&MySQLConnectionAbstract.cmd_stmt_reset� r9 r= c � � t �)z2Resets the session state without re-authenticatingr7 r@ s r; r& z,MySQLConnectionAbstract.cmd_reset_connection� r9 r= )NN�T)r r )Fr r )NNNNNN)FNN)NFN)FFF�N)r r r r )r? r? r )H�__name__�
__module__� __qualname__�__doc__r< rA r^ �propertyr` rc re rI r rh �setterrn rV r� r� r� r� r� r� r� r� r r� r� r� r� rq rr r� rw r� r� rx r� r� r� r� r* r� r r� r r r r� r r# r. r� r5 r8 rk r> rA rC rF rH rJ rM rO rQ r( rU rZ r] r` rb r& r? r= r; r r $ s� � � B�(&�T�3�j �� �� �� �� �� �� �!� �!� �
� �
� �_�_�)� �)� �%� �%�^4�@ �B$� � �
� �
�"�:� �@� �@� ��� � � �
�?� �?� �_�_� � � � �
� �
�
� .� �-� �-�
���!� �!� �"� �"� ���
#� �
#� �'� �'� � � �#� �#�$ �#� �#� ���
$� �
$� � :� � :� � � � � +5�Z � B� � B� �
� �
� �
� �
� +� �
� �
�
�E� � "�: �
� �
� �
� �
� �
� �
� �JN�,0�
� �
�
�
� �
� �
� �
� 5:�9=�2 �h&�P A� �
� �
�"�"�"�"�"�"�"� K�"�"�"� BD� "�"�
"�"�"�"�"�"r= r c �� � e Zd ZdZd� Zedd�� Zed� � Zedd�� Zed� � Z ed� � Z
edd�� Z ed � � Z d
� Z
d � Zdd
�Zdd�Zed� � Zed� � Zed� � Zd� Zy )�MySQLCursorAbstractz�Abstract cursor class
Abstract class defining cursor class with method and members
required by the Python Database API Specification v2.0.
c �J � d| _ d| _ d| _ d| _ d| _ y)�InitializationN���r )� _description� _rowcount�_last_insert_id� _warnings� arraysizer@ s r; r< z MySQLCursorAbstract.__init__� s' � � ������ #�� � �����r= c � � y)a Calls a stored procedure with the given arguments
The arguments will be set during this session, meaning
they will be called like _<procname>__arg<nr> where
<nr> is an enumeration (+1) of the arguments.
Coding Example:
1) Defining the Stored Routine in MySQL:
CREATE PROCEDURE multiply(IN pFac1 INT, IN pFac2 INT, OUT pProd INT)
BEGIN
SET pProd := pFac1 * pFac2;
END
2) Executing in Python:
args = (5,5,0) # 0 is to hold pprod
cursor.callproc('multiply', args)
print(cursor.fetchone())
Does not return a value, but a result set will be
available when the CALL-statement execute successfully.
Raises exceptions when something is wrong.
Nr? )r9 �procname�argss r; �callprocz MySQLCursorAbstract.callproc� s � �0
r= c � � y)zClose the cursor.Nr? r@ s r; r* zMySQLCursorAbstract.close� ri r= c � � y)a� Executes the given operation
Executes the given operation 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,))
The multi argument should be set to True when executing multiple
statements in one operation. If not set and multiple results are
found, an InterfaceError will be raised.
If warnings where generated, and connection.get_warnings is True, then
self._warnings will be a list containing these warnings.
Returns an iterator when multi is True, otherwise None.
Nr? )r9 � operation�params�multis r; r) zMySQLCursorAbstract.execute� s � �&
r= c � � y)a� Execute the given operation multiple times
The executemany() method will execute the operation iterating
over the list of parameters in seq_params.
Example: Inserting 3 new employees and their phone number
data = [
('Jane','555-001'),
('Joe', '555-001'),
('John', '555-003')
]
stmt = "INSERT INTO employees (name, phone) VALUES ('%s','%s')"
cursor.executemany(stmt, data)
INSERT statements are optimized by batching the data, that is
using the MySQL multiple rows syntax.
Results are discarded. If they are needed, consider looping over
data using the execute() method.
Nr? )r9 r| � seqparamss r; � executemanyz MySQLCursorAbstract.executemany s � �.
r= c � � y)zQReturns next row of a query result set
Returns a tuple or None.
Nr? r@ s r; �fetchonez MySQLCursorAbstract.fetchone( � � �
r= c � � y)a Returns the next set of rows of a query result, returning a
list of tuples. 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
Nr? )r9 �sizes r; � fetchmanyz MySQLCursorAbstract.fetchmany0 s � �
r= c � � y)zRReturns all rows of a query result set
Returns a list of tuples.
Nr? r@ s r; �fetchallz MySQLCursorAbstract.fetchall; r� r= c � � y�zNot Implemented.Nr? r@ s r; �nextsetzMySQLCursorAbstract.nextsetC � � � r= c � � yr� r? )r9 �sizess r; �
setinputsizesz!MySQLCursorAbstract.setinputsizesG r� r= Nc � � yr� r? )r9 r� �columns r; �
setoutputsizez!MySQLCursorAbstract.setoutputsizeK r� r= c � � y)zReset the cursor to defaultNr? )r9 �frees r; �resetzMySQLCursorAbstract.resetO r� r= c � � | j S )a� Returns 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.
)rq r@ s r; � descriptionz MySQLCursorAbstract.descriptionS s � �$ � � � r= c � � | j S )a Returns 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.
Returns an integer.
)rr r@ s r; �rowcountz MySQLCursorAbstract.rowcountg s � � �~�~� r= c � � | j S )a Returns 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.
Returns a long value or None.
)rs r@ s r; � lastrowidz MySQLCursorAbstract.lastrowidx s � � �#�#�#r= c � � | j S )zReturns Warnings.)rt r@ s r; �
fetchwarningsz!MySQLCursorAbstract.fetchwarnings� s � ��~�~� r= )r? )r? F)r re rd )rf rg rh ri r< r ry r* r) r� r� r� r� r� r� r� r� r r� r� r� r� r? r= r; rm rm � s� � ��
� �
� �
�2 �
� �
� �
� �
�( �
� �
�0 �
� �
� �
� �
� �
� �
�
�
�
�
� �!� �!�& � � � � � $� � $� r= rm )ri �abcr r r r� r� �catch23r r �
conversionr � constantsr
r r � optionfilesr
r r �objectr rm r? r= r; �<module>r� sm ��0 1� 9� 9� � � )� *� F� F� +� � �'��d"�f� d"� �d"�N
�'��y �&� y � �y r=