iUdZddlZddlZddlmZmZddlmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZmZmZmZdd lmZmZmZmZdd lmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'd Z(e)e*d <Gd dZ+y)z,Implements the MySQL Client/Server protocol.N)DecimalDecimalException)AnyDictListOptionalSequenceTupleUnion)utils)get_auth_plugin)PARAMETER_COUNT_AVAILABLE ClientFlag FieldFlag FieldType ServerCmd) DatabaseErrorInterfaceErrorProgrammingError get_exception) ConnAttrsTypeDescriptionType EofPacketType HandShakeType OkPacketType%ParseValueFromBinaryResultPacketTypes SocketTypeStatsPacketType StrOrBytes!SupportedMysqlBinaryProtocolTypes PROTOCOL_VERSIONcReZdZdZededeedefdZ ededee deedeeded ed eed e defd Z dGdee dee deedeedededed e d eedeedeedefdZededefdZe dHdedededefdZedIdedeedefdZedJdededefdZ dKde dee deedeededed e d eedeedeedefdZedede fdZededeeeffdZededefdZededeefd ZedLded!edefd"Zdedefd#ZedMded$e de fd%Z! dJd&e"d'eed(fd)edee#eeed(feeffd*Z$eded+edeeeffd,Z%eded+edeee&ffd-Z'e dNdededeee(ffd.Z)eded/edeeee*e+jXe+jVfffd0Z-ededeee+j\ffd1Z/ dLd2e#edededee0d(ffd3Z1 dOd&e"d4e#ed)ededee#ee0d(feeff d5Z2edede3eeffd6Z4ed7edeeeeffd8Z5ed7e*e+jXe+jVfdeeeffd9Z6ed7e*e+j\e+jnfdeeeffd:Z8ed;edZ9 dPded=e:e;d?e:e<d@edAee3eee fdedBee#eeeededefdFZ?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 j/var/www/catia.catastroantioquia-mas.com/valormas/lib/python3.12/site-packages/mysql/connector/protocol.py_connect_with_dbzMySQLProtocol._connect_with_dbGs+ *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+)r1r2r'r6zFailed 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 packetNr5r4&Handshake misses authentication info ()r0r*xxxxxxxxxxxxxxxxxxxxxxzrCr/r PLUGIN_AUTH CONNECT_ARGSmake_conn_attrs)selfrDr1r2r'rEr&rFr6r4rGr3r5rAusername_bytesfiller username_lenpackets r. make_authzMySQLProtocol.make_authssm  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<).0xrGs r. z0MySQLProtocol.make_conn_attrs..s#@AZ]++@s$'r8r*)sumr<keysvaluesr=r>r-)rG attr_nameconn_attrs_lenconn_attrs_packets` r.rQzMySQLProtocol.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 ! r0ctj|tj|ztj|zdzS)z Make a SSL authentication packetsr int4store int2store)rEr&rFs r. make_auth_sslzMySQLProtocol.make_auth_sslsB OOL )oo01 2oog& '  r0commandargumentc>tj|}|||z }|S)z(Make a MySQL packet containing a command)r int1store)rjrkdatas r. make_commandzMySQLProtocol.make_commands'w'   H D r0 statement_idrowscXtj|tj|zS)z0Make a MySQL packet with Fetch Statement command)r rg)rprqs r.make_stmt_fetchzMySQLProtocol.make_stmt_fetchs!|,ut/DDDr0c 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 commandr5r4rIrJNr0r*r8rLr CHANGE_USERrCr/rrOrPrQ)rRrDr1r2r'rEr&r6r4rGr3r5rArSrUrVs 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.rVc 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-packetqAJ 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 r0ctj|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)rVstatusr4s r.parse_auth_next_factorz$MySQLProtocol.parse_auth_next_factorRsX2 Q; !QR R#//GD {))'222r0c|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).ryrz field_countN affected_rows insert_idz->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)rVcountrAs r.parse_column_countz MySQLProtocol.parse_column_countrsQ 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 ==( (. 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 informationr0rNs :rrz (:rJ) splitstriprrrintrMrrrepr) rVrerrmsgrpairslblpairvvalrAs 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. Nrsrr0rr ) recvrappendr read_lc_string_list bytearrayjoinrr) rRrrrrrqeofrowdatairVdatass 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-r0fieldc|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 >: :GF 1X++ +GF 8i(( (mmoGvwwq8H!I!!LMMr0c|dtjk(rd}d}nd}d}||dtj||d|dfS)z)Parse a float/double from a binary packetr r >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. Nrrrrzr )rrrrr) rRrrrrErqrrarrVs r.read_binary_resultz MySQLProtocol.read_binary_results c{Ezc{YY[FayCnnV,a227F12JP{v1 F##F++ FA!r0c\|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 packetrzNrpr num_columns num_paramsr r)rr rr)rVok_pktrAs 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 protocolNriririrrr8irulrz)rrrrs r.prepare_binary_integerz$MySQLProtocol.prepare_binary_integers  19}&^^ &&__ +%&^^ &// E|&^^ %&__ *$&^^ &//  GU+Z??r0c&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 rhrrmrrrrrrrgr<)rrpackeds r.prepare_binary_timestampz&MySQLProtocol.prepare_binary_timestamps) eX.. /"++J x}} -"JQR R OOEJJ 'ooekk* +ooeii( )  eX.. ///%**-.//%,,/0//%,,/0    1$%//%*;*;<<V-6 ##r0ct|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.timerNr0r i<)r%rrtimerrrrdivmodrr rgabsrmrrrrrr<) 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 ##r0 statementparamrncbtj|tj|z|z}|S)zMPrepare long data for prepared statements Returns a string. rf)r2r3rnrVs r.prepare_stmt_send_long_dataz)MySQLProtocol.prepare_stmt_send_long_dataBs+"OOI69OORVV r0 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-j.d |tj0}n t|t2j2t2j4fr&|j7|\} }| j| nt|t2j8t2j:fr&|j=|\} }| j| n|r[t|j!|}| jt j"t||ztj}n#t?d |j@jBd | jt j|t j|z|s|dz|kDs|||z dj!|}|jt j"t||zt jD|t j|zt jD| z}||t|z}n|}|r||t j"|z }|djG| Dcgc]}t-j.d |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 rrrr0utf8mb4r*zTFailed executing prepared statement: data values does not match number of parametersrz&MySQL binary protocol can not handle 'z ' objectsBr+)$r<rlistrrr r rmrNULLBLOBSTRINGr%rr#strr-lc_intbytesrrfloatr=r>rrrr'rr*r1r __class____name__rgr)rRrprnr6rr7rEr8r9iteration_countrratypesr&data_lenquery_attr_namesrattr_valrr_flagsrrrVparameter_countbitra_typea_values r.make_stmt_executezMySQLProtocol.make_stmt_executeMscc$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!*!1!1Ju-MM%,,s5z":U"BC!*!1!1Jw/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 packetrzNr+r|rrr*)rr rr)rV plugin_names r.parse_auth_switch_requestz'MySQLProtocol.parse_auth_switch_requestsgayC !JK K#//qr H fRjAoCR[F!!&)611r0c2|ddk(s td|ddS)z!Parse a MySQL AuthMoreData-packetrr z"Failed parsing AuthMoreData packetrzN)r)rVs r.parse_auth_more_dataz"MySQLProtocol.parse_auth_more_datas'ayA~ !EF Fabzr0) NNN-r@FNNN)rWrrXr[)r ) NNNrWrFNNN)r)T)r*)r r)rYrNr*NF)@rF __module__ __qualname____doc__ staticmethodrrrArCr/r boolrCrrrWrQrrirorsrwrr rrrrrrrrrrrrrrrDrrrr rrrrr rrrrrr#r'r*r1r5r r!rrQrTrVrYr0r.r%r%As 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"*/ =?$&;?7;',AA89ASM A  A !c5;&6!78 AAd5c?34A!%A AF 2% 2E#u*4E 2 2Uur0r%),r\rr=decimalrrtypingrrrrr r r rYr authenticationr constantsrrrrrerrorsrrrrrHrrrrrrrrr r!r#r__annotations__r%rYr0r.res]>3 -DDD+SR   #aar0