BRZ9 dPded=e:e;d?e:e<d@edAee3eee fdedBee=dCe defdDZ>ededeeeffdEZ?ededefdFZ@y )Q MySQLProtocolzRImplements MySQL client/server protocol Create and parses MySQL packets. client_flagsdatabasereturncV|tjzr|r|jddzSy)z.Prepare database string for handshake responseutf8)rCONNECT_WITH_DBencode)r'r(s Y/var/www/html/delta-backend/venv/lib/python3.12/site-packages/mysql/connector/protocol.py_connect_with_dbzMySQLProtocol._connect_with_dbHs+ *44 4??6*W4 4usernamepasswordauth_plugin_class auth_plugin auth_data ssl_enabledc$|sy t|||||||}|j} |tj zr&t | } tjd| | z} | S| dz} | S#ttf$r} td| | d} ~ wwxYw)z#Prepare the authentication responser,)r2r3r(r7zFailed authentication: N* K #:3%!@As J Ks'A,,B;B  BN handshakecharsetmax_allowed_packet conn_attrsc &|i} |d} | xs|d} |sd} |jd}d}t |}t jd ||d ||||}||j||||| | | |z }||j||z }|tjzr|| jdd zz }|tjzr| ||j| z }|S#ttf$r} td| ddd} ~ wwxYw#t$r|}YwxYw) z"Make a MySQL Authentication packetNr6r5&Handshake misses authentication info ()r1r+xxxxxxxxxxxxxxxxxxxxxxzr?rDr0r PLUGIN_AUTH CONNECT_ARGSmake_conn_attrs)selfrEr2r3r(rFr'rGr7r5rHr4r6rBusername_bytesfiller username_lenpackets r/ make_authzMySQLProtocol.make_authtsm  I )2;)?I%A=)AK H &%__V4N >* 6(<. +       $%%           $'' h?? *00 0 k((07: :F :22 2 8N d**:6 6F W8$ "8Q?   &%N &s(CDC?*C::C? DDc D] }| d|<tfdDtjztjz}t j d|}D]t}|t j dt|z }||j dz }|t j dt|z }||j dz }v|S)z Encode the connection attributesc3RK|]}t|t|z ywN)r=).0xrHs r/ z0MySQLProtocol.make_conn_attrs..s#@AZ]++@s$'r9r+)sumr=keysvaluesr>r?r.)rH attr_nameconn_attrs_lenconn_attrs_packets` r/rRzMySQLProtocol.make_conn_attrss$ +I)$,(* 9% + @Z@ @*//#$ %*##%& '  #KKn=# FI T3y>!B B  !1!1&!9 9  T3z)7L3M!N N  I!6!=!=f!E E   F ! r1ctj|tj|ztj|zdzS)z Make a SSL authentication packetsr int4store int2store)rFr'rGs r/ make_auth_sslzMySQLProtocol.make_auth_sslsB OOL )oo01 2oog& '  r1commandargumentc>tj|}|||z }|S)z(Make a MySQL packet containing a command)r int1store)rkrldatas r/ make_commandzMySQLProtocol.make_commands'w'   H D r1 statement_idrowscXtj|tj|zS)z0Make a MySQL packet with Fetch Statement command)r rh)rqrrs r/make_stmt_fetchzMySQLProtocol.make_stmt_fetchs!|,ut/DDDr1c b |d} |xs|d}|sd} |jd} t | }t jd|d tj| }||j||||| || |z }||j||z }|t jd |z }|tjzr||jdd zz }|tjzr| ||j| z }|S#ttf$r} td| ddd} ~ wwxYw#t$r|} YwxYw) z0Make a MySQL packet with the Change User commandr6r5rJrKNr1r+r9rMr?r CHANGE_USERrDr0rrPrQrR)rSrEr2r3r(rFr'r7r5rHr4r6rBrTrVrWs r/make_change_userzMySQLProtocol.make_change_usersl )2;)?I%A=)AK H &%__V4N >* b !  ! !   $%%           $'' h??&++dG,, *00 0 k((07: :F :22 2 8N d**:6 6F S8$ "8Q?   &%N &s(C8D8DDD D.-D.rWc i}tjd|ddd|d<|dtk7rtd|ddtt j |ddd \}|d <tjd |dd \|d <}}|d<|d<}}|d j |d <|d d}t j||z}d}|tjzr*|rtd|dz nd}|d|}||d}|ddk(r|dd}|tjzrVd|vr|d jdr d|c}|d<nt j |d \}|d<|dj d|d<nd|d<||z|d<||d<|S)zParse a MySQL Handshake-packetunpackr$rr read_stringdecodeintreadrr<minrP startswith) rWres auth_data1 capabilities1 capabilities2auth_data_lengthr auth_data2sizes r/parse_handshakezMySQLProtocol.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$JDE]F"~"'_ *00 0f$-F)G)R)R*14V,]+/4/@/@W/U,]+!$]!3!:!:7!CC !8C % 2K*N r1ctj|d\}}|dk7r tdtj|d\}}||j dfS)z$Parse a MySQL AuthNextFactor packet.r z.Failed parsing AuthNextFactor packet (invalid)r,r}r)r read_intrrr)rWstatusr5s r/parse_auth_next_factorz$MySQLProtocol.parse_auth_next_factorSsX2 Q; !QR R#//GD {))'222r1c|ddk(s tdi} tjd|ddd|d<tj|dd\}|d<tj|\}|d <tjd |dd\|d <|d <|dd}|r2tj |\}|d <|d j d|d <|S#t$r}td|d}~wwxYw)zParse a MySQL OK-packetrz#Failed parsing OK packet (invalid).rzr{ field_countN affected_rows insert_idzrr read_lc_intread_lc_stringr ValueError)rW ok_packetrBs r/parse_okzMySQLProtocol.parse_ok\sayA~ !FG G  G'-}}Xva{'KA'NIm $161B1B6!":1N .FIo.-2->->v-F *FIk* eVAa[1 -(/*ABZF050D0DV0L- *-(1*(=(D(DW(M *% G !<=3 F GsB3C C& C!!C&c tj|ddd}|S#tjtf$r}t d|d}~wwxYw)z=Parse a MySQL packet with the number of columns in result setrNr zFailed parsing column count)r rr>errorrr)rWcountrBs r/parse_column_countz MySQLProtocol.parse_column_countssQ I%%fQRj1!4EL j) I !>?S H IsA  AA encodingc tj|dd\}}tj|\}}tj|\}}tj|\}}tj|\}}tj|\}} tjd|\}}}}}|j ||dddd|tjz||f S#tj$r t ddwxYw)zParse a MySQL column-packetrNz rrrrrNOT_NULL)rWr_namerF column_typeflagss r/ parse_columnzMySQLProtocol.parse_column|s((4 ((0 ((0 ((0 ++F3 ((0  P k62   KK !      FY'' '    || P !DE4 O Ps C C=c|ddk(r|j|Sd}i} tjd|}|ddk(rt |dks t ||d |d <|d |d <|S#tj$r}t ||d}~wwxYw) zParse a MySQL EOF-packetrrzFailed parsing EOF packet.zrrrr=)rSrWerr_msgrunpackedrBs r/ parse_eofzMySQLProtocol.parse_eofs !9>==( (. 3}}Z8H s"s6{a'7 ) )'{O%a[M || 3 )s 2 3sA((B ; BB  with_headerc $d}i}dg}d}|r|ddjd}n|jd}|D]T} |jddDcgc]}|jc}\}}|j d} t |||<V|Scc}w#t$r} t|| d} ~ wwxYw#t tf$rQ t|j d||<n/#t$r#} t|d |d t|d | d} ~ wwxYwYwxYw) zParse the statistics packetz)Failed getting COM_STATISTICS informationr1rNs :rrz (:rK) splitstriprrrintrNrrrepr) rWrerrmsgrpairslblpairvvalrBs r/parse_statisticszMySQLProtocol.parse_statisticss8=.0!U 12J$$[1ELL-E SD 6/3zz$/BC!AGGICS **W%C Ss8C S D 6$V,#5 6j) SS&szz'':;CH'S(F82cU!DI;a)HIsRS Ss_B B #B;B/ B B, B''B,/D?CD D &DD  DDsockversion.rc|}g}d}d}d} |s||k(r ||fS|j} | jdr| ddg} |j} | jdr6| j| dd|j} | jdr6| j| ddtjt dj | }n>| ddk(r| ddkr|j| }d}nd}tj| dd}|||j|n| | t| |dz }6) 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. Nrsrr1rr ) recvrappendr read_lc_string_list bytearrayjoinrr) rSrrrrrreofrowdatairWdatass r/read_text_resultzMySQLProtocol.read_text_resultsU  a5j*Sy)YY[F  1 ''8LL,!YY[F''8 VABZ(33IcN4G4G4NOc!fQi!mnnV,33F12J?{w2 G$#F++ FA-r1fieldc|dtjk(rd}d}n_|dtjk(rd}d}nD|dtjtjfvrd}d}n|dtj k(rd}d}|d t jzrj}|d tj|d |d fS) z%Parse an integer from a binary packetr r)rWrformat_lengths r/_parse_binary_integerz#MySQLProtocol._parse_binary_integers 8y~~ %GF 1X (GF 1X)//9>>: :GF 1X++ +GF 8i(( (mmoGvwwq8H!I!!LMMr1c|dtjk(rd}d}nd}d}||dtj||d|dfS)z)Parse a float/double from a binary packetr rr)rWrrrs r/_parse_binary_floatz!MySQLProtocol._parse_binary_floatsR 8y'' 'FGFGvwwq8H!I!!LMMr1cjtj|\}}|t|j|fS)z(Parse a New Decimal from a binary packet)r rrr)rWrFvalues r/_parse_binary_new_decimalz'MySQLProtocol._parse_binary_new_decimals1  ..v6 W 5677r1 field_typec |d}d}|dk(rztjd|ddd}|d}|d}|tjtjfvrt j |||}nt j |||}np|dk\rkd}|d k(rtjd |d |dzd}t j tjd|ddd|d|d|d |d |d|}||dzd|fS)z&Parse a timestamp from a binary packetrNrrvr r)yearmonthdayr rrDATETIME TIMESTAMPdatetimedate)rWrrrrrrmcss r/_parse_binary_timestampz%MySQLProtocol._parse_binary_timestamp$s  Q;==va{3A6D1IE)Ci00)2E2EFF ))t5cJ 4u#F q[C|mmD&VaZ*@A!D%%]]4!5a8Qi1IAYayayEvz|$e,,r1cD|d}|s|ddtjfS|d|dz}d}|dkDrtjd|ddd}tjd|ddd}|ddk(r|dz}tj||d||d |d }||dzd|fS) z'Parse a time value from a binary packetrr Nrrr{rrr)daysseconds microsecondsminuteshours)r timedeltar>r)rWrrorrtmps r/_parse_binary_timez MySQLProtocol._parse_binary_timeDs12J 2 2 45 5a&1*% A:--d12h/2C}}T4!9-a0 7a< BJD  GGq'  vz|$c**r1fieldsc0t|dzdzdz}|d|Dcgc] }t|}}||d}g}d}t|D]\} } |t| dzdz d| dzdzzzr|jd9| dtj tj tjtjtjfvr'|j|| \}}|j|| dtjtjfvr'|j|| \}}|j|| dtjtjfvr(|j!||\}}|j|K| dtj"tj$tj&fvr+|j)|| d\}}|j|| dtj*k(r'|j-|\}}|j|t/j0|\}} |j|j3|"t7|Scc}w#t4$r|j|YPwxYw)z(Parse values from a binary result packetrrrrNr )r=r enumeraterrrrrrrrrFLOATrDECIMAL NEWDECIMALrrDATErrTIMEr r rrUnicodeDecodeErrortuple) rSr rWrFnull_bitmap_lengthr null_bitmaprbrposrs r/_parse_binary_valuesz"MySQLProtocol._parse_binary_values[sZ"&kAo1a7'-a0B'CD!s1vD D*+,#F+" )JC3a1}-.!a1}2DE d#Qx"" !% : :65 I  e$qi.. @@ $ 8 8 G  e$qi//1E1EFF $ > >vw O  e$q""## #'">">vuQx"P e$qY^^+"&"9"9&"A e$"'"6"6v">)MM%,,w"78A" )HV}SEL*)MM%()sI2 I77JJcolumnsc$g}d}d}d} | ||fS||k(r ||fS|j} | ddk(r|j| }d}n | ddk(rd}|j|| dd|}|||j|n| | t | |dz })zwRead MySQL binary protocol result Reads all or given number of binary resultset rows from the socket. Nrrrr{r )rrrrr) rSrrrrFrrrrbrrWs r/read_binary_resultz MySQLProtocol.read_binary_results c{Ezc{YY[FayCnnV,a227F12JP{v1 F##F++ FA!r1c\|ddk(s tdi} tj|ddd\}|d<tj|d\}|d<tj|d\}|d <|d d}tj|d\}|d <|S#t$r}td|d}~wwxYw) z'Parse a MySQL Binary Protocol OK packetrrzFailed parsing Binary OK packetr{Nrqr num_columns num_paramsr r)rr rr)rWok_pktrBs r/parse_binary_prepare_okz%MySQLProtocol.parse_binary_prepare_oksayA~ !BC C M-2^^F12J-J *FF>*,1NN61,E )FF=)+0>>&!+D (FF<(ABZF.3nnVQ.G +FF?+  M !BC L MsA8B B+ B&&B+rcd}d}|dkr[|dk\rd}tj}n|dk\rd}tj}n|dk\rd}tj}nod }tj}n\d }|d krd }tj}nB|d krd}tj}n*|dkrd}tj}ntj}d}t j ||||fS)z0Prepare an integer for the MySQL binary protocolNriririrrr9irvlrzr?)rrrrs r/prepare_binary_integerz$MySQLProtocol.prepare_binary_integers  19}&^^ &&__ +%&^^ &// E|&^^ %&__ *$&^^ &//  GU+Z??r1c&t|tjrtj}n6t|tjrtj }n t dtj|jtj|jztj|jz}t|tjr|tj|jztj|jztj|jz}|j dkDr"|tj"|j z }tjt%||z}||fS)aPrepare a timestamp object for the MySQL binary protocol This method prepares a timestamp of type datetime.datetime or datetime.date for sending over the MySQL binary protocol. A tuple is returned with the prepared value and field type as elements. Raises ValueError when the argument value is of invalid type. Returns a tuple. z2Argument must a datetime.datetime or datetime.dater) isinstancerrrrrrr rirrnrrrrrrrhr=)rrpackeds r/prepare_binary_timestampz&MySQLProtocol.prepare_binary_timestamps) eX.. /"++J x}} -"JQR R OOEJJ 'ooekk* +ooeii( )  eX.. ///%**-.//%,,/0//%,,/0    1$%//%*;*;<<V-6 ##r1ct|tjtjfs t dt j }d}d}d}t|tjr|jdkrd}t|jd\}}t|d\}}|tjt|jtj|ztj|ztj|zz }|j}n|tjdtj|jztj|j ztj|j"zz }|j$}|r|tj|z }tj||z}tjt'||z}||fS)aPrepare a time object for the MySQL binary protocol This method prepares a time object of type datetime.timedelta or datetime.time for sending over the MySQL binary protocol. A tuple is returned with the prepared value and field type as elements. Raises ValueError when the argument value is of invalid type. Returns a tuple. z3Argument must a datetime.timedelta or datetime.timerNr1r i<)r&rrtimerrrrdivmodrr rhabsrnrrrrrr=) rrnegativerr'r remainderminssecss r/prepare_binary_timez!MySQLProtocol.prepare_binary_times%("4"4hmm!DERS S^^  eX// 0zzA~!' t!< UI!)R0LT4 EJJ0//%()//$'(//$'( F $$C "//%**-.//%,,/0//%,,/0 F ##C  eooc* *F*V3V-6 ##r1 statementparamrocbtj|tj|z|z}|S)zMPrepare long data for prepared statements Returns a string. rg)r3r4rorWs r/prepare_stmt_send_long_dataz)MySQLProtocol.prepare_stmt_send_long_dataCs+"OOI69OORVV r1 parametersrlong_data_used query_attrsconverter_str_fallbackc V d} dgt|dzdzz} g} g} d} t|}g}|s|n|tz}|dk(rd}|i}|r;t|}|D]\}}|j|dgt|dzdzz} |s|r)|t|k7r t dt |D]\}}d}|_| |dzxxd|dzzzcc<| jt jtjt j|zj||vr,||drtj}ntj}nt|tr(|j|\} }}| j| nt|trS|j!|}| jt j"t||ztj$}n;t|t&rB| jt j"t||ztj}nt|t(rr| jt j"tt|j!|t|j!|ztj*}ngt|t,r7| jt/j0d |tj2}n t|t4j4t4j6fr&|j9|\} }| j| nt|t4j:t4j<fr&|j?|\} }| j| n|r[t|j!|}| jt j"t||ztj}n#tAd |jBjDd | jt j|t j|z|s|dz|kDs|||z dj!|}|jt j"t||zt jF|t j|zt jF| z}||t|z}n|}|r||t j"|z }|djI| Dcgc]}t/j0d |c}t jdzz }d}| D]'}||z }||dz|kDr ||||z z }n|d z }|dz })| D]}||z } |Scc}w)z6Make a MySQL packet with the Statement Execute commandr rrrr1utf8mb4r+zTFailed executing prepared statement: data values does not match number of parametersrz&MySQL binary protocol can not handle 'z ' objectsBr,)%r=rlistrrr r rnrNULLBLOBSTRINGr&rr$strr.lc_intVARCHARbytesrrfloatr>r?rrrr(rr+r2r __class____name__rhr)rSrqror7rr8rFr9r:iteration_countrrbtypesr'data_lenquery_attr_namesrattr_valrr_flagsrrrWparameter_countbitra_typea_values r/make_stmt_executezMySQLProtocol.make_stmt_executeNscc$i!m12 t9(e6O.O i G  !N :D* & 8 H% &##d)a-A!56K 3z?*$2(o8 L U=+qS1W~=+LL 7%//&:QQ.(%c*1-%.^^ &/%5%5 s+ 33E: "MM&)s+!LL1EMM%,,s5z":U"BC!*!2!2Ju-MM%,,s5z":U"BC!*Jw/MM SU):):7)C%DEe*++G45"+!2!2Ju-MM&++dE":;!*!1!1J(9(98=='IJ+/+H+H+O(VZMM&)(:(:HMM'JK+/+C+CE+J(VZMM&)+J--g6EMM%,,s5z":U"BC!*!1!1J*!OO445Y@ U__Z85??6;RRS37X#5&sX~6q9@@ID$++ELLT,Cd,JKq8 Lt OOL )ooe$ %ooo. /   "&[)99O&O &%,,77 chh2=>3S#&>"# #FE &  *qy8+"2583C"DD')  " "'! " '?s.V& c|ddk(s tdtj|ddd\}}|r |dd k(r|dd}|jd |fS) z&Parse a MySQL AuthSwitchRequest-packetrrz'Failed parsing AuthSwitchRequest packetr{Nr,r}rrr+)rr rr)rW plugin_names r/parse_auth_switch_requestz'MySQLProtocol.parse_auth_switch_requestsgayC !JK K#//qr H fRjAoCR[F!!&)611r1c2|ddk(s td|ddS)z!Parse a MySQL AuthMoreData-packetrr z"Failed parsing AuthMoreData packetr{N)r)rWs r/parse_auth_more_dataz"MySQLProtocol.parse_auth_more_datas'ayA~ !EF Fabzr1) NNN-r@FNNN)rYrrZr\)r ) NNNrYrFNNN)r)T)r+)r r)r[rNr+NF)ArH __module__ __qualname____doc__ staticmethodrrrBrEr0r!boolrDrrrXrRrrjrprtrxrr rrrrrrrrr rrrrrrFrrrr rrrrr rrrrr r$r(r+r2r6r r"rrrSrVrXr[r1r/r&r&Bs shsm "":&"3-"3- "  "  "E?"" ""N*."&"&",!%).2+/?M*?:&?3- ? 3- ?  ?? ??c]?]+?$C=? ?B!M!e!!&LV    ),  FI      cXe_ EcEEYEE*."&"&!%).2+/; ;:&;3- ; 3- ;  ;;;c];]+;$C=; ;z11-11f3u3ucz1B33<,I5IXc]II U c   @-(T_:HI'').sCx'AD' tE(5/3./0(=2IJ K'RNN-N ucz NN, N N- N ue|  N N&,88 #8 ug~ 88--- uhuX]]H4E4E%EFGG H-->+5+U5(:L:L3L-M++4 1_%11 1 4c9 : 1n ##o&# #  #  U8#= >? !  #J$sCx."@c@eE3O.D@@B&$X]]H$5$556&$ y#~ &$&$P0$X''670$ y#~ 0$0$d"*/ =?$&;?/3',AA89ASM A  A !c5;&6!78 AAm,A!%A AF 2% 2E#u*4E 2 2Uur1r&)-r^rr>decimalrrtypingrrrrr r r rZr authenticationr constantsrrrrrerrorsrrrrrJrrrrrrrrr r!r"r$r__annotations__r&r[r1r/rgsb>3 -DDD+SR    #aar1