Dh(mdZddlZddlZddlmZddlmZmZmZm Z m Z ddl m Z m Z ddlmZddlmZmZdd l mZGd d eZy) z,Implements the MySQL Client/Server protocol N)Decimal) FieldFlag ServerCmd FieldType ClientFlagMAX_MYSQL_TABLE_COLUMNS)errorsutils)get_auth_plugin)PY2 struct_unpack) get_exceptionceZdZdZdZdZ ddZ ddZd dZ d!dZ d Z d Z d Z d"d Z d Zd#dZd$dZdZdZdZdZdZd$dZdZdZdZdZdZ d%dZdZdZy)& MySQLProtocolzRImplements MySQL client/server protocol Create and parses MySQL packets. cV|tjzr|r|jddzSy)z.Prepare database string for handshake responseutf8)rCONNECT_WITH_DBencode)self client_flagsdatabases X/var/www/html/civilisation/venv/lib/python3.12/site-packages/mysql/connector/protocol.py_connect_with_dbzMySQLProtocol._connect_with_db-s) *44 4??6*W4 4cr|sy t||||||}|j} |tjzr&t| } tjd| | z} | S| dz} | S#ttjf$r2} tj dj t| d} ~ wwxYw)z#Prepare the authentication responser)usernamepasswordr ssl_enabledzFailed authentication: {0}Nz > $'' h?? *00 0 k((07: :F 58$ J))<CCCHJ J J &%N &s(B4C/4C,$C''C,/ C=<C=ctj|tj|ztj|zdzS)z Make a SSL authentication packets)r int4store int1store)rr;rr<s r make_auth_sslzMySQLProtocol.make_auth_sslosB|,123w'( rc>tj|}|||z }|S)z(Make a MySQL packet containing a command)r rB)rcommandargumentdatas r make_commandzMySQLProtocol.make_commandws%w'   H D rc H |d} |xs|d}|sd} |j d} tjdj t| tj| } | |j|||||| |z } | |j||z } | tjd |z } |tjzr| |j dd zz } | S#ttf$r)} tjdj | d} ~ wwxYw#t $r|} YwxYw) z0Make a MySQL packet with the Change User commandr,r+r3Nrrz s rmake_change_userzMySQLProtocol.make_change_user~sE  J!+.I%A=)AK H &%__V4N^22#n:M2N&22ND $%%lHh&.&1&/> > $'' h??&++dG,, *00 0 k((07: :F 58$ J))<CCCHJ J J &%N &s(CDD'$D  D D! D!c i}td|ddd|d<tj|ddd\}|d<td |dd \|d <}}|d <|d <}}|dj|d<|d d}tj||z}d}|t j zr*|rtd|dz nd} |d| }|| d}|ddk(r|dd}|t jzrVd|vr|djdr d|c}|d<ntj|d\}|d<|djd|d<nd|d<||z|d<||d<|S)zParse a MySQL Handshake-packetres auth_data1 capabilities1 capabilities2auth_data_lengthr[ auth_data2sizes rparse_handshakezMySQLProtocol.parse_handshakes'&1+>qAJ383D3D 12JG4%0./ 2F1RL A      Y _   ),-F)G)N)N)P %&}}]]%BC  *66 64D3r+a/0"D$JDE]F"~"'_ *00 0v%56AA'J03V,]+/4/@/@0),]+!$]!3!:!:7!CC !8C % 2K*N rc|ddk(stjdi} td|ddd|d<tj|dd\}|d<tj|\}|d <td |dd\|d <|d <|dd}|r2tj |\}|d <|d j d|d <|S#t$rtjdwxYw)zParse a MySQL OK-packetrz#Failed parsing OK packet (invalid).rMrN field_countN affected_rows insert_idz ok_packets rparse_okzMySQLProtocol.parse_oksayA~''(MN N  E'4Xva{'KA'NIm $383D3DVABZ3P 0VY//4/@/@/H ,VY{++8q +L )Y} %  'ABZF272F2Fv2N/:.(1*(=(D(DW(M *% E''(CD D Es BCC!c tj|ddd}|tkDry|S#tjt f$rt jdwxYw)z=Parse a MySQL packet with the number of columns in result setrjNrzFailed parsing column count)r rqr r)errorrsr r#)rr>counts rparse_column_countz MySQLProtocol.parse_column_counts` G%%fQRj1!4E..L j) G''(EF F Gs $))/Actj|dd\}}tj|\}}tj|\}}tj|\}}tj|\}}tj|\}} td|\}}}}}|j||dddd|tjz|fS#tj$rt j dwxYw)zParse a MySQL column-packetrjNz r;_name field_typeflagss r parse_columnzMySQLProtocol.parse_columns**6!":6 **62 **62 **62 --f5**62  M&{F; Q: A KK      FY'' '   || M''(KL L Ms C)C;c(|ddk(r|j|Sd}i} td|}|ddk(rt |dkst j ||d|d <|d |d <|S#tj$rt j |wxYw) zParse a MySQL EOF-packetrjrzFailed parsing EOF packet.zerr_msgraunpackeds r parse_eofzMySQLProtocol.parse_eofs !9>==( (. 1$Z8H s"s6{a'7''0 0'{O%a[M || 1''0 0 1s A(()Bc d}i}|r|ddjd}n|jd}|D]T} |jddDcgc]}|jc}\}} |j d} t | ||<V|Scc}w#tj|xYw# t | j d||<n+#tjdj||| xYwYxYw) zParse the statistics packetz)Failed getting COM_STATISTICS informationrjNs :rrYz{0} ({1}:{2}).)splitstripr r#r]intrr%) rr> with_headererrmsgrapairspairvlblvals rparse_statisticszMySQLProtocol.parse_statisticss< 12J$$[1ELL-E CD 415D!1DEAaggiE c **W%C Cs8C C  F 4++F33  CC&szz'':;CHC //(//SACCsAB BB 6B'B  B$'C5*CC5(C00C5cg}d}d}d}|dk\} |s||k(r ||fS|j} | jdr| ddg} |j} | jdr6| j| dd|j} | jdr6| j| ddtjt dj | }nd| ddk(r| ddkr|j| }d}n@|r$| ddk(r| dd kDr|j| }d}nd}tj| dd}|||j|n| | t| |d z }\) 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)rNrNsrjrrrrr) recvr`appendr read_lc_string_list bytearrayjoinrrur) rsockversionrxrowseofrowdataieof57r>datass rread_text_resultzMySQLProtocol.read_text_result5s 9$a5j2Sy1YY[F  1 ''8LL,!YY[F''8 VABZ(33IcN4G4G4NO)s"vay1}nnV,F1INvay1}mmF+33F12J?{w2 G$#F++ FA5rcp|dtjk(rd}d}n_|dtjk(rd}d}nD|dtjtjfvrd}d}n|dtj k(rd}d}|d t jzrj}|d t|d |d fS) z%Parse an integer from a binary packetrbhrrrjqrWrNr) rTINYSHORTINT24LONGLONGLONGrUNSIGNEDupperr)rr>fieldformat_lengths r_parse_binary_integerz#MySQLProtocol._parse_binary_integer_s 8y~~ %GF 1X (GF 1X)//9>>: :GF 1X++ +GF 8i(( (mmoGvwwq8H!I!!LMMrcn|dtjk(rd}d}nd}d}||dt||d|dfS)z)Parse a float/double from a binary packetrrWdrjfNr)rDOUBLEr)rr>rrrs r_parse_binary_floatz!MySQLProtocol._parse_binary_floatssL 8y'' 'FGFGvwwq8H!I!!LMMrc D|d}d}|dk(r/tjtd|ddd|d|d}n\|dk\rWd}|d k(rtd |d |dzd}tjtd|ddd|d|d|d |d |d|}||dzd|fS)z&Parse a timestamp from a binary packetrNrjHrr)yearmonthdayr IrWrN)rrrhourminutesecond microsecond)datetimedater)rr>rrvaluemcss r_parse_binary_timestampz%MySQLProtocol._parse_binary_timestamp~s Q;MM"3q 4Q7Qi1IEq[C|#C&1*)=>qA%%"3q 4Q7Qi1IAYayay!Evz{#U++rc|d}|d|dz}d}|dkDrtd|ddd}td|ddd}|ddk(r|dz}tj||d||d |d }||dzd|fS) z'Parse a time value from a binary packetrrrWrNrNrXrr)daysseconds microsecondsminuteshours)rr timedelta)rr>rrrGrrtmps r_parse_binary_timez MySQLProtocol._parse_binary_timesa # A:T!"X.q1CS$q),Q/ 7a< BJD  d)-a.1)-a'+Aw 0 vz{#S))rc,t|dzdzdz}|d|Dcgc] }t|}}||d}g}t|D]\}}|t|dzdz d|dzdzzzr|jd9|dtj tj tjtjtjfvr'|j||\}} |j| |dtjtjfvr'|j||\}} |j| |dtjtjtj fvr(|j#||\}} |j| Z|dtj$k(r(|j'||\}} |j| t)j*|\}} |j| t-|Scc}w)z(Parse values from a binary result packetrrrWrNr)r(r enumeraterrrrrrrrrFLOATrDATETIMEDATE TIMESTAMPrTIMErr rrtuple) rfieldsr>null_bitmap_lengthr null_bitmapvaluesposrrs r_parse_binary_valuesz"MySQLProtocol._parse_binary_valuess!&kAo1a7'-a0B'CD!s1vD D*+,#F+ %JC3Aqy>*aC!Gq=.@A d#qinnioo'oo'nni.@.@BB#'"<"">vu"M e$qY^^+"&"9"9&%"H e$"'"6"6v"> e$+ %.V}7EsHc"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. NrrjrrNr)rrrrr) rrcolumnsrxrrrrr>s rread_binary_resultz MySQLProtocol.read_binary_results  c{Ezc{YY[FayCnnV,a227F12JG{v1 F##F++ FA!rcz|ddk(stjdi} tj|ddd\}|d<tj|d\}|d<tj|d\}|d <|d d}tj|d\}|d <|S#t$rtjdwxYw) z'Parse a MySQL Binary Protocol OK packetrjrzFailed parsing Binary OK packetrNN statement_idr num_columns num_paramsrro)r r#r read_intrs)rr>ok_pkts rparse_binary_prepare_okz%MySQLProtocol.parse_binary_prepare_oksayA~''(IJ J K/4~~fQRj!/L ,VVN+.3nnVQ.G +VVM*-2^^FA-F *VVL)ABZF05vq0I -VVO,  K''(IJ J Ks A8BB:cd}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 protocolNriririrrBirlrQ)rrrrrr)r*)rrr~rrs r_prepare_binary_integerz%MySQLProtocol._prepare_binary_integers  19}&^^ &&__ +%&^^ &// E|&^^ %&__ *$&^^ &//  GU+Z??rc&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) isinstancerrrrrrsr int2storerrBrrrrrrrAr()rrr~packeds r_prepare_binary_timestampz'MySQLProtocol._prepare_binary_timestamps$ eX.. /"++J x}} -"JDF F//%**-//%++.///%)),- eX.. /uuzz::ooell34ooell34F  1$%//%*;*;<<V-6 ##rct|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.timerNrri<)rrrtimersrrrdivmodrr rAabsrBrrrrrr() rrr~negativerrr remainderminssecss r_prepare_binary_timez"MySQLProtocol._prepare_binary_time8s%("4"4hmm!DEEG G^^  eX// 0zzA~!' t!< UI!)R0LT4 us5::7u-.t,-t,- .F$$C uq)uzz23u||45u||45 6F##C  eooc* *F*V3V-6 ##rcbtj|tj|z|z}|S)zMPrepare long data for prepared statements Returns a string. )r rAr)r statementparamrGr>s r_prepare_stmt_send_long_dataz*MySQLProtocol._prepare_stmt_send_long_dataes5 OOI & OOE " #    rc & d}dgt|dzdzz}g} g} d} |i}|rD|rAt|t|k7rtjdt|D]\} } || }d}|_|| dzxxd| dzzzcc<| j t j tjt j |zo| |vr,|| drtj}n@tj}n.t|tr(|j|\} }}| j | nt|trtr1| j t j t||znA|j#|}| j t j t||ztj$}n\t|t&rB| j t j t||ztj}n trct|t(rS|j#|}| j t j t||ztj$}nt|t*rr| j t j tt|j#|t|j#|ztj,}nt|t.r6| j t1j2d|tj4}nt|t6j6t6j8fr&|j;|\} }| j | nt|t6j<t6j>fr&|jA|\} }| j | n9tjBdjE|jFjH | j t j |t j |z t jJ|t j |zt jJ|zdjM|Dcgc]}t1j2d |c}zt j dz}| D]}||z } | D]}||z } |Scc}w) z6Make a MySQL packet with the Statement Execute commandrrrrWrzTFailed executing prepared statement: data values does not match number of parametersrz:MySQL binary protocol can not handle '{classname}' objects) classnamer)'r(r r#rrr rBrNULLBLOBSTRINGrrrr&r lc_intrVARCHARbytesunicoderDECIMALfloatr)r*rrrrrrrr$r% __class____name__rAr)rrrG parametersrlong_data_usedr;iteration_countrrtypesrrr|rr~bitr>a_typea_values rmake_stmt_executezMySQLProtocol.make_stmt_executeps;cc$i!m12   !N $4yC O+++233$J/9 5QS =+qS1W~=+LL!@!&!7"89N*%c*1-%.^^ &/%5%5 s+"::5AVZMM&)s+ ell3u:&>&+',-!& W 5 !LLU4u<>!*!2!2Ju-MM%,,s5z":U"BC!*J"5'2!LL1EMM%,,s5z":U"BC!*!2!2Jw/MM SU):):#*%&&'),U):):7)CDE"+!2!2Ju-MM&++c5"9:!*!1!1J(9(98=='IJ+/+I+I,(VZMM&)(:(:HMM'JK+/+D+DU+K(VZMM&) 11006&+oo&>&>171@AA U__Z8"__U345q9 5x OOL ) OOE " # OOO , - HH{Cfkk#s+C D E OOA     F f F  G g F  Ds8T c|ddk(stjdtj|ddd\}}|r |dd k(r|dd}|j d |fS) z&Parse a MySQL AuthSwitchRequest-packetrjrz'Failed parsing AuthSwitchRequest packetrNNrrPrXrr)r r#r r\r])rr> plugin_names rparse_auth_switch_requestz'MySQLProtocol.parse_auth_switch_requestsqayC''9; ;!& 1 1&*' J fRjAoCR[F!!&)611rcF|ddk(stjd|ddS)z!Parse a MySQL AuthMoreData-packetrjrz"Failed parsing AuthMoreData packetrNN)r r#)rr>s rparse_auth_more_dataz"MySQLProtocol.parse_auth_more_datas1ayA~''46 6abzr)NNN!r@FN)rrr )N)NNNrrFN)rY)T)r)r!rNr)r __module__ __qualname____doc__rr1r?rCrHrKrhruryrrrrrrrrrrrrrrrrrrr!rrrr's  .KO+,=B"#J67)3CGAB8<"H*X(G 4(6(TN( N,0*$@8"@B $D+$Z CE@FXt 2rr)r$r)rdecimalr constantsrrrrr r r authenticationr catch23r rrobjectrr!rrr+s;0JJ+'!u Fu r