Ë
|
Wñúh(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)ÚAnyÚDictÚListÚOptionalÚTupleé )Ú
|
ClientFlagÚ ServerCmd)ÚInterfaceErrorÚProgrammingErrorÚ get_exception)Úlogger)ÚDEFAULT_CHARSET_IDÚDEFAULT_MAX_ALLOWED_PACKETr )ÚBinaryProtocolTypeÚDescriptionTypeÚ EofPacketTypeÚ HandShakeType)Úlc_intÚread_lc_string_listé )Ú MySQLSocket)ÚMySQLAuthPluginÚget_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_dataÚusernameÚpasswordÚ auth_pluginÚauth_plugin_classÚ ssl_enabledÚ plugin_configÚreturnc ó@ |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
|
úOH:\Change_password\venv_build\Lib\site-packages\mysql/connector/aio/protocol.pyÚauth_plugin_first_responsez(MySQLProtocol.auth_plugin_first_response: sì ñD K¨2Ò -àÔ >Ø(° ô ð ð ð Ð Ø Mð KØ KO¨KÐ9JÓ KØ(° ô Mð 8M× 7Ñ 7¸ Ñ SÀ]Ñ SMð Ð Ü ðØ'×,Ñ,Ð-ð/óð ô
|
s =Ó 1Ó2°]ÑB à mÐ+Ð+øô >Ð*ò KÜ Ð#:¸3¸%Ð!@ÓAÀsÐ Jûð Kús (A: Á:B Â BÂB r Ú handshakeÚdatabaseÚcharsetÚ client_flagsÚmax_allowed_packetÚ
|
conn_attrsÚis_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<BÚsxÚxxxxxxxxxxxxxxxxxxxxxxxz<IIB)r r r r! r" r# r$ z<Hr( ó )Úencoder Údebugr Úgetr* ÚKeyErrorÚappendÚstructÚpackr, r Ú CHANGE_USERr r0 Úconnect_with_dbr
|
Ú PLUGIN_AUTHÚ CONNECT_ARGSÚmake_conn_attrsÚjoin)r1 r r r2 r3 r4 r5 r! r" r6 r7 r# r$ Ú
|
b_usernameÚresponse_payloadr. Úfillerr) r- s r/ Ú make_authzMySQLProtocol.make_authw s, ðf __Ó&
|
Ø Ðá !Ü LLÐ6Ô 7ä Ð3Ô4Ø Ð Ü"Ð#9Ó:ÀÐ Dà ==Ó %Ð -Ü"Ð#IÓJÐPTÐ Tð Ø%ÒA¨°=Ñ)AKô Ð:¸KÔHá !Ø × #Ñ #Ü ØZ Ð)¨Ð,Ü ×)Ñ)Ø óõ ð FØ × #Ñ #Ü Ø6(¤3 z£?Ð"3°2Ð6Ø Ø&ØØ ó ô ô (5×'OÑ'OØ Ñ,Ø Ø Ø#Ø /Ø#Ø'ð (Pó (
|
Ñ$ }ð × Ñ Ô.ð × Ñ ¤ × =Ñ =¸lÈHÓ UÔVñ "Ø × #Ñ #¤F§K¡K°°gÓ$>Ô ?ð *×0Ñ0Ò 0Ø × #Ñ # K×$6Ñ$6Ó$8¸7Ñ$BÔ Cð :×2Ñ2Ò 2¸
|
Ð8NØ × #Ñ #¤M×$AÑ$AÀ*Ó$MÔ NàxxÐ(Ó)¨=Ð8Ð8øôm 8Ð$ò Ü"Ø?À¸uÀAÐFóàð ûð ús Á+ H ÈH+ÈH&È&H+ÚsockÚcolumnsÚcountÚ 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 ÚrowsÚeofÚvaluesÚiÚpackets r/ Úread_binary_resultz MySQLProtocol.read_binary_resultò sÐ è ø ð ØØØ ØÙa5jØð c{Ðð 99 \Ó2×2FØayCÒ Ønn VÓ,Ø Øa ØØ ×2Ñ2°7¸FÀ1À2¸JÈÓPØ{vÐ 1Ø FÕ#Ø Ü# FÓ+Ð+Ø FAð ð 3ús *B¬BA,BÚversionc ó¨ 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) z·Read 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 \Ó2×2FØ× Ñ Ô1Ø Ø #yy¨ Ó 6×6Ø ×'Ñ'¨Ô8ØLL ¨¨ Ô,Ø#'§9¡9¨\Ó#:× :Fð ×'Ñ'¨Õ8ð V A BZÔ(Ü-¨c¯h©h°u«oÓ>ØcÒ! f¨Q¡i°!¢mØnn VÓ,Ø àÜ-¬e°F¸1¸2°JÓ.?Ó@Ø{wÐ 2Ø GÕ$Ø Ü# FÓ+Ð+Ø FAñ- ð 3ùð 7øð ;ús: ,E®E ¯/EÁ EÁ =E E EÂ3BEÅEÅE)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Ø',Ø !Ø26ñw9Ø ðw9àðw9ð ð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 Ú_MySQLProtocolÚtypesr r r r Úutilsr r Únetworkr Úpluginsr r Ú plugins.caching_sha2_passwordr rq r< r/ ú<module>r} sT ðñ: 3à Ð
|
ã ç 3Õ 3ç -ß DÑ DÝ ÷ñ ÷
|
VÓ Uß /Ý ß 5Ý MôQNõ Qr<
|
