| Server IP : 198.38.94.13 / Your IP : 216.73.217.33 Web Server : Apache System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : revivere ( 1140) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/pymysql/__pycache__/ |
Upload File : |
a
ۖX_r� � @ sP d dl mZ ddlmZmZmZmZmZmZ d dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZddlmZ ddlmZmZ ddlmZmZmZmZmZ ddlm Z dd l m Z dd
l m Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' dd l(m)Z)m*Z* dd
lm+Z+m,Z, zd dl-Z-dZ.W n e/�y4 dZ-dZ.Y n0 zd dl0Z0e0�1� Z2[0W n e/e3f�yh dZ2Y n0 dZ4ej5dd� Z6e�r�n.e6dk �r�dd� e7d�D �Z8dd� Z9ndd� Z9e�r�e�s�ddl:m;Z; dd� Z<ndd� Z<ej=ej>ej?ej@ejAejBejCejDejEh ZFd ZGd ZHd d � ZId d!� ZJG d"d#� d#eK�ZLG d$d%� d%eK�ZMG d&d'� d'eK�ZNdS )(� )�print_function� )�PY2�
range_type� text_type�str_type�JYTHON�
IRONPYTHONN)�_auth)�charset_by_name�
charset_by_id)�CLIENT�COMMAND�CR�
FIELD_TYPE�
SERVER_STATUS)�
converters)�Cursor)�Parser)� dump_packet� MysqlPacket�FieldDescriptorPacket�OKPacketWrapper�EOFPacketWrapper�LoadLocalPacketWrapper)�byte2int�int2byte)�err�VERSION_STRINGTF� )� � c C s( g | ] }|d k rt |�n
t |d ��qS )� i � )�chr)�.0�i� r& �7/usr/lib/python3.9/site-packages/pymysql/connections.py�
<listcomp>6 � r( � c C s | � d��t�S )N�latin1)�decode� translate�_surrogateescape_table��sr& r& r' �_fast_surrogateescape8 s r1 c C s | � dd�S )N�ascii�surrogateescape)r, r/ r& r& r' r1 ; s )�SocketIOc C s t �t| |��S �N)�io�BufferedReaderr4 ��sock�moder& r& r' � _makefileF s r; c C s
| � |�S r5 )Zmakefiler8 r& r& r' r; J s Zutf8mb4�� c C s t �d| �d d� S )N�<Ir )�struct�pack)�nr& r& r' �
pack_int24` s rA c C s� | dk rt d| ��np| dk r&t| �S | dk r>dt�d| � S | dk r^dt�d | �d d
� S | d k rvd t�d
| � S t d| d f ��d S )Nr zFEncoding %d is less than 0 - no representation in LengthEncodedInteger� i � ��<H� � �r= r l � �z<QzIEncoding %x is larger than %x - no representation in LengthEncodedInteger)�
ValueErrorr r> r? )r% r& r& r' �
lenenc_inte s rI c @ s e Zd ZdZdZdZdZdZddddddddddddedddddddddddddddddddf dd �Z d
d � Z
d d
� Z e dd� �Z
dd� ZeZdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd]d$d%�Zd&d'� Zd(d)� Zd*d+� Z d^d,d-�Z d_d.d/�Z d`d0d1�Z d2d3� Z d4d5� Z!dad7d8�Z"d9d:� Z#dbd;d<�Z$d=d>� Z%e&fd?d@�Z'dAdB� Z(dCdD� Z)dcdEdF�Z*dGdH� Z+dIdJ� Z,dKdL� Z-dMdN� Z.dOdP� Z/dQdR� Z0dSdT� Z1dUdV� Z2dWdX� Z3dYdZ� Z4d[d\� Z5e6j7Z7e6j8Z8e6j9Z9e6j:Z:e6j;Z;e6j<Z<e6j=Z=e6j>Z>e6j?Z?e6j@Z@dS )d�
Connectiona�
Representation of a socket with a mysql server.
The proper way to get an instance of this class is to call
connect().
Establish a connection to the MySQL database. Accepts several
arguments:
:param host: Host where the database server is located
:param user: Username to log in as
:param password: Password to use.
:param database: Database to use, None to not use a particular one.
:param port: MySQL port to use, default is usually OK. (default: 3306)
:param bind_address: When the client has multiple network interfaces, specify
the interface from which to connect to the host. Argument can be
a hostname or an IP address.
:param unix_socket: Optionally, you can use a unix socket rather than TCP/IP.
:param read_timeout: The timeout for reading from the connection in seconds (default: None - no timeout)
:param write_timeout: The timeout for writing to the connection in seconds (default: None - no timeout)
:param charset: Charset you want to use.
:param sql_mode: Default SQL_MODE to use.
:param read_default_file:
Specifies my.cnf file to read these parameters from under the [client] section.
:param conv:
Conversion dictionary to use instead of the default one.
This is used to provide custom marshalling and unmarshalling of types.
See converters.
:param use_unicode:
Whether or not to default to unicode strings.
This option defaults to true for Py3k.
:param client_flag: Custom flags to send to MySQL. Find potential values in constants.CLIENT.
:param cursorclass: Custom cursor class to use.
:param init_command: Initial SQL statement to run when connection is established.
:param connect_timeout: Timeout before throwing an exception when connecting.
(default: 10, min: 1, max: 31536000)
:param ssl:
A dict of arguments similar to mysql_ssl_set()'s parameters.
:param read_default_group: Group to read from in the configuration file.
:param compress: Not supported
:param named_pipe: Not supported
:param autocommit: Autocommit mode. None means use server default. (default: False)
:param local_infile: Boolean to enable the use of LOAD DATA LOCAL command. (default: False)
:param max_allowed_packet: Max size of packet sent to server in bytes. (default: 16MB)
Only used to limit size of "LOAD LOCAL INFILE" data packet smaller than default (16KB).
:param defer_connect: Don't explicitly connect on construction - wait for connect call.
(default: False)
:param auth_plugin_map: A dict of plugin names to a class that processes that plugin.
The class will take the Connection object as the argument to the constructor.
The class needs an authenticate method taking an authentication packet as
an argument. For the dialog plugin, a prompt(echo, prompt) method can be used
(if no authenticate method) for returning a string from the user. (experimental)
:param server_public_key: SHA256 authentication plugin public key value. (default: None)
:param db: Alias for database. (for compatibility to MySQLdb)
:param passwd: Alias for password. (for compatibility to MySQLdb)
:param binary_prefix: Add _binary prefix on bytes and bytearray. (default: False)
See `Connection <https://www.python.org/dev/peps/pep-0249/#connection-objects>`_ in the
specification.
N� Fr �
rE c! $ s� | d u rt jd dkrd} |d ur.|d u r.|}|d ur>|s>|}|sF|rNtd��t|�| _| jrh| tjO } �r�| s�t j�d�r�d} nd} | �rR�s�d�t � � � �
t j �
| �� � �fd d
�}!|!d |�}|!d |�}|!d
|�}|!d|�}|!d|�}t|!d|��}|!d| �} |!d|�}|�si }t|t��rRdD ](}"|!d|" |�|"��}#|#�r(|#||"< �q(d| _|�r�t�sltd��d| _| tjO } | �|�| _|�p�d| _|�p�d| _t| j�tu�r�td��|�p�t| _ |�p�d| _ t| j t ��r�| j � d�| _ || _ || _!| | _"d| k �rd k�s n td ��|�p(d | _#|d u�rH|dk�rHtd ��|| _$| d u�rj| dk�rjtd ��| | _%|�r�|| _&d| _'n t(| _&d| _'| d u�r�| | _'t)| j&�j*| _*| tj+O } | j �r�| tj,O } | | _-|
| _.d | _/d| _0d | _1|| _2|
d u �r�t3j4}
d!d"� |
�5� D �| _6d#d"� |
�5� D �| _7|| _8|| _9|| _:|�p@i | _;| | _<| | _=d$t>t �?� �t@d%�| _A| �rv| | jAd&< |�r�d | _Bn| �C� d S )'Nr r Tz3compress and named_pipe arguments are not supported�winz c:\my.iniz /etc/my.cnfZclientc s2 |r|S z� � �| �W S ty, | Y S 0 d S r5 )�get� Exception)�key�arg�Zcfg�read_default_groupr& r' �_config� s z$Connection.__init__.<locals>._config�user�password�host�database�socket�portz bind-addresszdefault-character-set)�ca�capath�certrP �cipherzssl-Fzssl module not foundZ localhosti� zport should be of type intr) r+ i�3�z+connect_timeout should be >0 and <=31536000zread_timeout should be > 0zwrite_timeout should be > 0z
Not connectedc S s" i | ]\}}t |�tur||�qS r& ��type�int�r$ �k�vr& r& r' �
<dictcomp>2 r) z'Connection.__init__.<locals>.<dictcomp>c S s" i | ]\}}t |�tu r||�qS r& r_ rb r& r& r' re 3 r) Zpymysql)Z _client_nameZ_pidZ_client_version� program_name)D�sys� version_info�NotImplementedError�bool�
_local_infiler
Z LOCAL_FILES�platform�
startswithr �read�os�path�
expanduserra �
isinstance�dictrN �ssl� SSL_ENABLED�SSL�_create_ssl_ctx�ctxrW rZ r` rH � DEFAULT_USERrU rV r �encode�db� unix_socket� bind_address�connect_timeout�
_read_timeout�_write_timeout�charset� use_unicode�DEFAULT_CHARSETr �encodingZ CAPABILITIES�CONNECT_WITH_DB� client_flag� cursorclass�_result�_affected_rows� host_info�autocommit_moder Z conversions�items�encoders�decoders�sql_mode� init_command�max_allowed_packet�_auth_plugin_map�_binary_prefix�server_public_key�str�getpidr �_connect_attrs�_sock�connect)$�selfrW rU rV rX rZ r| r� r� Zread_default_file�convr� r� r� r� r~ rt rS �compressZ
named_pipe�
autocommitr{ �passwdZ local_infiler� Z
defer_connectZauth_plugin_mapZ read_timeoutZ
write_timeoutr} Z
binary_prefixrf r� rT rP �valuer& rR r' �__init__� s�
�
zConnection.__init__c C s� t |tj�r|S |�d�}|�d�}|d u o2|d u }tj||d�}| oR|�dd�|_|r`tjntj|_d|v r�|j |d |�d�d� d |v r�|�
|d � | j tj O _ | j tj
O _ |S )
Nr[ r\ )Zcafiler\ �check_hostnameTr] rP )Zkeyfiler^ )rr rt Z
SSLContextrN Zcreate_default_contextr� Z CERT_NONEZ
CERT_REQUIREDZ verify_modeZload_cert_chainZ set_ciphers�optionsZ OP_NO_SSLv2Z OP_NO_SSLv3)r� Zsslpr[ r\ Zhasnocarx r& r& r' rw I s
zConnection._create_ssl_ctxc C sr | j rt�d��d| _ | jdu r$dS t�ddtj�}z.z| �|� W n t yV Y n0 W | �
� n
| �
� 0 dS )z�
Send the quit message and close the socket.
See `Connection.close() <https://www.python.org/dev/peps/pep-0249/#Connection.close>`_
in the specification.
:raise Error: If the connection is already closed.
�Already closedTN�<iBr ) �_closedr �Errorr� r> r? r ZCOM_QUIT� _write_bytesrO � _force_close)r� � send_datar& r& r' �closeZ s
zConnection.closec C s
| j duS )z%Return True if the connection is openN)r� �r� r& r& r' �openp s zConnection.openc C s2 | j r"z| j �� W n Y n0 d| _ d| _dS )z%Close connection without QUIT messageN)r� r� �_rfiler� r& r& r' r� u s zConnection._force_closec C s& t |�| _| �� }||kr"| �� d S r5 )rj r� �get_autocommit�_send_autocommit_mode)r� r� �currentr& r& r' r� � s
zConnection.autocommitc C s t | jtj@ �S r5 )rj �
server_statusr ZSERVER_STATUS_AUTOCOMMITr� r& r& r' r� � s �zConnection.get_autocommitc C s0 | � � }|�� s t�dd��t|�}|j| _|S )N�� zCommand Out of Sync)� _read_packet� is_ok_packetr �OperationalErrorr r� )r� �pkt�okr& r& r' �_read_ok_packet� s zConnection._read_ok_packetc C s& | � tjd| �| j� � | �� dS )z2Set whether or not to commit after every execute()zSET AUTOCOMMIT = %sN)�_execute_commandr � COM_QUERY�escaper� r� r� r& r& r' r� � s
�z Connection._send_autocommit_modec C s | � tjd� | �� dS )zBegin transaction.ZBEGINN�r� r r� r� r� r& r& r' �begin� s zConnection.beginc C s | � tjd� | �� dS )z�
Commit changes to stable storage.
See `Connection.commit() <https://www.python.org/dev/peps/pep-0249/#commit>`_
in the specification.
ZCOMMITNr� r� r& r& r' �commit� s zConnection.commitc C s | � tjd� | �� dS )z�
Roll back the current transaction.
See `Connection.rollback() <https://www.python.org/dev/peps/pep-0249/#rollback>`_
in the specification.
ZROLLBACKNr� r� r& r& r' �rollback� s zConnection.rollbackc C s$ | � tjd� t| �}|�� |jS )z%Send the "SHOW WARNINGS" SQL command.z
SHOW WARNINGS)r� r r� � MySQLResultrn �rows)r� �resultr& r& r' �
show_warnings� s zConnection.show_warningsc C s | � tj|� | �� dS )zI
Set current db.
:param db: The name of the db.
N)r� r Z COM_INIT_DBr� )r� r{ r& r& r' � select_db� s zConnection.select_dbc C sX t |t�r d| �|� d S t |ttf�rF| �|�}| jrBd| }|S tj|| j |d�S )z}Escape whatever value you pass to it.
Non-standard, for internal use; do not use this in your applications.
�'Z_binary)�mapping)
rr r �
escape_string�bytes� bytearray� _quote_bytesr� r Z escape_itemr� )r� �objr� �retr& r& r' r� � s
zConnection.escapec C s | � || j�S )zjAlias for escape()
Non-standard, for internal use; do not use this in your applications.
)r� r� )r� r� r& r& r' �literal� s zConnection.literalc C s" | j tj@ r|�dd�S t�|�S )Nr� z'')r� r �"SERVER_STATUS_NO_BACKSLASH_ESCAPES�replacer r� �r� r0 r& r& r' r� � s
� zConnection.escape_stringc C s, | j tj@ r"dt|�dd��f S t�|�S )Nz'%s'� 's '')r� r r� r1 r� r Z escape_bytesr� r& r& r' r� � s
�zConnection._quote_bytesc C s |r || �S | � | �S )a
Create a new cursor to execute queries with.
:param cursor: The type of cursor to create; one of :py:class:`Cursor`,
:py:class:`SSCursor`, :py:class:`DictCursor`, or :py:class:`SSDictCursor`.
None means use Cursor.
)r� )r� �cursorr& r& r' r� � s zConnection.cursorc C sT t |t�r2ts2ts2tr$|�| j�}n|�| jd�}| �tj |� | j
|d�| _ | j S )Nr3 ��
unbuffered) rr r r r r rz r� r� r r� �_read_query_resultr� )r� �sqlr� r& r& r' �query� s zConnection.queryc C s | j |d�| _| jS )Nr� )r� r� )r� r� r& r& r' � next_result� s zConnection.next_resultc C s | j S r5 )r� r� r& r& r' �
affected_rows s zConnection.affected_rowsc C s" t �d|�}| �tj|� | �� S )Nr= )r> r? r� r ZCOM_PROCESS_KILLr� )r� � thread_idrQ r& r& r' �kill s zConnection.killTc C sr | j du r&|r | �� d}n
t�d��z| �tjd� | �� W n, tyl |rf| �� | � d� n� Y n0 dS )z�
Check if the server is alive.
:param reconnect: If the connection is closed, reconnect.
:raise Error: If the connection is closed and reconnect=False.
NFr� rK )
r� r� r r� r� r ZCOM_PINGr� rO �ping)r� Z reconnectr& r& r' r� s
zConnection.pingc C s: t |�j}| �tjd| �|� � | �� || _|| _d S )Nz SET NAMES %s)r r� r� r r� r� r� r� )r� r� r� r& r& r' � set_charset s
zConnection.set_charsetc
C sn d| _ �z�|d u �r2| jr\t�tjtj�}|�| j� |�| j� d| _d| _ t
rZt d� n�i }| j d urx| j df|d< z&tj
| j| jf| jfi |��}W q�W qx ttfy� } z&|jtjkr�W Y d }~qx� W Y d }~qxd }~0 0 qxd| j| jf | _t
�rt d� |�tjtjd � |�tjtjd � |�d � || _t|d
�| _d| _ | � � | � � | j d u�r~| � � }|�!d | j f� | j"d u�r�| � � }|�!| j"� |�#� | �$� | j%d u�r�| �&| j%� W n� t'�yh } z�d | _|d u�rz |�#� W n Y n0 t(|tttj)f��rRt*�+d d
| j|f �}||_,t-�.� |_-t
�rNt |j-� |�� W Y d }~n
d }~0 0 d S )NFzLocalhost via UNIX socketTzconnected using unix_socketr Zsource_addressz socket %s:%dzconnected using socketr �rbzSET sql_mode=%si� z(Can't connect to MySQL server on %r (%s))/r� r| rY ZAF_UNIXZ SOCK_STREAM�
settimeoutr~ r� r� �_secure�DEBUG�printr} Zcreate_connectionrW rZ �OSError�IOError�errno�EINTRZ
setsockoptZ IPPROTO_TCPZ TCP_NODELAYZ
SOL_SOCKETZ SO_KEEPALIVEr� r; r� � _next_seq_id�_get_server_information�_request_authenticationr� r� Zexecuter� r� r� r� r� �
BaseExceptionrr �errorr r� Zoriginal_exception� traceback�
format_exc)r� r9 �kwargs�e�c�excr& r& r' r� ( s~
��
��
zConnection.connectc C sD t t|��t| j� | }tr&t|� | �|� | jd d | _dS )zvWrites an entire "mysql packet" in its entirety to the network
adding its length and sequence number.
r r* N)rA �lenr r� r� r r� )r� Zpayload�datar& r& r' � write_packetr s
zConnection.write_packetc
C s� t � }| �d�}t�d|�\}}}||d> }|| jkrj| �� |dkrVt�tj d��t�
d|| jf ��| jd d | _| �|�}t r�t |� ||7 }|d kr�q|t
k rq�q|t|�| j�} | �� r�| jd
ur�| jjd u r�d | j_| �� | S )
a! Read an entire "mysql packet" in its entirety from the network
and return a MysqlPacket type that represents the results.
:raise OperationalError: If the connection to the MySQL server is lost.
:raise InternalError: If the packet sequence number is wrong.
� z<HBB� r �,Lost connection to MySQL server during queryz1Packet sequence number wrong - got %d expected %dr r* r< NTF)r� � _read_bytesr> �unpackr� r� r r� r �CR_SERVER_LOST�
InternalErrorr� r �MAX_PACKET_LENr� r� Zis_error_packetr� �unbuffered_activeZraise_for_error)
r� Z packet_typeZbuffZ
packet_headerZbtrlZbtrhZ
packet_numberZ
bytes_to_readZ recv_data�packetr& r& r' r� } s<
���
zConnection._read_packetc
C s� | j �| j� z| j�|�}W q�W q ttfy~ } z@|jtjkrNW Y d }~q| � � t
� t j
d|f ��W Y d }~qd }~0 ty� | � � � Y q0 qt|�|k r�| � � t
� t j
d��|S )Nz1Lost connection to MySQL server during query (%s)r� )r� r� r r� rn r� r� r� r� r� r r� r r� r� r� )r� Z num_bytesr� r� r& r& r' r� � s* �
�zConnection._read_bytesc
C sd | j �| j� z| j �|� W n@ ty^ } z(| �� t�tj d|f ��W Y d }~n
d }~0 0 d S )Nz MySQL server has gone away (%r))
r� r� r� Zsendallr� r� r r� r ZCR_SERVER_GONE_ERROR)r� r� r� r& r& r' r� � s �zConnection._write_bytesc C sj d | _ |r<zt| �}|�� W qL d|_d |_� Y qL0 nt| �}|�� || _ |jd urd|j| _|jS �NF)r� r� �init_unbuffered_queryr� �
connectionrn r� r� )r� r� r� r& r& r' r� � s
z Connection._read_query_resultc C s | j r| j jS dS d S �Nr )r� � insert_idr� r& r& r' r � s zConnection.insert_idc C s | j st�dd��| jdurP| jjr8t�d� | j�� | jjrJ| � � q8d| _t
|t �rf|� | j
�}ttt|�d �}t�d||�}||d|d � }| �|� tr�t|� d| _|tk r�dS ||d d� }ttt|��}| �|d|� � ||d� }|s�|tk rҐqq�dS )z~
:raise InterfaceError: If the connection is closed.
:raise ValueError: If no username was specified.
r rK Nz.Previous unbuffered result was left incompleter r� )r� r �InterfaceErrorr� r� �warnings�warn�_finish_unbuffered_query�has_nextr� rr r rz r� �minr� r� r> r? r� r� r r� r� )r� Zcommandr� � packet_sizeZpreluder� r& r& r' r� � s2
zConnection._execute_commandc
C s� t | j�dd�d �dkr*| jtjO _| jd u r<td��t| j �j
}t | jt �rd| j�
| j�| _t�d| jt|d�}| jr�| jtj@ r�| �|� | jj| j| jd�| _t| jd �| _d
| _ || j d }d}d }| j d kr�d}t � | j | j!�}n�| j d
k�rd}t � | j | j!�}n�| j dk�r^d}| j �rNt"�r<t#d� t �$| j | j!�}nt"�r�t#d� nD| j dk�r�d}| j�r�| jtj@ �r�| j d }n| j �r�d}nd }| jtj%@ �r�|t&t'|��| 7 }n4| jtj(@ �r�|t�dt'|��| 7 }n ||d 7 }| j)�r<| jtj*@ �r<t | j)t ��r.| j)�
| j�| _)|| j)d 7 }| jtj+@ �r\||�pTdd 7 }| jtj,@ �r�d}| j-�.� D ]N\}}|�
d�}|t�dt'|��| 7 }|�
d�}|t�dt'|��| 7 }�qx|t�dt'|��| 7 }| �|� | �/� } | �0� �rht"�r
t#d� | �1� | �2� }| jtj+@ �r@|d u�r@| �3|| �} n&t �4| j | j!�d }| �|� | �/� } nZ| �5� �r�t"�r�t#d� | j dk�r�t �6| | �} n(| j dk�r�t �7| | �} nt8�9d| j ��t"�r�t#d� d S ) N�.r r � zDid not specify a usernamez<iIB23sr) )Zserver_hostnamer� T� rK Zmysql_native_password� mysql_native_passwordZcaching_sha2_password� caching_sha2_passwordz caching_sha2: trying fast pathz caching_sha2: empty passwordZsha256_password� sha256_password� �B�utf-8zreceived auth switchzreceived extra dataz(Received extra packet for auth method %rzSucceed to auth):ra �server_version�splitr� r
Z
MULTI_RESULTSrU rH r r� �idrr r rz r� r> r? r� rt �server_capabilitiesrv r� rx Z wrap_socketr� rW r; r� r� �_auth_plugin_namer
�scramble_native_passwordrV �saltr� r� Zscramble_caching_sha2Z PLUGIN_AUTH_LENENC_CLIENT_DATArI r� ZSECURE_CONNECTIONr{ r� � PLUGIN_AUTHZ
CONNECT_ATTRSr� r� r� Zis_auth_switch_request�
read_uint8Z read_string�
_process_auth�scramble_old_passwordZis_extra_auth_data�caching_sha2_password_auth�sha256_password_authr r� )
r� Z
charset_idZ data_initr� Zauthresp� plugin_nameZ
connect_attrsrc rd � auth_packetr& r& r' r�
s�
z"Connection._request_authenticationc C s( | � |�}|rNz |�|�W S tyL |dkrHt�dd|t|�f ��Y n0 |dkrbt�| |�S |dkrvt�| |�S |dkr�t� | j
|� � �}�nv|dkr�t� | j
|� � �}�nX|dkr�t�
| j
|� � �d }�n6|d
kr�| j
d }�n |dk�r�|}|�� }|d @ d k}|d
@ d
k}|� � } | dk�r<| �| j
d � n�|�r�d}
z |�|| �}
| �|
d � W nR t�y� t�dd||f ��Y n, t�y� t�dd|||
| f ��Y n0 nt�dd||f ��| �� }|�� |�� �s�|� r��q�� q�|S t�dd| ��| �|� | �� }|�� |S )Ns dialog� zGAuthentication plugin '%s' not loaded: - %r missing authenticate methodr r r s client_ed25519s mysql_old_passwordr
s mysql_clear_passwordr! r r s
Password: z3no response - TypeError within plugin.prompt methodzAAuthentication plugin '%s' not loaded: - %r missing prompt methodi
zTAuthentication plugin '%s' %r didn't respond with string. Returned '%r' to prompt %rz.Authentication plugin '%s' (%r) not configuredz)Authentication plugin '%s' not configured)�_get_auth_plugin_handlerZ authenticate�AttributeErrorr r� r` r
r r r rV Zread_allZed25519_passwordr r r� �prompt� TypeErrorr� Z check_errorr� ) r� r! r" �handlerr� r� �flagZechoZlastr& Zrespr& r& r' r r sj
�
�
�
zConnection._process_authc C sn | j �|�}|s,t|t�r,| j �|�d��}|rfz || �}W qj tyb t�dd||f ��Y qj0 nd }|S )Nr2 r# zXAuthentication plugin '%s' not loaded: - %r cannot be constructed with connection object)r� rN rr r� r, r' r r� )r� r! Z plugin_classr( r& r& r' r$ � s �z#Connection._get_auth_plugin_handlerc C s
| j d S r )�server_thread_idr� r& r& r' r� � s zConnection.thread_idc C s | j S r5 )r� r� r& r& r' �character_set_name� s z Connection.character_set_namec C s | j S r5 )r� r� r& r& r' �
get_host_info� s zConnection.get_host_infoc C s | j S r5 )�protocol_versionr� r& r& r' �get_proto_info� s zConnection.get_proto_infoc C s d}| � � }|�� }t|||d � �| _|d7 }|�d|�}|||� �d�| _|d }t�d|||d � �| _ |d7 }|||d � | _
|d7 }t�d |||d
� �d | _ |d
7 }t |�|d k�rpt�d |||d � �\}}}}|d 7 }|| _
zt|�j| _W n t�y& d | _Y n0 || _t�r@td
| � | j |d> O _ t�rbtd|� td|d �}|d7 }t |�|| k�r�| j
|||| � 7 _
||7 }|d7 }| j tj@ �rt |�|k�r|�d|�}|dk �r�||d � �d�| _n|||� �d�| _d S )Nr r r
r+ r= r� � � rD r r! z<BHHBzserver_status: %xr� z salt_len:� rL r )r� Z get_all_datar r- �findr, r r> r� r* r r r� Zserver_languager �nameZserver_charset�KeyErrorr� r� r� �maxr
r r ) r� r% r� r� Z
server_end�lang�statZcap_hZsalt_lenr& r& r' r� � sJ
z"Connection._get_server_informationc C s | j S r5 )r r� r& r& r' �get_server_info s zConnection.get_server_info)N)N)F)F)T)N)F)A�__name__�
__module__� __qualname__�__doc__r� r r� r� r r� rw r� �propertyr� r� �__del__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� r8 r �Warningr� r Z
DatabaseErrorZ DataErrorr� ZIntegrityErrorr� ZProgrammingErrorZNotSupportedErrorr& r& r& r' rJ t s� =�
J *
*h:?rJ c @ st e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� ZdS ) r� c C sF || _ d| _d| _d| _d| _d| _d| _d| _d| _d| _ d| _
dS )z.
:type connection: Connection
Nr F) r r� r r� �
warning_count�message� field_count� descriptionr� r r� )r� r r& r& r' r� s zMySQLResult.__init__c C s | j r| �� d S r5 )r� r r� r& r& r' r> ' s zMySQLResult.__del__c C sT zF| j �� }|�� r | �|� n |�� r4| �|� n
| �|� W d | _ nd | _ 0 d S r5 )r r� r� r� �is_load_local_packet�_read_load_local_packet�_read_result_packet�r� � first_packetr& r& r' rn + s
zMySQLResult.readc C sl d| _ | j�� }|�� r0| �|� d| _ d| _n8|�� rP| �|� d| _ d| _n|�� | _| � � d| _
dS )zw
:raise OperationalError: If the connection to the MySQL server is lost.
:raise InternalError:
TFNl ���� ) r� r r� r� r� rD rE �read_length_encoded_integerrB �_get_descriptionsr� rG r& r& r' r 8 s
z!MySQLResult.init_unbuffered_queryc C s< t |�}|j| _|j| _|j| _|j| _|j| _|j| _d S r5 )r r� r r� r@ rA r )r� rH � ok_packetr& r& r' r� Q s zMySQLResult._read_ok_packetc C sx | j jstd��t|�}t|j| j �}z |�� W n | j �� � Y n0 | j �� }|�� sjt �
dd��| � |� d S )NzF**WARN**: Received LOAD_LOCAL packet but local_infile option is false.r� zCommands Out of Sync) r rk � RuntimeErrorr �
LoadLocalFile�filenamer� r� r� r r� r� )r� rH Z load_packetZsenderrK r& r& r' rE Z s �
z#MySQLResult._read_load_local_packetc C s( |� � s dS t|�}|j| _|j| _dS )NFT)Z
is_eof_packetr r@ r )r� r� Zwpr& r& r' �_check_packet_is_eofk s z MySQLResult._check_packet_is_eofc C s |� � | _| �� | �� d S r5 )rI rB rJ �_read_rowdata_packetrG r& r& r' rF w s
z MySQLResult._read_result_packetc C sP | j s
d S | j�� }| �|�r4d| _ d | _d | _d S | �|�}d| _|f| _|S )NFr )r� r r� rO r� �_read_row_from_packetr� )r� r� �rowr& r& r' � _read_rowdata_packet_unbuffered| s
z+MySQLResult._read_rowdata_packet_unbufferedc C s, | j r(| j�� }| �|�r d| _ d | _q d S r� )r� r r� rO )r� r� r& r& r' r � s
z$MySQLResult._finish_unbuffered_queryc C sJ g }| j �� }| �|�r d| _ q2|�| �|�� qt|�| _t|�| _dS )z:Read a rowdata packet for each data row in the result set.N) r r� rO �appendrQ r� r� �tupler� )r� r� r� r& r& r' rP � s
z MySQLResult._read_rowdata_packetc C s� g }| j D ]p\}}z |�� }W n ty6 Y q|Y n0 |d urp|d urR|�|�}tr`td|� |d urp||�}|�|� q
t|�S )NzDEBUG: DATA = )r Zread_length_coded_string�
IndexErrorr, r� r� rT rU )r� r� rR r� � converterr� r& r& r' rQ � s
z!MySQLResult._read_row_from_packetc
C s� g | _ g | _| jj}| jj}g }t| j�D ]�}| j�t�}| j � |� |� |�
� � |j }|r�|t j
krn|}q�|tv r�|jdkr�d}q�|}q�d}nd}| jj�|�}|tju r�d}tr�td�||�� | j� ||f� q*| j�� } t|�| _
dS )z>Read a column descriptor packet for each column in the result.�? Nr2 z DEBUG: field={}, converter={})�fieldsr r r� r� r rB r� r rT rC Z type_coder ZJSON�
TEXT_TYPESZ charsetnrr� rN Zthroughr� r� �formatrU )
r� r� Z
conn_encodingrC r% ZfieldZ
field_typer� rW Z
eof_packetr& r& r' rJ � s4
z MySQLResult._get_descriptionsN)r9 r: r; r� r> rn r r� rE rO rF rS r rP rQ rJ r& r& r& r' r� s
r� c @ s e Zd Zdd� Zdd� ZdS )rM c C s || _ || _d S r5 )rN r )r� rN r r& r& r' r� � s zLoadLocalFile.__init__c C s� | j jst�dd��| j }z�zXt| jd��8}t|jd�}|�|�}|sHqT|� |� q8W d � n1 sh0 Y W n& t
y� t� dd� | j���Y n0 W |� d� n |� d� 0 dS ) z3Send data packets from the local file to the serverr rK r� i @ Ni� zCan't find file '{0}'r) )
r r� r r r� rN r r� rn r� r� r� r[ )r� ZconnZ open_filer
�chunkr& r& r' r� � s
. zLoadLocalFile.send_dataN)r9 r: r; r� r� r& r& r& r' rM � s rM )OZ
__future__r Z_compatr r r r r r r� r6 ro rY r> rg r� r rK r
r� r r Z constantsr
r r r r r Zcursorsr Z
optionfiler Zprotocolr r r r r r �utilr r r r rt ru � ImportErrorZgetpassZgetuserry r4 r� rh Z _py_version�ranger. r1 Z _socketior4 r; ZBITZBLOBZ LONG_BLOBZ MEDIUM_BLOB�STRINGZ TINY_BLOBZ
VAR_STRINGZVARCHARZGEOMETRYrZ r� r� rA rI �objectrJ r� rM r& r& r& r' �<module> s�
�
( N