vd(mdZddlZddlZddlmZddlmZmZmZm Z m Z ddl m Z m Z ddlmZddlmZmZdd l mZGd d eZdS) 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 d'd Z d(d Zd)d Z d*d Z d Z dZ dZ d+dZ dZd,dZd-dZdZdZdZdZdZd-dZdZdZdZd Zd!Z d.d$Zd%Zd&ZdS)/ MySQLProtocolzRImplements MySQL client/server protocol Create and parses MySQL packets. cX|tjzr|r|ddzSdS)z.Prepare database string for handshake responseutf8)rCONNECT_WITH_DBencode)self client_flagsdatabases T/var/www/html/t/fyr/venv311/lib/python3.11/site-packages/mysql/connector/protocol.py_connect_with_dbzMySQLProtocol._connect_with_db-s5 *4 4 5 5??6**W4 4wc|sdS t||||||}|} nR#ttjf$r9} tjdt| d} ~ wwxYw|tj zr(t| } tj d| | z} n| dz} | S)z#Prepare the authentication responser)usernamepasswordr ssl_enabledzFailed authentication: {0}Nz |d} | p|d} n@#ttf$r,} tjd| d} ~ wwxYw|sd} |d} n#t $r|} YnwxYwtjddt|  |||| } | | ||||| | |z } | | ||z } |tj zr| | dd zz } | S) z"Make a MySQL Authentication packetr,r+*Handshake misses authentication info ({0})Nrrz> > $'' h??? *0 0 ; k((007: :F &A'A  AA00 A?>A?ctj|tj|ztj|zdzS)z Make a SSL authentication packets)r int4store int1store)rr=rr>s r make_auth_sslzMySQLProtocol.make_auth_sslosE|,,1223w''( rc<tj|}|||z }|S)z(Make a MySQL packet containing a command)r rE)rcommandargumentdatas r make_commandzMySQLProtocol.make_commandws&w''   H D rc | |d} |p|d}n@#ttf$r,} tjd| d} ~ wwxYw|sd} |d} n#t $r|} YnwxYwtjdt| tj | } | | |||||| |z } | | ||z } | tjd |z } |tjzr| |dd zz } | S) z0Make a MySQL packet with the Change User commandr,r+r5Nrrz > > $'' h???&+dG,,, *0 0 ; k((007: :F rBc i}td|ddd|d<tj|ddd\}|d<td |dd \|d <}}|d <|d <}}|d|d<|d d}tj||z}d}|t jzrA|rtd|dz nd} |d| }|| d}|ddkr |dd}|t jzrcd|vr$|d dr d|c}|d<ntj|d\}|d<|dd|d<nd|d<||z|d<||d<|S)zParse a MySQL Handshake-packet>qAJ383D 122JG4%4%4%0./ 2F1R4L A A      Y _   ),-F)G)N)N)P)P %&}]]%BCC  *6 6 -4DL3r+a/000"D$JDEE]F"~""'_ *0 0 9v%%56AA'JJ&14V,]++/4/@0)0)0),]+!$]!3!:!:7!C!CC  !8C % 2K*N rc|ddkstjdi} td|ddd|d<tj|dd\}|d<tj|\}|d <td |dd\|d <|d <|dd}|r8tj|\}|d <|d d|d <n"#t$rtjdwxYw|S)zParse a MySQL OK-packetrz#Failed parsing OK packet (invalid).rPrQ field_countN affected_rows insert_idz>==(( (. 1$Z88HH| 1 1 1'00 0 1 s""s6{{a'7'7'00 0'{O%a[M s 8$ATc d}i}|r|ddd}n|d}|D]} d|ddD\}}n#tj|xYw|d} t |||<i# t |d||<n.#tjd |||xYwYxYw|S) zParse the statistics packetz)Failed getting COM_STATISTICS informationrmNs c6g|]}|S)strip).0vs r z2MySQLProtocol.parse_statistics..%s EEEAaggiiEEEr:rr\z{0} ({1}:{2}).)splitr r#r`intrr%) rr@ with_headererrmsgrdpairspairlblvals rparse_statisticszMySQLProtocol.parse_statisticss7<  .122J$$[11EELL--E C CD 4EED!1D1DEEE cc 4+F333**W%%C Cs88C CC&szz'':':;;CHHC /(//SAACCCH s/#A##A9B%%C>(%C C>+C99C>rcg}d}d}d}|dk} |s||krn|} | dr| ddg} |} | drF| | dd|} | dF| | ddtjt d| }n| ddkr$| dd kr|| }d}nP|r0| ddkr$| dd kr|| }d}nd}tj| dd}||||n||t| |d z }||fS) 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)rQrQTsrmrrrrr) recvrcappendr read_lc_string_list bytearrayjoinrrxr) rsockversionr{rowseofrowdataieof57r@datass rread_text_resultzMySQLProtocol.read_text_result5s 9$  a5jjYY[[F  11 @ ''88)LL,,,!YY[[F''88) VABBZ(((3IcNN4G4G4N4NOO)s""vay1}}nnV,, @F1INNvay1}}mmF++3F122J??{w2 G$$$$#F+++ FA5 6Syrc|dtjkrd}d}nZ|dtjkrd}d}n?|dtjtjfvrd}d}n|dtjkrd}d}|d t jzr|}||d t||d |d fS) z%Parse an integer from a binary packetrbhrrrmqrZrNr) rTINYSHORTINT24LONGLONGLONGrUNSIGNEDupperr)rr@fieldformat_lengths r_parse_binary_integerz#MySQLProtocol._parse_binary_integer_s 8y~ % %GFF 1X ( (GFF 1X)/9>: : :GFF 1X+ + +GF 8i( ( &mmooGvwwwqx8H!I!I!!LMMrc|dtjkrd}d}nd}d}||dt||d|dfS)z)Parse a float/double from a binary packetrrZdrmfNr)rDOUBLEr)rr@rrrs r_parse_binary_floatz!MySQLProtocol._parse_binary_floatssU 8y' ' 'FGGFGvwwwqx8H!I!I!!LMMrc |d}d}|dkr@tjtd|ddd|d|d}n|dkr~d}|d kr!td |d |dzd}tjtd|ddd|d|d|d |d |d|}||dzd|fS)z&Parse a timestamp from a binary packetrNrmHrr)yearmonthdayr IrZrQ)rrrhourminutesecond microsecond)datetimedater)rr@rrvaluemcss r_parse_binary_timestampz%MySQLProtocol._parse_binary_timestamp~s Q;;M"3qs 44Q7Qi1IEEq[[C||#C&1* )=>>qA%"3qs 44Q7Qi1IAYayay!!!Evz{{#U++rcJ|d}|d|dz}d}|dkrtd|ddd}td|ddd}|ddkr|dz}tj||d||d |d }||dzd|fS) z'Parse a time value from a binary packetrrrZrNrQr[rr)daysseconds microsecondsminuteshours)rr timedelta)rr@rrrJrrtmps r_parse_binary_timez MySQLProtocol._parse_binary_timesa l# A::T!""X..q1CS$qs),,Q/ 7a<< BJD d)-a.1)-a'+Aw 000 vz{{#S))rcRt|dzdzdz}d|d|D}||d}g}t|D]\}}|t|dzdz d|dzdzzzr|dC|dtjtjtjtjtj fvr/| ||\}}|||dtj tj fvr0| ||\}}|||dtjtjtjfvr0|||\}}||^|dtjkr0|||\}}||t)j|\}}||t-|S)z(Parse values from a binary result packetrrrZc,g|]}t|Sr)r)rrs rrz6MySQLProtocol._parse_binary_values..sDDD!s1vvDDDrrNr)r( enumeraterrrrrrrrrrFLOATrDATETIMEDATE TIMESTAMPrTIMErr rutuple) rfieldsr@null_bitmap_length null_bitmapvaluesposrrs r_parse_binary_valuesz"MySQLProtocol._parse_binary_valuess!&kkAo1a7DDva0B.B'CDDD *++,#F++ % %JC3Aqy>>*aC!Gq=.@A % d###qinio'o'ni.@BBB#'"<"">vu"M"M e$$$$qY^++"&"9"9&%"H"H e$$$$"'"6v">"> e$$$$V}}rc^g}d}d}d} |n||krn|}|ddkr||}d}n,|ddkr d}|||dd}||||n||t ||dz }||fS)zwRead MySQL binary protocol result Reads all or given number of binary resultset rows from the socket. NrTrmrrQr)rrrrr) rrcolumnsr{rrrrr@s rread_binary_resultz MySQLProtocol.read_binary_results   EzzYY[[FayCnnV,,a227F122JGG{v1 F#####F+++ FA! "c{rc|ddkstjdi} tj|ddd\}|d<tj|d\}|d<tj|d\}|d <|d d}tj|d\}|d <n"#t$rtjdwxYw|S) z'Parse a MySQL Binary Protocol OK packetrmrzFailed parsing Binary OK packetrQN statement_idr num_columns num_paramsrrr)r r#r read_intrv)rr@ok_pkts rparse_binary_prepare_okz%MySQLProtocol.parse_binary_prepare_oksayA~~'(IJJ J K/4~fQRRj!/L/L ,VVN+.3nVQ.G.G +VVM*-2^FA-F-F *VVL)ABBZF05vq0I0I -VVO,, K K K'(IJJ J K s A>B##Ccd}d}|dkrN|dkrd}tj}n|dkrd}tj}ns|dkrd}tj}n^d }tj}nOd }|d krd }tj}n8|d krd}tj}n#|dkrd}tj}ntj}d}t j||||fS)z0Prepare an integer for the MySQL binary protocolNriririrrBirlrQ)rrrrrr)r*)rrrrrs r_prepare_binary_integerz%MySQLProtocol._prepare_binary_integers  199}}&^ &&_ +%%&^ &/ E||&^ %&_ *$$&^ &/  GU++Z??rct|tjr tj}n6t|tjr tj}nt dtj|j tj |j ztj |j z}t|tjrw|tj |j ztj |jztj |jz}|jdkr|tj|jz }tj t%||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) isinstancerrrrrrvr int2storerrErrrrrrrDr()rrrpackeds r_prepare_binary_timestampz'MySQLProtocol._prepare_binary_timestamps6 eX. / / F"+JJ x} - - F"JJDFF F/%*--/%+..//%),,- eX. / / =uuz:::oel334oel334F 1$$%/%*;<<<V--6 ##rct|tjtjfst dt j}d}d}d}t|tjr|jdkrd}t|j d\}}t|d\}} |tj t|jtj |ztj |ztj | zz }|j}nl|tj dtj |jztj |jztj |jzz }|j}|r|tj |z }tj ||z}tj t'||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<)rrrtimervrrrdivmodrr rDabsrErrrrrr() rrrnegativerrr remainderminssecss r_prepare_binary_timez"MySQLProtocol._prepare_binary_time8s%("4hm!DEE GEGG G^  eX/ 0 0 $zA~~!' t!.s$CCCfk#s++CCCr)'r(r r#rrr rErNULLBLOBSTRINGrrrr&r lc_intrVARCHARbytesunicoderDECIMALfloatr)r*rrrrrrrr$r% __class____name__rDr)rrrJ parametersrlong_data_usedr=iteration_countrrtypesrrrrrr@a_typea_values rmake_stmt_executezMySQLProtocol.make_stmt_executepsFcc$ii!m12   !N > 5$> 54yyC OO+++2333$J//9 59 5QS =+++qS1W~=+++LL!@!@!&!7!7"8999N**%c*1-6%.^ &/%5 s++(A"::5AAVZMM&))))s++$A> el3u::&>&>&+',----!& W 5 5 !LU44u<>>>!*!2JJu--AMM%,s5zz":":U"BCCC!*JJA"5'22A!LL11EMM%,s5zz":":U"BCCC!*!2JJw//AMM SU):):#*%*%&&&&''),U):):7)C)CDEEE"+!2JJu--AMM&+c5"9"9:::!*!1JJ(98='IJJ A+/+I+I,,(VZMM&))))(:HM'JKKA+/+D+DU+K+K(VZMM&)))) 1006&+o&>171@1@AAA U_Z88"_U3345555 OL ) ) OE " " # OO , , - HHCC{CCC D D E OA       F f FF  G g FF rc|ddkstjdtj|ddd\}}|r|dd kr |dd}|d |fS) z&Parse a MySQL AuthSwitchRequest-packetrmrz'Failed parsing AuthSwitchRequest packetrQNrrSr[rr)r r#r r_r`)rr@ plugin_names rparse_auth_switch_requestz'MySQLProtocol.parse_auth_switch_requestsayC'9;; ;!& 1&*' J J J  !fRjAooCRC[F!!&))611rcV|ddkstjd|ddS)z!Parse a MySQL AuthMoreData-packetrmrz"Failed parsing AuthMoreData packetrQN)r r#)rr@s rparse_auth_more_dataz"MySQLProtocol.parse_auth_more_datas7ayA~~'466 6abbzr)NNNr2rr3FN)r2rr3)N)NNNr2rFN)r\)T)r)rrrNr)r __module__ __qualname____doc__rr1rArFrKrNrkrxr|rrrrrrrrrrrrrrr r"r%r'rrrrr's(  .KO+,=B"####J67)3CGAB8<""""H***X(GGG    4(6((((TNNN( N N N,,,0***$@8"@@@B $ $ $D+$+$+$Z   CE@FXXXXt 2 2 2rr)r*r)rdecimalr constantsrrrrr r r authenticationr catch23r rrobjectrrrrr1s0 JJJJJJJJJJJJJJ++++++''''''''!!!!!!u u u u u Fu u u u u r