?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/__pycache__/protocol.cpython-39.pyc
???????
a ��Jh3� � @ sL 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:dZ;dZ<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~ddddddddd�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�dDdEdd4dFdG�dHdI�Zedd8dJdK�dLdM��Zedd8dNdK�dOdP��Zed�dddRdS�dTdU��ZedddVdW�dXdY��ZeddZd.�d[d\��Z d�d]ddd^d_�d`da�Z d�dDd]ddd4dbdc�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/ � r4 �M/home/agenciai/.local/lib/python3.9/site-packages/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 r1 z'Failed parsing AuthSwitchRequest packetr2 N� ��end���r )�AUTH_SWITCH_STATUSr r � read_string�decode)r/ � plugin_namer4 r4 r5 �parse_auth_switch_requestt 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 r1 Nr z.Failed parsing AuthNextFactor packet (invalid)r7 r8 )r �read_int� MFA_STATUSr r< r= )r/ �statusr> r4 r4 r5 �parse_auth_next_factor� s z$MySQLProtocol.parse_auth_next_factorzDict[str, str])� conn_attrsr0 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�rD r4 r5 � <genexpr>� � z0MySQLProtocol.make_conn_attrs.<locals>.<genexpr>�<BrK ) �sumrF �keys�values�struct�pack�append�encode�join)rD � attr_nameZconn_attrs_lenZconn_attrs_packetr4 rI r5 �make_conn_attrs� s � ��z MySQLProtocol.make_conn_attrs�intz Optional[str])� client_flags�databaser0 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 r7 )r ZCONNECT_WITH_DBrS )rX rY r4 r4 r5 �connect_with_db� s ���z MySQLProtocol.connect_with_dbNF�str�boolzOptional[Dict[str, Any]]z Tuple[bytes, MySQLAuthPlugin])� auth_data�username�password� auth_plugin�auth_plugin_class� ssl_enabled� plugin_configr0 c C s� |s |dkr dt |||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� ���t�t|��| }||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. rE r7 )rb NzFailed authentication: z8Got NULL auth response while authenticating with plugin ) r r � auth_response� TypeErrorr �namer �lc_intrF ) r] r^ r_ r` ra rb rc � auth_strategyrd �errr4 r4 r5 �auth_plugin_first_response� s* " ��&��z(MySQLProtocol.auth_plugin_first_responser r" zOptional[Dict[str, str]])� handshaker^ r_ rY �charsetrX �max_allowed_packetr` ra rD �is_change_user_requestrb rc r0 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 �||�� | �rN|�t� d|�� |tj@ �rl|�|� � 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 %srL ZsxZxxxxxxxxxxxxxxxxxxxxxxxz<IIB)r] r^ r_ r` ra rb rc �<Hr7 rK )rS r �debugr �getre �KeyErrorrR rP rQ rF r Z CHANGE_USERr- rj rZ r � PLUGIN_AUTHZ CONNECT_ARGSrV rT )rk r^ r_ rY rl rX rm r` ra rD rn rb rc Z b_usernameZresponse_payloadri Zfillerrd rh r4 r4 r5 � make_auth sl 3 �� ���� � zMySQLProtocol.make_auth)rl rX rm r0 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 rK s )rT r � int4store� int1store)rl rX rm r4 r4 r5 � make_auth_ssl� s ��zMySQLProtocol.make_auth_sslzOptional[bytes])�command�argumentr0 c C s t �| �}|du r|S || S )z(Make a MySQL packet containing a commandN)r rw )ry rz �datar4 r4 r5 � make_command� s zMySQLProtocol.make_commandr )� statement_id�rowsr0 c C s t �| �t �|� S )z0Make a MySQL packet with Fetch Statement command)r rv )r} r~ r4 r4 r5 �make_stmt_fetch� s z MySQLProtocol.make_stmt_fetch)�packetr0 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 r2 �protocolz$Protocol mismatch; server version = z, client version = Nr7 r8 Zserver_version_originalz<I8sx2sBH2sBxxxxxxxxxx� Zserver_threadidrl Z server_statusrK � � r: z5.5.8r` �utf-8Zmysql_native_passwordr] � capabilities) rP �unpack�PROTOCOL_VERSIONr r r< r= Zintreadr ZSECURE_CONNECTION�minrt � startswith) r� �resZ auth_data1Z capabilities1Z capabilities2Zauth_data_lengthr� Z auth_data2�sizer4 r4 r5 �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-packetr1 r z#Failed parsing OK packet (invalid).r� r2 Z field_countNZ affected_rowsZ insert_idz<HH� status_flag� warning_countZinfo_msgr� zFailed parsing OK packet.)r rP r� r � read_lc_int�read_lc_stringr= � ValueError)r� Z ok_packetri r4 r4 r5 �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 setr1 Nr zFailed parsing column count)r r� rP �errorr� r )r� �countri r4 r4 r5 �parse_column_count s z MySQLProtocol.parse_column_countr� r )r� �encodingr0 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.r1 Nz <xHIBHBxxz!Failed parsing column information) r r� rP r� r� r r= r ZNOT_NULL)r� r� �_rf rl Z column_type�flagsr4 r4 r5 � 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-packetr1 r zFailed parsing EOF packet.z<xxxBBHHNr r( � r) r� � r� )r� rP r� r� r rF )�selfr� �err_msgr� �unpackedri r4 r4 r5 � parse_eof6 s zMySQLProtocol.parse_eofTr$ )r� � with_headerr0 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 informationrK r1 Ns c S s g | ] }|� � �qS r4 )�strip)rG �vr4 r4 r5 � <listcomp>X rK z2MySQLProtocol.parse_statistics.<locals>.<listcomp>� :r) r� z (�:ro ) �splitr� r r= rW rs r r �repr) r� r� �errmsgr� �pairsZlbl�pair�valri r4 r4 r5 �parse_statisticsJ s* >z MySQLProtocol.parse_statisticsr& zTuple[int, ...]zATuple[List[Tuple[Optional[bytes], ...]], Optional[EofPacketType]])�sock�versionr� � read_timeoutr0 c C s( |}g }d}d}d} |s | |kr$�q |� |�} | �d�r�| dd� g} |� |�} | �d�rx| �| dd� � |� |�} qP| �| 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 ���r1 rK r( � r ) �recvr� rR r Zread_lc_string_listrT r� r. r ) r� r� r� r� r� r� r~ �eofZrowdata�ir� Zdatasr4 r4 r5 �read_text_resultg s6 z MySQLProtocol.read_text_resultzTuple[bytes, int])r� �fieldr0 c C s� |d t jkrd}d}nV|d t jkr0d}d}n>|d t jt jfv rNd}d}n |d t jkrfd}d}ntd ��|d tj@ r�|� � }| |d � t � || d |� �d fS ) z%Parse an integer from a binary packetr �<b�<hr) �<ir1 �<qr� zUnknown integer typer� Nr ) r �TINY�SHORT�INT24�LONG�LONGLONGr� r ZUNSIGNED�upperrP r� )r� r� �format_�lengthr4 r4 r5 �_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� �<dr1 z<fNr )r �DOUBLErP r� )r� r� r� r� r4 r4 r5 �_parse_binary_float� s z!MySQLProtocol._parse_binary_float�utf8zTuple[bytes, Decimal])r� rl r0 c C s t �| �\} }| t|�|��fS )z(Parse a New Decimal from a binary packet)r r� r r= )r� rl �valuer4 r4 r5 �_parse_binary_new_decimal� s z'MySQLProtocol._parse_binary_new_decimalz?Tuple[bytes, Optional[Union[datetime.date, datetime.datetime]]])r� � field_typer0 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 Nr1 rp r r� )�year�month�dayr� � �<Ir� r2 � )r� r� r� �hour�minute�second� microsecond)rP r� r �DATETIME� TIMESTAMP�datetime�date)r� r� r� r� r� r� r� �mcsr4 r4 r5 �_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� r2 r: r� r� )�days�seconds� microseconds�minutes�hours)r� � timedeltarP r� )r� r� r{ r� r� �tmpr4 r4 r5 �_parse_binary_time� s$ �z MySQLProtocol._parse_binary_timezList[DescriptionType]z Tuple[BinaryProtocolType, ...])�fieldsr� rl r0 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 r4 )rW )rG r� r4 r4 r5 r� rK z6MySQLProtocol._parse_binary_values.<locals>.<listcomp>r Nr �? )!rF � enumeraterW rR 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_bitmaprO r� �posr� r4 r4 r5 �_parse_binary_values� s\ $ � � z"MySQLProtocol._parse_binary_valueszDTuple[List[Tuple[BinaryProtocolType, ...]], Optional[EofPacketType]])r� �columnsr� rl r� r0 c C s� g }d}d}d} |durq�| |kr$q�t |�|��} | d dkrN| �| �}d}n&| d dkrtd}| �|| 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 r1 r( r2 r )r. r� r� r� rR r ) r� r� r� r� rl r� r~ r� rO r� r� r4 r4 r5 �read_binary_result8 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.r1 r z Failed parsing Binary OK packetr2 Nr} r) Z num_columnsZ num_paramsr r� )r r r@ r� )r� Zok_pktri r4 r4 r5 �parse_binary_prepare_ok^ s z%MySQLProtocol.parse_binary_prepare_okzTuple[bytes, int, int])r� r0 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* rL i�� rp l �� r� z<Q)r r� r� r� r� rP rQ )r� r� r� r� r4 r4 r5 �prepare_binary_integerp 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 rK )� isinstancer� r r� r� r� r� r � int2storer� rw r� r� �extendr� r� r� r� rR rv rT rF )r� r� �chunks�packedr4 r4 r5 �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 �< rK )r� r� r� �timer� r r� r r� �divmodr� r� r rv �absrw r� r� r� r� r� rR � appendleftrT rF ) r� r� �negativer� r� r� � remainderZminsZsecsr� r4 r4 r5 �prepare_binary_time� s@ �� �� z!MySQLProtocol.prepare_binary_time)� statement�paramr{ r0 c C s d� t�| �t�|�|g�S )zMPrepare long data for prepared statements Returns a string. rK )rT r rv r� )r r r{ r4 r4 r5 �prepare_stmt_send_long_data� s z)MySQLProtocol.prepare_stmt_send_long_datar4 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_fallbackr0 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� rK 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)rP rQ )rG �bitr4 r4 r5 r� n rK z3MySQLProtocol.make_stmt_execute.<locals>.<listcomp>r7 )%rF r �listrR r r� r rw r ZNULLZBLOB�STRINGr� rW r� r[ rS rg r. r r� �floatrP rQ r� r� r� r� r� r� r r � __class__�__name__rv r� rT ) r� r} r{ r r� r rl r r Ziteration_countr� rO �typesr� �data_lenZquery_attr_namesr� Zattr_valr� r� �_flagsr� rf r� Zparameter_countr� �a_typeZa_valuer4 r4 r5 �make_stmt_execute� s� � � � �� ��� z MySQLProtocol.make_stmt_execute)NFN)N)r )r� )T)r N)r� )r� )r r� N)r4 r4 r Nr� NF)%r � __module__� __qualname__�__doc__� staticmethodr6 r? rC rV rZ rj �DEFAULT_CHARSET_ID�DEFAULT_MAX_ALLOWED_PACKETru rx r| r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r4 r4 r4 r5 r- X s� � <�,y� 3 �0 � �> �&!*7 �r- )>r � __future__r r� rP � collectionsr �decimalr r �typingr r r r r r r r r rE 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; r3 Z OK_STATUSZ EOF_STATUSrA Z ERR_STATUSZLOCAL_INFILE_STATUSr r r- r4 r4 r4 r5 �<module> s6 , $
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????