*h3ZSrSSKJr SSKrSSKrSSKJr SSKJrJ r SSK J r J r J r JrJrJrJrJrJr SSKJr SS KJrJrJrJrJr SS KJr SS KJrJ r J!r!J"r" SS K#J#r# SS K$J%r%J&r& SSK'J(r( SSK)J*r*J+r+J,r,J-r-J.r.J/r/J0r0 \ (aSSK1J2r2 Sr3Sr4Sr5Sr6Sr7Sr8Sr9Sr:Sr;Sr<"SS5r=g)z,Implements the MySQL Client/Server protocol.) annotationsN)deque)DecimalDecimalException) TYPE_CHECKINGAnyDequeDictListOptionalSequenceTupleUnion)utils)PARAMETER_COUNT_AVAILABLE ClientFlag FieldFlag FieldType ServerCmd)MySQLConverter) DatabaseErrorInterfaceErrorProgrammingError get_exception)logger)MySQLAuthPluginget_auth_plugin)"MySQLCachingSHA2PasswordAuthPlugin)BinaryProtocolTypeDescriptionType EofPacketType HandShakeType OkPacketTypeStatsPacketType StrOrBytes) MySQLSocket -i@c \rSrSrSr\S%Sj5r\S&Sj5r\S&Sj5r\S'Sj5r \S(Sj5r \S)S*S jj5r \S\ S \ SSSS S S4 S+S jj5r\\ S \ 4S,S jj5r\S-S.Sjj5r\S/S0Sjj5r\S1Sj5r\S2Sj5r\S3Sj5r\S4S5Sjj5rS6Sjr\S7S8Sjj5rS9S:Sjjr\S;Sj5r\SSjj5r\S?Sj5r\S@Sj5rS4SASjjrSBSCSjjr\SDSj5r \SESj5r!\SFS j5r"\SGS!j5r#\SHS"j5r$SISJS$jjr%S#r&g)K MySQLProtocolXzJImplements MySQL client/server protocol Create and parses MySQL packets. c<US[:Xd [S5eUSS$)aParse a MySQL auth more data packet. Args: pkt: Packet representing an `auth more data` response. Returns: auth_data: Authentication method data (see [1]). Raises: InterfaceError: If packet's status tag doesn't match `protocol.EXCHANGE_FURTHER_STATUS`. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_auth_more_data.html z"Failed parsing AuthMoreData packetN)EXCHANGE_FURTHER_STATUSr)pkts P/var/www/auris/envauris/lib/python3.13/site-packages/mysql/connector/protocol.pyparse_auth_more_data"MySQLProtocol.parse_auth_more_data^s($1v00 !EF F12wcUS[:wa [S5e[R"USSSS9upU(aUSS:XaUSSnUR 5U4$) aParse a MySQL auth switch request packet. Args: pkt: Packet representing an `auth switch request` response. Returns: plugin_name: Name of the client authentication plugin to switch to. plugin_provided_data: Plugin provided data (see [1]). Raises: InterfaceError: If packet's status tag doesn't match `protocol.AUTH_SWITCH_STATUS`. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/ latest/page_protocol_connection_phase_packets_protocol_ auth_switch_request.html r2z'Failed parsing AuthSwitchRequest packetr3Nendr)AUTH_SWITCH_STATUSrr read_stringdecode)r5 plugin_names r6parse_auth_switch_request'MySQLProtocol.parse_auth_switch_requesttsd( q6' ' !JK K ,,SW'B 3r7a<cr(C!!#S((r9c[R"USSS5upU[:wa [S5e[R"USS9upUR 5U4$)aFParse a MySQL auth next factor packet. Args: pkt: Packet representing an `auth next factor` response. Returns: plugin_name: Name of the client authentication plugin. plugin_provided_data: Initial authentication data for that client plugin (see [1]). Raises: InterfaceError: If packet's packet type doesn't match `protocol.MFA_STATUS`. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_auth_ next_factor_request.html r2Nrz.Failed parsing AuthNextFactor packet (invalid)r;r<)rread_int MFA_STATUSrr@rA)r5statusrBs r6parse_auth_next_factor$MySQLProtocol.parse_auth_next_factorsY*nnSWa0  Z  !QR R ,,Sg>!!#S((r9c j^THnTUbM STU'M [U4SjT55[TR55-[TR55-n[R "SU5/nTHnUR [R "S[U555 UR UR55 UR [R "S[TU555 UR TUR55 M SRU5$)aBEncode the connection attributes. Args: conn_attrs: Connection attributes. Returns: serialized_conn_attrs: Serialized connection attributes as per [1]. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html c3X># UHn[U5[TU5-v M! g7fN)len).0x conn_attrss r6 0MySQLProtocol.make_conn_attrs..s#@ZAZ]++Zs'*?#I  $ $V[[s9~%F G  $ $Y%5%5%7 8  $ $V[[s:i;P7Q%R S  $ $Z %:%A%A%C D $ xx)**r9cjU[R-(aU(aUR5S-$S$)aPrepare database string for handshake response. Args: client_flags: Integer representing client capabilities flags. database: Initial database name for the connection. Returns: serialized_database: Serialized database name as per [1]. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_handshake_response.html r;)rCONNECT_WITH_DBr\) client_flagsdatabases r6connect_with_dbMySQLProtocol.connect_with_dbs4"j888X OO  '  r9NFcTU(dUS:Xa S[XUS94$Uc0n[X45"XUS9nUR"U40UD6nUc[ SUR 35e[ R"[U55U-nX4$![[4an [ SU 35U eSn A ff=f)aPrepare 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. rLr;) ssl_enabledNzFailed authentication: z8Got NULL auth response while authenticating with plugin ) rr auth_response TypeErrorrnamerlc_intrO) auth_datausernamepassword auth_pluginauth_plugin_classrj plugin_config auth_strategyrkerrs r6auth_plugin_first_response(MySQLProtocol.auth_plugin_first_responsesDK2->    M K+KK M*77 S]SM   ',,-/   S%78=H ++>* K #:3%!@As J Ks#BB'B""B'rc UR5n /nU (a[R"S5 [R"S5 Uc [S5SeUR S5c [S5SeU=(d USn[R"S U5 U (aCUR[R"S [U 5S 3[RU 55 O:S nUR[R"SU[U 5S 3UUUU 55 [RUSUUUUU U S9unnURU5 UR[RXS55 U (a&UR[R"SU55 U[ R"-(a"URUR5S-5 U[ R$-(a'U b$UR[R'U 55 SR)U5U4$![ [ 4an[SUS 35SeSnAff=f)aMake 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` requestzStarting authorization phaseNzGot a NULL handshakeroz$Handshake misses authentication inforrz-Handshake misses authentication plugin info ()z#The provided initial strategy is %srUsxxxxxxxxxxxxxxxxxxxxxxxxz ? *00 0  # #K$6$6$87$B C :22 2 8N  # #M$A$A*$M Nxx()=88m8$ "?uAF  s4H**I:I  IcSR[R"U5[R"U5[R"U5S/5$)aCMake a SSL authentication packet (see [1]). Args: charset: Client charset (see [2]), only the lower 8-bits. client_flags: Integer representing client capabilities flags. max_allowed_packet: Maximum packet size. Returns: ssl_request_pkt: SSL connection request packet. References: [1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_connection_phase_packets_protocol_ssl_request.html [2]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set r9s)r]r int4store int1store)rrers r6 make_auth_sslMySQLProtocol.make_auth_sslsB0xx - 23(    r9c@[R"U5nUcU$X!-$)z(Make a MySQL packet containing a command)rr)commandargumentdatas r6 make_commandMySQLProtocol.make_commands$w''tz5.5.8rrutf-8mysql_native_passwordro capabilities) rYunpackPROTOCOL_VERSIONrrr@rAintreadrSECURE_CONNECTIONminr startswith) packetres auth_data1 capabilities1 capabilities2auth_data_lengthr auth_data2sizes r6parse_handshakeMySQLProtocol.parse_handshakes --&1+>qAJ z?. .6s:6GH$$4#57 271B1B 12JG2 .-. MM2F1RL A ! "    N   ),-F)G)N)N)P %&}}]%BC  *66 64D3r+a/0"D$JE]F"~"'_ *00 0f$-F)G)R)R**14V,]+/4/@/@W/U,]+!$]!3!:!:7!CC !8C %2K*N r9cUSS:Xd [S5e0n[R"SUSS5SUS'[R"USS5uoS'[R"U5uoS '[R"S USS5uUS 'US 'USSnU(a2[R "U5uoS 'US R S5US 'U$![an[S5UeSnAff=f)zParse a MySQL OK-packetr2rz#Failed parsing OK packet (invalid).rr3 field_countN affected_rows insert_idz->v-F *Fk* eVAa[1 -(/*ABZF050D0DV0L-*-(1*(=(D(DW(M *% G !<=3 F GsB:C C/ C**C/c[R"USS5SnU$![R[4an[ S5UeSnAff=f)z=Parse a MySQL packet with the number of columns in result setr2NrzFailed parsing column count)rrrYerrorrr)rcountrvs r6parse_column_count MySQLProtocol.parse_column_count sQ I%%fQRj1!4EL j) I !>?S H Is A  AA c [R"USS5up[R"U5up[R"U5up[R"U5up[R"U5up[R"U5up[R"SU5unnnnnUR U5USSSSU)[R-UU4 $![Ra [ S5Sef=f)zParse a MySQL column-packet.r2Nz ==( (. 3}}Z8H s"s6{a'7 ) )'{O%a[M || 3 )s 2 3sA,,B B  Bc 6Sn0nS/nSnU(aUSSRS5nOURS5nUHUnURSS5Vs/sHowR5PM snupXUR S5n[ U5X5'MW U$s snf![an [U5U eSn A ff=f![ [4aQ [UR S55X5'M![a#n [US US [U5S 35U eSn A ff=ff=f) zParse the statistics packetz)Failed getting COM_STATISTICS informationr9r2Ns :r*rz (:rz) splitstriprrrAintrrrrepr) r with_headererrmsgrpairslblpairvvalrvs r6parse_statisticsMySQLProtocol.parse_statisticsJs*=.0 12J$$[1ELL-ED 6/3zz$/BC/B!GGI/BC **W%C Ss8 D 6$V,#5 6j) SS&szz'':;CH'S(F82cU!DI;a)HIsRS SsSBB*B B7B B4# B//B47DC'' D1DDDcUn/nSnSnSn U(dX:XaXg4$URU5n U RS5(aU SS/n URU5n U RS5(a=U RU SS5 URU5n U RS5(aM=U RU SS5 [R"SR U 55nOJU SS:XaU SS:aUR U 5nSnO$Sn[R"[U SS55nUcUbURU5 OUcUc [U 5eU S- n GMV) 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. Nrsr2r9r)r) recvrr[rread_lc_string_listr]rbytesr) rsockversionr read_timeoutrreofrowdatairdatass r6read_text_resultMySQLProtocol.read_text_resultgsa$  aj*y)YY|,F  11 <0''88LL,!YY|4F''88 VABZ(33CHHUODc!fQi!mnnV,33E&*4EF{w2 G$#F++ FA-r9cUS[R:XaSnSnOoUS[R:XaSnSnOSUS[R[R4;aSnSnO'US[R :XaSnSnO [ S 5eUS [R-(aUR5nXS [R"X S U5S 4$) z%Parse an integer from a binary packetr>: :GF 1X++ +GF34 4 8i(( (mmoGwwq8H!I!!LMMr9cUS[R:XaSnSnOSnSnXS[R"X0SU5S4$)z)Parse a float/double from a binary packetrrrr)daysseconds microsecondsminuteshours)r  timedeltarYr)rrrr#r'tmps r6_parse_binary_time MySQLProtocol._parse_binary_times12J 2 2 45 5a&1*% A:--d12h/2C}}T4!9-a0 7a< BJD  GGq'  z|$c**r9c[U5S-S-S-nUSUVs/sHn[U5PM nnX$Sn/nSn[U5GHupU[U S-S- 5SU S-S---(aURS5 M>U S[R [R [R[R[R4;a&URX*5up(URU5 MU S[R[R4;a'URX*5up(URU5 GMU S[R[R4;a'UR!X#5up(URU5 GMTU S[R"[R$[R&4;a*UR)X*S5up(URU5 GMU S[R*:Xa'UR-U5up(URU5 GMU S[R.:Xa@[0R2"U5up(UR[4R6"U55 GMIU S[8R::Xd U SS:Xa,[0R2"U5up(URU5 GM[0R2"U5up(URUR=U55 GM [AU5$s snf![>a URU5 GMf=f)z(Parse values from a binary result packetrr*rrNr?)!rOr enumerater[rrrrrrrr FLOATr DECIMAL NEWDECIMALrrDATErr$TIMEr.VECTORrrr_vector_to_pythonrBINARYrAUnicodeDecodeErrortuple) rfieldsrrnull_bitmap_lengthr null_bitmaprXrposrs r6_parse_binary_values"MySQLProtocol._parse_binary_valuess"&kAo1a7'-a0B'CD'C!s1v'C D+,$(#F+JC3a1}-.!a1}2DE d#Qx"" !% : :6 I  e$qi.. @@ $ 8 8 G  e$qi//1E1EFF $ > >v O  e$q""## #'">">vQx"P e$qY^^+"&"9"9&"A e$qY---"'"6"6v"> n>>uEFqY---qR"'"6"6v"> e$"'"6"6v">)MM%,,w"78O,VV}aEZ*)MM%(()sL$4 L))M M cB/nSnSnSn UbXg4$X:XaXg4$[URU55n U SS:XaURU 5nSnO U SS:XaSnURX*SSU5nUcUbUR U5 OUcUc [ U 5eU S- n M)zgRead MySQL binary protocol result Reads all or given number of binary resultset rows from the socket. Nrr2r)r3r)rrrrAr[r) rrcolumnsrrrrrrXrrs r6read_binary_result MySQLProtocol.read_binary_result8s {z{499\23FayCnnV,a22712JP{v1 F##F++ FA!r9c`USS:Xd [S5e0n[R"USSS5uoS'[R"US5uoS'[R"US5uoS 'US Sn[R"US5uoS 'U$![an[S5UeSnAff=f) z(Parse a MySQL Binary Protocol OK packet.r2rzFailed parsing Binary OK packetr3Nrr* num_columns num_paramsrr)rrrFr)rok_pktrvs r6parse_binary_prepare_ok%MySQLProtocol.parse_binary_prepare_ok^sayA~ !BC C M-2^^F12J-J *F>*,1NN61,E )F=)+0>>&!+D (F<(ABZF.3nnVQ.G +F?+  M !BC L MsA8B B- B((B-cSnSnUS:a^US:aSn[RnOUS:aSn[RnOUS:aSn[RnOrS n[RnO_S nUS ::aS n[RnODUS ::aSn[RnO+US::aSn[RnO[RnSn[ R "X05X4$)z0Prepare an integer for the MySQL binary protocolNriririrrr+rUir}lrz++4 8%88 8 ( 8|&* $$'$ $  $ $ $ $L"@@B(A6(A (A(AT5A75A 5A5AnTT.0!;?FJ',E E +E  E  E 9 E E DE !%E  E E r9r/)>r __future__rr rY collectionsrdecimalrrtypingrrr r r r r rrrLr constantsrrrrr conversionrerrorsrrrrrpluginsrrplugins.caching_sha2_passwordrr|r r!r"r#r$r%r&networkr'rr?r4 OK_STATUS EOF_STATUSrG ERR_STATUSLOCAL_INFILE_STATUSrrr/rjr9r6rs:3" -   'RR5M$     'j j r9