Ë
|
Wñúho ã ó¾ d Z ddgZddlZddlZddlZ ddlZej ej ej ej dZ
|
ddl m Z mZ ddlmZ ddlmZmZmZmZmZ d d
|
lmZmZmZmZm Z m Z d d l m Z m Z m!Z!m"Z" d d l#m$Z$m%Z% de&de'fdZ( G d de « Z) G d de)« Z* G d de*« Z+ G d de « Z, G d de,« Z- G d de,« Z.y# e $ r dZY w xY w)zFModule implementing low-level socket communication with MySQL servers.ÚMySQLTcpSocketÚMySQLUnixSocketé N)ÚTLSv1úTLSv1.1úTLSv1.2úTLSv1.3)ÚABCÚabstractmethod)Údeque)ÚAnyÚDequeÚListÚOptionalÚTupleé )ÚInterfaceErrorÚNotSupportedErrorÚOperationalErrorÚProgrammingErrorÚReadTimeoutErrorÚWriteTimeoutError)Ú COMPRESSED_PACKET_HEADER_LENGTHÚMAX_PAYLOAD_LENGTHÚMIN_COMPRESS_LENGTHÚPACKET_HEADER_LENGTHé )Ú StreamWriterÚopen_connectionÚerrÚreturnc óf | j s t | « S | j d| j S )z`Reformat the IOError error message.
|
|
This function reformats the IOError error message.
|
ú )ÚerrnoÚstrÚstrerror)r s úNH:\Change_password\venv_build\Lib\site-packages\mysql/connector/aio/network.pyÚ _strioerrorr' I s, ð
|
993s8ÐG¨S¯Y©Y¨K°q¸¿ ¹ ¸Ð*GÐGó c ó e Zd ZdZe ddedededee dee dee d dfd
|
« Z
|
e dd e j ded ee d e fd « Zy)Ú NetworkBrokeraP Broker class interface.
|
|
The network object is a broker used as a delegate by a socket object. Whenever the
|
socket wants to deliver or get packets to or from the MySQL server it needs to rely
|
on its network broker (netbroker).
|
|
The netbroker sends `payloads` and receives `packets`.
|
|
A packet is a bytes sequence, it has a header and body (referred to as payload).
|
The first `PACKET_HEADER_LENGTH` or `COMPRESSED_PACKET_HEADER_LENGTH`
|
(as appropriate) bytes correspond to the `header`, the remaining ones represent the
|
`payload`.
|
|
The maximum payload length allowed to be sent per packet to the server is
|
`MAX_PAYLOAD_LENGTH`. When `send` is called with a payload whose length is greater
|
than `MAX_PAYLOAD_LENGTH` the netbroker breaks it down into packets, so the caller
|
of `send` can provide payloads of arbitrary length.
|
|
Finally, data received by the netbroker comes directly from the server, expect to
|
get a packet for each call to `recv`. The received packet contains a header and
|
payload, the latter respecting `MAX_PAYLOAD_LENGTH`.
|
NÚwriterÚaddressÚpayloadÚ packet_numberÚcompressed_packet_numberÚ write_timeoutr c ó K yw)a Send `payload` to the MySQL server.
|
|
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
|
broken down into packets.
|
|
Args:
|
sock: Object holding the socket connection.
|
address: Socket's location.
|
payload: Packet's body to send.
|
packet_number: Sequence id (packet ID) to attach to the header when sending
|
plain packets.
|
compressed_packet_number: Same as `packet_number` but used when sending
|
compressed packets.
|
write_timeout: Timeout in seconds before which sending a packet to the server
|
should finish else WriteTimeoutError is raised.
|
|
|
Raises:
|
:class:`OperationalError`: If something goes wrong while sending packets to
|
the MySQL server.
|
N© )Úselfr+ r, r- r. r/ r0 s r& ÚwritezNetworkBroker.writei ó è ø ùó ÚreaderÚ read_timeoutc ó K yw)aM Get the next available packet from the MySQL server.
|
|
Args:
|
sock: Object holding the socket connection.
|
address: Socket's location.
|
read_timeout: Timeout in seconds before which reading a packet from the server
|
should finish.
|
|
Returns:
|
packet: A packet from the MySQL server.
|
|
Raises:
|
:class:`OperationalError`: If something goes wrong while receiving packets
|
from the MySQL server.
|
:class:`ReadTimeoutError`: If the time to receive a packet from the server takes
|
longer than `read_timeout`.
|
:class:`InterfaceError`: If something goes wrong while receiving packets
|
from the MySQL server.
|
Nr2 )r3 r7 r, r8 s r& ÚreadzNetworkBroker.read r5 r6 ©NNN©N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r
|
r r$ Úbytesr Úintr4 ÚasyncioÚ StreamReaderÚ bytearrayr: r2 r( r& r* r* Q s¿ ñð. ð (,Ø26Ø'+ñ à ð ð ð ð ð ð
|
}ð ð #+¨3¡-ð ð }ð ð
|
ò ó ð ð> ð
|
'+ñ à×$Ñ$ð ð ð ð smð ð
|
|
ò ó ñ r( r* c ó e Zd ZdZddZededeeef fd« Z dde
|
e ddfdZ d e d
|
e deddfd Z dd ej d ede
|
e defdZ dd e d
|
e dede
|
e de
|
e de
|
e ddfdZ dd ej d
|
e de
|
e defdZy)ÚNetworkBrokerPlainú,Broker class for MySQL socket communication.r Nc ó d| _ y ©Néÿÿÿÿ©Ú_pktnr©r3 s r& Ú__init__zNetworkBrokerPlain.__init__¨ s Ø r( Úpktc ó t | « t k r t d« t j d| dd dz « d | d }}||fS )ú-Recover the header information from a packet.ú3Can't recover header info from an incomplete packetú<Ir é ó )Úlenr Ú
|
ValueErrorÚstructÚunpack)rP ÚpllÚseqids r& Ú
|
get_headerz NetworkBrokerPlain.get_header« sW ô s8Ô*Ò *Ü Ð RÓSÐ Sô MM$ A a ¨7Ñ 2Ó 3°AÑ 6Ø Fð ð
|
EzÐr( Únext_idc ól || xj dz c_ n|| _ | xj dz c_ y©z:Set the given packet id, if any, else increment packet id.Nr é rL ©r3 r^ s r& Ú_set_next_pktnrz"NetworkBrokerPlain._set_next_pktnr¸ s* à ?Ø KK1Ñ Kà!DKØ sÑ r( r+ r, c óê K |j |« |j « d{ y7 # t $ r }t d|t |« f¬« |d}~wt
|
$ r}t d¬« |d}~ww xY ww)z!Write packet to the comm channel.Né ©r# ÚvaluesiÖ ©r# )r4 ÚdrainÚIOErrorr r' ÚAttributeError)r3 r+ r, rP r s r& Ú
|
_write_pktz NetworkBrokerPlain._write_pktÀ sl è ø ð 8Ø LLÔ Ø,,.× Ò ùÜò Ü"Ø G¬[¸Ó-=Ð#>ôàð ûô ò 8Ü"¨Ô.°CÐ 7ûð 8üs< A3$0 ¨.©0 A3®0 ° A0¹AÁ A0Á A+Á+A0Á0A3r7 Úsizer8 c ó| K t d« }t |« |k r[t j |j |t |« z
|
« |« d{ }|s t d¬« ||z }t |« |k r[|S 7 (# t j $ r}t d¬« |d}~wt j $ r}|d}~ww xY ww)z(Read `size` bytes from the comm channel.r( NiÝ rh éÐ ) rE rW rC Úwait_forr: r Ú TimeoutErrorr ÚCancelledError)r3 r7 rm r8 rP Úchunkr s r& Ú _read_chunkz NetworkBrokerPlain._read_chunkÑ s´ è ø ð ÜC.CÜc(T/Ü %× .Ñ .ØKK ¤s¨3£x¡Ó0°,ó ÷ ñ Ü(¨tÔ4Ð4Øu ô c(T/ð Jð ùô ×#Ñ#ò 8Ü"¨Ô.°CÐ 7ûÜ×%Ñ%ò ØIûð üsM B<A A< ÁA:Á%A< Á8A< Á9B<Á:A< Á<B9 B  B9Â2B4Â4B9Â9B<r- r. r/ r0 c óÚ K | j |« d} t t |« t z « D ]x }t j
|
| j ||dt j d| j « z |||t z z « |« d{ | j « |t z }z t j
|
| j ||t j dt |« |z
|
« dd t j d| j « z ||d z « |« d{ y7 7 # t j $ r} t d¬« | d} ~ wt j $ r} | d} ~ ww xY ww) z¤Send payload to the MySQL server.
|
|
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
|
broken down into packets.
|
r ó ÿÿÿú<BNrT rU ro rh ) rc ÚrangerW r rC rp rl rY ÚpackrM rq r rr )
|
r3 r+ r, r- r. r/ r0 ÚoffsetÚ_r s
|
r& r4 zNetworkBrokerPlain.writeç sp è ø ð × Ñ ]Ô+ð ð Ü3w<Ô+=Ñ=Ó>ò -ä ×&Ñ&ØOOØ Ø Ø#Ü ++ d¨D¯K©KÓ8ñ9à! &¨6Ô4FÑ+FÐGñHóð "ó ÷ ð ð ×$Ñ$Ô&ØÔ,Ñ,ð -ô ×"Ñ"ØØØÜKK ¤c¨'£l°VÑ&;Ó<¸Q¸qÐAÜ kk $¨¯ © Ó4ñ5à fgÐ&ñ'óð ó ÷ ñ ð øð ùô ×#Ñ#ò 9Ü#¨$Ô/°SÐ 8ûÜ×%Ñ%ò ØIûð üsZ E+A6D+  D'ÂBD+ Ä!D)Ä"D+ Ä&E+Ä'D+ Ä)D+ Ä+E(Ä> E Å E(Å!E#Å#E(Å(E+c ó K | j |t |« d{ }| j |« \ }| _ || j |||« d{ z S 7 ;7 # t $ r }t d|t |« f¬« |d}~ww xY ww)z+Receive `one` packet from the MySQL server.Nre rf )rt r r] rM rj r r' )r3 r7 r, r8 ÚheaderÚ payload_lenr s r& r: zNetworkBrokerPlain.read s è ø ð à ×+Ñ+¨FÔ4HÈ,ÓW×WFð (,§¡°vÓ'>Ñ $Kð $×"2Ñ"2°6¸;È Ó"U× UÑUÐ Uð Xøð VùÜò Ü"Ø G¬[¸Ó-=Ð#>ôàð ûð üsJ BA A4A ÁA ÁA ÁBÁA Á A Á BÁ'B  BÂB©r Nr< )r Nr; )r= r> r? r@ rO Ú staticmethodrA r rB r] r rc r r$ rl rC rD rE rt r4 r: r2 r( r& rG rG ¥ sN Ù6ó ð ð
|
ð
|
%¨¨S¨¡/ò
|
ó ð
|
ñ x°¡}ð Àó ð8à ð8ð ð8ð ð 8ð
|
|
ó 8ð( Ø&*ñ à×$Ñ$ðð ðð smð ð
|
|
ó ð6 (,Ø26Ø'+ñ/à ð/ð ð/ð ð /ð
|
}ð /ð #+¨3¡-ð /ð }ð/ð
|
ó/ðj '+ñ à×$Ñ$ðð ðð smð ð
|
|
ô r( rG c óX e Zd ZdZd fd Zedededee fd« Z edede
|
eeef fd « Z dd
|
e e ddfd Z d ed ededdf fd Z dd ed edede e de e de e ddf fd Z ddej& dede e ddf fd Z ddej& d ede e def fd Z xZS )ÚNetworkBrokerCompressedrH r Nc óN t | « d| _ t « | _ y rJ )ÚsuperrO Ú_compressed_pktnrr Ú _queue_read)r3 Ú __class__s r& rO z NetworkBrokerCompressed.__init__1 s ø Ü ÑÔØ!#Ô Ü-2«WÕr( r- Úpktnrc ó| d}g }t t | « t z « D ]H }|j dt j
|
d|« z | ||t z z « |dz dz }|t z }J |j t j
|
dt | « |z
|
« dd t j
|
d|« z | |d z « |S ) z2Prepare a payload for sending to the MySQL server.r rv rw r ra rT rU N)rx rW r ÚappendrY ry )r- r rz Úpktsr{ s r& Ú_prepare_packetsz(NetworkBrokerCompressed._prepare_packets6 sÖ ð Øô
|
s7|Ô'9Ñ9Ó:ò )Aà KKØÜ++d EÓ*ñ+à& 6Ô,>Ñ#>Ð?ñ@ô ð
|
QY #Ñ%EØ Ô(Ñ (Fð )ð Ü KKc 'l¨VÑ 3Ó 4°Q°qÐ 9Ükk$ Ó&ñ 'àfgÐ ñ ô
|
ð
|
r( rP c óÌ t | « t k r t d« t j d| dd dz « d | d t j d| dd dz « d }}}|||fS )rR rS rT r rU rV é é )rW r rX rY rZ )rP Úcompressed_pllr\ Úuncompressed_plls r& r] z"NetworkBrokerCompressed.get_headerO s{ ô s8Ô5Ò 5Ü Ð RÓSÐ Sô MM$ A a ¨7Ñ 2Ó 3°AÑ 6Ø FÜ MM$ A a ¨7Ñ 2Ó 3°AÑ 6ð 0ð uÐ&6Ð6Ð6r( r^ c ól || xj dz c_ n|| _ | xj dz c_ yr` )r
rb s r& Ú_set_next_compressed_pktnrz2NetworkBrokerCompressed._set_next_compressed_pktnr] s1 à ?Ø × "Ò " aÑ 'Ö "à%,DÔ "Ø × Ò #Ñ%Ö r( r+ r, c ó> K t j |« }t j dt |« « dd t j d| j
|
« z t j dt |« « dd z |z }t | |||« d{ S 7 w)z1Compress packet and write it to the comm channel.rT r rU rw N)ÚzlibÚcompressrY ry rW r
r rl )r3 r+ r, rP Úcompressed_pktr s r& rl z"NetworkBrokerCompressed._write_pkte s øè ø ô sÓ+ä KKc .Ó 1Ó 2°1°QÐ 7Ükk$ × 6Ñ 6Ó7ñ 8äkk$¤ C£Ó)¨!¨AÐ.ñ /ð ñ ð ô WÑ'¨°¸Ó=×=Ð=Ð=ús BB ÂBÂB r. r/ r0 c óX K | j |« | j |« t d« j | j || j
|
« « }t |« t t z
|
k\ r§d}t t |« t z « D ]T } t j | j |||||t z « |« d{ | j « |t z }V t j | j ||||d « |« d{ yt |« t kD r0t j | j |||« |« d{ yt j t | 1 ||t j dt |« « dd t j d| j" « z t j dd« dd z |z « |« d{ y7 !7 Ö7 7 # t j$ t j& f$ r}
|
t) d¬« |
|
d}
|
~
|
ww xY ww) z¼Send `payload` as compressed packets to the MySQL server.
|
|
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
|
broken down into packets.
|
r( r NrT rU rw ro rh )rc r rE Újoinr rM rW r r rx rC rp rl r r rY ry r
rr rq r ) r3 r+ r, r- r. r/ r0 Ú payload_preprz r{ r r s r& r4 z NetworkBrokerCompressed.writeu s% øè ø ð × Ñ ]Ô+Ø ×'Ñ'Ð(@ÔAð6 9Ü$ S>×.Ñ.Ø×%Ñ% g¨t¯{©{Ó;ó Lô 7|Ô 1Ô4HÑ HÒHð ô s <Ó 0Ô4FÑ FÓGò
|
1AÜ!×*Ñ*Ø Ø "Ø #Ø (¨°&Ô;MÑ2MÐ Nóð
|
&ó ÷ ð ð ×3Ñ3Ô5ØÔ 0Ñ0Fð
|
1ô ×&Ñ&ØOO F¨G°\À&À'Ð5JÓKØ!ó÷ ñ ô w<Ô"5Ò5ä!×*Ñ*Ø ¨°¸ ÓFÈ ó÷ ñ ô
|
"×*Ñ*Ü Ñ*Ø "Ø #Ü "KK¨¬c°,Ó.?Ó @ÀÀ1Ð EÜ $kk¨$°×0FÑ0FÓ Gñ Hä $kk¨$°Ó 2°1°QÐ 7ñ 8ð +ñ +óð &ó
|
÷
|
ñ
|
ð5ùðøðøð
|
|
ùô ×&Ñ&¬×(<Ñ(<Ð=ò 9Ü#¨$Ô/°SÐ 8ûð 9üs #H*§B!G2 ÃG)à A G2 ÄG,ÄG2 ÄH*Ä<G2 ÅG.ÅG2 Å H*Å BG2 Ç#G0Ç$G2 Ç(H*Ç)G2 Ç,G2 Ç.G2 Ç0G2 Ç2#H'È H"È"H'È'H*r7 r r8 c ó K t t j t
|
| |||« d{ « « }d}|t |« k rôt j d|||t z dz
|
dz « d }t |z t |« |z
|
kD rot
|
| |t |« d{ }| j |« \ }| _ }t
|
| |||« d{ } ||dk( r| nt j | « z }| j j |||t z |z « |t |z z }|t |« k róyy7 7 7 mw)z&Handle reading of a compressed packet.Nr rT r rV )rE r Ú
|
decompressr rt rW rY rZ r r r] r
r r ) r3 r7 r r8 rP rz r[ r} r r r s r& Ú_read_compressed_pktz,NetworkBrokerCompressed._read_compressed_pkt¾ sf øè ø ô Ü OOÜgÑ)¨&°.À,ÓO×Oó ó
|
ð
|
Øs3xÒ ä--Øc& 6Ô,@Ñ#@À1Ñ#DÐEÈÑOóàñCô $ cÑ)¬C°«H°vÑ,=Ò=ô %wÑ 2ØÔ ;¸\ó ÷ ð OO FÓ+ñ Ø"ØÔ*Ø$ä',¡wÑ':ØN¨Ló(÷ "ð à'¨1Ò,ñ #ä ¨ Ó8ñð × Ñ × #Ñ # C¨°Ô:NÑ1NÐQTÑ1TÐ$UÔ VØ Ô*¨SÑ0Ñ 0Fð? s3xÕ ð Pùðøð"ús; )E¬D> A5EÂ"EÂ#2EÃEÃA%EÄ<EÅEÅEc ó K | j s t | |t |« d{ }| j |« \ }| _ }|dk( r3| j j t | |||« d{ « n| j |||« d{ | j sy| j j « }|d | _ |S 7 ¤7 Y7 ;# t $ r }t d|t |« f¬« |d}~ww xY ww)z{Receive `one` or `several` packets from the MySQL server, enqueue them, and
|
return the packet at the head.
|
Nr re rf rU ) r r rt r r] r
r r rj r r' ÚpopleftrM )
|
r3 r7 r, r8 r} r r r rP r s
|
r& r: z NetworkBrokerCompressed.readí s øè ø ð × Ò ð ä $wÑ 2ØÔ ;¸\ó ÷ ð OO FÓ+ñ Ø"ØÔ*Ø$ð $ qÒ(à×$Ñ$×+Ñ+Ü #gÑ 1°&¸.È,Ó W×Wõð
|
×3Ñ3Ø ° ó÷ ð ð × Ò Øà× Ñ ×&Ñ&Ó(Ø!f à
|
ðAøð Xøðùô ò Ü&Ø ¨´¸SÓ1AÐ'Bôàðûð üs] C>C ©CªA C Á6CÁ7 C ÂCÂC Â3C>ÃC ÃC ÃC Ã C;Ã C6Ã6C;Ã;C>r r< r; )r= r> r? r@ rO r rA rB r r r r] r r r r$ rl r4 rC rD r rE r: Ú __classcell__©r s @r& r r . s ø Ù6õ5ð
|
ð %ð °ð ¸¸U¹ ò ó ðð0 ð 7ð 7 %¨¨S°#¨ Ñ"6ò 7ó ð 7ñ&°(¸3±-ð &È4ó &ð>à ð>ð ð>ð ð >ð
|
|
õ >ð* (,Ø26Ø'+ñG9à ðG9ð ðG9ð ð G9ð
|
}ð G9ð #+¨3¡-ð G9ð }ðG9ð
|
õG9ðZ '+ñ -1à×$Ñ$ð-1ð ð-1ð smð -1ð
|
|
õ -1ðf '+ñ -à×$Ñ$ð-ð ð-ð smð -ð
|
|
÷ -ñ -r( r c óh e Zd ZdZd dZedefd« Zede ddfd« Z
|
d dZ de fd Z d
|
eddfd Zd d Zd ej$ ddfdZ d dedee dee dee ddf
|
dZd!dee defdZdddddg g fdee dee dee dee dee d eee d eee dej$ fd Zy)"Ú MySQLSocketzMySQL socket communication interface.
|
|
Examples:
|
Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket.
|
r Nc óh d| _ d| _ d| _ d| _ t « | _ d| _ y)zsNetwork layer where transactions are made with plain (uncompressed) packets
|
is enabled by default.
|
NF)Ú_readerÚ_writerÚ_connection_timeoutÚ_addressrG Ú
|
_netbrokerÚ _is_connectedrN s r& rO zMySQLSocket.__init__$ s3 ð 8< Ø/3 Ø26Ô Ø'+ Ü);Ó)=Ø#(Õr( c ó | j S )zSocket location.)r¨ rN s r& r, zMySQLSocket.address/ s ð }}Ð r( Úkwargsc ó K yw)zOpen the socket.Nr2 ©r3 r¬ s r& r zMySQLSocket.open_connection4 r5 r6 c ón K | j r | j j « | j j $| j j j « | j j « d{ d| _ yd| _ y7 # t
|
$ r}Y d}~d| _ yd}~ww xY ww)zClose the connection.NF)r¦ ÚcloseÚ transportÚabortÚ wait_closedÚ Exceptionrª )r3 r{ s r& Úclose_connectionz MySQLSocket.close_connection8 s è ø à <<ð Ø ×"Ñ"Ô$à<<×)Ñ)Ð5ØLL×*Ñ*×0Ñ0Ô2Øll×.Ñ.Ó0×0Ð0ð
|
#ÕUÕð 1ùÜ ò ó Ø "Õûð üs; B5A1B ÂBÂB ÂB5ÂB Â B2Â! B5Â-B2Â2B5c ó | j S )zCheck if the socket is connected.
|
|
Return:
|
bool: Returns `True` if the socket is connected to MySQL server.
|
)rª rN s r& Ú is_connectedzMySQLSocket.is_connectedG s ð ×!Ñ!Ð!r( Útimeoutc ó || _ y)zSet the connection timeout.N)r§ )r3 r¸ s r& Úset_connection_timeoutz"MySQLSocket.set_connection_timeoutO s
|
à#*Õ r( c ó" t « | _ y)zIEnable network layer where transactions are made with compressed packets.N)r r© rN s r& Úswitch_to_compressed_modez%MySQLSocket.switch_to_compressed_modeS s ä1Ó3r( Ú ssl_contextc óð K | j J | j j j d« }|j dk( r t d« | j j |« d{ y7 w)a? Upgrade an existing stream-based connection to TLS.
|
|
The `start_tls()` method from `asyncio.streams.StreamWriter` is only available
|
in Python 3.11. This method is used as a workaround.
|
|
The MySQL TLS negotiation happens in the middle of the TCP connection.
|
Therefore, passing a socket to open connection will cause it to negotiate
|
TLS on an existing connection.
|
|
Args:
|
ssl_context: The SSL Context to be used.
|
|
Raises:
|
RuntimeError: If the transport does not expose the socket instance.
|
NÚsocketr z,SSL is not supported when using Unix sockets)r¦ r± Úget_extra_infoÚfamilyr Ú start_tls)r3 r½ r¿ s r& Ú switch_to_sslzMySQLSocket.switch_to_sslW sb è ø ð" ||Ð'Ð'Ð'à ×'Ñ'×6Ñ6°xÓ@Ø ==AÒ Ü"Ð#QÓRÐ Ràll×$Ñ$ [Ó1×1Ò1ús A,A6Á.A4Á/A6r- r. r/ r0 c ó K | j j | j | j ||||¬« d{ y7 w)z!Send packets to the MySQL server.)r. r/ r0 N)r© r4 r¦ r, )r3 r- r. r/ r0 s r& r4 zMySQLSocket.writep sC è ø ð oo×#Ñ#Ø LLØ LLØ Ø'Ø%=Ø'ð $ó
|
÷
|
ò
|
ús 9A»A¼Ar8 c ó K | j j | j | j |« d{ S 7 w)z#Read packets from the MySQL server.N)r© r: r¥ r, )r3 r8 s r& r: zMySQLSocket.read s- è ø à__×)Ñ)¨$¯,©,¸¿ ¹ ÀlÓS×SÐSÐSús 5>·<¸>FÚssl_caÚssl_certÚssl_keyÚssl_verify_certÚssl_verify_identityÚ tls_versionsÚtls_cipher_suitesc óÆ d}| j s t d¬« t t d« |r°|j d¬« |d }t
|
| } t j | « }
|
|dk( rd |vr#|
|
xj t j z c_ d
|
|vr#|
|
xj t j z c_ d |vr8|
|
xj t j z c_ nt j « }
|
||
|
_ |rt j |
|
_ n-|rt j |
|
_ nt j |
|
_ |
|
j# « |r |
|
j% |« |r |
|
j+ ||« |r%|d k( r |
|
j- dj/ |« « |
|
S # t& t j( f$ r} t d | « | d} ~ ww xY w# t& t j( f$ r} t d | « | d} ~ ww xY w# t0 $ r} t3 d« | d} ~ wt& t4 t j6 t j( f$ r} t t9 | « « | d} ~ ww xY w)zBuild a SSLContext.Ni rh z&Python installation has no SSL supportT)Úreverser r r r r zInvalid CA Certificate: zInvalid Certificate/Key: ú:) r¥ r ÚsslÚ RuntimeErrorÚsortÚ TLS_VERSIONSÚ
|
SSLContextÚoptionsÚ OP_NO_TLSv1_2Ú OP_NO_TLSv1_1Ú OP_NO_TLSv1Úcreate_default_contextÚcheck_hostnameÚ CERT_REQUIREDÚ verify_modeÚ CERT_OPTIONALÚ CERT_NONEÚload_default_certsÚload_verify_locationsrj ÚSSLErrorÚload_cert_chainÚ set_ciphersr Ú NameErrorr ÚNotImplementedErrorÚCertificateErrorr$ ) r3 rÆ rÇ rÈ rÉ rÊ rË rÌ Ú tls_versionÚ ssl_protocolÚcontextr s r& Úbuild_ssl_contextz MySQLSocket.build_ssl_context
s% ð &* à||Ü tÔ,Ð ,ä ;Ü Ð GÓHÐ Hð5 4ÙØ ×!Ñ!¨$Ð!Ô/Ø *¨1o Ü +¨KÑ 8 Ü ..¨ Ó6à )Ò+Ø ¨ Ñ4Ø ¬3×+<Ñ+<Ñ<Ø ¨ Ñ4Ø ¬3×+<Ñ+<Ñ<Ø lÑ2Ø ¬3¯?©?Ñ:ä ×4Ñ4Ó6à%8GÔ "á Ü&)×&7Ñ&7Õ#Ù$Ü&)×&7Ñ&7Õ#ä&)§m¡mÔ#à × &Ñ &Ô (áðTØ×1Ñ1°&Ô9ñ ðUØ×+Ñ+¨H°gÔ>ñ ! [°IÒ%=Ø×#Ñ# C§H¡HÐ->Ó$?Ô@àNøô ¤§ ¡ Ð.ò TÜ(Ð+CÀCÀ5Ð)IÓJÐPSÐSûðTûô
|
¤§ ¡ Ð.ò UÜ(Ð+DÀSÀEÐ)JÓKÐQTÐTûðUûô ò WÜ#Ð$LÓMÐSVÐ Vûä Ü Ü × Ñ Ü LLð
|
ò 4ô !¤ S£Ó*°Ð 3ûð 4úsl D$H ÅF! Å#H Å&G Å8(H Æ!GÆ:G Ç GÇH ÇG>Ç*G9Ç9G>Ç>H È I È
|
HÈ0I ÉIÉI r r; r< )r= r> r? r@ rO Úpropertyr$ r, r
|
r r rµ Úboolr· rB rº r¼ rÐ rÔ rà rA r r4 rE r: r rê r2 r( r& r£ r£ s ñó )ð ð ò ó ð ð ð ¨cð °dò ó ð ó #ð "dó "ð+¨cð +°dó +ó4ð2¨s¯~©~ð 2À$ó 2ð8 (,Ø26Ø'+ñ
|
àð
|
ð }ð
|
ð #+¨3¡-ð
|
ð
|
}ð
|
ð
|
ó
|
ñ"T x°¡}ð TÀ ó Tð !%Ø"&Ø!%Ø*/Ø.3Ø,.Ø13ñH4à ðH4ð 3-ðH4ð # ð H4ð
|
" $ ð H4ð & d^ð H4ð t CyÑ)ðH4ð $ D¨¡IÑ.ðH4ð
|
ôH4r( r£ c óD e Zd ZdZ d
|
dededef fd Zdeddfd Z xZ
|
S ) r zMySQL socket class using TCP/IP.
|
|
Args:
|
host: MySQL host name.
|
port: MySQL port.
|
force_ipv6: Force IPv6 usage.
|
ÚhostÚportÚ
|
force_ipv6c ód t | « || _ || _ || _ | d| | _ y )NrÏ )r rO Ú_hostÚ_portÚ _force_ipv6r¨ )r3 rî rï rð r s r& rO zMySQLTcpSocket.__init__Ù s8 ø ô ÑÔØ
|
Ø
|
Ø!+ÔØ $v Q t fÐ - r( r¬ r Nc ó K t d| j | j d|¤ d{ \ | _ | _ d| _ y7 w)zOpen TCP/IP connection.)rî rï NTr2 )r rò ró r¥ r¦ rª r® s r& r z MySQLTcpSocket.open_connectionâ sG è ø ä+:ð ,
|
Ø $§*¡*ñ,
|
Ø06ñ,
|
÷ &
|
Ñ" dlð "Õð&
|
ús &A¨A©A)z 127.0.0.1iê F) r= r> r? r@ r$ rB rì rO r r r r¡ s @r& r r Ð s? ø ñð MRñ.Øð.Ø-0ð.ØEIõ.ð"¨cð "°d÷ "r( c ó: e Zd ZdZddef fd ZdeddfdZ xZS ) r zbMySQL socket class using UNIX sockets.
|
|
Args:
|
unix_socket: UNIX socket file path.
|
Ú unix_socketc ó0 t | « || _ y r< )r rO r¨ )r3 r÷ r s r& rO zMySQLUnixSocket.__init__ñ s ø Ü ÑÔØ ( r( r¬ r Nc ó K t j dd| j i|¤ d{ \ | _ | _ d| _ y7 w)z Open UNIX socket connection.ÚpathNTr2 )rC Úopen_unix_connectionr¨ r¥ r¦ rª r® s r& r z MySQLUnixSocket.open_connectionõ sM è ø ô
|
×.Ñ.ñ
|
Ø ð
|
Ø"(ñ
|
÷
|
ñ
|
Ø LØ Lð "Õð
|
ús %A§A¨A)z/tmp/mysql.sock) r= r> r? r@ r$ rO r r r r¡ s @r& r r ê s' ø ññ ) Cõ )ð"¨cð "°d÷ "r( )/r@ Ú__all__rC rY r rÐ ÚPROTOCOL_TLSv1ÚPROTOCOL_TLSv1_1ÚPROTOCOL_TLSv1_2Ú PROTOCOL_TLSrÓ Ú ImportErrorÚabcr r
|
Ú collectionsr Útypingr r r r r Úerrorsr r r r r r Únetworkr r r r Úutilsr r rj r$ r' r* rG r r£ r r r2 r( r& ú<module>r sÿ ðñ> Mð Ð .Ð
|
/ã Û Û ð
|
Ûð ×#Ñ#Ø×'Ñ'Ø×'Ñ'Ø×#Ñ#ñ L÷ $Ý ß 4Õ 4÷÷ ÷ó ÷ 1ðHWð H ó HôQ Cô Q ôhF ô FôRlÐ 0ô lô^p4#ô p4ôf"[ô "ô4"kõ "øðs ò Ø
|
Cðús 3C ÃC ÃC
|
