fume-manage-python.git

U  
¤ý°d÷Âã5@sRdZddlmZmZmZmZmZmZmZm    Z    ddl
mZddlm Z mZddlmZmZddlmZmZmZmZmZmZGdd    d    Zeejejejejejej ej!ej"ej#ej$ej%ej&ej'ej(ej)ej*ej+ej,ej-ej.gZ/ej0ej1ej2ej3ej4ej5ej6ej7ej8ej9ej:ej;ej<ej=ej>ej?ej@ejAejBejejejejej ej!ej"ej#ejejCejDejEejFejGejHejIejJejKejLejMejNejOej$ej%ej&ej'ej(ej)ej*ej+ej,ej-ej.d
4ZPejFej<ejIejJejKejLejHejMdZQddd dddddddddddddddddd dddd d!d"d#d$d%d&d'd(d)!ZRd*d+d$dd,d-ZSd.d/d0d1d2d3d4d5ZTGd6d7d7ZUeed8d9d:ZVeed8d;d<ZWe    eefed=d>d?ZXeeed@dAdBZYedCdDdEZZe[ed8dFdGZ\e]ed8dHdIZ^e]ed8dJdKZ_eed8dLdMZ`eaed8dNdOZbeced8dPdQZdeed8dRdSZeefeedTdUdVZgefefdWdXdYZhGdZd[d[Zid\S)]zExpression Parser.é)ÚAnyÚCallableÚDictÚIterableÚListÚOptionalÚSequenceÚUnioné)ÚDbDoc)Ú
BYTE_TYPESÚget_item_or_attr©ÚMessageÚ mysqlxpb_enum)ÚBuildExprTypesÚBuildScalarTypesÚMessageTypeÚProtobufMessageCextTypeÚProtobufMessageTypeÚ
StrOrBytesc@steZdZdZdZdZdZdZdZdZ    dZ
d    Zd
ZdZ dZd 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:Z<d;Z=d<Z>d=Z?d>Z@d?ZAd@ZBdAZCdBZDdCZEdDZFdEZGdFZHdGZIdHZJdIZKdJZLdKZMdLZNdMZOdNZPdOZQdPZRdQZSdRZTdSZUdTZVdUZWdVZXdWZYdXZZdYZ[dZZ\d[S)\Ú    TokenTypezToken types class.r
éééééééé    é
ééé ééééééééééééééééééé é!é"é#é$é%é&é'é(é)é*é+é,é-é.é/é0é1é2é3é4é5é6é7é8é9é:é;é<é=é>é?é@éAéBéCéDéEéFéGéHéIéJéKéLéMéNéOéPéQéRéSéTéUéVéWéXéYN)]Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚNOTÚANDÚORÚXORÚISÚLPARENÚRPARENÚ
LSQBRACKETÚ
RSQBRACKETÚBETWEENÚTRUEÚNULLÚFALSEÚINÚLIKEÚINTERVALÚREGEXPÚESCAPEÚIDENTÚLSTRINGÚLNUMÚDOTÚDOLLARÚCOMMAÚEQÚNEÚGTÚGEÚLTÚLEÚBITANDÚBITORÚBITXORÚLSHIFTÚRSHIFTÚPLUSÚMINUSÚMULÚDIVÚHEXÚBINÚNEGÚBANGÚMICROSECONDÚSECONDÚMINUTEÚHOURÚDAYÚWEEKÚMONTHÚQUARTERÚYEARÚEROTEMEÚ
DOUBLESTARÚMODÚCOLONÚORORÚANDANDÚLCURLYÚRCURLYÚCASTÚDOTSTARÚORDERBY_ASCÚORDERBY_DESCÚASÚARROWÚQUOTEÚBINARYÚDATETIMEÚTIMEÚCHARÚDATEÚDECIMALÚSIGNEDÚINTEGERÚUNSIGNEDÚJSONÚSECOND_MICROSECONDÚMINUTE_MICROSECONDÚ MINUTE_SECONDÚHOUR_MICROSECONDÚHOUR_SECONDÚHOUR_MINUTEÚDAY_MICROSECONDÚ
DAY_SECONDÚ
DAY_MINUTEÚDAY_HOURÚ
YEAR_MONTHÚOVERLAPS©rÍrÍúBd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysqlx/expr.pyr/s´r)4ÚandÚorÚxorÚisÚnotÚlikeÚinÚoverlapsÚregexpÚbetweenÚintervalÚescapeÚcastÚdivÚhexÚbinÚtrueÚfalseÚnullÚsecondÚminuteÚhourÚdayÚweekÚmonthZquarterÚyearÚmicrosecondZascÚdescÚasÚbinaryÚdatetimeÚtimeÚcharÚdateÚdecimalÚsignedÚunsignedÚintegerÚjsonZsecond_microsecondZminute_microsecondZ minute_secondZhour_microsecondZhour_secondZhour_minuteZday_microsecondZ
day_secondZ
day_minuteZday_hourZ
year_month)rìrÛrïrðrñròrîróú==ú&&rÜú||rÓrÑú^rÒrØrÕrÔú!=ú>ú>=ú<ú<=ú&ú|ú<<ú>>ú+ú-Ú*ú/ú~ú%rÛÚcont_inrÖ)!ú=rörÏrÜrørÐrÓrÑrùrÒrØrÕrÔrúú<>rûrürýrþrÿr÷rrrrrrrrrrÛr    rÖZ    sign_plusZ
sign_minusú!)rrrrÓrÚis_notZnot_betweenZ
not_regexpZnot_likeZnot_inZnot_cont_inZnot_overlaps)rÒrØr×rÔrÕr    rÖc@sBeZdZdZdeeeddddZeddd    Zedd
dZdS) ÚTokenzToken representation class.r
N)Ú
token_typeÚvalueÚlengthÚreturncCs||_||_||_dS©N)rrr)ÚselfrrrrÍrÍrÎÚ__init__#szToken.__init__©rcCs| ¡Sr)Ú__str__©rrÍrÍrÎÚ__repr__(szToken.__repr__cCs2|jtjtjtjfkr*|jd|jdS|jS)Nú(ú))rrrrrrrrÍrÍrÎr+sýz Token.__str__)r
)    rprqrrrsÚintÚstrrrrrÍrÍrÍrÎr sr)rrcCs¤td}t|tr|St|tr,|jddSt|ttfrXtd|d<t| ¡|d<nHt|t    t
frtd|d<t| ¡|d<ntd    |d<t| ¡|d
<|S)NúMysqlx.Expr.ExprT)ÚreparseúMysqlx.Expr.Expr.Type.OBJECTÚtypeÚobjectúMysqlx.Expr.Expr.Type.ARRAYÚarrayúMysqlx.Expr.Expr.Type.LITERALÚliteral) rÚ
isinstanceÚ
ExprParserÚexprÚdictrrÚbuild_objectÚget_messageÚlistÚtupleÚbuild_arrayÚbuild_scalar©rÚmsgrÍrÍrÎÚ
build_expr8s
 
r3cCs~t|trt|St|tr$t|St|tr6t|St|trHt|St|t    rZt
|S|dkrhtStdt |dS)NzUnsupported data type: )r'rÚbuild_string_scalarrÚbuild_bytes_scalarÚboolÚbuild_bool_scalarrÚbuild_int_scalarÚfloatÚbuild_double_scalarÚbuild_null_scalarÚ
ValueErrorr!©rrÍrÍrÎr0Js
 
 
 
 
r0)ÚobjrcCsxt|trt|jStd}| ¡D]N\}}td}t|trF| ¡n||d<t|     ¡|d<|d 
|     ¡g¡q$|S)NúMysqlx.Expr.ObjectúMysqlx.Expr.Object.ObjectFieldÚkeyrÚfld)r'rr+Ú__dict__rÚitemsrÚencoder3r,Úextend)r>r2rArÚpairrÍrÍrÎr+Zs
 
r+)r$rcCs$td}|d dd|D¡|S)NúMysqlx.Expr.ArrayrcSsg|]}t| ¡qSrÍ)r3r,)Ú.0rrÍrÍrÎÚ
<listcomp>iszbuild_array.<locals>.<listcomp>)rrF)r$r2rÍrÍrÎr/gsr/rcCstd}td|d<|S)NúMysqlx.Datatypes.Scalarz#Mysqlx.Datatypes.Scalar.Type.V_NULLr!r©r2rÍrÍrÎr;msr;cCs td}td|d<||d<|S)NrKz%Mysqlx.Datatypes.Scalar.Type.V_DOUBLEr!Zv_doublerr1rÍrÍrÎr:ssr:cCs td}td|d<||d<|S)NrKz#Mysqlx.Datatypes.Scalar.Type.V_SINTr!Zv_signed_intrr1rÍrÍrÎr8zsr8cCs td}td|d<||d<|S)NrKz#Mysqlx.Datatypes.Scalar.Type.V_UINTr!Zv_unsigned_intrr1rÍrÍrÎÚbuild_unsigned_int_scalarsrMcCs@t|trtt|d}td}td|d<td|d|d<|S)Nzutf-8rKz%Mysqlx.Datatypes.Scalar.Type.V_STRINGr!zMysqlx.Datatypes.Scalar.Stringr=Zv_string)r'rÚbytesÚ    bytearrayrrr1rÍrÍrÎr4s
r4cCs td}td|d<||d<|S)NrKz#Mysqlx.Datatypes.Scalar.Type.V_BOOLr!Zv_boolrr1rÍrÍrÎr7sr7cCs(td}td|d<td|d|d<|S)NrKz%Mysqlx.Datatypes.Scalar.Type.V_OCTETSr!zMysqlx.Datatypes.Scalar.Octetsr=Zv_octetsrr1rÍrÍrÎr5sr5cCs td}td|d<||d<|S)Nrr%r!r&rr1rÍrÍrÎÚbuild_literal_exprsrP)ÚnameÚparamrcCsFtd}t||d<| ¡g|d<td}td|d<| ¡|d<|S)NúMysqlx.Expr.OperatorrQrRrúMysqlx.Expr.Expr.Type.OPERATORr!Úoperator)rÚ_UNARY_OPERATORSr,r)rQrRrUr2rÍrÍrÎÚbuild_unary_op¦srW)ÚstringrcCs| dd¡S)Nú"z"")Úreplace©rXrÍrÍrÎÚescape_literal°sr\c@seZdZdZd~eeddddZeddd    Zddd
dZe    eedd dZ
e    edddZde    eedddZ e    edddZddddZe    ddddZe    edddZe    ed d!d"Ze    edd#d$Ze    ed d%d&Ze    e    ed'd(d)Ze    edd*d+Zeeeefdd,d-Zedd.d/Zedd0d1Zedd2d3Zedd4d5Z edd6d7Z!eeeefdd8d9Z"edd:d;Z#edd<d=Z$e    ddd>d?Z%edd@dAZ&eddBdCZ'eddDdEZ(eddFdGZ)eedHdIdJZ*eddKdLZ+eddMdNZ,dee-edOdPdQZ.e/eddRdSZ0eddTdUZ1e2e    e3gefedVdWdXZ4eddYdZZ5edd[d\Z6edd]d^Z7edd_d`Z8eddadbZ9eddcddZ:eddedfZ;eddgdhZ<eddidjZ=eddkdlZ>deedmdndoZ?deedmdpdqZ@eddrdsZAeBddtduZCeeddvdwZDeeeefddxdyZEeeeefddzd{ZFeeeefdd|d}ZGdS)r(zExpression parser class.TN)rXÚallow_relationalrcCs>||_g|_g|_d|_||_i|_d|_| ¡| ¡dS©Nr)    rXÚtokensÚpath_name_queueÚposÚ_allow_relational_columnsÚplaceholder_name_to_positionÚpositional_placeholder_countÚclean_expressionÚlex)rrXr]rÍrÍrÎr·szExprParser.__init__rcCsd|jdS)Nz<mysqlx.ExprParser 'z'>r[rrÍrÍrÎrÂszExprParser.__str__cCs¢t|jtst|j|_|j d¡|_t|jdkrR|jddkrR|jdd|_d|jdd ¡krx|jdd|_d|jdd     ¡kr|jd    d|_dS)
zµRemoves 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
éÿÿÿÿú;NZSELECTrZWHEREr)r'rXrÚreprÚstripÚlenÚupperrrÍrÍrÎreÅszExprParser.clean_expression)rArïrcCs$|dt|jko"|j|d|kS©Nr
)rlrX)rrArïrÍrÍrÎÚnext_char_isÖszExprParser.next_char_is)rarcCs~|}d}|t|jkr^|j| ¡s2|j|dkr^|j|dkrT|dkrPtdd}|d7}q|j||}ttj|t|S)NFÚ.Tz"Invalid number. Found multiple '.'r
)rlrXÚisdigitr<rrr)rraÚstartZ    found_dotÚvalrÍrÍrÎÚ
lex_numberÙsÿÿ
zExprParser.lex_numberF)ÚiÚallow_spacercCsà|}|t|jkrJ|j| ¡s@|j|dks@|j| ¡rJ|rJ|d7}q|j||}z\|t|jkr|j|dkr| ¡tkrttj|t|}ntt    | ¡| ¡t|}Wn&t
k
rÚttj|t|}YnX|S)NÚ_r
r)rlrXÚisalnumÚisspaceÚlowerÚ%_SQL_FUNTION_RESERVED_WORDS_COLLISIONrrrÚ_RESERVED_WORDSÚKeyError)rrurvrrrsÚtokenrÍrÍrÎÚ    lex_alphaês0ÿþýý
ÿþ
ý zExprParser.lex_alpha)rArcCs|j|}d}|d7}|}|t|jkrª|j|}||kr`|dt|jkr`|j|d|kr`qª||dfkr|dt|jkrqª|d7}||j|7}n||7}|d7}q|t|jksÆ|j||krÔtd||dkròttj|t|dSttj|t|dS)NÚr
ú\z'Unterminated quoted string starting at ú`r)rXrlr<rrrr)rrAÚ
quote_charrsrrrïrÍrÍrÎÚlex_quoted_tokens2
 
ÿþý
zExprParser.lex_quoted_tokencCsêd}d}d}|t|jkræ|j|}| ¡r8|d7}q| ¡rN| |¡}n| ¡s^|dkrn| ||¡}n`|dkrttj    |}nH|dkrttj
|}n0|dkr¶ttj|}n|dkrÎttj|}n|d    krættj |}nè|d
kr(| |d¡r|sttjdd }d}nttj|}n¦|dkr`| |d¡rPttjdd }nttj|}nn|dkrzttj|}nT|dkrttj|}n:|dkr®ttj|}n |dkrè| |d¡rÖttjdd }nttjdd}næ|dkr | |d¡rttjdd }nttj|}n®|dkr:ttj|}n|dkrr| |d¡rbttjdd }nttj|}n\|dkrttj|}nB|dkr¦ttj|}n(|dkrÀttj|}n|dkrÚttj|}nô|dkrôttj |}nÚ|d krttj!|}nÀ|d!krF| |d¡r6ttj"d"d }nttj#|}n|d#krº| |d¡rnttj"d$d }nH| |d#¡rttj$d%d }n*| |d¡rªttj%d&d }nttj&|}n|dkr| |d¡râttj'd'd }n*| |d¡rttj(d(d }nttj)|}nÀ|d)krx| |d¡r6ttj*d*d }n@|dt|jkrj|j|d ¡rj| |¡}nttj+|}nV|d+krª|rªttj,|}|s d}nd}d}n$|d,krÀ| -|¡}nt.d-||j/ 0|¡||j17}qdS).NrFr
rwú?ú:Ú{Ú}rrrûz->rTrz**rú$rr
rörÿr÷rùrrørrú[ú]rú,rrúrýrrrþrrürpz.*)ú'rY)rYrrzUnknown character at )2rlrXryrqrtÚisalpharrrr¨r«r®r¯rrorµrr©rrrrªrrrrr¬rryrzr{r|rrrrrrrrrrr±rr¶rr<r_Úappendr)rruZ
arrow_lastZinside_arrowrïr~rÍrÍrÎrfsÄ
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
(
zExprParser.lex)rrc    Csj|jt|jkr(td|d|jd|j|jj|krftd|d|jd|j|jd|jdS)NúExpected token type z at pos z but no tokens leftz but found type z, on tokens )rarlr_r<r©rrrÍrÍrÎÚassert_cur_tokensÿ&ÿzExprParser.assert_cur_tokencCs| |j|¡Sr©Úpos_token_type_israrrÍrÍrÎÚcur_token_type_isszExprParser.cur_token_type_is)ÚtypesrcGs"|jt|jko |j|jj|kSr©rarlr_r©rrrÍrÍrÎÚcur_token_type_inszExprParser.cur_token_type_incCs| |jd|¡SrnrrrÍrÍrÎÚnext_token_type_isszExprParser.next_token_type_iscGs&|jt|jko$|j|jdj|kSrnrrrÍrÍrÎÚnext_token_type_in¢sþzExprParser.next_token_type_in)rarrcCs|t|jko|j|j|kSr)rlr_r)rrarrÍrÍrÎr¨szExprParser.pos_token_type_iscCs*| |¡|j|jj}|jd7_|Srn)rr_rar)rrrrÍrÍrÎÚ consume_token«s
zExprParser.consume_tokencCsäg}d}| tj¡| tj¡sÆ| ¡ ¡}t|drV|jj    rV|j
 d|jj    ¡d}n8t|dsd|krd|dkr|j
 d|dd¡d}| |¡| tj ¡rÆ|jd7_| | ¡ ¡¡q| tj¡|rà|j
 ¡|S)z{Parse a paren-bounded expression list for function arguments or IN
        list and return a list of Expr objects.
        FÚ
identifierrTrQr
)rrryrrzÚ_exprr,ÚhasattrrrQr`ÚinsertrrraÚpop)rÚexprsZpath_name_addedÚmsg_exprrÍrÍrÎÚparen_expr_list±s0ÿþ
ý
 
zExprParser.paren_expr_listcCs`| tj¡td}| tj¡r<| tj¡|d<| tj¡|j|jj    |d<|jd7_|S)NzMysqlx.Expr.IdentifierÚschema_namerQr
)
rrrrrrrr_rar)rÚidentrÍrÍrÎrÏszExprParser.identifiercCsDtd}| ¡|d<| ¡|d<td}td|d<| ¡|d<|S)NzMysqlx.Expr.FunctionCallrQrRrzMysqlx.Expr.Expr.Type.FUNC_CALLr!Ú function_call)rrr¤rr,)rr§r£rÍrÍrÎr§ÙszExprParser.function_callcCs°| tj¡|j|j}|jtjkr`|j d¡rL|j     d¡rLt
|jd| tj¡|j}n0|jtjkr| tj¡|j}nt
d|jtd}t d|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)rrrr_rarrrÚ
startswithÚendswithr<rrr)rr~Úmember_nameÚ doc_path_itemrÍrÍrÎÚdocpath_memberâs*
ÿ
ÿÿzExprParser.docpath_membercCs¼| tj¡| tj¡rH| tj¡| tj¡td}td|d<|S| tj¡r¨t    | tj¡}|dkr|t
d|j| tj¡td}td|d<||d<|Std|jdS)    Nr¨z6Mysqlx.Expr.DocumentPathItem.Type.ARRAY_INDEX_ASTERISKr!rz"Array index cannot be negative at z-Mysqlx.Expr.DocumentPathItem.Type.ARRAY_INDEXÚindexzGException token type MUL or LNUM in JSON path array index at token pos ) rrr{rrr|rrrrÚ
IndexErrorrar<)rrrrÍrÍrÎÚdocpath_array_locüs.ÿÿ
ÿzExprParser.docpath_array_loccCs¸|jstd| tj¡r&| tj¡td}| tj¡rrtd}td|d<| tj¡|d<|d     | 
¡g¡|d     | ¡¡|jr|jd|d    <td
}td|d<||d<|S) Nz-Empty string cannot be used as document fieldúMysqlx.Expr.ColumnIdentifierr¨r©r!rÚ document_pathrrQrúMysqlx.Expr.Expr.Type.IDENTr) r_r<rrrrrrrrFr,r³r`)rÚcol_idrr)rÍrÍrÎÚdocument_fields&ÿzExprParser.document_fieldcCsþg}| tj¡r$| | ¡ ¡¡q| tj¡r`| tj¡td}t    d|d<| | ¡¡q| tj
¡r| | ¡ ¡¡q| tj¡rÀ| tj¡td}t    d|d<| | ¡¡qqÀqt |}|dkrút||ddt    dkrútd|j|S)z°Parse 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)
        r¨z1Mysqlx.Expr.DocumentPathItem.Type.MEMBER_ASTERISKr!z1Mysqlx.Expr.DocumentPathItem.Type.DOUBLE_ASTERISKrr
z!JSON path may not end in '**' at )rrrrr®r,r±rrrr{r±r©rlr r<ra)rZdoc_pathrrDrÍrÍrÎr³+s4ÿÿÿzExprParser.document_pathcCsÂg}| | tj¡¡| tj¡rB| tj¡| | tj¡¡qt|dkr^td|j|     ¡t
d}tdt|D]D}|dkr|d|d<q||dkr¬|d|d<q||dkr||d|d    <q|d
}| tj¡rðd}| tj¡|  ¡|d<nj| tj¡rZd}| tj¡d
}| tj¡r0d}| tj¡| tj¡|  ¡|d<|rZ| tj¡|r¢t|ddkr¢t
d }td|d<d|d<|d | ¡g¡t
d}td|d<||d<|S)Nrz Too many parts to identifier at r²rrQr
Z
table_namerr¥FTr³r¨r©r!rrrr´r)rrrrrrrlr<raÚreverserÚrangerr³rµr¶rrFr,)rÚpartsrµruZis_docZ    is_quotedrr£rÍrÍrÎÚcolumn_identifierOsVÿzExprParser.column_identifiercCs6|jt|jkrtd|j|j}|jd7_|S)NzUnexpected end of token streamr
)rarlr_r<)rr~rÍrÍrÎÚ
next_tokens
zExprParser.next_tokencCs$| ¡}|j|kr td|dS)Nr)r»rr<)rrr~rÍrÍrÎÚexpect_tokens
zExprParser.expect_tokencCs|j|jSr)r_rarrÍrÍrÎÚ
peek_tokenszExprParser.peek_tokencCs |j|jj}|jd7_|Srn)r_rar)rrrÍrÍrÎÚconsume_any_tokenszExprParser.consume_any_tokencCstd}|jt|jkrX| tj¡sX|d | ¡     ¡g¡| tj
¡sJqX| tj
¡q| tj¡td}td|d<|     ¡|d<|S)zH
        jsonArray            ::=  "[" [ expr ("," expr)* ] "]"
        rHrrr#r!r$) rrarlr_rrr|rFrr,rrr)rr2r)rÍrÍrÎÚparse_json_arraysÿzExprParser.parse_json_arraycCs¸td}|jt|jkr| tj¡std}| tj¡|d<| tj    ¡| 
¡ ¡|d<|d | ¡g¡| tj ¡szq| tj ¡q| tj¡td}td|d<| ¡|d    <|S)
z
        jsonDoc              ::=  "{" [jsonKeyValue ("," jsonKeyValue)*] "}"
        jsonKeyValue         ::=  STRING_DQ ":" expr
        r?r@rArrBrr r!r")rrarlr_rrr¯rrr«rr,rFrr)rr2Úitemr)rÍrÍrÎÚparse_json_doc§s"ÿzExprParser.parse_json_doc)r~rcCs¶d}| tj¡r| tj¡}nB| tj¡r8| tj¡}n(|jtjkrPt|j}nt    d|j
td}td|d<||j kr|j ||d<n$|j|d<|j|j |<|jd7_|S)Nrz&Invalid placeholder name at token pos rz!Mysqlx.Expr.Expr.Type.PLACEHOLDERr!Úpositionr
)rrrrrrr¨rrdr<rarrrc)rr~Zplace_holder_namer£rÍrÍrÎÚparse_place_holder¿s&
 
þÿzExprParser.parse_place_holdercCstddd}| tj¡|d | ¡ ¡g¡| tj¡tt     
| ¡¡}|d t| ¡g¡| tj ¡td| ¡d}td|d<|S)    z2cast ::= CAST LPAREN expr AS cast_data_type RPARENrSrÛ©rQrRr©rUrTr!)rrrryrFrr,r´r5rrEÚcast_data_typerPrzr)rrUZtype_scalarr2rÍrÍrÎrÛÖszExprParser.castcCsâ| ¡}|jtjtjtjtjfkrB| ¡}|r<|j|S|jS|jtj    krp| d¡}|rj|j|S|jS|jtj
tjfkr | tj ¡r| tj ¡|jS|jtj tjtjfkr¼|jStd|jd|jd|jddS)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 (rN)r»rrr·rºr¸r¹Úcast_data_type_dimensionrr¼r½r¿rr¾rrÀr»r<ra)rr~Ú    dimensionrÍrÍrÎrÆäs2ü
ýÿzExprParser.cast_data_type)rñrcCs¢| tj¡sdSg}| tj¡| | tj¡¡|r`| tj¡r`| tj¡| | tj¡¡| tj¡t|dkrd|ddSd|dd|ddS)z*dimension ::= LPAREN LNUM (, LNUM)? RPARENNr
rrrr)    rrryrrrrrzrl)rrñrÈrÍrÍrÎrÇs
ÿýz#ExprParser.cast_data_type_dimensioncCs(td}td|d<tddd|d<|S)NrrTr!rSrrÄrUrrLrÍrÍrÎÚ star_operatorszExprParser.star_operatorcCsb| ¡}|jtjtjfkr$| |¡S|jtjkr8| ¡S|jtjkrL|     ¡S|jtj
kr`| ¡S|jtjkr|  ¡}| tj¡|S|jtjtjfkrØ| ¡}|jtjkrÈ|j|j|j|j_| ¡St|j| ¡S|jtjtjtjfkrþt|j| ¡S|jtjkrtt|jS|jtjkr2tt S|jtjkrpd|jkr^tt!t"|jStt#t$|jS|jtj%tj&fkrtt'|jtj%kS|jtj(kr®| )¡S|jtj*krÄ| +¡S|jtj,krF|jd|_| -tj¡s&| -tj.¡r.| /|jdtj,¡r.| /|jdtj¡r.| 0¡S|j1s>| )¡S| 2¡St3d|jd|jdS)z<Parse an atomic expression and return a protobuf Expr objectrpr
rrzUnknown token type = z&  when expecting atomic expression at N)4r»rrr¨r«rÃr®rÁr{r¿r°rÛryrr¼rzrrr½rrr_raÚatomic_exprrWrtrrrrPr4rr;r:r9r8rr~rr7rr¶rrÉrrrrr§rbrºr<)rr~r)ÚpeekrÍrÍrÎrÊ%sl
 
ÿ
ÿþýÿýÿzExprParser.atomic_expr)rÚinner_parserrcCs|}|jt|jkr|j|jj|krtd}td|d<td}t|j|jj|d<| ¡g|d<|jd7_|d     | ¡g¡||d<|}q|S)    z}Given a `set' of types and an Expr-returning inner parser function,
        parse a left associate binary operator expressionrrTr!rSrQrRr
rU)
rarlr_rrrÚ
_OPERATORSrr,rF)rrrÌÚlhsr2rUrÍrÍrÎÚparse_left_assoc_binary_op_expras"z*ExprParser.parse_left_assoc_binary_op_exprcCsè| ¡}| tjtj¡rä| tj¡rä| ¡}td}|d     | 
¡g¡|jtjkrXdnd|d<| tj¡|d     |  ¡ 
¡g¡|jtstd|jt | ¡ ¡¡}|d     tt| 
¡g¡td|d}td    |d
<|S)NrSrRZdate_addZdate_subrQz#Expected interval type at position rrÅrTr!)rÊrrrrrrr»rrFr,rrÚbit_exprÚ_INTERVAL_UNITSr<rarrEr¾rmrPr5r)rrÎr~rUrÍrÍrÎÚadd_sub_intervalts.ÿ
þÿ
ÿzExprParser.add_sub_intervalcCs| ttjtjtjg|j¡Sr)rÏÚsetrrrrªrÒrrÍrÍrÎÚmul_div_exprsþzExprParser.mul_div_exprcCs| ttjtjg|j¡Sr)rÏrÓrrrrÔrrÍrÍrÎÚadd_sub_exprsÿzExprParser.add_sub_exprcCs| ttjtjg|j¡Sr)rÏrÓrrrrÕrrÍrÍrÎÚ
shift_exprsÿzExprParser.shift_exprcCs| ttjtjtjg|j¡Sr)rÏrÓrrrrrÖrrÍrÍrÎrÐ¡sþzExprParser.bit_exprc    Cs*| ttjtjtjtjtjtjg|j    ¡Sr)
rÏrÓrrrrrrrrÐrrÍrÍrÎÚ    comp_expr§súÿ
õzExprParser.comp_exprcCsbg}| ¡}d}| tj¡r,d}| tj¡|jt|jkr^| |     ¡¡|j|jj
}| tj¡r¤| tj¡| tj¡rd}| tj¡| | ¡     ¡¡nj| tj¡rò| tj¡| tj ¡rØ| | ¡¡nd}| | ¡     ¡¡n| tj¡r | tj¡| | ¡     ¡¡nî| tj¡rz| tj¡| | ¡     ¡¡| tj¡r| tj¡| | ¡     ¡¡n| tj¡rÆ| tj¡| | ¡     ¡¡| tj¡| | ¡     ¡¡nH| tj¡rô| tj¡| | ¡     ¡¡n|r
td|jd}|r^td}|r*t|n||d<||d<td}td    |d
<|     ¡|d<|}|S)NFTr    zUnknown token after NOT as pos rSrQrRrrTr!rU)r×rrrtrrarlr_rr,rrxrryrFr¤rÌrrr}rurr<rÚ    _NEGATIONr)rÚparamsrÎr Zop_namerUr£rÍrÍrÎÚ    ilri_expr¶sdzExprParser.ilri_exprcCs| ttjtjg|j¡Sr)rÏrÓrrurrÚrrÍrÍrÎÚand_exprîsÿzExprParser.and_exprcCs| ttjg|j¡Sr)rÏrÓrrwrÛrrÍrÍrÎÚxor_exprószExprParser.xor_exprcCs| ttjtjg|j¡Sr)rÏrÓrrvr¬rÜrrÍrÍrÎÚor_exprösÿzExprParser.or_expr)rrcCs,|r$g|_d|_i|_d|_| ¡| ¡Sr^)r_rarcrdrfrÝ)rrrÍrÍrÎrûszExprParser._exprcCsd| |¡}|j}| t|jdtj¡r0|d7}|t|jkr`td|j|jdd|j|S)NrzUnused token types z" found in expression at position: )rrarrlr_rr´r<)rrZ
expressionZused_tokensrÍrÍrÎr)s
ÿzExprParser.exprcCstd| tj¡dS)NzMysqlx.Crud.ColumnrÄ)rrrrrrÍrÍrÎÚparse_table_insert_fieldsz#ExprParser.parse_table_insert_fieldcCs
| ¡jSr)rºrrrÍrÍrÎÚparse_table_update_fieldsz#ExprParser.parse_table_update_fieldcCsg}|j d¡}| ¡|r| ¡}| d¡| d¡ks`| d¡| d¡ks`| d¡| d¡krt| ¡d|}q$| | ¡¡q|S)Nrrrrrrr)rXÚsplitr·r¡Úcountrrk)rÚfieldsÚtempÚfieldrÍrÍrÎÚ _table_fieldssÿþýzExprParser._table_fieldscCsg}d}| ¡}|jt|jkr|s0| tj¡d}td| ¡d}|     tj
¡rn| tj
¡| tj¡|d<n|t||d<| |  ¡¡q|S)NTFzMysqlx.Crud.Projection)ÚsourceÚalias)rårarlr_rrrrrrr´rrr,)rZproject_exprÚfirstrâZ
projectionrÍrÍrÎÚparse_table_select_projection%sz(ExprParser.parse_table_select_projectioncCsg}d}|jt|jkr|s(| tj¡d}td| ¡d}| tj    ¡rbt
d|d<| tj    ¡n$| tj¡rt
d|d<| tj¡| |  ¡¡q|S)NTFzMysqlx.Crud.Order)r)zMysqlx.Crud.Order.Direction.ASCÚ    directionz Mysqlx.Crud.Order.Direction.DESC)rarlr_rrrrrrr²rr³rr,)rZorder_specsrèÚorderrÍrÍrÎÚparse_order_spec9szExprParser.parse_order_speccCsDg}d}|jt|jkr@|s(| tj¡d}| | ¡ ¡¡q|S)NTF)    rarlr_rrrrrr,)rZ    expr_listrèrÍrÍrÎÚparse_expr_listLszExprParser.parse_expr_list)T)F)F)F)F)Hrprqrrrsrr6rrrerrorrtrrrfrrrrrrrrr    rrr¤rrr§r®r±r¶r³rºr»r¼r½r¾r¿rÁrÃrÛrÆrrÇÚstaticmethodrÉrÊrrrÏrÒrÔrÕrÖrÐr×rÚrÛrÜrÝrr)rÞrrßrårérìrírÍrÍrÍrÎr(´soþ
    þ$1'=
þ8    þþþr(N)jrsÚtypingrrrrrrrr    ZdbdocrZhelpersrr ZprotobufrrrrrrrrrrrÓrr r¡r¢r£r¤r¥r¦r§rÁrÂrÃrÄrÅrÆrÇrÈrÉrÊrËrÑrurvrwrxrtrrrÌrr}rrr°rrrr~rrr²r³r´r·r¸r¹rºr»r¼r½r¿r¾rÀr|r{rÍrVrØrr3r0r+r/r;r9r:rr8rMr4r6r7rNr5rPrrWr\r(rÍrÍrÍrÎÚ<module>s6( ^ìÿÌ8øß%û    ù