BRej@ejBejDejFejHejJejLejNejPejRejTejVejXejZej\gZ/id ej`d ejbd ejdd ejfdejhdejjdejldejndejpdejrdejtdejvdejxdejzdej|dej~dejidejdejdej8dej:dej<d ej>d!ej@d"ejBd#ejDd$ejFd%ej6d&ejd'ejd(ejd)ejd*ejd+ejid,ejd-ejd.ejd/ejd0ejd1ejd2ejd3ejHd4ejJd5ejLd6ejNd7ejPd8ejRd9ejTd:ejVd;ejXdZQid?d@d@d@d dAdddBdBd dBddd d dCdCd d dddddddDdDdEdDdFdFdGdGidHdHdIdIdJdJdAdAdKdKdLdLdMdMdNdNdOdOdPdPdQdQdRdRdSdSdddTdTddZRdUdVdRddWdXZSdYdZd[d\d]d^d_d`ZTGdadbZUdceddefdeZVdceddefdfZWdge ee fddefdhZXdieeddefdjZYddefdkZZdce[ddefdlZ\dce]ddefdmZ^dce]ddefdnZ_dceddefdoZ`dceaddefdpZbdcecddefdqZddceddefdrZedsefdteddefduZgdvefddeffdwZhGdxdyZiyz){zExpression Parser.)AnyCallableDictIterableListOptionalSequenceUnion)DbDoc) BYTE_TYPESget_item_or_attrMessage mysqlxpb_enum)BuildExprTypesBuildScalarTypes MessageTypeProtobufMessageCextTypeProtobufMessageType StrOrBytescteZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*d)Z+d*Z,d+Z-d,Z.d-Z/d.Z0d/Z1d0Z2d1Z3d2Z4d3Z5d4Z6d5Z7d6Z8d7Z9d8Z:d9Z;d:Zd=Z?d>Z@d?ZAd@ZBdAZCdBZDdCZEdDZFdEZGdFZHdGZIdHZJdIZKdJZLdKZMdLZNdMZOdNZPdOZQdPZRdQZSdRZTdSZUdTZVdUZWdVZXdWZYdXZZdYZ[dZZ\y[)\ TokenTypezToken types class.r   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYN)]__name__ __module__ __qualname____doc__NOTANDORXORISLPARENRPAREN LSQBRACKET RSQBRACKETBETWEENTRUENULLFALSEINLIKEINTERVALREGEXPESCAPEIDENTLSTRINGLNUMDOTDOLLARCOMMAEQNEGTGELTLEBITANDBITORBITXORLSHIFTRSHIFTPLUSMINUSMULDIVHEXBINNEGBANG MICROSECONDSECONDMINUTEHOURDAYWEEKMONTHQUARTERYEAREROTEME DOUBLESTARMODCOLONORORANDANDLCURLYRCURLYCASTDOTSTAR ORDERBY_ASC ORDERBY_DESCASARROWQUOTEBINARYDATETIMETIMECHARDATEDECIMALSIGNEDINTEGERUNSIGNEDJSONSECOND_MICROSECONDMINUTE_MICROSECOND MINUTE_SECONDHOUR_MICROSECOND HOUR_SECOND HOUR_MINUTEDAY_MICROSECOND DAY_SECOND DAY_MINUTEDAY_HOUR YEAR_MONTHOVERLAPSL/var/www/html/delta-backend/venv/lib/python3.12/site-packages/mysqlx/expr.pyrr/s C C B C B F FJJG D D E B DH F F EG D C F E B B B B B B F E F F F D E C C C C C DK F F D C D EG DGJ C E D F F F DGKL B E E FH D D DG FGH DMKKOJJHJHrrandorxorisnotlikeinoverlapsregexpbetweenintervalescapecastdivhexbintruefalsenullsecondminutehourdayweekmonthquarteryear microsecondascdescasbinarydatetimetimechardatedecimalsignedunsignedintegerjsonsecond_microsecondminute_microsecond minute_secondhour_microsecond hour_second hour_minuteday_microsecond day_second day_minuteday_hour year_month)rrrrrrrr===&&||^!=<>>>=<<=&|<<>>+-*/~%cont_in sign_plus sign_minus!)rrrrris_not not_between not_regexpnot_likenot_in not_cont_in not_overlaps)rrrrrrrc BeZdZdZd dedededdfdZdefdZdefd Zy) TokenzToken representation class. token_typevaluelengthreturnNc.||_||_||_yN)r(r)r*)selfr(r)r*s r__init__zToken.__init__#s) ! rc"|jSr-)__str__r.s r__repr__zToken.__repr__(s||~rc|jtjtjtjfvr|jd|j dS|jS)N())r(rrrrr)r2s rr1z Token.__str__+sU ?? OO NN     oo&a |15 5//"#r)r ) rrrsrtruintstrr/r3r1rrrr'r' s>%"3"s"C"" #$$rr'r)r+ctd}t|tr|St|tr|jdSt|tt fr,t d|d<t|j|d<|St|ttfr,t d|d<t|j|d<|St d |d<t|j|d <|S) NMysqlx.Expr.ExprT)reparseMysqlx.Expr.Expr.Type.OBJECTtypeobjectMysqlx.Expr.Expr.Type.ARRAYarrayMysqlx.Expr.Expr.Type.LITERALliteral) r isinstance ExprParserexprdictr r build_object get_messagelisttuple build_array build_scalarr)msgs r build_exprrO8s $ %C%'# %*&zz$z''%$'#$BCF $U+779H  J ED%= )#$ABF "5)557G  J$$CDF %e,88:I JrcVt|tr t|St|tr t |St|t r t |St|tr t|St|tr t|S| tStdt|)NzUnsupported data type: )rCr8build_string_scalarr build_bytes_scalarboolbuild_bool_scalarr7build_int_scalarfloatbuild_double_scalarbuild_null_scalar ValueErrorr=r)s rrLrLJs%"5))%$!%((% ''%&&%"5)) } "" .tE{m< ==robjctt|trt|jSt d}|j D]t\}}t d}t|t r|jn||d<t|j|d<|dj|jgv|S)NMysqlx.Expr.ObjectMysqlx.Expr.Object.ObjectFieldkeyr)fld) rCr rG__dict__ritemsr8encoderOrHextend)r[rNr_r)pairs rrGrGZs#uCLL)) & 'Ciik0 U78&0c&:cjjlU "5)557W  E 4++-./ 0 Jrr@ctd}|dj|Dcgc]}t|jc}|Scc}w)NMysqlx.Expr.Arrayr))rrdrOrH)r@rNr)s rrKrKgsC % &CLeLUE*668LM JMs Ac8td}td|d<|S)NMysqlx.Datatypes.Scalarz#Mysqlx.Datatypes.Scalar.Type.V_NULLr=rrNs rrXrXms! + ,C EFCK JrcBtd}td|d<||d<|S)Nriz%Mysqlx.Datatypes.Scalar.Type.V_DOUBLEr=v_doublerrMs rrWrWss* + ,C GHCKC O JrcBtd}td|d<||d<|S)Nriz#Mysqlx.Datatypes.Scalar.Type.V_SINTr= v_signed_intrrMs rrUrUzs+ + ,C EFCKC JrcBtd}td|d<||d<|S)Nriz#Mysqlx.Datatypes.Scalar.Type.V_UINTr=v_unsigned_intrrMs rbuild_unsigned_int_scalarrqs, + ,C EFCK!C Jrct|trtt|d}t d}t d|d<t d||d<|S)Nzutf-8riz%Mysqlx.Datatypes.Scalar.Type.V_STRINGr=zMysqlx.Datatypes.Scalar.StringrZv_string)rCr8bytes bytearrayrrrMs rrQrQsM%iw/0 + ,C GHCK>eLC O JrcBtd}td|d<||d<|S)Nriz#Mysqlx.Datatypes.Scalar.Type.V_BOOLr=v_boolrrMs rrTrTs* + ,C EFCKCM JrcXtd}td|d<td||d<|S)Nriz%Mysqlx.Datatypes.Scalar.Type.V_OCTETSr=zMysqlx.Datatypes.Scalar.OctetsrZv_octetsrrMs rrRrRs2 + ,C GHCK>eLC O JrcBtd}td|d<||d<|S)Nr:rAr=rBrrMs rbuild_literal_exprr{s* $ %C ?@CKC N Jrnameparamctd}t||d<|jg|d<td}td|d<|j|d<|S)NMysqlx.Expr.Operatorr|r}r:Mysqlx.Expr.Expr.Type.OPERATORr=operator)r_UNARY_OPERATORSrHr)r|r}rrNs rbuild_unary_oprsc-.H'-HV**,-HW $ %C @ACK**,C O Jrstringc&|jddS)N"z"")replacers rescape_literalrs >>#t $$rcleZdZdZdGdededdfdZdefdZdHdZd e d edefd Z d e de fd Z dIde dede fdZ d e de fdZdHdZde ddfdZde defdZde defdZde defdZde defdZd e de defdZde defdZdeeeeffdZdefdZdefdZdefdZdefd Z defd!Z!deeeeffd"Z"defd#Z#de fd$Z$de ddfd%Z%de fd&Z&defd'Z'defd(Z(defd)Z)d*e defd+Z*defd,Z+defd-Z,dId.ede-efd/Z.e/defd0Z0defd1Z1de2e d2e3gefdefd3Z4defd4Z5defd5Z6defd6Z7defd7Z8defd8Z9defd9Z:defd:Z;defd;ZdId>edefd?Z?dId>edefd@Z@defdAZAdeBfdBZCdeefdCZDdeeeeffdDZEdeeeeffdEZFdeeeeffdFZGy)JrDzExpression parser class.rallow_relationalr+Nc||_g|_g|_d|_||_i|_d|_|j|jyNr) rtokenspath_name_queuepos_allow_relational_columnsplaceholder_name_to_positionpositional_placeholder_countclean_expressionlex)r.rrs rr/zExprParser.__init__sL! #% *,/?&<>)12)   rc"d|jdS)Nzrr2s rr1zExprParser.__str__s%dkk]"55rct|jtst|j|_|jj d|_t |jdkDr&|jddk(r|jdd|_d|jddj vr|jdd|_d|jdd j vr|jd d|_yy) zRemoves the keywords that does not form part of the expression. Removes the keywords "SELECT" and "WHERE" that does not form part of the expression itself.  r ;NSELECTrWHEREr)rCrr8reprstriplenupperr2s rrzExprParser.clean_expressions $++s+t{{+DKkk'', t{{ a DKKOs$:++cr*DK t{{2A,,. .++ab/DK dkk"1o++- -++ab/DK .rr_rcf|dzt|jkxr|j|dz|k(SNr )rr)r.r_rs r next_char_iszExprParser.next_char_iss1QwT[[))Jdkk#'.Bd.JJrrc|}d}|t|jkr|j|js|j|dk(rq|j|dk(r|dur tdd}|dz }|t|jkr1|j|jr^|j|dk(rq|j||}t t j |t|S)NF.Tz"Invalid number. Found multiple '.'r )rrisdigitrYr'rr)r.rstart found_dotvals r lex_numberzExprParser.lex_numbers C $$ KK  $ $ &$++c*:c*A{{33&$$%IJJ  1HCC $$ KK  $ $ &$++c*:c*Akk%$Y^^S#c(33ri allow_spacecz|}|t|jkr|j|js1|j|dk(s|j|jrp|rn|dz }|t|jkrQ|j|jr;|j|dk(rN|j|jr|rn|j||} |t|jkrN|j|dk(r<|j t vr&t tj|t|}|St t|j |j t|} |S#t$r(t tj|t|}Y|SwxYw)N_r r5) rrisalnumisspacelower%_SQL_FUNTION_RESERVED_WORDS_COLLISIONr'rr_RESERVED_WORDSKeyError)r.rrrrtokens r lex_alphazExprParser.lex_alphasd#dkk"" KKN " " ${{1~$ A&&([ FA #dkk"" KKN " " ${{1~$ A&&([kk%" :C $$KKNc)IIK'LLioosCH=  ociik:CIIKSR  :)//3C9E  :s'A$F 9F -F:9F:c|j|}d}|dz }|}|t|jkr|j|}||k(r1|dzt|jkr|j|dz|k7rn]||dfvr4|dzt|jk\rn;|dz }||j|z }n||z }|dz }|t|jkr|t|jk\s|j||k7rtd||dk(r'ttj |t|dzSttj |t|dzS)Nr \z'Unterminated quoted string starting at `r)rrrYr'rrr)r.r_ quote_charrrrs rlex_quoted_tokenzExprParser.lex_quoted_tokensU[[%  qC $$;;s#D "!Gc$++..KKa(J6 D))7c$++..qt{{3''t  1HC#C $$$ #dkk" "dkk#&6*&DFugNO O  #s3x!|< <Y&&SX\::rc d}d}d}|t|jkr|j|}|jr|dz }>|jr|j |}n|j s|dk(r|j ||}n|dk(rttj|}n|dk(rttj|}n|dk(rttj|}n|dk(rttj|}ne|d k(rttj|}nD|d k(rO|j|d r!|sttjd d }d}n ttj |}n|dk(rK|j|drttj"dd }nttj$|}n|dk(rttj&|}n|dk(rttj(|}n^|dk(rttj*|}n=|dk(rL|j|drttj,dd }n ttj,dd}n|dk(rK|j|drttj.dd }nttj0|}n|dk(rttj2|}n{|dk(rK|j|drttj4dd }nGttj6|}n+|dk(rttj8|}n |dk(rttj:|}n|dk(rttj<|}n|dk(rttj>|}n|dk(rttj@|}n|d k(rttjB|}ne|d!k(rK|j|drttjDd"d }n1ttjF|}n|d#k(r|j|d rttjDd$d }n|j|d#rttjHd%d }n|j|drttjJd&d }nttjL|}ng|d k(ry|j|d rttjNd'd }n3|j|drttjPd(d }nttjR|}n|d)k(r|j|drttjTd*d }n|dzt|jkr2|j|dzjr|j |}nittjV|}nN|d+vr&|r$ttjX|}|sd}n)d}d}n$|d,vr|j[|}nt]d-||j^ja|||jbz }|t|jkryy).NrFr r?:{}rrr z->rTrz**r$rrrrrr rr r5r6[]r,rr rr rrrrrz.*)'r)rrrzUnknown character at )2rrrrrisalpharr'rrrrrrrrrrrrrrrrrrrrr{r|r}r~rrrrrrrrrrrrrrrYrappendr*)r.r arrow_last inside_arrowrrs rrzExprParser.lexs'   #dkk"";;q>D||~Q||~*43;q,7i//6ioot4i..5i..5innd3$$Q,Z!)//4;E!%J!)//48E$$Q,!)"6"6a@E!)--6EimmT2i..5immT2$$Q,!),,a8E!),,a8E$$Q,!)"2"2D! DHHqL)44= rcn|t|jkxr|j|j|k(Sr-)rrr()r.rr(s rrzExprParser.pos_token_type_iss/S%%S$++c*:*E*E*SSrc|j||j|jj}|xjdz c_|Sr)rrrr))r.r(r)s r consume_tokenzExprParser.consume_tokens: j) DHH%++ A  rcg}d}|jtj|jtjs@|j j }t|drI|jjr3|jjd|jjd}n;t|ds/d|vr+d|dvr$|jjd|ddd}|j||jtjrb|xjdz c_|j|j j |jtjrb|jtj|r|jj|S)z{Parse a paren-bounded expression list for function arguments or IN list and return a list of Expr objects. F identifierrTr|r )rrr{rr|_exprrHhasattrrr|rinsertrrrpop)r.exprspath_name_addedmsg_exprs rparen_expr_listzExprParser.paren_expr_listsW  9++,%%i&6&67zz|//1Hx.83F3F3K3K$$++Ax/B/B/G/GH"&Hl3 H,h|44$$++Ax /Ef/MN"& LL "((9A  TZZ\5578((9 9++,   $ $ & rc|jtjtd}|j tj rA|j tj|d<|j tj |j|jj|d<|xjdz c_|S)NzMysqlx.Expr.Identifier schema_namer|r ) rrrrrrrrrr))r.idents rrzExprParser.identifiers ioo.01  " "9== 1#'#5#5ioo#FE-   y}} - DHH-33f  A  rctd}|j|d<|j|d<td}td|d<|j |d<|S)NzMysqlx.Expr.FunctionCallr|r}r:zMysqlx.Expr.Expr.Type.FUNC_CALLr= function_call)rrrrrH)r.rrs rrzExprParser.function_callsd :; $ 1 f!%!5!5!7 g-.()JK$1$=$=$?!rc|jtj|j|j}|j tj k(rz|jjdr3|jjdrt|jd|jtj |j}na|j tjk(r,|jtj|j}ntd|jtd}td|d<||d<|S)Nrz* is not a valid JSON/ECMAScript identifierz?Expected token type IDENT or LSTRING in JSON path at token pos Mysqlx.Expr.DocumentPathItem(Mysqlx.Expr.DocumentPathItem.Type.MEMBERr=r))rrrrrr(rr) startswithendswithrYrrr)r.r member_name doc_path_items rdocpath_memberzExprParser.docpath_members 9==) DHH%   y .{{%%c*u{{/C/CC/H {{m#MN   y /++K   !2!2 2   y00 1++Kxxj"  >? - 6! f"- grc|jtj|jtjrY|jtj|jtj t d}td|d<|S|jtjrt|jtj}|dkrtd|j|jtj t d}td|d<||d<|Std|j) Nrz6Mysqlx.Expr.DocumentPathItem.Type.ARRAY_INDEX_ASTERISKr=rz"Array index cannot be negative at z-Mysqlx.Expr.DocumentPathItem.Type.ARRAY_INDEXindexzGException token type MUL or LNUM in JSON path array index at token pos ) rrr}rrr~rrrr7 IndexErrorrrY)r.rr)s rdocpath_array_loczExprParser.docpath_array_locs 9//0  ! !)-- 0   y}} -   y33 4#$BCM$1H%M& !!  ! !).. 1**9>>:;Eqy #EdhhZ!PQQ   y33 4#$BCM$1?%M& !&+M' "    $  rc||js td|jtjr|j tjt d}|jtjr^t d}td|d<|j tj|d<|dj|jg|dj|j|jr|jd|d <t d }td |d<||d <|S) Nz-Empty string cannot be used as document fieldMysqlx.Expr.ColumnIdentifierrrr=r) document_pathrr|r:Mysqlx.Expr.Expr.Type.IDENTr) rrYrrrrrrrrdrHrr)r.col_idrrEs rdocument_fieldzExprParser.document_fields{{LM M  ! !)"2"2 3   y// 078  ! !)// 2#$BCM$1:%M& !&*%7%7 %HM' " ? # * *M,E,E,G+H I&&t'9'9';<   !11!4F6N)*$%BCV #\ rcg} |jtjr/|j|j j n<|jtj rX|jtj td}td|d<|j|j n|jtjr.|j|jj nx|jtjrX|jtjtd}td|d<|j|j nnt|}|dkDr6t||dz dtdk(rtd|j |S)zParse a JSON-style document path, like WL#7909, but prefix by @. instead of $. We parse this as a string because the protocol doesn't support it. (yet) rz1Mysqlx.Expr.DocumentPathItem.Type.MEMBER_ASTERISKr=z1Mysqlx.Expr.DocumentPathItem.Type.DOUBLE_ASTERISKrr z!JSON path may not end in '**' at )rrrrrrHrrrrr}rrrrrYr)r.doc_pathrrbs rrzExprParser.document_path+s%%imm4 3 3 5 A A CD'' (9(9:""9#4#45 '(F G (5G) f% 9 9 ;<'' (<(<= 6 6 8 D D FG'' (<(<=""9#7#78 '(F G (5G) f% 9 9 ;<)*H  19)(519*=vF- ?K  @ KL Lrcg}|j|jtj|j tj rm|jtj |j|jtj|j tj rmt |dkDrtd|j|jtd}tdt |D],}|dk(r |d|d<|dk(r |d|d<|dk(s%|d|d <.d }|j tjr5d }|jtj|j|d <n|j tjrd }|jtjd }|j tjr!d }|jtj|jtj|j|d <|r|jtj|rRt |d dk(rAtd }t!d|d<d|d<|d j#|j%gtd}t!d|d<||d<|S)Nrz Too many parts to identifier at rrr|r table_namerrFTrrrr=rr)r:rr)rrrrrrrrYrreverserrangerrrrrrdrH)r.partsrris_doc is_quotedrrs rcolumn_identifierzExprParser.column_identifierOse T'' 89$$Y]]3   y}} - LL++IOO< =$$Y]]3 u:>?zJK K 78q#e*% 1AAv!&qva',Qx|$a(-a}%  1  ! !)"2"2 3F   y// 0&*&8&8&:F? #  # #IOO 4F   y /I%%ioo6 ""9??3   y// 0&*&8&8&:F? #""9??3 c&12a7#$BCM$1:%M& !&(M' " ? # * *M,E,E,G+H I-.()FG!'rc|jt|jk\r td|j|j}|xjdz c_|S)NzUnexpected end of token streamr )rrrrY)r.rs r next_tokenzExprParser.next_tokensG 88s4;;' '=> > DHH% A  rc^|j}|j|k7rtd|y)Nr)r r(rY)r.r(rs r expect_tokenzExprParser.expect_tokens4!   z )3J<@A A *rc4|j|jSr-)rrr2s r peek_tokenzExprParser.peek_tokens{{488$$rcv|j|jj}|xjdz c_|Sr)rrr))r.r)s rconsume_any_tokenzExprParser.consume_any_tokens, DHH%++ A  rctd}|jt|jkr|j t j s|dj|jjg|j t jsna|jt j|jt|jkr |j t j s|jt j td}td|d<|j|d<|S)zH jsonArray ::= "[" [ expr ("," expr)* ] "]" rgr)r:r?r=r@) rrrrrrr~rdrrHrrr)r.rNrEs rparse_json_arrayzExprParser.parse_json_arrays)*hhT[[))$2H2H  3  L  !9!9!; < =)))//:   y / hhT[[))$2H2H  3  9//0)*$%BCV )W  rc\td}|jt|jkr2|j t j std}|jt j|d<|jt j|jj|d<|dj|jg|j t jsnb|jt j|jt|jkr!|j t j s|jt j td}td|d<|j|d <|S) z jsonDoc ::= "{" [jsonKeyValue ("," jsonKeyValue)*] "}" jsonKeyValue ::= STRING_DQ ":" expr r]r^r_r)r`r:r<r=r>)rrrrrrrrrrrrHrdrr)r.rNitemrEs rparse_json_doczExprParser.parse_json_docsB *+hhT[[))$2H2H   3 ;->?DK   y / JJL446DM J  t//12 3)))//:   y /hhT[[))$2H2H   3  9++,)*$%CDV *X rrcd}|jtjr |jtj}n|jtjr |jtj}nK|j tj k(rt|j}ntd|jtd}td|d<||jvr|j||d<|S|j|d<|j|j|<|xjdz c_|S)Nrz&Invalid placeholder name at token pos r:z!Mysqlx.Expr.Expr.Type.PLACEHOLDERr=positionr )rrrrrr(rr8rrYrrrr)r.rplace_holder_namers rparse_place_holderzExprParser.parse_place_holders   ! !).. 1 $ 2 29>> B   # #IOO 4 $ 2 29?? C    !2!2 2 #D$E$E F EdhhZPQ Q-.()LM  A A A#'#D#DEV#WHZ  $(#D#DHZ 11  - -!   - - 2 -rc>tdd}|jtj|dj |j j g|jtjttj|j}|dj t|j g|jtjtd|j }td|d<|S) z2cast ::= CAST LPAREN expr AS cast_data_type RPARENrrr|r}r:rrr=)rrrr{rdrrHrrRr8rccast_data_typer{r|r)r.r type_scalarrNs rrzExprParser.casts1? 9++,  $**,":":" 9<<((D4G4G4I)JK   "4["A"M"M"O!PQ 9++,(83G3G3IJ#$DEF  rc |j}|jtjtjtj tj fvr.|j}|r|j|S|jS|jtjur/|jd}|r|j|S|jS|jtjtjfvrJ|jtjr|jtj|jS|jtjtjtj fvr |jSt#d|jd|j$d|jd)acast_data_type ::= ( BINARY dimension? ) | ( CHAR dimension? ) | ( DATE ) | ( DATETIME dimension? ) | ( TIME dimension? ) | ( DECIMAL dimension? ) | ( SIGNED INTEGER? ) | ( UNSIGNED INTEGER? ) | JSON TzUnknown token type z at position z (r6)r r(rrrrrcast_data_type_dimensionr)rrrrrrrrrYr)r.r dimensions rrzExprParser.cast_data_typesu!       NN    NN   557I2;ekk]9+. L L   y00 055d;I2;ekk]9+. L L    0 0)2D2DE E%%i&7&78""9#4#45;;        NN NN  ;; !%"2"2!3= K }A   rrcF|jtjsyg}|jtj|j |jtj |rl|jtj rM|jtj |j |jtj |jtjt|dk(r d|ddSd|dd|ddS)z*dimension ::= LPAREN LNUM (, LNUM)? RPARENNr r5rr6r) rrr{rrrrr|r)r.rr"s rr!z#ExprParser.cast_data_type_dimension s%%i&6&67  9++,++INN;< t--ioo>   y /   T// ? @ 9++,9~" ! ~Q  Yq\N!IaL>3 rcXtd}td|d<tdd|d<|S)Nr:rr=rrrrrrjs r star_operatorzExprParser.star_operators2()#$DEF !"8sCJ rc |j}|jtjtjfvr|j |S|jtj k(r|jS|jtjk(r|jS|jtjk(r|jS|jtjk(r1|j}|jtj|S|jtj tj"fvr|j%}|jtj&k(rE|j(|j(z|j*|j,_|j/St1|j(|j/S|jtj2tj4tj6fvr$t1|j(|j/S|jtj8k(rt;t=|j(S|jtj>k(rt;tAS|jtj&k(r\d|j(vr't;tCtE|j(St;tGtI|j(S|jtjJtjLfvr/t;tO|jtjJk(S|jtjPk(r|jSS|jtjTk(r|jWS|jtjXk(r|j,dz |_|j[tjsy|j[tj\rj|j_|j,dztjXr=|j_|j,dztjr|jaS|jbs|jSS|jeStgd|jd|j,)zP*QRR%&6s5;;7G&HI I     @ @%!%"2"2inn"DE    y// /&&( (   y}} ,%%' '   y .xx!|DH&&y'7'78'' 6**488a<I**488a<9I9IJ))++55##% ++-  #E$4$4#56!XXJ (  r inner_parserc|}|jt|jkr|j|jj|vrt d}t d|d<t d}t |j|jj|d<|jg|d<|xjdz c_|dj|jg||d<|}|jt|jkr&|j|jj|vr|S) z}Given a `set' of types and an Expr-returning inner parser function, parse a left associate binary operator expressionr:rr=rr|r}r r) rrrr(rr _OPERATORSr)rHrd)r.rr)lhsrNrs rparse_left_assoc_binary_op_exprz*ExprParser.parse_left_assoc_binary_op_expras  nhhT[[))dkk$((.C.N.NRW.W,-C'(HICK56H)$++dhh*?*E*EFHV !$!2 3HW  HHMH W  $ $ln&@&@&B%C D&C OChhT[[))dkk$((.C.N.NRW.W rc~|j}|jtjtjr}|j tj r]|j}td}|dj|jg|jtjurdnd|d<|jtj |dj|jjg|jtstd|j t"j%|j'j)}|djt+t-|jgtd|}t/d |d <|S) Nrr}date_adddate_subr|z#Expected interval type at position r:rrr=)r'rrrrrrr rrdrHr(rbit_expr_INTERVAL_UNITSrYrr8rcrrr{rRr)r.r,rrs radd_sub_intervalzExprParser.add_sub_intervaltse   ! ! NNIOO %%i&8&89OO%E56H W  $ $coo&7%8 9#..)..@ j V    y11 2 W  $ $dmmo&A&A&C%D E)4))?; #Ftxxj!QRRJJt557==?@E W  $ $#$6u$=>JJLM ,x@C'(HICK rc|jttjtjtj g|j Sr-)r-setrrrrr3r2s r mul_div_exprzExprParser.mul_div_exprs933  y}}= >  ! !  rc|jttjtjg|j Sr-)r-r5rrrr6r2s r add_sub_exprzExprParser.add_sub_exprs233 1 2D4E4E  rc|jttjtjg|j Sr-)r-r5rrrr8r2s r shift_exprzExprParser.shift_exprs633 !!9#3#34 5t7H7H  rc|jttjtjtj g|j Sr-)r-r5rrrrr:r2s rr1zExprParser.bit_exprs;33 !!9??I4D4DE F OO  rc |jttjtjtj tj tjtjg|jSr-) r-r5rrrrrrrr1r2s r comp_exprzExprParser.comp_exprsU33 LLLLLLLLLLLL   MM  rc g}|j}d}|jtjr!d}|j tj|j t |jkrt|j|j|j|j j}|jtjr|j tj|jtjr!d}|j tj|j|jjn5|jtjr|j tj|jtjr!|j|jnd}|j|jjn|jtj rN|j tj |j|jjn|jtj"r|j tj"|j|jj|jtj$r|j tj$|j|jjn@|jtj&r|j tj&|j|jj|j tj(|j|jjn|jtj*rM|j tj*|j|jjn|rt-d|j d}|rNt/d}|r t0|n||d<||d<t/d}t3d |d <|j|d <|}|S) NFTrzUnknown token after NOT as pos rr|r}r:rr=r)r=rrrvrrrrrrHr)rzrr{rdrrrrrrwrrYr _NEGATIONr)r.paramsr,rop_namerrs r ilri_exprzExprParser.ilri_exprsXnn  ! !)-- 0F   y}} - 88c$++& & MM#//+ ,kk$((+11G%%ill3""9<<0)))--8!F&&y}}5 dnn.::<='' 5""9<<0)))*:*:;MM$"6"6"89'GMM$.."2">">"@A'' (:(:;""9#5#56 dnn.::<='' 7""9>>2 dnn.::<=)))*:*:;&&y'7'78MM$.."2">">"@A'' (9(9:""9#4#45 dnn.::<=""9==1 dnn.::<='' (8(89""9#3#34 dnn.::<=$'Ftxxj%QRR"#9:9?9W#5W $*!"#56#01Q#R '/';';'=$ rc|jttjtjg|j Sr-)r-r5rrwrrBr2s rand_exprzExprParser.and_exprs233  0 01 2DNN  rcj|jttjg|jSr-)r-r5rryrDr2s rxor_exprzExprParser.xor_exprs$33C4H$--XXrc|jttjtjg|j Sr-)r-r5rrxrrFr2s ror_exprzExprParser.or_exprs033 y~~. /  rr;c~|r,g|_d|_i|_d|_|j |j Sr)rrrrrrH)r.r;s rrzExprParser._exprs8 DKDH02D -01D - HHJ||~rcJ|j|}|j}|jt|jdz t j r|dz }|t|jkr2td|j|jdd|j|S)NrzUnused token types z" found in expression at position: )rrrrrrrrY)r.r; expression used_tokenss rrEzExprParser.exprsZZ( hh  ! !#dkk"2Q"6 E 1 K T[[) )%dkk$((*&=%>?++/88*6 rcVtd|jtjS)NzMysqlx.Crud.Columnr)rrrrr2s rparse_table_insert_fieldz#ExprParser.parse_table_insert_fields+$2D2DY__2UVVrc6|jjSr-)r rr2s rparse_table_update_fieldz#ExprParser.parse_table_update_fields%%'222rcg}|jjd}|j|r|j}|j d|j dk7sF|j d|j dk7s#|j d|j dk7r|jd|}|j d|j dk7r9|j d|j dk7r]|j d|j dk7r|j |j |r|S)Nrr5r6rrrr)rsplitrrcountrr)r.fieldstempfields r _table_fieldszExprParser._table_fieldss{{  % HHJE C EKK$44;;s#u{{3'77;;s#u{{3'7788:,aw/  C EKK$44;;s#u{{3'77;;s#u{{3'77 MM%++- ( rcVg}d}|j}|jt|jkr|s|j t j d}td|j}|jt jrB|j t j|j t j|d<n|t||d<|j|j|jt|jkr|S)NTFzMysqlx.Crud.Projection)sourcealias)rWrrrrrrrrrrrrrH)r. project_exprfirstrT projections rparse_table_select_projectionz(ExprParser.parse_table_select_projection%s ##%hhT[[))""9??3E !9$**,OJ%%ill3""9<<0&*&8&8&I 7#&,S->&? 7#    6 6 8 9hhT[[))rcg}d}|jt|jkr|s|jtj d}t d|j}|jtjr.td|d<|jtjnL|jtjr-td|d<|jtj|j|j|jt|jkr|S)NTFzMysqlx.Crud.Order)rEzMysqlx.Crud.Order.Direction.ASC directionz Mysqlx.Crud.Order.Direction.DESC)rrrrrrrrrrrrrrH)r. order_specsr\orders rparse_order_speczExprParser.parse_order_spec9s hhT[[))""9??3E/djjlCE%%i&;&;<%23T%Uk"""9#8#89'' (>(>?%23U%Vk"""9#9#9:   u002 3hhT[[))rc8g}d}|jt|jkrs|s|jtj d}|j |jj|jt|jkrs|S)NTF) rrrrrrrrrH)r. expr_listr\s rparse_expr_listzExprParser.parse_expr_listLsy hhT[[))""9??3E   TZZ\557 8 hhT[[)) r)T)r+N)F)Hrrrsrtrur8rSr/r1rr7rr'rrrrrrrrrrrrr rrrrrrrrrrr r r rrrrrrrrr! staticmethodr%r'rrr-r3r6r8r:r1r=rBrDrFrHrrErNrrPrWr^rcrfrrrrDrDs" s d d 66*"KK3K4K4c4e4"3Te.;C;E;:m^ 3 4 rls:QQQ1,[[| $$$$""!!)45 9==5),,5 9==5 ),, 5  9== 5  INN 5 ),,5 ""5 i5y  5 ""5 i5 INN5 9==5 9==5  9==!5" INN#5$ Y__%5& INN'5( i)5* i+5, INN-5. 9==/50 INN152 Y__354y  556 INN7589((95: 9 ;5< I " "=5> ),,?5@ iA5B ""C5D INNE5F INNG5H INNI5Jy  K5L iM5N ""O5Py  Q5R INNS5T)66U5V)66W5XY,,Y5Z 22[5\9((]5^9((_5`y00a5b)&&c5d)&&e5f ""g5h)&&i5p NN NN NN   NN"" )%""$" 4" 5 "  $ "  $ " 5" 5"" $"y" $" F" $" $" !"" $#"$%"& $'"()"* $+",-". $/"0 $1"23"45"67"89":;"<="> F?"@yA"B C" J         $$0n$ >( >[ > eD%K( [ x/K ; uCKS[zkTke kk[[%3%3%bbr