Ë
|
Wñúhu ã óà d Z ddlZddlZddlZddlZddlmZmZ ddlm Z ddl
|
m Z m Z m Z mZmZmZ ddlZej$ ej& ej( ej* dZ eed« xr ej0 Zd d
|
lm Z m Z m Z m Z m Z m!Z!m"Z" d Z#d Z$d Z%dZ&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 d e-« Z/y# e$ r dZdZY pw xY w) zFModule implementing low-level socket communication with MySQL servers.é N)ÚABCÚabstractmethod)Údeque)ÚAnyÚDequeÚListÚOptionalÚTupleÚUnion)ÚTLSv1úTLSv1.1úTLSv1.2úTLSv1.3Ú HAS_TLSv1_3Fé )ÚConnectionTimeoutErrorÚInterfaceErrorÚNotSupportedErrorÚOperationalErrorÚProgrammingErrorÚReadTimeoutErrorÚWriteTimeoutErroré2 iÿÿÿ é é ÚerrÚreturnc óh | j s t | « S d| j d| j S )z`Reformat the IOError error message.
|
|
This function reformats the IOError error message.
|
zErrno z: )ÚerrnoÚstrÚstrerror)r s úJH:\Change_password\venv_build\Lib\site-packages\mysql/connector/network.pyÚ _strioerrorr# I s. ð
|
993s8ÐN¨F°3·9±9°+¸RÀÇ Á ¸~Ð*NÐNó c ó e Zd ZdZe d dej
|
dededee dee ddf d « Z
|
edej
|
dede fd
|
« Z y) Ú 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ÚsockÚaddressÚpayloadÚ packet_numberÚcompressed_packet_numberr c ó y)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.
|
|
Raises:
|
:class:`OperationalError`: If something goes wrong while sending packets to
|
the MySQL server.
|
N© )Úselfr' r( r) r* r+ s r" ÚsendzNetworkBroker.sendi ó r$ c ó y)a) Get the next available packet from the MySQL server.
|
|
Args:
|
sock: Object holding the socket connection.
|
address: Socket's location.
|
|
Returns:
|
packet: A packet from the MySQL server.
|
|
Raises:
|
:class:`OperationalError`: If something goes wrong while receiving packets
|
from the MySQL server.
|
:class:`InterfaceError`: If something goes wrong while receiving packets
|
from the MySQL server.
|
Nr- )r. r' r( s r" ÚrecvzNetworkBroker.recv
r0 r$ ©NN) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r Úsocketr Úbytesr Úintr/ Ú bytearrayr2 r- r$ r" r& r& Q s ñð. ð (,Ø26ñ àmmð ð ð ð ð ð
|
}ð ð #+¨3¡-ð ð
|
ò ó ð ð6 ð ð °ð ¸ò ó ñ r$ r& c óä e Zd ZdZddZddZdej dededdfd Z ddej d
|
e
|
de fd Z ddej ded ed e e
|
de e
|
ddf dZdej dede fdZy)ÚNetworkBrokerPlainú,Broker class for MySQL socket communication.r Nc ó d| _ y ©Néÿÿÿÿ©Ú_pktnr©r. s r" Ú__init__zNetworkBrokerPlain.__init__ s Ø r$ c ó2 | j dz dz | _ y©zIncrement packet id.r é NrB rD s r" Ú_set_next_pktnrz"NetworkBrokerPlain._set_next_pktnr s à{{ Q¨#Ñ- r$ r' r( Úpktc ó |j |« y# t j t f$ r}t d¬« |d}~wt
|
$ r }t d|t |« f¬« |d}~wt $ r}t d¬« |d}~ww xY w)z!Write packet to the comm channel.éÐ ©r Né ©r ÚvaluesiÖ ) Úsendallr8 ÚtimeoutÚ TimeoutErrorr ÚIOErrorr r# ÚAttributeError)r. r' r( rJ r s r" Ú _send_pktz NetworkBrokerPlain._send_pkt¢ sy ð 8Ø LLÕ øܤ Ð-ò 9Ü#¨$Ô/°SÐ 8ûÜò Ü"Ø G¬[¸Ó-=Ð#>ôàð ûô ò 8Ü"¨Ô.°CÐ 7ûð 8ús* A= :º A=ÁA Á A=Á+ A8Á8A=Úsizec ó t |« }t |« }|r5|j ||« }|dk( r|dkD r t d¬« ||d }||z }|r5|S )z(Read `size` bytes from the comm channel.r iÝ rM N)r; Ú
|
memoryviewÚ recv_intor )r. r' rW rJ Úpkt_viewÚreads r" Ú _recv_chunkz NetworkBrokerPlain._recv_chunk¯ s_ äoÜ c?ÙØ>> (¨DÓ1DØqyT AXÜ$¨4Ô0Ð0Ø HØ DLDò ð
|
r$ r) r* r+ c
|
ó || j « n|| _ t |« t k\ rd}t t |« t z « D ]\ }| j ||dt j d| j « z |||t z z « | j « |t z }^ ||d }| j ||t j dt |« « dd t j d| j « z |z « y)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.
|
Nr ó ÿÿÿú<Bú<Ié )rI rC ÚlenÚMAX_PAYLOAD_LENGTHÚrangerV ÚstructÚpack)r. r' r( r) r* r+ ÚoffsetÚ_s r" r/ zNetworkBrokerPlain.send» s ð Ð Ø × Ñ Õ "à'DKô w<Ô-Ò -ØFÜ3w<Ô+=Ñ=Ó>ò
|
-àØØØ#Ü kk $¨¯ © Ó4ñ5à f vÔ0BÑ'BÐCñDôð ×$Ñ$Ô&ØÔ,Ñ,ð
|
-ð fgÐ&GØ Ø Ø Ü KKc 'lÓ +¨A¨aÐ 0Ükk$ § ¡ Ó,ñ -àñ õ
|
r$ c ón | j |t ¬« }t j d|dd dz « d |d c}| _ || j ||¬« z S # t
|
j t f$ r }t d|j ¬« |d}~wt $ r }t d |t |« f¬
|
« |d}~ww xY w) z+Receive `one` packet from the MySQL server.©rW ra r rb ó rL )r ÚmsgNrN rO ) r] ÚPACKET_HEADER_LENGTHrf ÚunpackrC r8 rR rS r r! rT r r# )r. r' r( ÚheaderÚ payload_lenr s r" r2 zNetworkBrokerPlain.recvç sÁ ð à×%Ñ% dÔ1EÐ%ÓFFô d F¨1¨Q K°'Ñ$9Ó:¸1Ñ=Øq ð %Kð D× ,Ñ ,¨T¸ Ð ,Ó DÑDÐ Døܤ Ð-ò JÜ"¨°3·<±<Ô@ÀcÐ IûÜò Ü"Ø G¬[¸Ó-=Ð#>ôàð ûð ús$ AA ÁB4Á2B
|
Â
|
B4ÂB/Â/B4©r N)r r3 )r4 r5 r6 r7 rE rI r8 r r9 rV r: r; r] r r/ r2 r- r$ r" r= r= sÄ Ù6ó ó.ð 8fmmð 8°cð 8Àð 8È$ó 8ñ
|
§ ¡ ð
|
°Sð
|
Àó
|
ð" (,Ø26ñ *
|
àmmð*
|
ð ð*
|
ð ð *
|
ð
|
}ð *
|
ð #+¨3¡-ð *
|
ð
|
ó*
|
ðX ð °ð ¸ô r$ r= c ó& e Zd ZdZd fd Zedededee fd« Z ddZ
|
d e j d
|
e d eddf fd Z dd e j d
|
e ded ee dee ddf fd Zd e j dededdf fd Zd e j d
|
e def fd Z xZS )ÚNetworkBrokerCompressedr> r Nc óN t | « d| _ t « | _ y r@ )ÚsuperrE Ú_compressed_pktnrr Ú _queue_read)r. Ú __class__s r" rE z NetworkBrokerCompressed.__init__ s ø Ü ÑÔØ!#Ô Ü-2«WÕr$ r) Úpktnrc ó g }t | « t k\ rmd}t t | « t z « D ]H }|j dt j
|
d|« z | ||t z z « |dz dz }|t z }J | |d } |j t j
|
dt | « « dd t j
|
d|« z | z « |S ) z2Prepare a payload for sending to the MySQL server.r r_ r` r rH Nra rb )rc rd re Úappendrf rg )r) rz Úpktsrh ri s r" Ú_prepare_packetsz(NetworkBrokerCompressed._prepare_packets sÝ ð ô w<Ô-Ò -ØFÜ3w<Ô+=Ñ=Ó>ò -à Ø#Ü kk $¨Ó.ñ/à f vÔ0BÑ'BÐCñDôð
|
cÑ)ØÔ,Ñ,ð -ð fgÐ&GØ Ü KKc 'lÓ +¨A¨aÐ 0´6·;±;¸tÀUÓ3KÑ KÈgÑ Uô
|
ð r$ c ó2 | j dz dz | _ yrG )rw rD s r" Ú_set_next_compressed_pktnrz2NetworkBrokerCompressed._set_next_compressed_pktnr s à"&×"8Ñ"8¸1Ñ"<ÀÑ!CÕ r$ r' r( rJ c ó" t j |« }t j dt |« « dd t j d| j
|
« z t j dt |« « dd z |z }t | |||« S )z1Compress packet and write it to the comm channel.ra r rb r` )ÚzlibÚcompressrf rg rc rw rv rV )r. r' r( rJ Úcompressed_pktry s r" rV z!NetworkBrokerCompressed._send_pkt# s ø ä sÓ+ä KKc .Ó 1Ó 2°1°QÐ 7Ükk$ × 6Ñ 6Ó7ñ 8äkk$¤ C£Ó)¨!¨AÐ.ñ /ð ñ ð ô wÑ w°Ó4Ð4r$ r* r+ c
|
ó || j « n|| _ || j « n|| _ t d« j | j || j « « }t |« t t z
|
k\ rod}t t |« t z « D ]8 }| j |||||t z « | j « |t z }: | j ||||d « yt |« t kD r| j |||« yt | - ||t j dt |« « dd t j d| j « z t j dd« dd z |z « y)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.
|
Nr$ r ra rb r` )rI rC r rw r; Újoinr~ rc rd rn re rV ÚMIN_COMPRESS_LENGTHrv rf rg )
|
r. r' r( r) r* r+ Ú payload_preprh ri ry s
|
r" r/ z NetworkBrokerCompressed.send. sv ø ð Ð Ø × Ñ Õ "à'DKØ #Ð +Ø × +Ñ +Õ -à%=DÔ "ä ~×*Ñ*¨4×+@Ñ+@ÀÈ$Ï+É+Ó+VÓW Ü w<Ô-Ô0DÑDÒ Dð Fô 3|Ó,Ô0BÑBÓCò -ØØ' <°¸ÔBTÑ9TÐ#Uôð ×/Ñ/Ô1ØÔ,Ñ,ð -ð NN4 ¨,°v°wÐ*?Õ @ô 7|Ô 1Ò1àt W¨lÕ;ô Ñ!ØØÜKK ¤c¨,Ó&7Ó8¸¸1Ð=Ü kk $¨×(>Ñ(>Ó?ñ@ä kk $¨Ó*¨1¨QÐ/ñ0ð #ñ#õr$ Úcompressed_pllÚuncompressed_pllc ó¾ t | ||¬« }|dk( r|n t t j |« « }d}|t |« k rt j d|||t z dz
|
dz « d }t |z t |« |z
|
kD rt | |t ¬« }t j d|dd dz « d |d t j d|dd dz « d c}| _
|
}t | ||¬« }||dk( r|nt j |« z }| j j |||t z |z « |t |z z }|t |« k ry y )
|
z&Handle reading of a compressed packet.rk r ra r rl rb r r N) rv r] r; r Ú
|
decompressrc rf ro rn Ú COMPRESSED_PACKET_HEADER_LENGTHrw rx r| )
|
r. r' r r r rJ rh Úpllrp ry s
|
r" Ú_recv_compressed_pktz,NetworkBrokerCompressed._recv_compressed_pktk s ø ô Ñ,¨T¸Ð,ÓGð 1Ò$ñ ä4??¨>Ó:Ó;ð ð Øs3xÓ ä--Øc& 6Ô,@Ñ#@À1Ñ#DÐEÈÑOóàñCô $ cÑ)¬C°«H°vÑ,=Ò=ô Ñ,¨TÔ8WÐ,ÓXô MM $¨¨q°¨ °gÑ(=Ó>¸qÑAØ1IÜMM $¨¨q°¨ °gÑ(=Ó>¸qÑAðð Ø"ØÔ*Ø$ô "'¡Ñ!4°TÀÐ!4Ó!Oð à'¨1Ò,ñ #ä ¨ Ó8ñð × Ñ × #Ñ # C¨°Ô:NÑ1NÐQTÑ1TÐ$UÔ VØ Ô*¨SÑ0Ñ 0Fð? s3xÖ r$ c ó | j ss t | |t ¬« }t j
|
d|dd dz « d |d t j
|
d|dd dz « d c}| _ }| j |||« | j sy
|
| j j « }|d | _ |S # t j t f$ r}t d¬ « |d
|
}~wt $ r }t d |t |« f¬ « |d
|
}~ww xY w) z{Receive `one` or `several` packets from the MySQL server, enqueue them, and
|
return the packet at the head.
|
rk ra r rb rl r r rL rM NrN rO )rx rv r] r rf ro rw r r8 rR rS r rT r r# ÚpopleftrC ) r. r' r( rp r r r rJ ry s r" r2 z NetworkBrokerCompressed.recv s ø ð × Ò ð ä Ñ,¨TÔ8WÐ,ÓXô MM $¨¨q°¨ °gÑ(=Ó>¸qÑAØ1IÜMM $¨¨q°¨ °gÑ(=Ó>¸qÑAðð Ø"ØÔ*Ø$ð ×)Ñ)¨$°Ð@PÔQð × Ò Øà× Ñ ×&Ñ&Ó(Ø!f à
|
øô NN¤LÐ1ò <Ü&¨TÔ2¸Ð;ûÜò Ü&Ø ¨´¸SÓ1AÐ'Bôàðûð ús$ A2B4 Â4Dà Cà DÃ&C?Ã?Drr r3 )r4 r5 r6 r7 rE Ú staticmethodr9 r: r r~ r r8 r rV r r/ r r; r2 Ú __classcell__©ry s @r" rt rt ý s ø Ù6õ5ð
|
ð %ð °ð ¸¸U¹ ò ó ðó2Dð 5fmmð 5°cð 5Àð 5È$õ 5ð (,Ø26ñ ;àmmð;ð ð;ð ð ;ð
|
}ð ;ð #+¨3¡-ð ;ð
|
õ;ðz.1ØMMð.1Ø36ð.1ØJMð.1à õ.1ð`! ð !°ð !¸÷ !ñ !r$ rt c óP e Zd ZdZd dZd dZd dZd dZd dZd e e
|
ddfd
|
Z d e d e ddfd Z d de e de e de e de e de e de ee de ee de fdZ d!dede e
|
de e
|
de e
|
ddf
|
dZd"de e
|
defd Zed d « Zeede fd « « Zy)#Ú MySQLSocketzMySQL socket communication interface.
|
|
Examples:
|
Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket.
|
r Nc óL d| _ d| _ d| _ t « | _ y)zsNetwork layer where transactions are made with plain (uncompressed) packets
|
is enabled by default.
|
N)r' Ú_connection_timeoutÚ server_hostr= Ú
|
_netbrokerrD s r" rE zMySQLSocket.__init__Æ s% ð
|
.2 Ø26Ô Ø*.ÔÜ);Ó)=r$ c ó" t « | _ y)zIEnable network layer where transactions are made with compressed packets.N)rt r rD s r" Úswitch_to_compressed_modez%MySQLSocket.switch_to_compressed_modeÐ s ä1Ó3r$ c ó¶ | j j t j « | j j « y# t
|
t f$ r Y yw xY w)z'Shut down the socket before closing it.N)r' Úshutdownr8 Ú SHUT_RDWRÚcloserU ÚOSErrorrD s r" r zMySQLSocket.shutdownÔ sD ð Ø II× Ñ v× /Ñ /Ô 0Ø IIOOÕ øÜ ¤Ð(ò Ù ð ús AA ÁAÁAc ód | j j « y# t t f$ r Y yw xY w)zClose the socket.N)r' r rU r¡ rD s r" Úclose_connectionz MySQLSocket.close_connectionÜ s, ð Ø IIOOÕ øÜ ¤Ð(ò Ù ð ús /®/c ó$ | j « y ©N)r rD s r" Ú__del__zMySQLSocket.__del__ã s Ø r$ rR c ób || _ | j r | j j |« yy)zSet the connection timeout.N)r r' Ú
|
settimeout)r. rR s r" Úset_connection_timeoutz"MySQLSocket.set_connection_timeoutæ s( à#*Ô Ø 99Ø II× Ñ Õ )ð r$ Ú ssl_contextÚhostc ó | j J | j j dk( r t d« t t d« |j | j |¬« | _ y# t $ r}t d« |d}~wt j t f$ r(}t d| j t |« f¬« |d}~wt j $ r}t t |« « |d}~wt $ r}t t |« « |d}~ww xY w)a Upgrade an existing connection to TLS.
|
|
Args:
|
ssl_context (ssl.SSLContext): The SSL Context to be used.
|
host (str): Server host name.
|
|
Returns:
|
None.
|
|
Raises:
|
ProgrammingError: If the transport does not expose the socket instance.
|
NotSupportedError: If Python installation has no SSL support.
|
Nr z,SSL is not supported when using Unix socketsú&Python installation has no SSL support)Úserver_hostnamerN rO )r' Úfamilyr Ússlr Ú wrap_socketÚ NameErrorÚSSLErrorrT r r( r# ÚCertificateErrorr ÚNotImplementedError)r. rª r« r s r" Ú switch_to_sslzMySQLSocket.switch_to_sslì sô ð yyÐ$Ð$Ð$à 99× Ñ qÒ Ü"Ð#QÓRÐ Rä ;Ü#Ð$LÓMÐ Mð 4Ø#×/Ñ/°· ± È4Ð/ÓPDIøÜò WÜ#Ð$LÓMÐSVÐ VûÜ gÐ&ò Ü Ø D§L¡L´+¸cÓ2BÐ#Côàð ûô ×#Ñ#ò 4Ü ¤ S£Ó*°Ð 3ûÜ"ò 4Ü ¤ S£Ó*°Ð 3ûð 4ús< Á"A( Á( D Á1 A=Á= D Â#B<Â<D ÃC'Ã' D Ã3DÄD Ú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« |g }|g } |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} t d« | d} ~ wt& t2 t j4 t j( f$ r} t t7 | « « | d} ~ ww xY w)aÊ Build a SSLContext.
|
|
Args:
|
ssl_ca: Certificate authority, opptional.
|
ssl_cert: SSL certificate, optional.
|
ssl_key: Private key, optional.
|
ssl_verify_cert: Verify the SSL certificate if `True`.
|
ssl_verify_identity: Verify host identity if `True`.
|
tls_versions: TLS protocol versions, optional.
|
tls_cipher_suites: Set of steps that helps to establish a secure connection.
|
|
Returns:
|
ssl_context (ssl.SSLContext): An SSL Context ready be used.
|
|
Raises:
|
NotSupportedError: Python installation has no SSL support.
|
InterfaceError: Socket undefined or invalid ssl data.
|
Ni rM r T)Úreverser r r r r zInvalid CA Certificate: zInvalid Certificate/Key: ú:) r' r r° r Ú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_locationsrT r³ Úload_cert_chainÚ set_ciphersr r² rµ r´ r ) r. r· r¸ r¹ rº r» r¼ r½ Ú tls_versionÚ ssl_protocolÚcontextr s r" Úbuild_ssl_contextz MySQLSocket.build_ssl_context s> ð8 &* àyyÜ tÔ,Ð ,ä ;Ü#Ð$LÓMÐ Mà Ð Ø Là Ð $Ø "Ð ð6 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 Æ (H Æ)GÇGÇGÇH ÇHÇ2HÈHÈH È I(È H È 0I(ÉI#É#I(r) r* r+ Ú write_timeoutc ó | j s4| j (| j j |r t |« nd« | j
|
j | j | j |||¬« y# t $ r
|
}Y d}~Cd}~ww xY w)at Send `payload` to the MySQL server.
|
|
NOTE: if `payload` is an instance of `bytearray`, then `payload` might be
|
changed by this method - `bytearray` is similar to passing a variable by
|
reference.
|
|
If you're sure you won't read `payload` after invoking `send()`,
|
then you can use `bytearray.` Otherwise, you must use `bytes`.
|
N)r* r+ )r r' r¨ Úfloatr¡ r r/ r( )r. r) r* r+ rÖ ri s r" r/ zMySQLSocket.sendr sz ð à×,Ò,°·±Ð1Fà ×$Ñ$¹]¤U¨=Ô%9ÐPTÔUð × Ñ Ø IIØ LLØ Ø'Ø%=ð õ
|
øô ò ä ûð ús A A7 Á7 B
|
ÂB
|
Ú read_timeoutc ó | j s4| j (| j j |r t |« nd« | j
|
j | j | j « S # t $ r
|
}Y d}~>d}~ww xY w)z.Get packet from the MySQL server comm channel.N)r r' r¨ rØ r¡ r r2 r( )r. rÙ ri s r" r2 zMySQLSocket.recv sj ð à×,Ò,°·±Ð1Fà ×$Ñ$¹L¤U¨<Ô%8ÈdÔSð ×#Ñ# D§I¡I¨t¯|©|Ó<Ð<øô ò ä ûð ús A A2 Á2 B Bc ó y)zOpen the socket.Nr- rD s r" Úopen_connectionzMySQLSocket.open_connection r0 r$ c ó y)z Get the location of the socket.Nr- rD s r" r( zMySQLSocket.address¢ r0 r$ rr )NNNFFNN)NNNr¥ )r4 r5 r6 r7 rE r r r£ r¦ r r: r© r r r¶ Úboolr rÕ r9 r/ r; r2 r rÜ Úpropertyr( r- r$ r" r r ¿ s ñó >ó4óóóð*¨h°s©mð *Àó *ð "4¨ð "4°Cð "4¸Dó "4ðL !%Ø"&Ø!%Ø*/Ø.3Ø,0Ø15ñ`4à ð`4ð 3-ð`4ð # ð `4ð
|
" $ ð `4ð & d^ð `4ð t CyÑ)ð`4ð $ D¨¡IÑ.ð`4ð
|
ó`4ðJ (,Ø26Ø'+ñ
|
àð
|
ð }ð
|
ð #+¨3¡-ð
|
ð
|
}ð
|
ð
|
ó
|
ñ@
|
= ¨#¡ ð
|
=¸)ó
|
=ð ò ó ð ð Øð.ò .ó ó ñ.r$ r c ó` e Zd ZdZd deddf fd Zedefd« Zd dZde d e ddfd
|
Z
|
xZ S ) ÚMySQLUnixSocketzpMySQL socket class using UNIX sockets.
|
|
Opens a connection through the UNIX socket of the MySQL Server.
|
Ú unix_socketr Nc ó> t | « || _ || _ y r¥ )rv rE râ Ú_address)r. râ ry s r" rE zMySQLUnixSocket.__init__® s ø Ü ÑÔØ +ÔØ ( r$ c ó | j S r¥ ©rä rD s r" r( zMySQLUnixSocket.address³ ó à}}Ð r$ c ó0 t j t j t j « | _ | j j | j
|
« | j j | j « y # t j t f$ r(}t d| j t |« f¬« |d }~wt $ r(}t d| j t |« f¬« |d }~wt $ r}t t! |« « |d }~ww xY w)NiÒ rO )r8 ÚAF_UNIXÚ SOCK_STREAMr' r¨ r Úconnectrâ rR rS r r( r# rT r Ú Exceptionr )r. r s r" rÜ z MySQLUnixSocket.open_connection· så ð 4Ü äÜ×"Ñ"óDIð
|
II× Ñ ×!9Ñ!9Ô :Ø II× Ñ d× .Ñ .Õ /øܤ Ð-ò Ü(ØàLLÜ Ó$ðôð ð ûô ò Ü Ø D§L¡L´+¸cÓ2BÐ#Côàð ûô ò 4Ü ¤ S£Ó*°Ð 3ûð 4ús0 BB ÂD #C à Dà #C/Ã/ DÃ;DÄDÚargsÚkwargsc ó8 t j dt « y)z Switch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)ÚwarningsÚwarnÚWarning)r. rí rî s r" r¶ z MySQLUnixSocket.switch_to_sslÏ s ô Ø @Ü õ
|
r$ )z/tmp/mysql.sockrr ) r4 r5 r6 r7 r rE rß r( rÜ r r¶ r r s @r" rá rá ¨ sX ø ññ
|
) Cð )Àõ )ð
|
ð ò ó ð ó4ð0
|
Øð
|
Ø$'ð
|
à ÷
|
r$ rá c óZ e Zd ZdZ d
|
dedededdf fd Zedefd« Z d d Z
|
xZ S ) ÚMySQLTCPSocketzYMySQL socket class using TCP/IP.
|
|
Opens a TCP/IP connection to the MySQL Server.
|
r« ÚportÚ
|
force_ipv6r Nc ór t | « || _ || _ || _ d| _ | d| | _ y )Nr rÀ )rv rE r Ú server_portrö Ú_familyrä )r. r« rõ rö ry s r" rE zMySQLTCPSocket.__init__ß s@ ø ô ÑÔØ $ÔØ $ÔØ *Ø Ø $v Q t fÐ - r$ c ó | j S r¥ ræ rD s r" r( zMySQLTCPSocket.addressì rç r$ c óJ d} t j | j | j dt j t j
|
« }|D ]B }| j r|d t j k( r|} n |d t j k( s@|} n | j r |d t d| j « |d |d }|\ | _ }}}} t j | j ||« | _ | j j | j « | j j! |« y# t $ r3}t d| j | j t |« f¬« |d}~ww xY w# t j" t$ f$ r3}t' d| j | j t |« f¬« |d}~wt $ r3}t d| j | j t |« f¬« |d}~wt( $ r}t t+ |« « |d}~ww xY w)z/Open the TCP/IP connection to the MySQL server.)NNNNNr NzNo IPv6 address found for iÓ rO )r8 Ú getaddrinfor rø rê ÚSOL_TCPrö ÚAF_INET6ÚAF_INETr rT r# rù r' r¨ r rë rR rS r rì r ) r. ÚaddrinfoÚ addrinfosÚinfor ÚsocktypeÚprotori Úsockaddrs r" rÜ z MySQLTCPSocket.open_connectionð s ð +ð ð Ü ×*Ñ*Ø× Ñ Ø× Ñ ØÜ×"Ñ"Üó Ið "ò Ø?? t¨A¡w´&·/±/Ò'AØ #HÙØ7fnnÓ,Ø #HÙð ð 8¨A¡;Ð#6Ü$Ð'AÀ$×BRÑBRÐASÐ%TÓUÐUØ{Ð"Ø$ Q<ð 8@Ñ4 x ¨¨8ð 4Ü d§l¡l°H¸eÓDDIØ II× Ñ ×!9Ñ!9Ô :Ø II× Ñ hÕ 'øô ò Ü ØØ ×(Ñ(¨$×*:Ñ*:¼KÈÓ<LÐMôð ð ûð ûô ¤ Ð-ò Ü(Øà×$Ñ$Ø×$Ñ$Ü Ó$ðôð ð ûô ò Ü ØØ ×(Ñ(¨$×*:Ñ*:¼KÈÓ<LÐMôð ð ûô ò 4Ü ¤ S£Ó*°Ð 3ûð 4úsO B
|
D< Â8D< ÃA&E; Ä< E8Å.E3Å3E8Å;H"Æ.GÇ H"Ç.G<Ç< H"ÈH È H")z 127.0.0.1iê Frr ) r4 r5 r6 r7 r r: rÞ rE rß r( rÜ r r s @r" rô rô Ù s^ ø ñð ØØ ñ .àð .ð ð .ð ð .ð
|
|
õ .ð ð ò ó ð ÷;4r$ rô )0r7 r8 rf rð r Úabcr r Ú collectionsr Útypingr r r r r
|
r r° ÚPROTOCOL_TLSv1ÚPROTOCOL_TLSv1_1ÚPROTOCOL_TLSv1_2Ú PROTOCOL_TLSr Úhasattrr ÚTLS_V1_3_SUPPORTEDÚ ImportErrorÚerrorsr r r r r r r r rd rn r rT r r# r& r= rt r rá rô r- r$ r" ú<module>r s& ðñ: Mó Û Û Û ç #Ý ß ;× ;ð Ûð ×#Ñ#Ø×'Ñ'Ø×'Ñ'Ø×#Ñ#ñ Lñ ! mÓ4ÒH¸¿ ¹ Ð÷ ÷ ñ ð Ð Ø Ð ØÐ Ø"#Ð ðOWð O ó OôD Cô D ôNb ô bôJÐ 0ô ôDf.#ô f.ôR.
|
kô .
|
ôbR4[õ R4øðK ò à ÐØ
|
Cðús ²A
|
C! Ã! C-Ã,C-
|
