opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
mysql
/
connector
/
__pycache__
/
Go to Home Directory
+
Upload
Create File
root@0UT1S:~$
Execute
By Order of Mr.0UT1S
[DIR] ..
N/A
__init__.cpython-312.pyc
6.22 KB
Rename
Delete
abstracts.cpython-312.pyc
45.93 KB
Rename
Delete
authentication.cpython-312.pyc
6.95 KB
Rename
Delete
catch23.cpython-312.pyc
3.32 KB
Rename
Delete
charsets.cpython-312.pyc
5.95 KB
Rename
Delete
connection.cpython-312.pyc
46.72 KB
Rename
Delete
connection_cext.cpython-312.pyc
26.63 KB
Rename
Delete
constants.cpython-312.pyc
24.67 KB
Rename
Delete
conversion.cpython-312.pyc
23.33 KB
Rename
Delete
cursor.cpython-312.pyc
55.98 KB
Rename
Delete
cursor_cext.cpython-312.pyc
34.61 KB
Rename
Delete
custom_types.cpython-312.pyc
1.35 KB
Rename
Delete
dbapi.cpython-312.pyc
2.41 KB
Rename
Delete
errorcode.cpython-312.pyc
50.41 KB
Rename
Delete
errors.cpython-312.pyc
9.64 KB
Rename
Delete
network.cpython-312.pyc
21.66 KB
Rename
Delete
optionfiles.cpython-312.pyc
13.54 KB
Rename
Delete
pooling.cpython-312.pyc
13.97 KB
Rename
Delete
protocol.cpython-312.pyc
30.85 KB
Rename
Delete
utils.cpython-312.pyc
10.06 KB
Rename
Delete
version.cpython-312.pyc
700 bytes
Rename
Delete
� ��g]0 � �� � d Z ddlZddlmZ ddlZddlZddlm Z ddl m Z ej � Z dZdZ ej d � Zd � Z G d � d e� Z G d � de� Zy# e$ r ddlZY �\w xY w)z6Implementing pooling of connections to MySQL servers. � N)�uuid4� )�errors)�MySQLConnection� �@ z[^a-zA-Z0-9._:\-*$#]c � � g }dD ] } |j t | | � � �" |st j d� �dj |� S # t $ r Y �Vw xY w)z�Generate a pool name This function takes keyword arguments, usually the connection arguments for MySQLConnection, and tries to generate a name for a pool. Raises PoolError when no name can be generated. Returns a string. )�host�port�user�databasez.Failed generating pool name; specify pool_name�_)�append�str�KeyErrorr � PoolError�join)�kwargs�parts�keys �n/opt/hc_python/lib64/python3.12/site-packages/../../../lib/python3.12/site-packages/mysql/connector/pooling.py�generate_pool_namer / sl � � �E�3�� � �L�L��V�C�[�)� *� 4� �� � � <�>� >� �8�8�E�?��� � � � �s � A� A �A c �8 � e Zd ZdZd� Zd� Zd� Zd� Zed� � Z y)�PooledMySQLConnectiona Class holding a MySQL Connection in a pool PooledMySQLConnection is used by MySQLConnectionPool to return an instance holding a MySQL connection. It works like a MySQLConnection except for methods like close() and config(). The close()-method will add the connection back to the pool rather than disconnecting from the MySQL server. Configuring the connection have to be done through the MySQLConnectionPool method set_config(). Using config() on pooled connection will raise a PoolError. c � � t |t � s t d� �t |t � s t d� �|| _ || _ y)z�Initialize The pool argument must be an instance of MySQLConnectionPoll. cnx if an instance of MySQLConnection. z$pool should be a MySQLConnectionPoolz cnx should be a MySQLConnectionN)� isinstance�MySQLConnectionPool�AttributeErrorr � _cnx_pool�_cnx)�self�pool�cnxs r �__init__z PooledMySQLConnection.__init__V sG � � �$� 3�4� �6�8� 8��#��/� �1�3� 3� ����� � c �. � t | j |� S )z0Calls attributes of the MySQLConnection instance)�getattrr )r! �attrs r � __getattr__z!PooledMySQLConnection.__getattr__e s � ��t�y�y�$�'�'r% c � � | j }| j j r|j � | j j |� d| _ y)aY Do not close, but add connection back to pool The close() method does not close the connection with the MySQL server. The connection is added back to the pool so it can be reused. When the pool is configured to reset the session, the session state will be cleared by re-authenticating the user. N)r r � reset_session�add_connection�r! r# s r �closezPooledMySQLConnection.closei s? � � �i�i�� �>�>� '� '� � � � � ���%�%�c�*��� r% c �, � t j d� �)z&Configuration is done through the poolzLConfiguration for pooled connections should be done through the pool itself.)r r )r! r s r �configz PooledMySQLConnection.configz s � �� � � /� � r% c �. � | j j S �z&Return the name of the connection pool)r � pool_name�r! s r r3 z PooledMySQLConnection.pool_name� s � � �~�~�'�'�'r% N) �__name__� __module__� __qualname__�__doc__r$ r) r. r0 �propertyr3 � r% r r r H s/ � � � � (��" � �(� �(r% r c �t � e Zd ZdZdd�Zed� � Zed� � Zed� � Zd� Z d� Z d � Z d � Z dd �Z d � Zd � Zy)r z*Class defining a pool of MySQL connectionsNc � � d| _ d| _ || _ | j |� | j |xs t di |��� i | _ t j | j � | _ t � | _ |rJ | j di |�� d}|| j k r&| j � |dz }|| j k r�%yyy)z�Initialize Initialize a MySQL connection pool with a maximum number of connections set to pool_size. The rest of the keywords arguments, kwargs, are configuration arguments for MySQLConnection instances. Nr r r: )� _pool_size� _pool_name�_reset_session�_set_pool_size�_set_pool_namer � _cnx_config�queue�Queue� _cnx_queuer �_config_version� set_configr, )r! � pool_sizer3 �pool_reset_sessionr �cnts r r$ z MySQLConnectionPool.__init__� s� � � ��� ��� 0��� ���I�&� ���I� E�);�)E�f�)E�F� ��� �+�+�d�o�o�6��� $�w�� � � �D�O�O� %�f� %��C�����'��#�#�%��q��� ����'� r% c � � | j S r2 )r> r4 s r r3 z MySQLConnectionPool.pool_name� � � � ��� r% c � � | j S )z0Return number of connections managed by the pool)r= r4 s r rH z MySQLConnectionPool.pool_size� rL r% c � � | j S )z Return whether to reset session)r? r4 s r r+ z!MySQLConnectionPool.reset_session� s � � �"�"�"r% c � � |syt 5 t � } |j di |�� || _ t � | _ ddd� y# t $ r)}t j dj |� � �d}~ww xY w# 1 sw Y yxY w)aT Set the connection configuration for MySQLConnection instances This method sets the configuration used for creating MySQLConnection instances. See MySQLConnection for valid connection arguments. Raises PoolError when a connection argument is not valid, missing or not supported by MySQLConnection. Nz'Connection configuration not valid: {0}r: ) �CONNECTION_POOL_LOCKr r0 rB r rF r r r �format)r! r �test_cnx�errs r rG z MySQLConnectionPool.set_config� s� � � � � !� K�*�,�� ����)�&�)�#)�� �',�w��$� "� !�� "� K� �&�&�=�D�D�S�I�K� K�� K�� "� !�s( �A=�2A� A:�$A5�5A:�:A=�=Bc �j � |dk s |t kD r t dj t � � �|| _ y)a Set the size of the pool This method sets the size of the pool but it will not resize the pool. Raises an AttributeError when the pool_size is not valid. Invalid size is 0, negative or higher than pooling.CNX_POOL_MAXSIZE. r z;Pool size should be higher than 0 and lower or equal to {0}N)�CNX_POOL_MAXSIZEr rQ r= )r! rH s r r@ z"MySQLConnectionPool._set_pool_size� s; � � ��>�Y�)9� 9� �(�(.��/?�(@�B� B� $��r% c �� � t j |� rt dj |� � �t |� t kD rt dj |� � �|| _ y)a Set the name of the pool This method checks the validity and sets the name of the pool. Raises an AttributeError when pool_name contains illegal characters ([^a-zA-Z0-9._\-*$#]) or is longer than pooling.CNX_POOL_MAXNAMESIZE. z+Pool name '{0}' contains illegal characterszPool name '{0}' is too longN)�CNX_POOL_NAMEREGEX�searchr rQ �len�CNX_POOL_MAXNAMESIZEr> )r! r3 s r rA z"MySQLConnectionPool._set_pool_name� s` � � � $� $�Y� /� �=�D�D�Y�O�Q� Q� �y�>� 0� 0� �-�4�4�Y�?�A� A�#��r% c �� � t |t � st j d� � | j j |d�� y# t j $ r t j d� Y yw xY w)z�Put connection back in the queue This method is putting a connection back in the queue. It will not acquire a lock as the methods using _queue_connection() will have it set. Raises PoolError on errors. �4Connection instance not subclass of MySQLConnection.F��block�'Failed adding connection; queue is fullN)r r r r rE �putrC �Fullr- s r �_queue_connectionz%MySQLConnectionPool._queue_connection� sg � � �#��/��"�"�F�H� H� H� �O�O� � ��5� � 1���z�z� H� � � � F� G� H�s � A �(A0�/A0c �> � t 5 | j st j d� �| j j � rt j d� �|skt di | j ��} | j r7| j d r(|j � dk rt j d� �| j |_ n%t |t � st j d� �| j |� ddd� y# t $ r Y �\w xY w# 1 sw Y yxY w) a� Add a connection to the pool This method instantiates a MySQLConnection using the configuration passed when initializing the MySQLConnectionPool instance or using the set_config() method. If cnx is a MySQLConnection instance, it will be added to the queue. Raises PoolError when no configuration is set, when no more connection can be added (maximum reached) or when the connection can not be instantiated. z&Connection configuration not availabler_ �compress)� � � z_Pool reset session is not supported with compression for MySQL server version 5.7.2 or earlier.r\ Nr: )rP rB r r rE �fullr r? �get_server_version�NotSupportedErrorr rF �_pool_config_versionr rb r- s r r, z"MySQLConnectionPool.add_connection� s � � "��#�#� �&�&�<�>� >� ���#�#�%� �&�&�=�?� ?� �%�9��(8�(8�9�� � �+�+��0@�0@��0L� #� 6� 6� 8�9� D� $� 6� 6� 8E� F� F� ,0�+?�+?��(� "�#��7� �*�*�N�P� P� � "� "�3� '�= "� !��& � ����' "� !�s2 �A(D�0AD�3AD� D� D�D�D�D c � � t 5 | j j d�� }|j � r| j |j k7 r> |j di | j �� |j � | j |_ t | |� cddd� S # t j $ r t j d� �w xY w# t j $ r | j |� � w xY w# 1 sw Y yxY w)aw Get a connection from the pool This method returns an PooledMySQLConnection instance which has a reference to the pool that created it, and the next available MySQL connection. When the MySQL connection is not connect, a reconnect is attempted. Raises PoolError on errors. Returns a PooledMySQLConnection instance. Fr] z)Failed getting connection; pool exhaustedNr: )rP rE �getrC �Emptyr r � is_connectedrF rk r0 rB � reconnect�InterfaceErrorrb r r- s r �get_connectionz"MySQLConnectionPool.get_connection$ s� � � "� A��o�o�)�)��)�6�� �#�#�%��+�+�s�/G�/G�G��� � �.�T� -� -�.���M�M�O� ,0�+?�+?��(� )��s�3�) "� !�� �;�;� A� �&�&�?�A� A� A�� �,�,� ��*�*�3�/���� "� !�s: �C6� B!�AC6�+C �; C6�!)C � C6� &C3�3C6�6C?c � � t 5 d}| j }|j � r9 |j d�� }|j � |dz }|j � r�9|cddd� S # t j $ r |cY cddd� S t j $ r � t j $ r Y �cw xY w# 1 sw Y yxY w)z�Close all connections This method closes all connections. It returns the number of connections it closed. Used mostly for tests. Returns int. r Fr] r N) rP rE �qsizerm � disconnectrC rn r r �Error)r! rJ �cnxqr# s r �_remove_connectionsz'MySQLConnectionPool._remove_connectionsG s� � � "��C��?�?�D��*�*�,� � �(�(��(�/�C��N�N�$��1�H�C� �*�*�,� �! "� !�� �{�{� � �J� "� !� �'�'� �� �|�|� ���� "� !�s@ � B5�'A*�B5� B5�*B2�?B5� %B2�/B5�1B2�2B5�5B>)re NT)N)r5 r6 r7 r8 r$ r9 r3 rH r+ rG r@ rA rb r, rr rx r: r% r r r � sm � �4��2 � � � � � � � � �#� �#�K�, $� $� H�$+(�Z!4�Fr% r )r8 �re�uuidr rC � ImportErrorrD � threading� r � connectionr �RLockrP rU rZ �compilerW r �objectr r r: r% r �<module>r� s� ��0� � ��� � � '�&�y���(� �� �� � �R�Z�Z� 7�8� ��2<(�F� <(�~Z�&� Z��O � ���s �A# �# A/�.A/
Save