şgRSrSSKJr 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:"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 MySQLProtocolVzJImplements 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 Y/var/www/blue/EV-Temp_rev04/venv/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 r1z'Failed parsing AuthSwitchRequest packetr2Nendr)AUTH_SWITCH_STATUSrr read_stringdecode)r4 plugin_names r5parse_auth_switch_request'MySQLProtocol.parse_auth_switch_requestrsd( q6' ' !JK K ,,SW'B 3r7a<cr(C!!#S((r8c[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 r1Nrz.Failed parsing AuthNextFactor packet (invalid)r:r;)rread_int MFA_STATUSrr?r@)r4statusrAs r5parse_auth_next_factor$MySQLProtocol.parse_auth_next_factorsY*nnSWa0  Z  !QR R ,,Sg>!!#S((r8c 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 c3V># UHn[U5[TU5-v M! g7fN)len).0x conn_attrss r5 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)**r8cjU[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 r5connect_with_dbMySQLProtocol.connect_with_dbs4"j888X OO  '  r8NFcTU(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. rKr:) ssl_enabledNzFailed authentication: z8Got NULL auth response while authenticating with plugin ) rr auth_response TypeErrorrnamerlc_intrN) auth_datausernamepassword auth_pluginauth_plugin_classri plugin_config auth_strategyrjerrs r5auth_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 handshakernz$Handshake misses authentication inforqz-Handshake misses authentication plugin info ()z#The provided initial strategy is %srTsxxxxxxxxxxxxxxxxxxxxxxxxz ? *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 r8s)r\r int4store int1store)rrdrs r5 make_auth_sslMySQLProtocol.make_auth_sslsB0xx - 23(    r8c@[R"U5nUcU$X!-$)z(Make a MySQL packet containing a command)rr)commandargumentdatas r5 make_commandMySQLProtocol.make_commands$w''tqAJ 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 r8cUSS: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-packetr1rz#Failed parsing OK packet (invalid).rr2 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 setr1NrzFailed parsing column count)rrrXerrorrr)rcountrus r5parse_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.r1Nz ==( (. 3}}Z8H s"s6{a'7 ) )'{O%a[M || 3 )s 2 3sA,,B B  Bc 4Sn0nS/nSnU(aUSSRS5nOURS5nUHTnURSS5Vs/sHowR5PM snupXUR S5n[ U5X5'MV 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 informationr8r1Ns :r*rz (:ry) splitstriprrr@intrrrrepr) r with_headererrmsgrpairslblpairvvalrus r5parse_statisticsMySQLProtocol.parse_statisticsHs*=.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 B6B B3" B..B36DC&& D0DDDcUn/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. Nrsr1r8r)r) recvrrZrread_lc_string_listr\rbytesr) rsockversionr read_timeoutrreofrowdatairdatass r5read_text_resultMySQLProtocol.read_text_resultesa$  aj*y)YY|,F  11 <0''88LL,!YY|4F''88 VABZ(33CHHUODc!fQi!mnnV,33E&*4EF{w2 G$#F++ FA-r8cUS[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!!LMMr8cUS[R:XaSnSnOSnSnXS[R"X0SU5S4$)z)Parse a float/double from a binary packetrrU 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?)!rNr enumeraterZrrrrrrrr FLOATr DECIMAL NEWDECIMALrrDATErr#TIMEr-VECTORrrr_vector_to_pythonrBINARYr@UnicodeDecodeErrortuple) rfieldsrrnull_bitmap_lengthr null_bitmaprWrposrs r5_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#3 L((MMcB/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. Nrr1r)r2r)rrrr@rZr) rrcolumnsrrrrrrWrrs r5read_binary_result MySQLProtocol.read_binary_result6s {z{499\23FayCnnV,a22712JP{v1 F##F++ FA!r8c`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.r1rzFailed parsing Binary OK packetr2Nrr* num_columns num_paramsrr)rrrEr)rok_pktrus r5parse_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+rTir|lrzrWtypesrUdata_lenquery_attr_namesrattr_valr?r_flagsr!rlrparameter_countbitra_typea_values r5make_stmt_executeMySQLProtocol.make_stmt_executescc$i!m12  t9(*(e6O.O i G  !N :D* 8 H% +##d)a-A!56K 3z?*$2(o U=+qS1W~=+LL 7%//&:QQ.(%c*1-%.^^ &/%5%5 s++ 33E: "MM&)s++!LL1EMM%,,s5z":U"BC!*!1!1Ju--MM%,,s5z":U"BC!*!1!1Jw//MM SU):):7)C%DEe*++G45"+!2!2Ju--MM&++dE":;!*!1!1J(9(98=='IJJ+/+H+H+O(VZMM&)(:(:HMM'JKK+/+C+CE+J(VZMM&)+J--g6EMM%,,s5z":U"BC!*!1!1J*!OO445Y@ U__Z85??6;RRS;37X#5&sX~6q9@@ID$++ELLT,Cd,JKq.t OOL ) OOE " OOO ,   "&[)99O&O & ell?;< MMKHKS6;;sC0KH I MM%//!, -E f% *qy8+ &6ux7G&HI g.  " g&"xx)Is Y,)r4rreturnr)r4rrzTuple[str, bytes])rQzDict[str, str]rr)rdrre Optional[str]rr)NFN)rnrrorrrprrrqrrrrrriboolrsOptional[Dict[str, Any]]rTuple[bytes, MySQLAuthPlugin])rr#rorrrprrrerrrrdrrrrqrrrrrQzOptional[Dict[str, str]]rrrirrsrrr)rrrdrrrrrrM)rrrzOptional[bytes]rr)r)rrrrrr)rrrr#)rrrr$)rrr Optional[int])r)rrrrrrr!)rrrr")T)rrrrrr%)rN) rr'rzTuple[int, ...]rrrrrzATuple[List[Tuple[Optional[bytes], ...]], Optional[EofPacketType]])rrrr!rTuple[bytes, int])rrrr!rzTuple[bytes, float])rl)rrrrrrzTuple[bytes, Decimal])rrr!rrz?Tuple[bytes, Optional[Union[datetime.date, datetime.datetime]]])rrrz Tuple[bytes, datetime.timedelta])r<List[DescriptionType]rrrrrrzTuple[BinaryProtocolType, ...])rrN) rr'rCrrrrrrrrrzDTuple[List[Tuple[BinaryProtocolType, ...]], Optional[EofPacketType]])rrrzDict[str, int])rrrzTuple[bytes, int, int])rz'Union[datetime.date, datetime.datetime]rr)rz(Union[datetime.timedelta, datetime.time]rr)rerrfrrrrr)ririrNrlNF)rrrzSequence[BinaryProtocolType]rvr rrrwz Optional[Dict[int, Tuple[bool]]]rrrrxz.Optional[List[Tuple[str, BinaryProtocolType]]]ryrrr)'ru __module__ __qualname____firstlineno____doc__ staticmethodr6rBrHr`rfrvDEFAULT_CHARSET_IDDEFAULT_MAX_ALLOWED_PACKETrrrrrrrrrrrrr rr#r-r@rDrJrNrVrbrgr__static_attributes__rir8r5r.r.Vs$ *))4))4++<  ( ,0!26:,:,:,:, :, ) :,  :,0:, ':,:,x #')"<%)+//3',!26w9 w9w9w9 w9  w9  w9 w9#w9)w9-w9!%w9w90w9 'w9w9r)"<         @== EE11f,II  @(@&* ..!. . $ .   .`NN-N NN2 N N- N  N N&,88 #8 88--- I-->++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 r8r.)r3 OK_STATUSrF ERR_STATUSrrr.rir8r5rs:3" -   'RR5M$    'j j r8