/var/opt/nydus/ops/mysql/connector/aio/__pycache__
Edit: /var/opt/nydus/ops/mysql/connector/aio/__pycache__/protocol.cpython-312.pyc (11514B)
N j(1 d Z dgZddlZddlmZmZmZmZmZ ddl m
Z
m Z ddl m
Z
mZmZ ddlmZ dd lmZmZmZ dd
lmZmZmZmZ dd lm Z m Z d d
l m Z d dl m!Z!m"Z" d dl#m$Z$ G d de Zy)z,Implements the MySQL Client/Server protocol.
MySQLProtocol N)AnyDictListOptionalTuple )
ClientFlag ServerCmd)InterfaceErrorProgrammingError
get_exception)logger)DEFAULT_CHARSET_IDDEFAULT_MAX_ALLOWED_PACKETr )BinaryProtocolTypeDescriptionType
EofPacketType
HandShakeType)lc_intread_lc_string_list ) MySQLSocket)MySQLAuthPluginget_auth_plugin)"MySQLCachingSHA2PasswordAuthPluginc e Zd ZdZe d dededededee d ed
ee ee
f d e ee f fd Z
eded
eddddddf
dedededee dedededee dee dee eef ded ed
ee ee
f d e ee f f d Z d dedee dededee d e ee edf ee f f dZ d ded e edf dedee d e ee ee df ee f f
d Zy)!r zSImplements MySQL client/server protocol.
Create and parses MySQL packets.
NF auth_datausernamepassword auth_pluginauth_plugin_class ssl_enabled
plugin_configreturnc @ |s|dk( rdt ||| fS |i } t || ||| } |j | fi |}|t d|j
t
t | |z }||fS # t t f$ r} t d| | d} ~ ww xY w)a Prepare the first authentication response.
Args:
auth_data: Authorization data from initial handshake.
username: Account's username.
password: Account's password.
client_flags: Integer representing client capabilities flags.
auth_plugin: Authorization plugin name.
auth_plugin_class: Authorization plugin class (has higher precedence
than the authorization plugin name).
ssl_enabled: Whether SSL is enabled or not.
plugin_config: Custom configuration to be passed to the auth plugin
when invoked. The parameters defined here will override
the ones defined in the auth plugin itself.
Returns:
auth_response: Authorization plugin response.
auth_strategy: Authorization plugin instance created based
on the provided `auth_plugin` and `auth_plugin_class`
parameters.
Raises:
InterfaceError: If authentication fails or when got a NULL auth response.
)r# NzFailed authentication: z8Got NULL auth response while authenticating with plugin )r r
auth_response TypeErrorr namer len)
r r r r! r" r# r$
auth_strategyr) errs
M/opt/nydus/tmp/pip-target-a90h98xg/lib/python/mysql/connector/aio/protocol.pyauth_plugin_first_responsez(MySQLProtocol.auth_plugin_first_response: s D K2 - >(
M K KOK9J K( M 8M 7 7 S] SM ',,-/
s= 12]B
m++ >* K #:3%!@As J Ks (A: :B BB r handshakedatabasecharset client_flagsmax_allowed_packet
conn_attrsis_change_user_requestc
\ |j }
g }|
rt j d t j d | t d d| j d t d d |xs | d }t j d
| |
rB|j t j d t |
d t j |
n9d
}|j t j d| t |
d ||||
t j | d ||||| | \ }}|j | |j t j || |
r%|j t j d| |t j" z r"|j |j dz |t j$ z r&| $|j t j' | dj) | |fS # t
t f$ r}t d| d dd}~ww xY w)a Make a MySQL Authentication packet.
Args:
handshake: Initial handshake.
username: Account's username.
password: Account's password.
database: Initial database name for the connection
charset: Client charset (see [2]), only the lower 8-bits.
client_flags: Integer representing client capabilities flags.
max_allowed_packet: Maximum packet size.
auth_plugin: Authorization plugin name.
auth_plugin_class: Authorization plugin class (has higher precedence
than the authorization plugin name).
conn_attrs: Connection attributes.
is_change_user_request: Whether is a `change user request` operation or not.
ssl_enabled: Whether SSL is enabled or not.
plugin_config: Custom configuration to be passed to the auth plugin
when invoked. The parameters defined here will override
the one defined in the auth plugin itself.
Returns:
handshake_response: Handshake response as per [1].
auth_strategy: Authorization plugin instance created based
on the provided `auth_plugin` and `auth_plugin_class`.
Raises:
ProgrammingError: Handshake misses authentication info.
References:
[1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html
[2]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set
zGot a `change user` requestz Starting authorization phaseNzGot a NULL handshaker z$Handshake misses authentication infor! z-Handshake misses authentication plugin info ()z#The provided initial strategy is %sz
? *00 0 # #K$6$6$87$B C
:22 2
8N # #M$A$A*$M Nxx()=88m 8$ "?uAF
s + H H+H&&H+sockcolumnscount read_timeout.c 8 K g }d}d}d} |s| |k( r ||fS |j | d{ }
|
d dk( r| j |
}d}n |
d dk( rd}| j ||
dd | }|||j | n|
| t |
| dz
} 7 kw)zxRead MySQL binary protocol result.
Reads all or given number of binary resultset rows from the socket.
Nr r )read parse_eof_parse_binary_valuesrA r ) selfrN rO rP r3 rQ rowseofvaluesipackets r/ read_binary_resultz MySQLProtocol.read_binary_result s
a5j c{ 99\22FayC nnV, a 227F12JP{v 1 F# #F++
FA 3s *BBA,Bversionc K |}g }d}d}d} |s| |k( r ||fS |j | d{ }
|
j d r|
dd g} |j | d{ }
|
j d r?| j |
dd |j | d{ }
|
j d r?| j |
dd t dj | }n=|
d dk( r |
d dk r| j |
}d}nd}t t
|
dd }|||j | n|
| t |
| dz
} =7 7 7 w) zRead MySQL text result.
Reads all or given number of rows from the socket.
Returns a tuple with 2 elements: a list with all rows and
the EOF packet.
Nr s rS r< rT r )rV
startswithrA r rI rW bytesr ) rY rN r` rP rQ _rZ r[ rowdatar] r^ datass r/ read_text_resultz MySQLProtocol.read_text_result sn $
a5j* Sy) 99\22F 1 #yy 66 ''8LL,#'99\#: :F ''8 VABZ(-chhuo>c!fQi!mnnV, -eF12J.?@{w 2 G$ #F++
FA- 3 7 ;s: ,EE /E E =E E E3BEEE)NFN)r zutf-8N)r N)__name__
__module__ __qualname____doc__ staticmethodrd strr boolr r r r r0 r r r intrM r r r r r r_ rh r< r/ r r 4 su
,0 !26:,:,:, :, :,
$C= :,
:, S#X/:,
uo% &:, :,x
#') "<%)+//3', !26w9 w9w9 w9 3- w9
w9
w9 w9 c]w9 $C=w9 T#s(^,w9 !%w9 w9 S#X/w9
uo% & w9 w9| &*
"" o&" "
" sm
"
U%s*
+, !
"R &* .. sCx . .
sm .
U8E?C'
() !
.r< )%rl __all__rB typingr r r r r constantsr
r errorsr r
r r protocolr r r _MySQLProtocoltypesr r r r utilsr r networkr pluginsr r plugins.caching_sha2_passwordr rq r< r/ r} sT : 3
3 3 - D D
V U / 5 MQN Qr<