OR
d dl mZ d dlmZmZ d dlmZ ddlZddlZdZ dZ
dZ dZ d Z
d
Zd Z G d d
Z G d de Z G d d Z G d d Z G d d ZdS ) )MBLENGTH)
FIELD_TYPE
SERVER_STATUS)err NF c d t dt t dd D ]:}t j | }t d||j j |j fz ;t d n# t $ r Y nw xY w fdt dt t d d
D }|D ]i}t d
d |D d
d
t | z
z z dz d
fd|D z jt d t d S )Nc D d| cxk rdk rn nt | S dS )N .)chr)datas p/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/pymysql/protocol.py printablez dump_packet..printable s5
t99 s zpacket length:r zcall[%d]: %s (line %d)zB------------------------------------------------------------------c * g | ]}||d z S ) ).0ir s r
z dump_packet..# s& MMMaa!b&j!MMMr r r c 3 K | ]}|d V dS )02XNr )r xs r z dump_packet..& s& ++AZZ++++++r z z c 3 . K | ]} | V d S Nr )r r! r s r r" z dump_packet..) s+ ..qiill......r ) printlenrangesys _getframef_codeco_namef_lineno
ValueErrorminjoin)r r f dump_datadr s ` @r dump_packetr4 s
D ***q! P PA
a A *a1A1:-NN O O O O
h
MMMM5CD 34G4G+L+LMMMI
HH+++++ + +rCFF{#
$
gg....A.....
/
(OOO GGGGGs A7A? ?
B B c e Zd ZdZdZd Zd Zd Zd Zd Z d d Z
d!d Z d Z d
Z
d Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d Z d Z d S )" MysqlPacketzrRepresentation of a MySQL response packet.
Provides an interface for reading/parsing the packet results.
_position_datac " d| _ || _ d S )Nr r7 selfr encodings r __init__zMysqlPacket.__init__7 s
r c | j S r% r9 r< s r get_all_datazMysqlPacket.get_all_data; s
zr c
Z | j | j | j |z }t | |k rkd| dt | d| j dt | j }t r#t | | t
| | xj |z
c_ |S )zCRead the first 'size' bytes in packet and advance cursor past them.z-Result length not requested length:
Expected=z
. Actual=z
. Position: z. Data Length: )r9 r8 r' DEBUGr& dumpAssertionError)r< sizeresulterrors r readzMysqlPacket.read> s DNdnt.C DE v;;$ x x x,/KKx xFJnx xfijnjtfufux x
e '' ' $
r c < | j | j d }d| _ |S )z`Read all remaining data in the packet.
(Subsequent read() will return errors.)
Nr9 r8 r< rH s r read_allzMysqlPacket.read_allM s$
DN , ,-
r c | j |z }|dk s|t | j k rt d| d| || _ dS )z1Advance the cursor in data buffer 'length' bytes.r zInvalid advance amount (z) for cursor. Position=N)r8 r' r9 Exception)r< length new_positions r advancezMysqlPacket.advanceV s] ~. ! |c$*oo = =Y6YY<YY
&r r c t |dk s|t | j k rt d|z || _ dS )z9Set the position of the data buffer cursor to 'position'.r z)Invalid position to rewind cursor to: %s.N)r' r9 rP r8 )r< positions r rewindzMysqlPacket.rewind_ s< a<<8c$*oo55 G( RSS S!r r c & | j |||z S )a> Get 'length' bytes starting at 'position'.
Position is start of payload (first four packet header bytes are not
included) starting at index '0'.
No error checking is done. If requesting outside end of buffer
an empty string (or string shorter than 'length') may be returned!
r@ )r< rU rQ s r get_byteszMysqlPacket.get_bytese s z(h&7899r c J | j | j }| xj dz
c_ |S Nr rL rM s r
read_uint8zMysqlPacket.read_uint8p s% DN+ !
r c r t j d| j | j d }| xj dz
c_ |S )Nz
4yy r c t j | }| | j | j }| xj |j z
c_ |S r% )r_ Structr` r9 r8 rG )r< fmtsrH s r read_structzMysqlPacket.read_struct s? M# tz4>:: !&
r c T | j d dk ot | j dk S )Nr r r9 r' rA s r is_ok_packetzMysqlPacket.is_ok_packet s% z!}!:c$*oo&::r c T | j d dk ot | j dk S )Nr r r rA s r
is_eof_packetzMysqlPacket.is_eof_packet s' z!}$<TZ 1)< rB rJ rN rS rV rX r[ ra rg rj rm rr rz r| r r r r r r r r r r rE r r r r6 r6 / s
'I
& & &" " " " : : : :
" " "
& & &$
!
!
! ; ; ;= = = % % %" " "' ' '% % %% % %# # #. . . r r6 c 0 e Zd ZdZd Zd Zd Zd Zd ZdS )FieldDescriptorPacketzA MysqlPacket that represents a specific column's metadata in the result.
Parsing is automatically done and the results are exported via public
attributes on the class such as: db, table_name, name, length, type_code.
c h t | || | | d S r% )r6 r> _parse_field_descriptorr; s r r> z FieldDescriptorPacket.__init__ s4 T4222 $$X.....r c 2 | | _ | | _ | | | _ | | | _ | | | _ | | | _ | d \ | _ | _
| _ | _ | _
dS )zParse the 'Field Descriptor' (Metadata) packet.
This is compatible with MySQL 4.1+ (not compatible with MySQL 4.0).
z >xHH
[ ) )
N K N J JJJr c | j | j d| | | j | j dz dk fS )zBProvides a 7-item tuple compatible with the Python PEP249 DB Spec.Nr] r )r r get_column_lengthr r rA s r descriptionz!FieldDescriptorPacket.description sL
I N " " $ $ " " $ $ J JNa
r c | j t j k r$t j | j d }| j |z S | j S rZ )r r
VAR_STRINGr getr rQ )r< mblens r r z'FieldDescriptorPacket.get_column_length
s: >Z 2 2 2 L 33E;%' '{r c r d | j | j | j | j | j | j S )Nz&{} {!r}.{!r}.{!r}, type={}, flags={:x})format __class__r r r r r rA s r __str__z FieldDescriptorPacket.__str__ s8 7>> N G O I N J
r N) r r r r r> r r r r r r r r r si / / /* * **
r r c e Zd ZdZd Zd ZdS )OKPacketWrapperz
OK Packet Wrapper. It uses an existing packet object, and wraps
around it, exposing useful variables while still providing access
to the original packet objects variables and methods.
c | s,t dt | j j z dz || _ | j d | j | _ | j | _ |
d \ | _ | _ | j
| _ | j t j z | _ d S )NzCannot create z object from invalid packet typer z zOKPacketWrapper.__init__% s '')) dn-../45
" A ![ D D F F @@BB151A1A%1H1H.D .{++-- *]-UU
r c , t | j | S r% getattrr r< keys r __getattr__zOKPacketWrapper.__getattr__6 t{C(((r Nr r r r r> r r r r r r s? V V V") ) ) ) )r r c e Zd ZdZd Zd ZdS )EOFPacketWrapperz
EOF Packet Wrapper. It uses an existing packet object, and wraps
around it, exposing useful variables while still providing access
to the original packet objects variables and methods.
c $ | st d| j d || _ | j d \ | _ | _ t rt d| j | j t j
z | _ d S )NCannot create '!' object from invalid packet typez zEOFPacketWrapper.__init__A s ((** S$.SSS
" 151H1H1P1P.D . 8 "D$6 7 7 7 *]-UU
r c , t | j | S r% r r s r r z EOFPacketWrapper.__getattr__M r r Nr r r r r r : s?
V
V
V) ) ) ) )r r c e Zd ZdZd Zd ZdS )LoadLocalPacketWrapperz
Load Local Packet Wrapper. It uses an existing packet object, and wraps
around it, exposing useful variables while still providing access
to the original packet objects variables and methods.
c | st d| j d || _ | j dd | _ t rt d| j d S d S )Nr r r z filename=)r r. r r rB filenamerD r& r s r r> z LoadLocalPacketWrapper.__init__X s //11 S$.SSS
" 00221226
. +t} - - - - - . .r c , t | j | S r% r r s r r z"LoadLocalPacketWrapper.__getattr__c r r Nr r r r r r Q s< . . .) ) ) ) )r r )charsetr constantsr r r# r r_ r) rD rt ru rv rw rx r4 r6 r r r r r r r r sf 0 0 0 0 0 0 0 0
4o o o o o o o o d:
:
:
:
:
K :
:
:
z) ) ) ) ) ) ) )8) ) ) ) ) ) ) ).) ) ) ) ) ) ) ) ) )r