Ë
|
^i$. ã óÀ 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« Zy)é )ÚMBLENGTH)Ú
|
FIELD_TYPEÚ SERVER_STATUS)Úerré NFéû éü éý éþ c ó` d t dt | « « t dd« D ]F }t j |« }t d||j
|
j |j fz « H t d« t dt t | « d« d « D cg c]
|
}| ||d z }}|D ]S }t d
|
j d |D « « d d t |« z
|
z z d z dj fd|D « « z « U t d« t « y # t $ r Y ¬w xY wc c}w )Nc ó4 d| cxk rdk r t | « S yy)Né é ú.)Úchr)Údatas õc H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\pymysql/protocol.pyÚ printablez dump_packet.<locals>.printable s! Ø Ô Ò Üt9Ð ð áó zpacket length:r é zcall[%d]: %s (line %d)zB------------------------------------------------------------------r é é ú c 3 ó$ K | ] }|d
|
yw)Ú02XN© )Ú.0Úxs r ú <genexpr>z dump_packet.<locals>.<genexpr>& s è ø Ò+ A#wZÑ+ùs z z Ú c 3 ó. K | ] } |« y w©Nr )r r r s r r z dump_packet.<locals>.<genexpr>) s øè ø Ò. qi lÑ.ùs ) ÚprintÚlenÚrangeÚsysÚ _getframeÚf_codeÚco_nameÚf_linenoÚ
|
ValueErrorÚminÚjoin)r ÚiÚfÚ dump_dataÚdr s @r Ú dump_packetr2 s$ ø òð
|
Ü Ð ¤ D£ Ô*Üq!ò PAÜ aÓ AÜ Ð*¨a°·±×1AÑ1AÀ1Ç:Á:Ð-NÑNÕ Oð Pô hô ,1°´C¼¸D» À3Ó4GÈÓ+LÖM aa!b&Ò!ÐMIÐMØ ò
|
Ü Ø HHÑ+¨Ô+Ó +ØrC F{Ñ#ñ $àñ ð ggÓ.¨AÔ.Ó.ñ /õ
|
ð
|
ô
|
(OÜ
Gøô ò Ù ð üâMs A5D Â D+Ä D(Ä'D(c ó´ e Zd ZdZdZd Zd Zd Zd Zd Z d dZ
|
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 y ) Ú MysqlPacketzrRepresentation of a MySQL response packet.
|
|
Provides an interface for reading/parsing the packet results.
|
©Ú _positionÚ_datac ó d| _ || _ y )Nr r5 ©Úselfr Úencodings r Ú__init__zMysqlPacket.__init__7 s ØØ
|
r c ó | j S r" ©r7 ©r: s r Ú get_all_datazMysqlPacket.get_all_data; s ØzzÐr c
|
óX | j | j | j |z }t |« |k7 r`d| dt |« d| j dt | j « }t rt |« | j « 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: )r7 r6 r$ ÚDEBUGr# ÚdumpÚAssertionError)r: ÚsizeÚresultÚerrors r ÚreadzMysqlPacket.read> s àDNN¨d¯n©n¸tÑ.CÐEÜ v;$Ò ð Ø 6 ¬C°«K¨=¸ ÀdÇnÁnÐEUÐUeÔfiÐjn×jtÑjtÓfuÐevðxð õ Üe Ø Ü Ó'Ð 'Ø $Ñ Ø r c óF | j | j d }d| _ |S )z`Read all remaining data in the packet.
|
|
(Subsequent read() will return errors.)
|
N©r7 r6 ©r: rF s r Úread_allzMysqlPacket.read_allM s% ð
|
DNNÐ ,Ð-Ø Ø r c ó | j |z }|dk s|t | j « kD rt d| d| « || _ y)z1Advance the cursor in data buffer 'length' bytes.r zInvalid advance amount (z) for cursor. Position=N)r6 r$ r7 Ú Exception)r: ÚlengthÚ new_positions r ÚadvancezMysqlPacket.advanceV sN à~~¨Ñ. Ø !Ò |¬c°$·*±*«oÒ =ÜØ*¨6¨(Ð2JÈ<È.ÐYóð ð &r c óh |dk s|t | j « kD rt d|z « || _ y)z9Set the position of the data buffer cursor to 'position'.r z)Invalid position to rewind cursor to: %s.N)r$ r7 rN r6 )r: Úpositions r ÚrewindzMysqlPacket.rewind_ s0 à a<8¤c¨$¯*©*£oÒ5ÜÐ GÈ(Ñ RÓSÐ SØ!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: rS rO s r Ú get_byteszMysqlPacket.get_bytese s ð zz( h°Ñ&7Ð9Ð9r c ób | j | j }| xj dz c_ |S ©Nr rJ rK s r Ú
|
read_uint8zMysqlPacket.read_uint8p s' ØDNNÑ+Ø !ÑØ r c ó t j d| j | j « d }| xj dz c_ |S )Nz<Hr é ©ÚstructÚ unpack_fromr7 r6 rK s r Ú read_uint16zMysqlPacket.read_uint16u ó6 Ü×#Ñ# D¨$¯*©*°d·n±nÓEÀaÑHØ !ÑØ r c ó t j d| j | j « \ }}| xj dz c_ ||dz z S )Nz<HBé r r\ )r: ÚlowÚhighs r Ú read_uint24zMysqlPacket.read_uint24z s? Ü×&Ñ& u¨d¯j©j¸$¿.¹.ÓI TØ !ÑØdbjÑ!Ð!r c ó t j d| j | j « d }| xj dz c_ |S )Nz<Ir é r\ rK s r Ú read_uint32zMysqlPacket.read_uint32 r` r c ó t j d| j | j « d }| xj dz c_ |S )Nz<Qr é r\ rK s r Ú read_uint64zMysqlPacket.read_uint64 r` r c ó¤ | j j d| j « }|dk ry | j | j | }|dz | _ |S )Nó r r )r7 Úfindr6 )r: Úend_posrF s r Ú read_stringzMysqlPacket.read_string sH Ø**// %¨¯ © Ó8Ø Q;ØØDNN¨WÐ5Ø 1Ø r c óä | j « }|t k( ry|t k r|S |t k( r| j « S |t
|
k( r| j « S |t k( r| j « S y)z´Read a 'Length Coded Binary' number from the data buffer.
|
|
Length coded numbers can be anywhere from 1 to 9 bytes depending
|
on the value of the first byte.
|
N) rY Ú NULL_COLUMNÚUNSIGNED_CHAR_COLUMNÚUNSIGNED_SHORT_COLUMNr_ ÚUNSIGNED_INT24_COLUMNre ÚUNSIGNED_INT64_COLUMNrk )r: Úcs r Úread_length_encoded_integerz'MysqlPacket.read_length_encoded_integer sv ð OOÓ Ø Ò ØØ Ô#Ò #ØHØ Ô'Ò 'Ø×#Ñ#Ó%Ð %Ø Ô'Ò 'Ø×#Ñ#Ó%Ð %Ø Ô'Ò 'Ø×#Ñ#Ó%Ð %ð (r c óJ | j « }|y| j |« S )a Read a 'Length Coded String' from the data buffer.
|
|
A 'Length Coded String' consists first of a length coded
|
(unsigned, positive) integer represented in 1-9 bytes followed by
|
that many bytes of binary data. (For example "cat" would be "3cat".)
|
N)rx rH )r: rO s r Úread_length_coded_stringz$MysqlPacket.read_length_coded_string£ s) ð ×1Ñ1Ó3Ø >ØØyyÓ Ð r c óº t j |« }|j | j | j « }| xj |j
|
z c_ |S r" )r] ÚStructr^ r7 r6 rE )r: ÚfmtÚsrF s r Ú read_structzMysqlPacket.read_struct¯ s? Ü MM#Ó Ø tzz¨4¯>©>Ó:Ø !&&Ñ Ø r c óZ | j d dk( xr t | j « dk\ S )Nr r ©r7 r$ r? s r Ú is_ok_packetzMysqlPacket.is_ok_packetµ s' àzz!} Ñ!Ò:¤c¨$¯*©*£o¸Ñ&:Ð:r c óZ | j d dk( xr t | j « dk S )Nr r é r r? s r Ú is_eof_packetzMysqlPacket.is_eof_packet¹ s) ð zz!} Ñ$Ò<¬¨T¯Z©Z« ¸1Ñ)<Ð<r c ó& | j d dk( S )Nr r r> r? s r Úis_auth_switch_requestz"MysqlPacket.is_auth_switch_request¿ s àzz!} Ñ$Ð$r c ó& | j d dk( S )Nr r r> r? s r Úis_extra_auth_dataz MysqlPacket.is_extra_auth_dataà s àzz!} Ñ!Ð!r c ó@ | j d }d|cxk xr dk S c S )Nr r éú r> )r: Ú field_counts r Úis_resultset_packetz MysqlPacket.is_resultset_packetÇ s% Øjj m ØKÖ& 3Ñ&Ð&Ñ&Ð&r c ó& | j d dk( S )Nr r r> r? s r Úis_load_local_packetz MysqlPacket.is_load_local_packetË ó Øzz!} Ñ$Ð$r c ó& | j d dk( S )Nr éÿ r> r? s r Úis_error_packetzMysqlPacket.is_error_packetÎ r r c óF | j « r| j « y y r" )r Úraise_for_errorr? s r Ú check_errorzMysqlPacket.check_errorÑ s Ø × Ñ Ô !Ø × Ñ Õ "ð "r c óÈ | j « | j d« | j « }t r t d|« t j | j « y )Nr zerrno =)rT rQ r_ rB r# r Úraise_mysql_exceptionr7 )r: Úerrnos r r zMysqlPacket.raise_for_errorÕ sC Ø Ø QØ× Ñ Ó"Ý Ü )UÔ #Ü ×!Ñ! $§*¡*Õ-r c ó. t | j « y r" )r2 r7 r? s r rC zMysqlPacket.dumpÝ s ÜDJJÕ r N)r )r ) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú __slots__r< r@ rH rL rQ rT rV rY r_ re rh rk rp rx rz r r r
r r r r r r r rC r r r r4 r4 / s ñð
|
'Iòòò ò ò&ó"ó :òò
|
ò
|
"ò
|
ò
|
ò
|
ò&ò$
|
!òò ;ò=ò %ò"ò'ò%ò%ò#ò.ó r r4 c ó. e Zd ZdZd Zd Zd Zd Zd Zy)ÚFieldDescriptorPacketzçA 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 óT t j | ||« | j |« y r" )r4 r< Ú_parse_field_descriptorr9 s r r< z FieldDescriptorPacket.__init__è s" Ü× Ñ T 4¨Ô2Ø ×$Ñ$ XÕ.r c óØ | j « | _ | j « | _ | j « j |« | _ | j « j |« | _ | j « j |« | _ | j « j |« | _ | j d« \ | _ | _
|
| _ | _ | _ y)z
Parse the 'Field Descriptor' (Metadata) packet.
|
|
This is compatible with MySQL 4.1+ (not compatible with MySQL 4.0).
|
z <xHIBHBxxN)rz ÚcatalogÚdbÚdecodeÚ
|
table_nameÚ org_tableÚnameÚorg_namer Ú charsetnrrO Ú type_codeÚflagsÚscale)r: r; s r r£ z-FieldDescriptorPacket._parse_field_descriptorì s¾ ð
|
×4Ñ4Ó6 Ø×/Ñ/Ó1Ø ×7Ñ7Ó9×@Ñ@ÀÓJØ ×6Ñ6Ó8×?Ñ?ÀÓIØ×1Ñ1Ó3×:Ñ:¸8ÓD Ø ×5Ñ5Ó7×>Ñ>¸xÓH ð × Ñ [Ó )ñ
|
Ø NØ KØ NØ JØ Jr c ó¨ | j | j d| j « | j « | 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® r? s r Ú descriptionz!FieldDescriptorPacket.description sN ð IIØ NNØ Ø × "Ñ "Ó $Ø × "Ñ "Ó $Ø JJØ JJNaÑ ð
|
ð
|
r c ó² | j t j k( r/t j | j
|
d« }| j |z S | j S rX )r r Ú
|
VAR_STRINGr Úgetr¬ rO )r: Úmblens r r± z'FieldDescriptorPacket.get_column_length sA Ø >>Z× 2Ñ 2Ò 2Ü LL § ¡ °Ó3EØ;; %Ñ'Ð 'Ø{{Ðr c ó¦ dj | j | j | j | j | j
|
| j « S )Nz&{} {!r}.{!r}.{!r}, type={}, flags={:x})ÚformatÚ __class__r¦ r¨ rª r r® r? s r Ú__str__z FieldDescriptorPacket.__str__ s? Ø7×>Ñ>Ø NNØ GGØ OOØ IIØ NNØ JJó
|
ð
|
r N) r r r r r< r£ r² r± rº r r r r¡ r¡ á s ñò /ò*ò*
|
|
òó
|
r r¡ c ó e Zd ZdZd Zd Zy)Ú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 óþ |j « s.t dt | j j « z dz « || _ | j
|
j d« | j
|
j « | _ | j
|
j « | _ | j d« \ | _ | _ | j
|
j « | _ | j t j z | _ y )NzCannot create z object from invalid packet typer z<HH)r r+ Ústrr¹ r ÚpacketrQ rx Ú affected_rowsÚ insert_idr Ú server_statusÚ warning_countrL Úmessager ÚSERVER_MORE_RESULTS_EXISTSÚhas_next©r: Ú from_packets r r< zOKPacketWrapper.__init__% sÈ Ø×'Ñ'Ô)Ü Ø Üdnn×-Ñ-Ó.ñ/à4ñ5óð ð " Ø ×ÑAÔ à ![[× DÑ DÓ FÔØ ×@Ñ@ÓBØ15×1AÑ1AÀ%Ó1HÑ.ÔDÔ .Ø{{×+Ñ+Ó- Ø ×*Ñ*¬]×-UÑ-UÑU r c ó. t | j |« S r" ©Úgetattrr¿ ©r: Úkeys r Ú __getattr__zOKPacketWrapper.__getattr__6 ó Üt{{ CÓ(Ð(r N©r r r r r< rÎ r r r r¼ r¼ s ñò Vó")r r¼ c ó e Zd ZdZd Zd Zy)Ú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 ó0 |j « st d| j d« || _ | j j d« \ | _ | _ t rt d| j « | j t j z | _ y )NúCannot create 'ú!' object from invalid packet typez<xhhzserver_status=) r
r+ r¹ r¿ r rà r rB r# r rÅ rÆ rÇ s r r< zEOFPacketWrapper.__init__A s Ø×(Ñ(Ô*Ü Ø! $§.¡.Ð!1Ð1RÐSóð ð " Ø15·±×1HÑ1HÈÓ1PÑ.ÔDÔ .Ý Ü Ð" D×$6Ñ$6Ô 7Ø ×*Ñ*¬]×-UÑ-UÑU 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ó)r rÒ c ó e Zd ZdZd Zd Zy)Ú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 óâ |j « st d| j d« || _ | j j « dd | _ t rt d| j
|
« y y )NrÔ rÕ r z filename=)r r+ r¹ r¿ r@ ÚfilenamerB r# rÇ s r r< z LoadLocalPacketWrapper.__init__X sg Ø×/Ñ/Ô1Ü Ø! $§.¡.Ð!1Ð1RÐSóð ð " Ø ×0Ñ0Ó2°1°2Ð6 Ý Ü +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& rB rr rs rt ru rv r2 r4 r¡ r¼ rÒ rØ r r r ú<module>rÞ sw ðõ ß 0Ý ã Û
|
ð à ØÐ ØÐ ØÐ ØÐ ò ÷4o ñ o ôd:
|
Kô :
|
÷z)ñ )÷8)ñ )÷.)ò )r
|
