⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.166
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
var
/
opt
/
nydus
/
ops
/
mysql
/
connector
/
__pycache__
/
View File Name :
protocol.cpython-39.pyc
a ��Rh�� � @ sD d Z ddlmZ ddlZddlZddlmZ ddlmZm Z ddl m Z m Z m Z mZmZmZmZmZmZ ddlmZ dd lmZmZmZmZmZ dd l m Z dd l m Z m Z m!Z!m"Z" dd l#m#Z# dd l$m%Z%m&Z& ddl'm(Z( ddl)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 e �rddl1m2Z2 dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:G dd� d�Z;dS )z,Implements the MySQL Client/Server protocol.� )� annotationsN)�deque)�Decimal�DecimalException) � TYPE_CHECKING�Any�Deque�Dict�List�Optional�Sequence�Tuple�Union� )�utils)�PARAMETER_COUNT_AVAILABLE� ClientFlag� FieldFlag� FieldType� ServerCmd)�MySQLConverter)� DatabaseError�InterfaceError�ProgrammingError� get_exception)�logger)�MySQLAuthPlugin�get_auth_plugin)�"MySQLCachingSHA2PasswordAuthPlugin)�BinaryProtocolType�DescriptionType� EofPacketType� HandShakeType� OkPacketType�StatsPacketType� StrOrBytes)� MySQLSocket� � � � �- i @c @ s� e Zd ZdZeddd�dd��Zeddd�dd��Zeddd�d d ��Zed dd �d d��Zedddd�dd��Z ed~dddddddddd� dd ��Z ede d e ddddddf d ddddddddd ddddd �d!d"��Z ee d e fddddd#�d$d%��Zeddd&dd'�d(d)��Zed�dddd+�d,d-��Zedd d.�d/d0��Zedd1d.�d2d3��Zedd4d.�d5d6��Zed�ddd8d9�d:d;��Zdd<d.�d=d>�Zed�ddd@dA�dBdC��Zd�dDdEddFdG�dHdI�Zedd8dJdK�dLdM��Zedd8dNdK�dOdP��Zed�dddRdS�dTdU��ZedddVdW�dXdY��ZeddZd.�d[d\��Z d�d]ddd^d_�d`da�Z d�dDd]dddbdc�ddde�Z eddfd.�dgdh��Z eddidj�dkdl��Z edmdJdj�dndo��Z!edpdJdj�dqdr��Z"eddddds�dtdu��Z#d�ddwdxddyddzddd{� d|d}�Z$dS )�� MySQLProtocolzRImplements MySQL client/server protocol Create and parses MySQL packets. �bytes)�pkt�returnc C s | d t kstd��| dd� S )a Parse a MySQL auth more data packet. Args: pkt: Packet representing an `auth more data` response. Returns: auth_data: Authentication method data (see [1]). Raises: InterfaceError: If packet's status tag doesn't match `protocol.EXCHANGE_FURTHER_STATUS`. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_auth_more_data.html � z"Failed parsing AuthMoreData packet� N)�EXCHANGE_FURTHER_STATUSr )r. � r3 �K/opt/nydus/tmp/pip-target-o2llkf2b/lib64/python/mysql/connector/protocol.py�parse_auth_more_data\ s z"MySQLProtocol.parse_auth_more_datazTuple[str, bytes]c C sV | d t krtd��tj| dd� dd�\} }| rJ| d dkrJ| dd� } |�� | fS ) a| Parse a MySQL auth switch request packet. Args: pkt: Packet representing an `auth switch request` response. Returns: plugin_name: Name of the client authentication plugin to switch to. plugin_provided_data: Plugin provided data (see [1]). Raises: InterfaceError: If packet's status tag doesn't match `protocol.AUTH_SWITCH_STATUS`. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/ latest/page_protocol_connection_phase_packets_protocol_ auth_switch_request.html r0 z'Failed parsing AuthSwitchRequest packetr1 N� ��end���r )�AUTH_SWITCH_STATUSr r � read_string�decode)r. � plugin_namer3 r3 r4 �parse_auth_switch_requestr s z'MySQLProtocol.parse_auth_switch_requestc C sF t �| dd� d�\} }|tkr(td��t j| dd�\} }|�� | fS )a� Parse a MySQL auth next factor packet. Args: pkt: Packet representing an `auth next factor` response. Returns: plugin_name: Name of the client authentication plugin. plugin_provided_data: Initial authentication data for that client plugin (see [1]). Raises: InterfaceError: If packet's packet type doesn't match `protocol.MFA_STATUS`. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_auth_ next_factor_request.html r0 Nr z.Failed parsing AuthNextFactor packet (invalid)r6 r7 )r �read_int� MFA_STATUSr r; r< )r. �statusr= r3 r3 r4 �parse_auth_next_factor� s z$MySQLProtocol.parse_auth_next_factorzDict[str, str])� conn_attrsr/ c s� � D ]}� | du rd� |< qt � fdd�� D ��t� �� � t� �� � }t�d|�g}� D ]T}|�t�dt|��� |�|�� � |�t�dt� | ��� |�� | �� � q^d�|�S )az Encode the connection attributes. Args: conn_attrs: Connection attributes. Returns: serialized_conn_attrs: Serialized connection attributes as per [1]. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html N� c 3 s" | ]}t |�t � | � V qd S )N)�len)�.0�x�rC r3 r4 � <genexpr>� � z0MySQLProtocol.make_conn_attrs.<locals>.<genexpr>�<BrJ ) �sumrE �keys�values�struct�pack�append�encode�join)rC � attr_nameZconn_attrs_lenZconn_attrs_packetr3 rH r4 �make_conn_attrs� s � ��z MySQLProtocol.make_conn_attrs�intz Optional[str])� client_flags�databaser/ c C s | t j@ r|r|�� d S dS )a� Prepare database string for handshake response. Args: client_flags: Integer representing client capabilities flags. database: Initial database name for the connection. Returns: serialized_database: Serialized database name as per [1]. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html r6 )r ZCONNECT_WITH_DBrR )rW rX r3 r3 r4 �connect_with_db� s ���z MySQLProtocol.connect_with_dbNF�str�boolzOptional[Dict[str, Any]]z Tuple[bytes, MySQLAuthPlugin]) � auth_data�username�passwordrW � auth_plugin�auth_plugin_class� ssl_enabled� plugin_configr/ c C s� |sdt |||d�fS |du r"i }z*t||�|||d�}|j| fi |��} W n8 ttfy� } z td| � ��| �W Y d} ~ n d} ~ 0 0 | du r�td|j� ���|tj@ r�t� t | ��| n| d } | |fS )a Prepare the first authentication response. Args: auth_data: Authorization data from initial handshake. username: Account's username. password: Account's password. client_flags: Integer representing client capabilities flags. auth_plugin: Authorization plugin name. auth_plugin_class: Authorization plugin class (has higher precedence than the authorization plugin name). ssl_enabled: Whether SSL is enabled or not. plugin_config: Custom configuration to be passed to the auth plugin when invoked. The parameters defined here will override the ones defined in the auth plugin itself. Returns: auth_response: Authorization plugin response. auth_strategy: Authorization plugin instance created based on the provided `auth_plugin` and `auth_plugin_class` parameters. Raises: InterfaceError: If authentication fails or when got a NULL auth response. r6 )ra NzFailed authentication: z8Got NULL auth response while authenticating with plugin ) r r � auth_response� TypeErrorr �namer �SECURE_CONNECTIONr � int1storerE ) r\ r] r^ rW r_ r` ra rb � auth_strategyrc �errr3 r3 r4 �auth_plugin_first_response� s0 #��&����z(MySQLProtocol.auth_plugin_first_responser r" zOptional[Dict[str, str]])� handshaker] r^ rX �charsetrW �max_allowed_packetr_ r` rC �is_change_user_requestra rb r/ c C s� |� � } g }| rt�d� t�d� | du r6td�d�| �d�du rNtd�d�z|pZ| d }W n: ttfy� } z td|� d ��d�W Y d}~n d}~0 0 t�d |� | r�|�t� d t | �� d �t j | �� n,d }|�t� d|� t | �� d �|||| �� t j| d |||||| | d�\}}|�|� |�t �||�� | �rP|�t� d|�� |tj@ �rn|�|� � d � |tj@ �r�| du�r�|�t �| �� d�|�|fS )a� Make a MySQL Authentication packet. Args: handshake: Initial handshake. username: Account's username. password: Account's password. database: Initial database name for the connection charset: Client charset (see [2]), only the lower 8-bits. client_flags: Integer representing client capabilities flags. max_allowed_packet: Maximum packet size. auth_plugin: Authorization plugin name. auth_plugin_class: Authorization plugin class (has higher precedence than the authorization plugin name). conn_attrs: Connection attributes. is_change_user_request: Whether is a `change user request` operation or not. ssl_enabled: Whether SSL is enabled or not. plugin_config: Custom configuration to be passed to the auth plugin when invoked. The parameters defined here will override the one defined in the auth plugin itself. Returns: handshake_response: Handshake response as per [1]. auth_strategy: Authorization plugin instance created based on the provided `auth_plugin` and `auth_plugin_class`. Raises: ProgrammingError: Handshake misses authentication info. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html [2]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set zGot a `change user` requestz Starting authorization phaseNzGot a NULL handshaker\ z$Handshake misses authentication infor_ z-Handshake misses authentication plugin info (�)z#The provided initial strategy is %srK ZsxZxxxxxxxxxxxxxxxxxxxxxxz<IIH)r\ r] r^ rW r_ r` ra rb �<Hr6 rJ )rR r �debugr �getrd �KeyErrorrQ rO rP rE r Z CHANGE_USERr, rj rY r � PLUGIN_AUTHZ CONNECT_ARGSrU rS )rk r] r^ rX rl rW rm r_ r` rC rn ra rb Z b_usernameZresponse_payloadri �fillerrc rh r3 r3 r4 � make_auth sn 3 �� ���� � zMySQLProtocol.make_auth)rl rW rm r/ c C s$ d� t�|�t�|�t�| �dg�S )a� Make a SSL authentication packet (see [1]). Args: charset: Client charset (see [2]), only the lower 8-bits. client_flags: Integer representing client capabilities flags. max_allowed_packet: Maximum packet size. Returns: ssl_request_pkt: SSL connection request packet. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_ssl_request.html [2]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set rJ s �rS r � int4store� int2store)rl rW rm r3 r3 r4 � make_auth_ssl� s ��zMySQLProtocol.make_auth_sslzOptional[bytes])�command�argumentr/ c C s t �| �}|du r|S || S )z(Make a MySQL packet containing a commandN)r rg )r{ r| �datar3 r3 r4 � make_command� s zMySQLProtocol.make_commandr )� statement_id�rowsr/ c C s t �| �t �|� S )z0Make a MySQL packet with Fetch Statement command)r rx )r r� r3 r3 r4 �make_stmt_fetch� s z MySQLProtocol.make_stmt_fetch)�packetr/ c C s� i }t �d| dd� �d |d< |d tkrDtd|d � dt� ���tj| dd� dd �\} |d < t �d | dd � �\|d < }}|d< |d< }}|d �� |d < | d d� } t�|| �}d}|tj @ �r|r�t d|d �nd}| d|� }| |d� } |d dk�r|dd� }|tj @ �rrd| v�rH|d � d��rHd| } |d< ntj| dd �\} |d< |d �d�|d< nd|d< || |d< ||d< |S )z Parse a MySQL Handshake-packet.�<xxxxBr r1 �protocolz$Protocol mismatch; server version = z, client version = Nr6 r7 Zserver_version_originalz<I8sx2sBH2sBxxxxxxxxxx� Zserver_threadidrl Z server_statusrJ � � r9 z5.5.8r_ �utf-8Zmysql_native_passwordr\ � capabilities) rO �unpack�PROTOCOL_VERSIONr r r; r< Zintreadr rf �minrt � startswith) r� �resZ auth_data1Z capabilities1Z capabilities2Zauth_data_lengthr� Z auth_data2�sizer3 r3 r4 �parse_handshake� sR �� � � � z MySQLProtocol.parse_handshaker# c C s� | d dkst d��i }z�t�d| dd� �d |d< t�| dd� �\} |d< t�| �\} |d < t�d | dd� �\|d < |d < | dd� } | r�t�| �\} |d < |d �d�|d < W n. ty� } zt d�|�W Y d}~n d}~0 0 |S )zParse a MySQL OK-packetr0 r z#Failed parsing OK packet (invalid).r� r1 Z field_countNZ affected_rowsZ insert_idz<HH� status_flag� warning_countZinfo_msgr� zFailed parsing OK packet.)r rO r� r � read_lc_int�read_lc_stringr< � ValueError)r� Z ok_packetri r3 r3 r4 �parse_ok� s$ � zMySQLProtocol.parse_okz Optional[int]c C sV z t �| dd� �d }|W S tjtfyP } ztd�|�W Y d}~n d}~0 0 dS )z=Parse a MySQL packet with the number of columns in result setr0 Nr zFailed parsing column count)r r� rO �errorr� r )r� �countri r3 r3 r4 �parse_column_count s z MySQLProtocol.parse_column_countr� r )r� �encodingr/ c C s� t �| dd� �\} }t �| �\} }t �| �\} }t �| �\} }t �| �\} }t �| �\} }zt�d| �\}}}}}W n tjy� td�d�Y n0 |�|�|dddd| tj@ ||f S )z Parse a MySQL column-packet.r0 Nz <xHIBHBxxz!Failed parsing column information) r r� rO r� r� r r< r ZNOT_NULL)r� r� �_re rl Z column_type�flagsr3 r3 r4 � parse_column s6 �� �zMySQLProtocol.parse_columnr! c C s� |d dkr| � |�S d}i }zt�d|�}W n0 tjy^ } zt|�|�W Y d}~n d}~0 0 |d dkrxt|�dks�t|��|d |d < |d |d < |S ) zParse a MySQL EOF-packetr0 r zFailed parsing EOF packet.z<xxxBBHHNr r( � r) r� � r� )r� rO r� r� r rE )�selfr� �err_msgr� �unpackedri r3 r3 r4 � parse_eof: s zMySQLProtocol.parse_eofTr$ )r� � with_headerr/ c C s" d}i }dg}d}|r*| dd� � d�}n | � d�}|D ]�}z dd� |� dd �D �\}}W n. ty� } zt|�|�W Y d}~n d}~0 0 |�d �}zt|�||< W q8 ttf�y zt|�d ��||< W nF t�y } z,t|� d |� d t|�� d ��|�W Y d}~n d}~0 0 Y q80 q8|S )zParse the statistics packetz)Failed getting COM_STATISTICS informationrJ r0 Ns c S s g | ] }|� � �qS r3 )�strip)rF �vr3 r3 r4 � <listcomp>\ rJ z2MySQLProtocol.parse_statistics.<locals>.<listcomp>� :r) r� z (�:ro ) �splitr� r r< rV rs r r �repr) r� r� �errmsgr� �pairsZlbl�pair�valri r3 r3 r4 �parse_statisticsN s* >z MySQLProtocol.parse_statisticsr& zTuple[int, ...]zATuple[List[Tuple[Optional[bytes], ...]], Optional[EofPacketType]])�sock�versionr� r/ c C s" |}g }d}d}d}|s ||kr$�q|� � } | �d�r�| dd� g} |� � } | �d�rr| �| dd� � |� � } qL| �| dd� � t�d�| ��}nB| d dkr�| d dk r�| �| �}d}nd}t�t| dd� ��}|du r�|dur�|�|� n |du �r|du �rt| ��|d7 }q||fS ) z�Read MySQL text result Reads all or given number of rows from the socket. Returns a tuple with 2 elements: a list with all rows and the EOF packet. Nr s ���r0 rJ r( � r ) �recvr� rQ r Zread_lc_string_listrS r� r- r ) r� r� r� r� r� r� �eofZrowdata�ir� Zdatasr3 r3 r4 �read_text_resultk s6 z MySQLProtocol.read_text_resultzTuple[bytes, int])r� �fieldr/ c C s� |d t jkrd}d}nL|d t jkr0d}d}n4|d t jt jfv rNd}d}n|d t jkrdd}d}|d tj@ rz|�� }| |d � t � || d |� �d fS ) z%Parse an integer from a binary packetr �<b�<hr) �<ir0 �<qr� r� Nr ) r �TINY�SHORT�INT24�LONG�LONGLONGr ZUNSIGNED�upperrO r� )r� r� �format_�lengthr3 r3 r4 �_parse_binary_integer� s z#MySQLProtocol._parse_binary_integerzTuple[bytes, float]c C sD |d t jkrd}d}nd}d}| |d� t�|| d|� �d fS )z)Parse a float/double from a binary packetr r� �<dr0 z<fNr )r �DOUBLErO r� )r� r� r� r� r3 r3 r4 �_parse_binary_float� s z!MySQLProtocol._parse_binary_float�utf8zTuple[bytes, Decimal])r� rl r/ c C s t �| �\} }| t|�|��fS )z(Parse a New Decimal from a binary packet)r r� r r< )r� rl �valuer3 r3 r4 �_parse_binary_new_decimal� s z'MySQLProtocol._parse_binary_new_decimalz?Tuple[bytes, Optional[Union[datetime.date, datetime.datetime]]])r� � field_typer/ c C s� | d }d}|dkrpt �d| dd� �d }| d }| d }|tjtjfv r^tj|||d�}q�tj|||d�}np|dkr�d}|d kr�t �d | d |d � �d }tjt �d| dd� �d | d | d | d | d | d |d�}| |d d� |fS )z&Parse a timestamp from a binary packetr Nr0 rp r r� )�year�month�dayr� � �<Ir� r1 � )r� r� r� �hour�minute�second� microsecond)rO r� r �DATETIME� TIMESTAMP�datetime�date)r� r� r� r� r� r� r� �mcsr3 r3 r4 �_parse_binary_timestamp� s. � z%MySQLProtocol._parse_binary_timestampz Tuple[bytes, datetime.timedelta]c C s� | d }|s | dd� t �� fS | d|d � }d}|dkrTt�d|dd� �d }t�d|dd� �d }|d dkr�|d9 }t j||d ||d |d d �}| |d d� |fS ) z'Parse a time value from a binary packetr r Nr� r� r1 r9 r� r� )�days�seconds� microseconds�minutes�hours)r� � timedeltarO r� )r� r� r} r� r� �tmpr3 r3 r4 �_parse_binary_time� s$ �z MySQLProtocol._parse_binary_timezList[DescriptionType]z Tuple[BinaryProtocolType, ...])�fieldsr� rl r/ c C s6 t |�d d d }dd� |d|� D �}||d� }g }d}t|�D �]�\}} |t|d d � d|d d > @ r�|�d� qF| d tjtjtjtjtj fv r�| � || �\}}|�|� qF| d tj tj fv r�| � || �\}}|�|� qF| d tjtjfv �r | �||�\}}|�|� qF| d tjtjtjfv �rX| �|| d �\}}|�|� qF| d tjk�r�| �|�\}}|�|� qF| d tjk�r�t�|�\}}|�t�|�� qF| d t j k�s�| d d k�r�t�|�\}}|�|� qFt�|�\}}z|�|� |�� W qF t �y* |�|� Y qF0 qFt |�S ) z(Parse values from a binary result packetr� r) r� c S s g | ] }t |��qS r3 )rV )rF r� r3 r3 r4 r� rJ z6MySQLProtocol._parse_binary_values.<locals>.<listcomp>r Nr �? )!rE � enumeraterV rQ r r� r� r� r� r� r� r� �FLOATr� �DECIMALZ NEWDECIMALr� r� �DATEr� r� �TIMEr� ZVECTORr r� r Z_vector_to_pythonr ZBINARYr< �UnicodeDecodeError�tuple) r� r� r� rl Znull_bitmap_length� null_bitmaprN r� �posr� r3 r3 r4 �_parse_binary_values� s\ $ � � z"MySQLProtocol._parse_binary_valueszDTuple[List[Tuple[BinaryProtocolType, ...]], Optional[EofPacketType]])r� �columnsr� rl r/ c C s� g }d}d}d}|durq�||kr$q�t |�� �} | d dkrL| �| �}d}n&| d dkrrd}| �|| dd� |�}|du r�|dur�|�|� n|du r�|du r�t| ��|d7 }q||fS )zwRead MySQL binary protocol result Reads all or given number of binary resultset rows from the socket. Nr r0 r( r1 r )r- r� r� r� rQ r ) r� r� r� r� rl r� r� rN r� r� r3 r3 r4 �read_binary_result5 s* z MySQLProtocol.read_binary_resultzDict[str, int]c C s� | d dkst d��i }zht�| dd� d�\} |d< t�| d�\} |d< t�| d�\} |d < | d d� } t�| d�\} |d < W n. ty� } zt d�|�W Y d}~n d}~0 0 |S ) z(Parse a MySQL Binary Protocol OK packet.r0 r z Failed parsing Binary OK packetr1 Nr r) Z num_columnsZ num_paramsr r� )r r r? r� )r� Zok_pktri r3 r3 r4 �parse_binary_prepare_okZ s z%MySQLProtocol.parse_binary_prepare_okzTuple[bytes, int, int])r� r/ c C s� d}d}| dk rX| dkr$d}t j}q�| dkr8d}t j}q�| dkrLd}t j}q�d }t j}nJd }| d krpd }t j}n2| d kr�d}t j}n | dkr�d}t j}n t j}d}t�|| �||fS )z0Prepare an integer for the MySQL binary protocolNr i����r� i ���r� i �r� r� � r* rK i�� rp l �� r� z<Q)r r� r� r� r� rO rP )r� r� r� r� r3 r3 r4 �prepare_binary_integerl s6 z$MySQLProtocol.prepare_binary_integerz'Union[datetime.date, datetime.datetime]c C s� t | tj�rtj}n t | tj�r(tj}ntd��t�| j �t� | j �t� | j �g}t | tj�r�|� t� | j�t� | j�t� | j�g� | jdkr�|�t�| j�� d�|�}t� t|��| |fS )a� Prepare a timestamp object for the MySQL binary protocol This method prepares a timestamp of type datetime.datetime or datetime.date for sending over the MySQL binary protocol. A tuple is returned with the prepared value and field type as elements. Raises ValueError when the argument value is of invalid type. Returns a tuple. z2Argument must a datetime.datetime or datetime.dater rJ )� isinstancer� r r� r� r� r� r ry r� rg r� r� �extendr� r� r� r� rQ rx rS rE )r� r� �chunks�packedr3 r3 r4 �prepare_binary_timestamp� s( � �� z&MySQLProtocol.prepare_binary_timestampz(Union[datetime.timedelta, datetime.time]c C s t | tjtjf�std��tj}d}d}tg �}t | tj�r�| jdk rJd}t | j d�\}}t |d�\}}|� t � t| j��t �|�t �|�t �|�g� | j}n6|� t � d�t �| j�t �| j�t �| j�g� | j}|r�|�t � |�� |�t �|�� d�|�} t �t| ��| |fS )a� Prepare a time object for the MySQL binary protocol This method prepares a time object of type datetime.timedelta or datetime.time for sending over the MySQL binary protocol. A tuple is returned with the prepared value and field type as elements. Raises ValueError when the argument value is of invalid type. Returns a tuple. z3Argument must a datetime.timedelta or datetime.timer Nr i �< rJ )r� r� r� �timer� r r� r r� �divmodr� r� r rx �absrg r� r� r� r� r� rQ � appendleftrS rE ) r� r� �negativer� r� r� � remainderZminsZsecsr� r3 r3 r4 �prepare_binary_time� s@ �� �� z!MySQLProtocol.prepare_binary_time)� statement�paramr} r/ c C s d� t�| �t�|�|g�S )zMPrepare long data for prepared statements Returns a string. rJ rw )r r r} r3 r3 r4 �prepare_stmt_send_long_data� s z)MySQLProtocol.prepare_stmt_send_long_datar3 z Sequence[BinaryProtocolType]r z Optional[Dict[int, Tuple[bool]]]z.Optional[List[Tuple[str, BinaryProtocolType]]]) r r} � parametersr� �long_data_usedrl � query_attrs�converter_str_fallbackr/ c C s d} dgt |�d d } g } g } d} t |�}g }|s:|n|t }|dkrNd}|du rZi }|r�t|�}|D ]\}}|�|� qjdgt |�d d } |s�|�r*|t |�kr�td ��t|�D �]l\}}d}|du �r | |d d|d > O < | �t�tj �t�|� � q�||v �r6|| d �r,tj }ntj }�n�t |t ��r`| �|�\} }}| �| � �npt |t��r�|�|�}| �t�t |��| � tj }�n8t |t��r�| �t�t |��| � tj }�n t |t��r| �t�t t|��|���t|��|� � tj}n�t |t��r,| �t�d |�� tj}n�t |tjtjf��rZ| �|�\} }| �| � nvt |tj tj f��r�| � |�\} }| �| � nH|�r�t|��|�}| �t�t |��| � tj }nt d |j j!� d ���| �t�|�t�|� � |r�|d |kr�||| d �|�}|�t�t |��| � q�t�"|�t�|�t�"| �g}|du�r^|t |� }n|}|�r|du�r�|�t�|�� |�#d d� | D �� |�t�d�� d}| D ]N}|�|� |du�r�|d |k�r�|�||| � n |�d� |d7 }�q�| D ]}|�|� �qd�$|�S )z6Make a MySQL packet with the Statement Execute commandr r r� r� rJ Zutf8mb4r� NzTFailed executing prepared statement: data values does not match number of parametersr� z&MySQL binary protocol can not handle 'z ' objectsc S s g | ]}t �d |��qS )�B)rO rP )rF �bitr3 r3 r4 r� j rJ z3MySQLProtocol.make_stmt_execute.<locals>.<listcomp>r6 )%rE r �listrQ r r� r rg r ZNULLZBLOB�STRINGr� rV r� rZ rR Zlc_intr- r r� �floatrO rP r� r� r� r� r� r� r r � __class__�__name__rx r� rS ) r� r r} r r� r rl r r Ziteration_countr� rN �typesr� �data_lenZquery_attr_namesr� �attr_valr� r� �_flagsr� re r� Zparameter_countr� �a_typeZa_valuer3 r3 r4 �make_stmt_execute� s� � � � �� ��� z MySQLProtocol.make_stmt_execute)NFN)N)r )r� )T)r )r� )r� )r r� )r3 r3 r Nr� NF)%r � __module__� __qualname__�__doc__� staticmethodr5 r> rB rU rY rj �DEFAULT_CHARSET_ID�DEFAULT_MAX_ALLOWED_PACKETrv rz r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r3 r3 r3 r4 r, V s� �"A�,z� 3 �, � �> �%!*7 �r, )<r � __future__r r� rO � collectionsr �decimalr r �typingr r r r r r r r r rD r � constantsr r r r r � conversionr �errorsr r r r r Zpluginsr r Z plugins.caching_sha2_passwordr r r r r! r" r# r$ r% �networkr& r� r: r2 Z OK_STATUSr@ Z ERR_STATUSr r r, r3 r3 r3 r4 �<module> s2 , $