]j d dl Z d dlZd dlZd dlZd dlZd dlZd dlZddlmZ ddl m
Z
m Z ddl m
Z
mZmZmZmZmZ ddlmZ ddlmZ ddlmZ dd lmZmZmZm Z m Z m Z dd
lm Z m Z d dl!Z!d Z"n# e#$ r dZ!d Z"Y nw xY w d dl$Z$ e$j% Z&[$n# e#e'f$ r dZ&Y nw xY wd Z(ej) ej* ej+ ej, ej- ej. ej/ ej0 ej1 h Z2d
Z3dZ4d Z5d Z6 G d d Z7 G d d Z8 G d d Z9dS ) N )_auth)charset_by_name
charset_by_id)CLIENTCOMMANDCRER
FIELD_TYPE
SERVER_STATUS)
converters)Cursor)Parser) dump_packet MysqlPacketFieldDescriptorPacketOKPacketWrapperEOFPacketWrapperLoadLocalPacketWrapper)errVERSION_STRINGTFutf8mb4i c < t j d| d d S )N<I )structpack)ns J/opt/imunify360/venv/lib64/python3.11/site-packages/pymysql/connections.py _pack_int24r C s ;tQ ## c R | dk rt d| z | dk rt | g S | dk rdt j d| z S | dk r dt j d | d d
z S | d k rd t j d
| z S t d| ddd dd )Nr zFEncoding %d is less than 0 - no representation in LengthEncodedInteger i <H r r l z<Qz Encoding xz is larger than z, - no representation in LengthEncodedInteger)
ValueErrorbytesr r )is r _lenenc_intr- H s 1uu TWX X
TaSzz
g T1----
g T1--bqb111
g T1---- d d d dW d d d d
r! c ) 8 e Zd ZdZdZdZdZdZdddddddddddddeddddddddddddddddddddddddddd (d
Z d Z
d Z d
Z d Z
ed Zd ZeZd Zd Zd Zd Zd Zd Zd Zd Zd Zd7dZd Z d Z d Z d7d Z d8d Z d8d Z!d! Z"d" Z#d9d#Z$d$ Z%d7d%Z&d7d&Z'd' Z(e)fd(Z*d) Z+d* Z,d8d+Z-d, Z.d- Z/d. Z0d/ Z1d0 Z2d1 Z3d2 Z4d3 Z5d4 Z6d5 Z7d6 Z8e9j: Z:e9j; Z;e9j< Z<e9j= Z=e9j> Z>e9j? Z?e9j@ Z@e9jA ZAe9jB ZBe9jC ZCdS ):
Connectiona
Representation of a socket with a mysql server.
The proper way to get an instance of this class is to call
connect().
Establish a connection to the MySQL database. Accepts several
arguments:
:param host: Host where the database server is located.
:param user: Username to log in as.
:param password: Password to use.
:param database: Database to use, None to not use a particular one.
:param port: MySQL port to use, default is usually OK. (default: 3306)
:param bind_address: When the client has multiple network interfaces, specify
the interface from which to connect to the host. Argument can be
a hostname or an IP address.
:param unix_socket: Use a unix socket rather than TCP/IP.
:param read_timeout: The timeout for reading from the connection in seconds.
(default: None - no timeout)
:param write_timeout: The timeout for writing to the connection in seconds.
(default: None - no timeout)
:param str charset: Charset to use.
:param str collation: Collation name to use.
:param sql_mode: Default SQL_MODE to use.
:param read_default_file:
Specifies my.cnf file to read these parameters from under the [client] section.
:param conv:
Conversion dictionary to use instead of the default one.
This is used to provide custom marshalling and unmarshalling of types.
See converters.
:param use_unicode:
Whether or not to default to unicode strings.
This option defaults to true.
:param client_flag: Custom flags to send to MySQL. Find potential values in constants.CLIENT.
:param cursorclass: Custom cursor class to use.
:param init_command: Initial SQL statement to run when connection is established.
:param connect_timeout: The timeout for connecting to the database in seconds.
(default: 10, min: 1, max: 31536000)
:param ssl: A dict of arguments similar to mysql_ssl_set()'s parameters or an ssl.SSLContext.
:param ssl_ca: Path to the file that contains a PEM-formatted CA certificate.
:param ssl_cert: Path to the file that contains a PEM-formatted client certificate.
:param ssl_disabled: A boolean value that disables usage of TLS.
:param ssl_key: Path to the file that contains a PEM-formatted private key for
the client certificate.
:param ssl_key_password: The password for the client certificate private key.
:param ssl_verify_cert: Set to true to check the server certificate's validity.
:param ssl_verify_identity: Set to true to check the server's identity.
:param read_default_group: Group to read from in the configuration file.
:param autocommit: Autocommit mode. None means use server default. (default: False)
:param local_infile: Boolean to enable the use of LOAD DATA LOCAL command. (default: False)
:param max_allowed_packet: Max size of packet sent to server in bytes. (default: 16MB)
Only used to limit size of "LOAD LOCAL INFILE" data packet smaller than default (16KB).
:param defer_connect: Don't explicitly connect on construction - wait for connect call.
(default: False)
:param auth_plugin_map: A dict of plugin names to a class that processes that plugin.
The class will take the Connection object as the argument to the constructor.
The class needs an authenticate method taking an authentication packet as
an argument. For the dialog plugin, a prompt(echo, prompt) method can be used
(if no authenticate method) for returning a string from the user. (experimental)
:param server_public_key: SHA256 authentication plugin public key value. (default: None)
:param binary_prefix: Add _binary prefix on bytes and bytearray. (default: False)
:param compress: Not supported.
:param named_pipe: Not supported.
:param db: **DEPRECATED** Alias for database.
:param passwd: **DEPRECATED** Alias for password.
See `Connection <https://www.python.org/dev/peps/pep-0249/#connection-objects>`_ in the
specification.
N Fr T
r& )(userpasswordhostdatabase unix_socketportcharset collationsql_moderead_default_fileconv use_unicode client_flag cursorclass init_commandconnect_timeoutread_default_group
autocommit local_infilemax_allowed_packet
defer_connectauth_plugin_map read_timeout
write_timeout bind_address
binary_prefix program_nameserver_public_keysslssl_cassl_cert ssl_disabledssl_keyssl_key_passwordssl_verify_certssl_verify_identitycompress
named_pipepasswddbc ( , |(||(}|'|s|'}|%s|&rt d t | | _ | j r|
t j z }
r&|
s$t
j d rd}
nd}
|
rsdt ,, t j |
,fd}) |)d| } |)d| } |)d | } |)d
| } |)d | }t |)d | } |)d
| } |)d| }| si } t | t r)dD ]&}* |)d|*z | j |* }+|+r|+| |*< 'd| _ | s~| s| s|!s|#s|$r,| t |$ |#|#ndd} | | | d< |!|!| d< |"|"| d< | rFt$ st d d| _ |
t j z }
| | | _ |pd| _ |pd| _ t1 | j t urt3 d |pt4 | _ |pd| _ t | j t: r | j d | _ || _ || _ || _! d |cxk rd k sn t3 d |pd | _" ||d k rt3 d || _# ||d k rt3 d || _$ |ptJ | _& || _' | | _( tS | j& j* | _* |
t j+ z }
| j r|
t j, z }
|
| _- || _. d | _/ d | _0 d!| _1 || _2 | tf j4 } d" | 5 D | _6 d# | 5 D | _7 | | _8 || _9 || _: |pi | _; || _< | | _= d$t| t; t j? d%| _@ |r
|| j@ d&< |r d | _A d S | B d S )'Nz3compress and named_pipe arguments are not supportedwinz c:\my.iniz /etc/my.cnfclientc ^ |r|S | S # t $ r |cY S w xY wN)get Exception)keyargcfgrB s r _configz$Connection.__init__.<locals>._config sN J 77#5s;;; JJJ s ,,r2 r3 r4 r5 socketr7 z bind-addresszdefault-character-set)cacapathcertra r3 cipherzssl-F)rf check_hostname verify_moderh ra zssl module not foundT localhosti zport should be of type intr! latin1r i3z+connect_timeout should be >0 and <=31536000zread_timeout should be > 0zwrite_timeout should be > 0z
Not connectedc F i | ] \ }}t | t u|| S typeint.0kvs r
<dictcomp>z'Connection.__init__.<locals>.<dictcomp>T s. OOO&1aDGG3<N<NA<N<N<Nr! c F i | ] \ }}t | t u || S ro rp rs s r rw z'Connection.__init__.<locals>.<dictcomp>U s) KKK&1aDGGsNNANNNr! pymysql) _client_name_client_version_pidrL )CNotImplementedErrorbool
_local_infiler LOCAL_FILESsysplatform
startswithr readospath
expanduserrr
isinstancedictr_ rN SSL_ENABLEDSSL_create_ssl_ctxctxr4 r7 rq r* DEFAULT_USERr2 r3 strencoderY r6 rJ rA
_read_timeout_write_timeoutDEFAULT_CHARSETr8 r9 r= r encoding CAPABILITIESCONNECT_WITH_DBr> r? _result_affected_rows host_infoautocommit_moder
conversionsitemsencodersdecodersr: r@ rE _auth_plugin_map_binary_prefixrM r getpid_connect_attrs_sockconnect)-selfr2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS rT rU rV rW rX rY rd ra valuerc s- ` @r __init__zConnection.__init__ sV X >h . H h H z %E
", / / . 6- -K 2&7 2|&&u--
2$0!!$1! )%
.%-"((C HHRW''(9:: ; ; ;
764((D wz844H764((D wz844H!'(K88Kwwvt,,--D"7><@@L g 5w??G
#t$$
)P ) )C #GFSL'#'#,, ? ?E )#(C 5
7
7W
7
7CV
7 &*+>&?&?&2 $3? '"*CK&!(CJ#/&6C
O
5" F-.DEEE vz) //44'K LD ??# % % 9:: :(L C
dmS ) ) ; M 0 0 : :DM& (O////x//// JKK K . 6$ # (9(9 9:: : ) $ !);); :;; ; + 1/ "&' 55>
v** 7 2 61 1K&& ( * < )D PODJJLLOOO
KKDJJLLKKK
("4 / 52 +!2 & - $$
?2>D / DJJJ LLNNNNNr! c | S r^ ro r s r __enter__zConnection.__enter__k s r! c 0 ~| d S r^ )close)r exc_infos r __exit__zConnection.__exit__n s
r! c 0 t |t j r|S | d }| d }|d u o|d u }t j || }| o| dd |_ | d }| |r t j n t j |_ nt |t r |r t j n t j |_ nt |t r| }|dv rt j |_ nM|dk rt j |_ n5|d v rt j |_ n |r t j n t j |_ d
|v rD|
|d
| d | d
d|v r| |d |xj t j z c_ |xj t j z c_ |S )Nrf rg )cafilerg rj Trk )none0falsenooptional)required1trueyesrh ra r3 )keyfiler3 ri )r rN
SSLContextr_ create_default_contextrj CERT_NONE
CERT_REQUIREDrk r~ r lower
CERT_OPTIONALload_cert_chain set_ciphersoptions OP_NO_SSLv2 OP_NO_SSLv3)r sslprf rg hasnocar verify_mode_values r r zConnection._create_ssl_ctxr s dCN + + K
XXd^^(##*/4 (6BBB!([ MTXX6F-M-M HH] 3 3 $/6 McmmC<MCOO
)4
0
0 R3D Wc / /#-COO+S11
>$5$;$;$=$=! $@@@"%-"j00"%"3"&FFF"%"33:"Q#--@Q T>> V dhhuoo@T@T
t OODN + + + s& s&
r! c D | j rt j d d| _ | j dS t j ddt j } | | n# t $ r Y nw xY w|
dS # |
w xY w)z
Send the quit message and close the socket.
See `Connection.close() <https://www.python.org/dev/peps/pep-0249/#Connection.close>`_
in the specification.
:raise Error: If the connection is already closed.
Already closedTN<iBr ) _closedr Errorr r r r COM_QUIT _write_bytesr` _force_close)r send_datas r r zConnection.close s < .) ,-- - : FKq'*:;; i ( ( ( ( D
D s*
A# "B #
A0-B /A00B B c | j duS )z&Return True if the connection is open.N)r r s r openzConnection.open s z%%r! c t | j r" | j n# Y nxY wd| _ d| _ dS )z&Close connection without QUIT message.N)r r _rfiler s r r zConnection._force_close sH :
""""
s # 'c t | | _ | }||k r| d S d S r^ )r~ r get_autocommit_send_autocommit_mode)r r currents r rC zConnection.autocommit sL #E{{ %%'' G & & ( ( ( ( ( r! c D t | j t j z S r^ )r~
server_statusr SERVER_STATUS_AUTOCOMMITr s r r zConnection.get_autocommit s D& )OOPPPr! c | }| s t j t j d t
| }|j | _ |S )NzCommand Out of Sync) _read_packet is_ok_packetr OperationalErrorr CR_COMMANDS_OUT_OF_SYNCr r )r pktoks r _read_ok_packetzConnection._read_ok_packet sd !! !! &*%
S
!
! - r! c | t j d| | j z | dS )z3Set whether or not to commit after every execute().zSET AUTOCOMMIT = %sN)_execute_commandr COM_QUERYescaper r r s r r z Connection._send_autocommit_mode sQ 4t{{4CW7X7X X
r! c n | t j d | dS )zBegin transaction.BEGINNr r r r r s r beginzConnection.begin s3 g /999 r! c n | t j d | dS )z
Commit changes to stable storage.
See `Connection.commit() <https://www.python.org/dev/peps/pep-0249/#commit>`_
in the specification.
COMMITNr r s r commitzConnection.commit s5
g /::: r! c n | t j d | dS )z
Roll back the current transaction.
See `Connection.rollback() <https://www.python.org/dev/peps/pep-0249/#rollback>`_
in the specification.
ROLLBACKNr r s r rollbackzConnection.rollback s5
g /<<< r! c | t j d t | }| |j S )z%Send the "SHOW WARNINGS" SQL command.z
SHOW WARNINGS)r r r MySQLResultr rows)r results r
show_warningszConnection.show_warnings s= g / AAA T""
{r! c n | t j | | dS )zI
Set current db.
:param db: The name of the db.
N)r r COM_INIT_DBr )r rY s r select_dbzConnection.select_db s5
g 12666 r! c t |t rd| | z dz S t |t t f r#| | }| j rd|z }|S t j || j | S )zxEscape whatever value is passed.
Non-standard, for internal use; do not use this in your applications.
'_binary)mapping)
r r
escape_stringr+ bytearray _quote_bytesr r
escape_itemr8 )r objr rets r r zConnection.escape s
c3 7++C00036 6 cE9- . . ##C((C"
& #oJ%c4<IIIIr! c 8 | || j S )zkAlias for escape().
Non-standard, for internal use; do not use this in your applications.
)r r )r r s r literalzConnection.literal
s
{{3
...r! c ~ | j t j z r| dd S t j | S )Nr z'')r r "SERVER_STATUS_NO_BACKSLASH_ESCAPESreplacer
r r ss r r zConnection.escape_string s:
P P (99S$'' ''***r! c | j t j z r=d | dd dd S t
j | S )Nz'{}' 's ''asciisurrogateescape)r r r formatr decoder
escape_bytesr
s r r zConnection._quote_bytes s`
P P == $&&--g7HII
&q)))r! c F |r || S | | S )a
Create a new cursor to execute queries with.
:param cursor: The type of cursor to create. None means use Cursor.
:type cursor: :py:class:`Cursor`, :py:class:`SSCursor`, :py:class:`DictCursor`,
or :py:class:`SSDictCursor`.
)r? )r cursors r r zConnection.cursor s. 6$<< %%%r! c t |t r| | j d }| t
j | | | | _ | j S )Nr
unbuffered) r r r r r r r _read_query_resultr )r sqlr s r queryzConnection.query- sg c3 ?**T],=>>C g /555 " 5 5 5 L L""r! c F | | | _ | j S )Nr )r r )r r s r next_resultzConnection.next_result6 s$ " 5 5 5 L L""r! c | j S r^ )r r s r
affected_rowszConnection.affected_rows: ""r! c t j d| }| t j | | S )Nr )r r r r COM_PROCESS_KILLr )r thread_idrb s r killzConnection.kill= s> k$ ** g 6<<<##%%%r! c R | j -|r| d}nt j d | t
j d | dS # t $ r0 |r,| | d Y dS w xY w)z
Check if the server is alive.
:param reconnect: If the connection is closed, reconnect.
:type reconnect: boolean
:raise Error: If the connection is closed and reconnect=False.
NFr r0 )
r r r r r r COM_PINGr r` ping)r reconnects r r& zConnection.pingB s :
2 ! i 0111 ! !'"2B 7 7 7 " " " " "
% s 4A, ,5B&$B&c 0 | | dS )z,Deprecated. Use set_character_set() instead.N)set_character_set)r r8 s r set_charsetzConnection.set_charset[ s
w'''''r! c t | j }|r d| d| }nd| }| t j | | || _ || _ || _ dS )z
Set charaset (and collation)
Send "SET NAMES charset [COLLATE collation]" query.
Update Connection.encoding based on charset.
z
SET NAMES z COLLATE N)r r r r r r r8 r9 )r r8 r9 r r s r r) z Connection.set_character_setc s #7++4 +>>>9>>EE***E g /777
"r! c d| _ || j rt j t j t j }| | j | | j d| _ d| _ t rt d ni }| j | j df|d< t j
| j | j f| j fi |}n-# t $ r }|j t" j k rY d }~K d }~ww xY wd| j | j fz | _ t rt d | t j t j d | t j t j d | d || _ | d
| _ d| _ | | | | j | j | j! D| " }|# d | j! f |$ | j% B| " }|# | j% |$ | j& | ' | j& d S d S # tP $ r}d | _ | |$ n# Y nxY wtS |t tT f rgtW j, tZ j. d | j d
| d }||_/ ta j1 |_0 t rt |j0 | d }~ww xY w)NFzLocalhost via UNIX socketTzconnected using unix_socketr source_addressz socket %s:%dzconnected using socketr rbzSET sql_mode=%sz!Can't connect to MySQL server on z ())2r r6 re AF_UNIX SOCK_STREAM
settimeoutrA r r _secureDEBUGprintrJ create_connectionr4 r7 OSErrorerrnoEINTR
setsockopt IPPROTO_TCP TCP_NODELAY
SOL_SOCKET SO_KEEPALIVEr makefiler _next_seq_id_get_server_information_request_authenticationr) r8 r9 r: r executer r@ r rC
BaseExceptionr IOErrorr r r CR_CONN_HOST_ERRORoriginal_exception traceback
format_exc)r sockkwargsecexcs r r zConnection.connectw sm X |# O!= 9KLLDOOD$8999LL!1222%@DN#'DL = ;<<< F(4484Eq3I /0 ""#)#;!%DI 68L$ $ PV$ $ D " & " " " w%+ 5 5 ( !" &4ty$)6L%LDN 8 6777OOF$68JANNNOOF$5v7JANNN%%% DJ ----DK !D ( ( * * * ( ( * * *
" "4< @ @ @}(KKMM +dm-=>>> ,KKMM $+,,, #/ 455555 0/ DK JJLLLLD!gw /00
*)K KKqKKK
*+& ) 4 6 6
)#-(((
/ sb B"J> ,$C J>
C;C60J> 5C66C;;F?J> >
M7 M2K'&M2'K+)B M22M7c t t | t | j g z |z }t rt | | | | j dz dz | _ dS )zvWrites an entire "mysql packet" in its entirety to the network
adding its length and sequence number.
r N)r lenr+ r@ r4 r r )r payloaddatas r write_packetzConnection.write_packet st 3w<<((5$2C1D+E+EEO $ ! . 2c 9r! c t } | d }t j d| \ }}}||dz z }|| j k rW| |dk r t
j t j d t
j
d|| j fz | j dz d z | _ | | }t rt | ||z
}|t k rn |t | | j } | r5| j | j j du r d | j _ | | S ) a! Read an entire "mysql packet" in its entirety from the network
and return a MysqlPacket type that represents the results.
:raise OperationalError: If the connection to the MySQL server is lost.
:raise InternalError: If the packet sequence number is wrong.
T z<HBB r ,Lost connection to MySQL server during queryz1Packet sequence number wrong - got %d expected %dr rP NF)r _read_bytesr unpackr@ r r r r CR_SERVER_LOST
InternalErrorr4 r MAX_PACKET_LENr+ r is_error_packetr unbuffered_activeraise_for_error)
r packet_typebuff
packet_headerbtrlbtrh
packet_number
bytes_to_read recv_datapackets
r r zConnection._read_packet s {{ , ,Q / /M )/
fm(L(L %D$
DBJ /M 111!!### A%% .)F 'G$d&789 "&!2Q!6# =D (( 77I
'I&&& I D ~--5 8 U4[[$-88 ! ! # # %|'DL,Jd,R,R16 . " " $ $ $
r! c | j | j | j | }n# t
$ rV}|j t j k rY d }~A| t j
t j d| d d }~wt $ r | w xY wt | |k r3| t j
t j d |S )NTz.Lost connection to MySQL server during query (r/ rX )r r2 r r r r7 r8 r9 r r r r r[ rD rQ )r num_bytesrS rL s r rY zConnection._read_bytes
s$
d 0111
{'' 22
7ek)) HHHH!!###*%IQIII !
!!###
t99y &!#Q
s =
B;B!7B#B;c | j | j | j | d S # t $ r<}| t
j t j d|d d }~ww xY w)Nz MySQL server has gone away (r/ )
r r2 r sendallr7 r r r r CR_SERVER_GONE_ERROR)r rS rL s r r zConnection._write_bytes# s
d 1222 J t $ $ $ $ $ &')N)N)N)N
s =
B7A>>Bc d | _ |r9 t | }| n7# d|_ d |_ xY wt | }| || _ |j |j | _ |j S )NF)r r init_unbuffered_queryr_
connectionr r r )r r r s r r z Connection._read_query_result- s
$T**,,....
+0($(! &&F KKMMM +!'!5D ##s #/ A c , | j r | j j S dS Nr )r insert_idr s r rt zConnection.insert_id? s < <) )1r! c ` | j st j dd | j l| j j r-t j d | j | j j r | | j j d| _ t |t r| | j
}t t t! | dz }t# j d|| }||d|dz
z }| | t( rt+ | d| _ |t k rdS ||dz
d } t t t! | }| |d| ||d }|s
|t k rdS Y)z~
:raise InterfaceError: If the connection is closed.
:raise ValueError: If no username was specified.
r r0 Nz.Previous unbuffered result was left incompleter r )r r InterfaceErrorr r_ warningswarn_finish_unbuffered_queryhas_nextr r r r r minr] rQ r r r r4 r r@ rT )r commandr packet_sizepreluderi s r r zConnection._execute_commandE s
z ,$Q++ + < #|-
8
NOOO 55777,'
# """ ,'
# DL c3 ,**T]++C.#c((Q,77 +e['::3 0q 011 &!!! ' ' F+/##$ nc#hh77K c,;, / 0 0 0kll#C
; 77 r! c t | j dd d dk r| xj t j z c_ | j t d t | j j
}t | j t r$| j
| j | _ t j d| j t" |d }| j rz| j t j z rf| | | j | j | j | _ | j d | _ d
| _ || j z d z }d}d }| j d k r"d}t= j | j | j! }n| j d
k r"d}t= j | j | j! }n| j dk rVd}| j r6tD rtG d t= j$ | j | j! }nVtD rtG d n?| j dk r4d}| j r | j t j z r | j d z }n | j rd}nd }| j t j% z r#|tM tO | |z z
}nE| j t j( z r)|t j dtO | |z z
}n||d z z
}| j) r_| j t j* z rKt | j) t r$| j)
| j | _) || j) d z z
}| j t j+ z r
||pdd z z
}| j t j, z rd}| j- . D ]s\ }}|
d }|tM tO | |z z
}|
d }|tM tO | |z z
}t|tM tO | |z z
}| | | / } | 0 rtD rtG d | 1 | 2 }| j t j+ z r|| 3 || } nti j5 d | 6 rrtD rtG d | j dk rt= j7 | | } n;| j dk rt= j8 | | } nti j5 d| j tD rtG d d S d S ) N.r r zDid not specify a usernamez<iIB23sr! )server_hostnamer. T r0 mysql_native_password mysql_native_passwordcaching_sha2_password caching_sha2_passwordz caching_sha2: trying fast pathz caching_sha2: empty passwordsha256_password sha256_password Butf-8zreceived auth switchz$received unknown auth switch requestzreceived extra dataz(Received extra packet for auth method %rzSucceed to auth)9rr server_versionsplitr> r
MULTI_RESULTSr2 r* r r8 idr r r r r r r] rN server_capabilitiesr rT r wrap_socketr r4 r? r r3 _auth_plugin_namer scramble_native_passwordr3 saltr4 r5 scramble_caching_sha2 PLUGIN_AUTH_LENENC_CLIENT_DATAr- rQ SECURE_CONNECTIONrY r PLUGIN_AUTH
CONNECT_ATTRSr r r is_auth_switch_request
read_uint8 read_string
_process_authr r is_extra_auth_datacaching_sha2_password_authsha256_password_auth)
r
charset_id data_initrS authresp plugin_name
connect_attrsru rv auth_packets
r rB z"Connection._request_authenticationp sn t"((a003 4 4 9 9 4 4 9 9:: :$T\225
di % % 8 (( 77DIK t' S
8 06:= i ( ( ( --dj$)-TTDJ *--d33DK DL49$u, !R ' ' K 5dmTYOOHH
#'>
>
>2K 5dmTYOOHH
#'>
>
>2K}
: <:;;; 6t}diPP :8999
#'8
8
8,Kx
!D 4vz A
! =50
! #f&K K % KH
..9 9DD
%(@
@ % FKS]]33h> >DD Hu$ $D 7 $t/&2HH $$'3''
8 '.. 77 DGeO #D #f&8 8 1 ['C50 0D #f&: : D M +1133
9
91HHW%% SVV!4!4q!88
HHW%% SVV!4!4q!88
KM 2 233mC CD $ '')) - - / /
.,--- " " $ $ $%1133K(6+==
S + " 0 0k J J *+QRRR
+
+
-
-
-+,,,%)@@@ # >t[ Q Q '+<<< # 8{ K K *>@V % # $ $ $ $ $ % %r! c R | | }|r_ | | S # t $ r< |dk r3t j t
j d| dt | d Y nw xY w|dk rt j | | S |dk rt j
| | S |dk r.t j | j |
}n |dk r.t j | j |
}n|d k r1t j | j |
d
z }n|d k r | j d
z }n|dk rc|} | }|d
z dk }|dz dk }|
} | dk r | | j d
z n|rd}
| || }
| |
d
z n# t $ r' t j t
j d| d|d t& $ r, t j t
j d| d|d|
d| w xY wt j t
j d| d | }| | s|rn^|S t j t
j d|z | | | }| |S )Ns dialogAuthentication plugin '' not loaded: - z missing authenticate methodr r r s client_ed25519s mysql_old_passwordr s mysql_clear_passwordT r s
Password: z3no response - TypeError within plugin.prompt methodz missing prompt methodz' z' didn't respond with string. Returned 'z ' to prompt z' not configuredz)Authentication plugin '%s' not configured)_get_auth_plugin_handler authenticateAttributeErrorr r r CR_AUTH_PLUGIN_CANNOT_LOADrq r r r r r3 read_alled25519_passwordscramble_old_passwordr rT prompt TypeErrorCR_AUTH_PLUGIN_ERRr check_errorr ) r r r handlerrS r flagecholastr resps r r zConnection._process_auth s // <<
++K888!
)++ .5X+ X X*.w--X X X ,+
2 2 23D+FF F
.
.
.-dK@@ @
4
4
41$-AUAUAWAWXXDD
-
-
-)$-9M9M9O9OPPDD
1
1
1+DM;;O;O;Q;QRR
D 3
3
3=5(DD
I
%
% C!
~~'' t , t , ]**%%dme&;<<<< PD &~~dF ; ; ))$,7777) ! 2 9 Pk P P.5 P P P
% ! 2 1 qk q q ' q qRV q qfl q q .5O+OOO ''))!!!##%% C!
D J&-;kI
$ !!
s . AA43A4 .G: :A%I c L | j | }|sBt |t r-| j | d }|rA || }n6# t
$ r' t
j t j d| d|d w xY wd }|S )Nr r r z- cannot be constructed with connection object)
r r_ r r+ r r r r r r )r r plugin_classr s r r z#Connection._get_auth_plugin_handler* s ,00== R
; > > R 044[5G5G5P5PQQL
&,t,,
*1dk d d&2d d d
Gs " A. .1B c | j d S rs )server_thread_idr s r r" zConnection.thread_id< s $Q''r! c | j S r^ )r8 r s r character_set_namez Connection.character_set_name? s
|r! c | j S r^ )r r s r
get_host_infozConnection.get_host_infoB s
~ r! c | j S r^ )protocol_versionr s r get_proto_infozConnection.get_proto_infoE s $$r! c d}| }| }|| | _ |dz
}| d| }||| d | _ |dz }t
j d|||dz | _ |dz
}|||dz | _ |dz
}t
j d |||d
z d | _
|d
z
}t | |d z k rt
j d |||d z \ }}}}|d z
}|| _ t | j | _ n# t $ r
d | _ Y nw xY w|| _ t$ rt' d
|z | xj
|dz z c_
t$ rt' d| t) d|dz
}|dz
}t | ||z k r | xj ||||z z
c_ ||z
}|dz
}| j
t* j z rwt | |k rf| d| }|dk r$||d d | _ d S ||| d | _ d S d S d S )Nr r r rm r rV r% r r z<BHHBzserver_status: %xrW z salt_len: r1 r )r get_all_datar findr r r rZ r r r rQ server_languager nameserver_charsetKeyErrorr r4 r5 maxr r r ) r r, ri rS
server_endlangstatcap_hsalt_lens r rA z"Connection._get_server_informationH s
""$$""$$ $Q QYYua((
"1Z< 0 7 7 A A N &
dDQUO D D QQUO Q#)=tAAI#G#G#J Q t99A *0-a!a%i *Q*Q 'D$x
FA $(D
+&3D&9&9&>##
+
+
+&*###
+ "&D
2)D0111 $ $ 3 $ $
-k8,,,2x!|,,H
R t99H $ $ IIa!h, ./ /II
MA Q #f&8 8 LSYY!^^ 5!,,JA~~)-abb )A)A&&&)-a
l);)B)B7)K)K&&& L L^^s 3E
E! E!c | j S r^ )r r s r get_server_infozConnection.get_server_info r r! r^ )F)T)D__name__
__module__ __qualname____doc__r r r r3 r r r r r r propertyr r __del__rC r r r r r r r r r r r r r r r r r# r& r* r) r rT r r rY r r rt r rB r r r" r r r rA r r Warningr rv
DatabaseError DataErrorr IntegrityErrorr\ ProgrammingErrorNotSupportedErrorro r! r r/ r/ [ s E EN
EGG
+ UA A A A AF D , & & X& G) ) ) Q Q Q
J J J J / / /+ + +
* * *
&
&
&
&# # # ## # # ## # #& & &
2( ( (# # # #(Z Z Z Zx
:
:
: (3 ) ) ) )V 2 $ $ $ $$ ) ) )Vl% l% l%\J J JX $( ( ( % % %?L ?L ?LB# # # kG IE'N%M
I+'N%M+-r! r/ c \ e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
ZdS )r c || _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _
dS )z.
:type connection: Connection
Nr F) rq r rt r
warning_countmessage field_count descriptionr rz r_ )r rq s r r zMySQLResult.__init__ s] % ! !
!& r! c @ | j r| d S d S r^ )r_ ry r s r r zMySQLResult.__del__ s/ ! , ) ) + + + + + , ,r! c 2 | j }| r| | n?| r| | n| | d | _ d S # d | _ w xY wr^ )rq r r r is_load_local_packet_read_load_local_packet_read_result_packetr first_packets r r zMySQLResult.read s
# ?7799L((**
7$$\2222 2244
7,,\::::(( 666 "DOOOdDO " " " "s BB
Bc d| _ | j }| r%| | d| _ d| _ dS | r%| | d| _ d| _ dS | | _ | d| _
dS )zw
:raise OperationalError: If the connection to the MySQL server is lost.
:raise InternalError:
TFNl ) r_ rq r r r r r read_length_encoded_integerr _get_descriptionsr r s r rp z!MySQLResult.init_unbuffered_query s
"& 3355 $ $ & & 6 . . .%*D " "DOOO
.
.
0
0 6 ( ( 6 6 6%*D " "DOOO + G G I ID " " $ $ $
"6D r! c t | }|j | _ |j | _ |j | _ |j | _ |j | _ |j | _ d S r^ )r r rt r r r rz )r r ok_packets r r zMySQLResult._read_ok_packet sR #L11 & 4", & 4 & 4 ( !*
r! c | j j st d t | }t |j | j } | n # | j xY w| j }| s t j
t j d |
| d S )NzF**WARN**: Received LOAD_LOCAL packet but local_infile option is false.zCommands Out of Sync)rq r RuntimeErrorr
LoadLocalFilefilenamer r r r r r r r )r r load_packetsenderr s r r z#MySQLResult._read_load_local_packet s , X
-\:: { 3T_EE O ( ( * * * O0022 &&(( &*&
Y'''''s A A7c | sdS t | }|j | _ |j | _ dS )NFT)
is_eof_packetr r rz )r ri wps r _check_packet_is_eofz MySQLResult._check_packet_is_eof sC ##%% 5 f
%
% -
tr! c | | _ | | d S r^ )r r r _read_rowdata_packetr s r r z MySQLResult._read_result_packet s@ 'CCEE !!#####r! c | j sd S | j }| | rd| _ d | _ d | _ d S | | }d| _ |f| _ |S )NFr )r_ rq r r r _read_row_from_packetr )r ri rows r _read_rowdata_packet_unbufferedz+MySQLResult._read_rowdata_packet_unbuffered s % F --// $ $V , , %*D " "DO DI F((00 F
r! c D | j r | j }nQ# t j $ r?}|j d t j t j fv rd| _ d | _ Y d }~d S d }~ww xY w| | rd| _ d | _ | j d S d S )Nr F)
r_ rq r r r argsr
QUERY_TIMEOUTSTATEMENT_TIMEOUTr )r ri rL s r ry z$MySQLResult._finish_unbuffered_query s $ '
5577'
6!9$(!
.3D*&*DOFFFFF
((00
').&"&# $ ' ' ' ' 's # A13A,+A,,A1c g } | j }| | rd| _ n)| | | _t | | _ t | | _ dS )z:Read a rowdata packet for each data row in the result set.TN) rq r r appendr rQ r tupler )r r ri s r r z MySQLResult._read_rowdata_packet. s <_1133F((00
"& KK226:: ; ; ; < !YY$KK r! c 0 g }| j D ]~\ }} | }n# t $ r Y nWw xY w|;|| | }t rt d| | || }| | t | S )NzDEBUG: DATA = )r
read_length_coded_string
IndexErrorr r4 r5 r
r )r ri r r converterrS s r r z!MySQLResult._read_row_from_packet; s #'? Hi
6688
' ;;x00D 2*D111 ($9T??D JJt Szzs %
33c " g | _ g | _ | j j }| j j }g }t | j D ]}| j t }| j | | |
|j }|r0|t j
k r|}n |t v r|j dk rd}n|}nd}nd}| j j | }|t j u rd}t& rt) d| d| | j ||f | j } | s
J d t- | | _
dS )z>Read a column descriptor packet for each column in the result.? Nr z
DEBUG: field=z , converter=z Protocol error, expecting EOF)fieldsr
rq r= r ranger r r r
r type_coder JSON
TEXT_TYPES charsetnrr r_ throughr4 r5 r r )
r r=
conn_encodingr r, field
field_typer r
eof_packets
r r z MySQLResult._get_descriptionsN s o1 0
t'(( : :AO001FGGE K u % % % u 0 0 2 2 3 3 3 J
00 -HH :-- ",,#'#0 'HH 044Z@@IJ ...
FDeDDDDEEE O " "Hi#8 9 9 9 9_1133
''))JJ+JJJ) --r! N)r r r r r r rp r r r r r ry r r r ro r! r r r s ' ' ' , , , # # #6 6 62+ + +( ( (. $ $ $
$' ' '. &). ). ). ). ).r! r c e Zd Zd Zd ZdS )r c " || _ || _ d S r^ )r rq )r r rq s r r zLoadLocalFile.__init__{ s
$r! c * | j j st j dd | j } t | j d 5 }t
|j d } | | }|sn| | . ddd n # 1 swxY w Y n6# t $ r) t j t j
d| j d w xY w|j s| d dS dS # |j s| d w w xY w)
z3Send data packets from the local file to the serverr r0 r. i @ TNzCan't find file 'r r! )rq r r rv r r r{ rE r rT r7 r r
FILE_NOT_FOUNDr )r conn open_filer} chunks r r zLoadLocalFile.send_data s $ ,$Q++ + ? 'dmT**
-i !+Y - %NN; 7 7E %%e,,, -
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- &!4DM444
<
'!!#&&&&&
'
'4<
'!!#&&&&
'sA B AB B BB BB C3 3CC3 3 DN)r r r r r ro r! r r r z s2 % % %' ' ' ' 'r! r ):r8 r re r r rH rw r0 r r8 r r constantsr r r r
r r r
cursorsr
optionfiler protocolr r r r r r r r rN r ImportErrorgetpassgetuserr r r4 BITBLOB LONG_BLOB MEDIUM_BLOBSTRING TINY_BLOB
VAR_STRINGVARCHARGEOMETRYr r r] r r- r/ r r ro r! r <module>r7 s
3 3 3 3 3 3 3 3 I I I I I I I I I I I I I I I I " ! ! ! ! ! ! !JJJKK
CKKKNNN"7?$$LX LLL NO
$ $ $
&z. z. z. z. z. z. z. z.z!_. _. _. _. _. _. _. _.D ' ' ' ' ' ' ' ' ' 's$ &A- - A98A9=B B B