o vi/@sddlmZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z m Z ddlmZddlmZmZmZmZddlmZmZmZmZmZmZmZmZddlmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%erej&d krrdd l'm(Z(ndd lm(Z(dd l)m*Z*m+Z+m,Z,d Z-d Z.edddZ/GdddZ0Gddde0Z1dddZ2dddZ3Gddde1Z4Gddde4Z5Gd d!d!e4Z6Gd"d#d#e5Z7Gd$d%d%e5Z8Gd&d'd'e5Z9Gd(d)d)e6Z:Gd*d+d+e6Z;Gd,d-d-e1ZGd2d3d3e1Z?Gd4d5d5e1Z@Gd6d7d7e1ZAGd8d9d9eAZBGd:d;d;eAZCGdd?d?eDZEGd@dAdAeDe?ZFGdBdCdCe1ZGGdDdEdEeFZHGdFdGdGeDZIGdHdIdIeIZJGdJdKdKeIZKGdLdMdMeDZLGdNdOdOeDZMGdPdQdQeDZNGdRdSdSeDZOGdTdUdUeDZPGdVdWdWePZQGdXdYdYePZRGdZd[d[eDZSGd\d]d]eDZTGd^d_d_eDZUGd`dadaeUZVGdbdcdceMZWGdddedee1ZXGdfdgdgeDZYGdhdidieDZZGdjdkdkeDZ[GdldmdmZ\GdndodoeDZ]Gdpdqdqe]Z^Gdrdsdse^Z_edtdudZ`Gdvdwdwe_ZaGdxdydye_ZbGdzd{d{e1ZcGd|d}d}e]ZdGd~dde]ZeGddde]ZfGddde1ZgGddde1ZhdS)) annotationsN)CallableIterableIteratorSequence)datedatetimetime)Enum) TYPE_CHECKINGAnyTypeVaroverload) ArithmeticBoolean ComparatorDialectsEquality JSONOperatorsMatchingOrder) CaseExceptionFunctionExceptionbuilderformat_alias_sql format_quotes ignore_copyresolve_is_aggregate) )Self) QueryBuilder SelectableTablez Timothy Heysztheys@kayak.comNodeTNode)boundc@s$eZdZdZd ddZd d d ZdS) r%NreturnIterator[NodeT]ccs |VdSNselfr*r*K/home/air/biblejyuku/back/venv/lib/python3.10/site-packages/pypika/terms.pynodes_)s z Node.nodes_type type[NodeT] list[NodeT]csfdd|DS)Ncsg|] }t|r|qSr*) isinstance).0noder/r*r- -zNode.find_..)r.)r,r/r*r5r-find_,z Node.find_r'r()r/r0r'r1)__name__ __module__ __qualname__ is_aggregater.r8r*r*r*r-r%& c@seZdZdZddddZedd d Zedd dZdddZ e ddddZ e ddddZ ddd Z dd$d%Zdd'd(Zdd*d+Zdd-d.Zdd2d3Zdd5d6Zdd7d8Zdd9d:Zdd;d<Zdd=d>Zdd?d@ZddBdCZddDdEZddFdGZddHdIZddJdKZddLdMZddOdPZddQdRZ ddVdWZ!dd[d\Z"dd]d^Z#dd`daZ$ddedfZ%ddgdhZ&ddidjZ'ddkdlZ(ddndoZ)ddpdqZ*ddrdsZ+ddtduZ,ddwdxZ-ddydzZ.dd{d|Z/dd}d~Z0dddZ1dddZ2dddZ3dddZ4dddZ5dddZ6dddZ7dddZ8dddZ9dddZ:dddZ;dddZdddZ?dddZ@dddZAdddZBdddZCdddZDdddZEdS)TermFNalias str | Noner'NonecC ||_dSr)rAr,rAr*r*r-__init__3 z Term.__init__strcCrDr)rErFr*r*r-as_6 zTerm.as_ set[Table]cCsddlm}t||S)Nrr#)pypikar#setr8)r,r#r*r*r-tables_:s z Term.tables_ set[Field]cCst|tSr))rOr8Fieldr+r*r*r-fields_@z Term.fields_ wrapper_clstype[Term] | None@ValueError | NodeT | LiteralValue | Array | Tuple | ValueWrappercCsPt|tr|S|durtSt|trt|St|tr t|S|p#t}||S)a, Used for wrapping raw inputs such as numbers in Criterions and Operator. For example, the expression F('abc')+1 stores the integer part in a ValueWrapper object. :param val: Any value. :param wrapper_cls: A pypika class which wraps a constant value so it can be handled as a component of the query. :return: Raw string, number, or decimal values will be returned in a ValueWrapper. Fields and other parts of the querybuilder will be returned as inputted. N)r2r% NullValuelistArraytupleTuple ValueWrapper)valrUr*r*r- wrap_constantCs   zTerm.wrap_constantr^-Term | QueryBuilder | None | str | int | bool5Term | QueryBuilder | NullValue | ValueWrapper | JSONcCsTddlm}t|t|fr|S|durtSt|tttfr&|p!t}||St |S)N)r!) queriesr!r2r@rXrIintboolr]JSON)r^rUr!r*r*r- wrap_jsoncs zTerm.wrap_json current_table Table | None new_tablecC|S)a Replaces all occurrences of the specified table with the new table. Useful when reusing fields across queries. The base implementation returns self because not all terms have a table property. :param current_table: The table to be replaced. :param new_table: The table to replace with. :return: Self. r*r,rhrjr*r*r- replace_tabless zTerm.replace_tableotherr BasicCriterioncCs||kSr)r*r,rnr*r*r-eqzTerm.eq NullCriterioncCt|Sr))rsr+r*r*r-isnullrrz Term.isnullNotcCs |Sr))runegater+r*r*r-notnull z Term.notnullNotNullCriterioncCrtr))rzr+r*r*r- isnotnullrrzTerm.isnotnullvaluerdBitwiseAndCriterioncCt|||Sr))r}r_r,r|r*r*r- bitwiseandzTerm.bitwiseandBitwiseOrCriterioncCr~r))rr_rr*r*r- bitwiseorrzTerm.bitwiseorcCs||kSr)r*rpr*r*r-gtrrzTerm.gtcCs||kSr)r*rpr*r*r-gterrzTerm.gtecCs||kSr)r*rpr*r*r-ltrrzTerm.ltcCs||kSr)r*rpr*r*r-lterrzTerm.ltecCs||kSr)r*rpr*r*r-nerrzTerm.neexprcCttj|||Sr))rorglobr_r,rr*r*r-rz Term.globcCrr))rorliker_rr*r*r-rrz Term.likecCrr))rornot_liker_rr*r*r-rrz Term.not_likecCrr))roriliker_rr*r*r-rrz Term.ilikecCrr))ror not_iliker_rr*r*r-rrzTerm.not_ilikecCrr))rorrliker_rr*r*r-rrz Term.rlikepatterncCrr))rorregexr_r,rr*r*r-rrz Term.regexcCrr))rorregexpr_rr*r*r-rrz Term.regexplowerupperBetweenCriterioncCt|||||Sr))rr_r,rrr*r*r-betweenz Term.betweenstartendPeriodCriterioncCrr))rr_)r,rrr*r*r-from_torz Term.from_tocCrr))roras_ofr_rr*r*r-rrz Term.as_ofAllcCrtr))rr+r*r*r-all_rrz Term.all_arg%list | tuple | set | frozenset | TermContainsCriterioncs8t|ttttfrttfdd|DSt|S)Ncg|]}|qSr*r_r3r|r+r*r-r6zTerm.isin..)r2rYr[rO frozensetrr\r,rr*r+r-isins z Term.isincCs||Sr))rrwrr*r*r-notinrTz Term.notincCrr))ror bin_regexr_rr*r*r-rrzTerm.bin_regexcCrtr)rvr+r*r*r-rwrrz Term.negateArithmeticExpressioncCs||>Sr)r*rpr*r*r-lshiftrrz Term.lshiftcCs||?Sr)r*rpr*r*r-rshiftrrz Term.rshiftcCrtr)rr+r*r*r- __invert__rrzTerm.__invert__cCrkr)r*r+r*r*r-__pos__z Term.__pos__NegativecCrtr))rr+r*r*r-__neg__rrz Term.__neg__cCrr)rraddr_rpr*r*r-__add__rz Term.__add__cCrr)rrsubr_rpr*r*r-__sub__rz Term.__sub__cCrr)rrmulr_rpr*r*r-__mul__rz Term.__mul__cCrr)rrdivr_rpr*r*r- __truediv__rzTerm.__truediv__PowcC t||Sr))rrpr*r*r-__pow__rHz Term.__pow__ModcCrr))rrpr*r*r-__mod__rHz Term.__mod__cCttj|||Sr)rrpr*r*r-__radd__rz Term.__radd__cCrr)rrpr*r*r-__rsub__rz Term.__rsub__cCrr)rrpr*r*r-__rmul__rz Term.__rmul__cCrr)rrpr*r*r- __rtruediv__rzTerm.__rtruediv__cCrr)rrrr_rpr*r*r- __lshift__rzTerm.__lshift__cCrr)rrrr_rpr*r*r- __rshift__rzTerm.__rshift__cCrr)rrpr*r*r- __rlshift__rzTerm.__rlshift__cCrr)rrpr*r*r- __rrshift__ rzTerm.__rrshift__cCrr))rorrqr_rpr*r*r-__eq__ rz Term.__eq__cCrr))rorrr_rpr*r*r-__ne__rz Term.__ne__cCrr))rorrr_rpr*r*r-__gt__rz Term.__gt__cCrr))rorrr_rpr*r*r-__ge__rz Term.__ge__cCrr))rorrr_rpr*r*r-__lt__rz Term.__lt__cCrr))rorrr_rpr*r*r-__le__rz Term.__le__itemslicecCs"t|ts td||j|jS)Nz"Field' object is not subscriptable)r2r TypeErrorrrstop)r,rr*r*r- __getitem__s zTerm.__getitem__cCs|jdddS)N"' quote_charsecondary_quote_charget_sqlr+r*r*r-__str__$rTz Term.__str__cCst|jdddS)NT) with_aliaswith_namespace)hashrr+r*r*r-__hash__'z Term.__hash__kwargscKtr)NotImplementedErrorr,rr*r*r-r*z Term.get_sqlr)rArBr'rC)rArIr'rC)r'rLr'rQ)rUrVr'rW)r^r`r'ra)rhrirjrir'r@rnr r'ro)r'rs)r'rv)r'rz)r|rdr'r})r|rdr'r)rrIr'ro)rrIr'ro)rr rr r'r)rr rr r'r)r'r)rrr'r)rnr r'r)r'r@)r'r)rnr r'r)rnr r'r)rrr'rr'rI)r'rdrr r'rI)Fr;r<r=r>rGrrJpropertyrPrS staticmethodr_rgrmrqrurxr{rrrrrrrrrrrrrrrrrrrrrrrwrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr*r*r*r-r@0s                                                            r@idxrdr'rIcCs t|dSNrbrIrr*r*r-idx_placeholder_gen.ryrcCsd|dS)Nparamrbr*rr*r*r-named_placeholder_gen2rTrcsLeZdZdZdfdd Zedd Zdd dZdddZdddZ Z S) ParameterN placeholder str | intr'rCct||_dSr))superrG _placeholderr,r __class__r*r-rG9  zParameter.__init__cC|jSr))rr+r*r*r-r=szParameter.placeholderrr rIcKs t|jSr))rIrrr*r*r-rArHzParameter.get_sql param_key param_valuecKdSr)r*)r,r rrr*r*r-update_parametersDrzParameter.update_parameterscK|Sr)r*r,rrr*r*r- get_param_keyGrzParameter.get_param_key)rrr'rCr)r r rr rr ) r;r<r=r>rGrrrrr __classcell__r*r*r r-r6s   rcsBeZdZefdfdd Zeddd Zd d ZdddZZ S) ListParameterr str | int | Callable[[int], str]r'rCctj|dt|_dSNr)rrGrY _parametersrr r*r-rGL zListParameter.__init__rIcC$t|jr |t|jSt|jSr)callablerlenrrIr+r*r*r-rP  zListParameter.placeholdercKr r)rrr*r*r-get_parametersWrzListParameter.get_parametersr|r cKs|j|dSr))rappendr,r|rr*r*r-rZrzListParameter.update_parametersrrr'rCrr|r ) r;r<r=rrGrrr#rrr*r*r r-rKs  rcsLeZdZefdfdd Zeddd Zd d Zdd dZdddZ Z S) DictParameterrrr'rCcrr)rrGdictrrr r*r-rG_rzDictParameter.__init__rIcCrr)rr+r*r*r-rcr!zDictParameter.placeholdercKr r)r"rr*r*r-r#jrzDictParameter.get_parametersr cKs |ddSrr*rr*r*r-rmryzDictParameter.get_param_keyr r|cKs||j|<dSr)r")r,r r|rr*r*r-rprTzDictParameter.update_parametersr&rr)r r r|r ) r;r<r=rrGrrr#rrrr*r*r r-r(^s  r(c@seZdZddZdS)QmarkParametercKdS)N?r*rr*r*r-rurzQmarkParameter.get_sqlNr;r<r=rr*r*r*r-r*ts r*c@eZdZdZd ddZdS) NumericParameterz0Numeric, positional style, e.g. ...WHERE name=:1rr r'rIcKdj|jdSNz:{placeholder}rformatrrr*r*r-r|rTzNumericParameter.get_sqlNrr;r<r=__doc__rr*r*r*r-r/yr/c@r.) FormatParameterz1ANSI C printf format codes, e.g. ...WHERE name=%srr r'rIcKr+)Nz%sr*rr*r*r-rrzFormatParameter.get_sqlNrr4r*r*r*r-r7r6r7c@r.) NamedParameterz%Named style, e.g. ...WHERE name=:namerr r'rIcKr0r1r2rr*r*r-rrTzNamedParameter.get_sqlNrr4r*r*r*r-r8r6r8c@s$eZdZdZd ddZd d d Zd S)PyformatParameterz9Python extended format codes, e.g. ...WHERE name=%(name)srr r'rIcKr0)Nz%({placeholder})srr2rr*r*r-rrTzPyformatParameter.get_sqlrcKs |ddS)Nr*rr*r*r-rryzPyformatParameter.get_param_keyNrr)r;r<r=r5rrr*r*r*r-r9r?r9cs6eZdZdfdd Zeddd Zdd dZZS)rtermr@r'rCcrr)rrGr<r,r<r r*r-rGr zNegative.__init__ bool | NonecC|jjSr)r<r>r+r*r*r-r>zNegative.is_aggregaterr rIcKsdj|jjdi|dS)Nz-{term}r<r*)r3r<rrr*r*r-rszNegative.get_sql)r<r@r'rCr'r?r)r;r<r=rGrr>rrr*r*r r-r  rcsXeZdZdZddfdd Zdd d ZedddZdddZ   dd ddZ Z S)!r]Nr|r rArBr'rCct|||_dSr)rrGr|r,r|rAr r*r-rG  zValueWrapper.__init__rrIcKs|j|jfi|Sr))get_formatted_valuer|rr*r*r- get_value_sqlrzValueWrapper.get_value_sqlcKs|dpd}t|tr|jdi|St|tr#|j|jfi|St|ttt fr6|j| fi|St|t r@t ||St|t rLt t |St|tjr]|jt |fi|S|durcdSt |S)Nrnullr*)getr2r@rr rJr|rrr isoformatrIrreruuidUUID)clsr|rrr*r*r-rJs       z ValueWrapper.get_formatted_value parameterrtuple[str, str]cKs$|jdi|}|j|d}||fSNrr*)rrr,rSr param_sqlr r*r*r-_get_param_datas zValueWrapper._get_param_datarrrc Ks|dur|jd||d|}t||jfd|i|St|jttfr'|j}n |jdd|i|}|j|fi|\}}|jd||d|t||jfd|i|S)Nrr)r r|r*) rKrrAr2r|rdfloatrXr) r,rrrSrsql value_sqlrWr r*r*r-rszValueWrapper.get_sqlr)r|r rArBr'rCrr'rSrr'rT)NrN) rrBrrIrSrrr r'rI) r;r<r=r>rGrK classmethodrJrXrrr*r*r r-r]s   r]cs*eZdZddfd d Zdd dZZS)ParameterValueWrapperNrSrr|r rArBr'rCcst||||_dSr))rrG _parameter)r,rSr|rAr r*r-rG zParameterValueWrapper.__init__rTcKs(|jjdi|}|jj|d}||fSrU)r`rrrVr*r*r-rXsz%ParameterValueWrapper._get_param_datar))rSrr|r rArBr'rCr])r;r<r=rGrXrr*r*r r-r_r_cseZdZdZd4d5fdd Zd6d d Zd7ddZd8ddZed9d:ddZ d;dd$d%Z d>d&d'Zd?d)d*Zd?d+d,Zd?d-d.Zd@d0d1Zd@d2d3ZZS)ArfNr|r rArBr'rCcrFr)rGrHr r*r-rGrIz JSON.__init__rrIcKs\t|tr|j|fi|St|tr|j|fi|St|tr*|j|fi|St|Sr))r2r) _get_dict_sqlrY _get_list_sqlrI _get_str_sqlr%r*r*r-_recursive_get_sqls   zJSON._recursive_get_sqlr)c s.fdd|D}ddd|dgS)Ncs:g|]\}}djj|fij|fidqS)z {key}:{value})keyr|)r3rf)r3kvrr,r*r-r6s(z&JSON._get_dict_sql..rL{,})itemsjoinr,r|rpairsr*rjr-rcs zJSON._get_dict_sqlrYc s*fdd|D}ddd|dgS)Ncsg|] }j|fiqSr*)rf)r3rirjr*r-r6sz&JSON._get_list_sql..rL[rl])rorpr*rjr-rdszJSON._get_list_sqlrrcKrr))r)r|rrr*r*r-rerKzJSON._get_str_sqlrrcKs&t||j|}t||jfi|Sr))rrfr|rrA)r,rrrZr*r*r-r sz JSON.get_sql key_or_indexrrocCrr))rorGET_JSON_VALUEr_r,rtr*r*r-get_json_valuerzJSON.get_json_valuecCrr))rorGET_TEXT_VALUEr_rvr*r*r-get_text_valuerzJSON.get_text_value path_jsoncCrr))rorGET_PATH_JSON_VALUErgr,rzr*r*r-get_path_json_valuerzJSON.get_path_json_valuecCrr))rorGET_PATH_TEXT_VALUErgr|r*r*r-get_path_text_valuerzJSON.get_path_text_valuerncCrr))rorHAS_KEYrgrpr*r*r-has_keyrz JSON.has_keycCrr))rorCONTAINSrgrpr*r*r-containsrz JSON.containscCrr))ror CONTAINED_BYrgrpr*r*r- contained_by rzJSON.contained_byrcCttj|t|Sr))rorHAS_KEYSrZrpr*r*r-has_keys#rz JSON.has_keyscCrr))ror HAS_ANY_KEYSrZrpr*r*r- has_any_keys&rzJSON.has_any_keysNNr\)r|r rr r'rI)r|r)rr r'rI)r|rYrr r'rI)r)r|rIrrIrr r'rI)r)rrIrr r'rI)rtrr'ro)rzrIr'ror)rnrr'ro)r;r<r=tablerGrfrcrdrrerrwryr}rrrrrrrr*r*r r-rfs$           rfcs*eZdZdfdd Zddd dZZS)Valuesfield str | Fieldr'rCcs.tdt|tst||_dS||_dSr))rrGr2rRr)r,rr r*r-rG+s "zValues.__init__NrrBrr rIcKsdj|jjdd|i|dS)NzVALUES({value})rr|r*)r3rrr,rrr*r*r-r/szValues.get_sql)rrr'rCr)rrBrr r'rIr;r<r=rGrrr*r*r r-r*srcs*eZdZd dfdd Zdd d ZZS) LiteralValueNrArBr'rCcrFr))rrG_valuerHr r*r-rG4rIzLiteralValue.__init__rr rIcKst|j|jfi|Sr))rrrArr*r*r-r8r9zLiteralValue.get_sqlr)rrrr*r*r r-r3rbrc eZdZdd fdd ZZS) rXNrArBr'rCctd|dS)NrMrrGrFr r*r-rG=rzNullValue.__init__r)rr;r<r=rGrr*r*r r-rX<rXcr) SystemTimeValueNrArBr'rCcr)N SYSTEM_TIMErrFr r*r-rGBrzSystemTimeValue.__init__r)rrr*r*r r-rArrc@szeZdZed"ddZed#d dZd$d dZd%ddZd%ddZd%ddZed&d'ddZ ed&d(ddZ d)dd Z d!S)* Criterion comparatorrrnEmptyCriterionr'r cCrr)r*r,rrnr*r*r-_compareGrzCriterion._comparer ComplexCriterioncCrr)r*rr*r*r-rJrSelf | ComplexCriterioncCst|tr|St|||Sr))r2rrrr*r*r-rMs  cC|tj|Sr))rrand_rpr*r*r-__and__RrTzCriterion.__and__cCrr))rror_rpr*r*r-__or__UrTzCriterion.__or__cCrr))rrxor_rpr*r*r-__xor__XrTzCriterion.__xor__r*termsIterable[Term](EmptyCriterion | Term | ComplexCriterioncCst}|D]}||O}q|Sr)rrcritr<r*r*r-any[ z Criterion.any Iterable[Any]'EmptyCriterion | Any | ComplexCriterioncCst}|D]}||M}q|Sr)rrr*r*r-alldrz Criterion.allrIcCrr)rr+r*r*r-rmrzCriterion.get_sqlN)rrrnrr'r )rrrnr r'r)rrrnr r'r)rnr r'r)r*)rrr'r)rrr'rr) r;r<r=rrrrrrrrrr*r*r*r-rFs      rc@sHeZdZdZeZdddZddd Zdd d Zdd d Z dddZ dS)rNr'rQcCstSr))rOr+r*r*r-rSurzEmptyCriterion.fields_rnr cCrr)r*rpr*r*r-rxrzEmptyCriterion.__and__cCrr)r*rpr*r*r-r{rzEmptyCriterion.__or__cCrr)r*rpr*r*r-r~rzEmptyCriterion.__xor__cCrkr)r*r+r*r*r-rrzEmptyCriterion.__invert__r)rnr r'r )r'r ) r;r<r=r>rOrPrSrrrrr*r*r*r-rqs    rcBeZdZddfd d Zdd dZedddZdddZZS)rRNnamerIrArBrstr | Selectable | Noner'rCcs<tj|d||_t|trddlm}||}||_dS)NrErrM)rrGrr2rIpypika.queriesr#r)r,rrArr#r r*r-rGs    zField.__init__r(cc*|V|jdur|jEdHdSdSr)rr.r+r*r*r-r.  z Field.nodes_rhrirjcCs |j|kr ||_dS|j|_dS)Q Replaces all occurrences of the specified table with the new table. Useful when reusing fields across queries. :param current_table: The table to be replaced. :param new_table: The table to replace with. :return: A copy of the field with the tables replaced. Nrrlr*r*r-rms zField.replace_tablerr cKs|dd}|dd}|dd}t|j|}|jr0|s!|jjr0|j}djt|||d}t|dd}|rCt||fd|i|S|S)NrFrrz{namespace}.{name}) namespacerrA) poprrrrAget_table_namer3getattrr)r,rrrr field_sql table_name field_aliasr*r*r-rs      z Field.get_sqlr)rrIrArBrrr'rCr:rhrirjrir'rCr r;r<r=rGr.rrmrrr*r*r r-rRs    rRcs,eZdZddfdd Zddd dZZS)IndexNrrIrArBr'rCcrFr)rrGr)r,rrAr r*r-rGrIzIndex.__init__rrr cKs t|j|Sr))rrrr*r*r-rryz Index.get_sqlr))rrIrArBr'rCrrr*r*r r-rsrcs8eZdZddfdd Zdd d Z ddddZZS)StarNrrr'rCcstjd|ddS)N*rr)r,rr r*r-rGrz Star.__init__r(ccrr)rr+r*r*r-r.rz Star.nodes_FrrerrrBrr rIcKs:|jr|s |jjr|jjpt|jd}dt||SdS)N _table_namez{}.*r)rrArr3r)r,rrrrrr*r*r-rsz Star.get_sqlr))rrr'rCr:)FFN) rrerrerrBrr r'rIr;r<r=rGr.rrr*r*r r-rs  rcsNeZdZdfdd Zddd Zdd d ZedddZedddZ Z S)r\valuesr r'rCcs"tfdd|D_dS)Ncrr*rrr+r*r-r6rz"Tuple.__init__..)rrGr)r,rr r+r-rGs zTuple.__init__r(cc&|V|jD] }|EdHqdSr))rr.rr*r*r-r.  z Tuple.nodes_rrIc s4ddfdd|jD}t||jfiS)N({})rlc3 |] }|jdiVqdSNr*rr3r<rr*r- z Tuple.get_sql..)r3rorrrAr,rrZr*rr-rs z Tuple.get_sqlrecCtdd|jDS)NcSg|]}|jqSr*r>)r3r^r*r*r-r6z&Tuple.is_aggregate..)rrr+r*r*r-r>szTuple.is_aggregaterhrirjcfdd|jD|_dS)rcg|]}|qSr*rmrrhrjr*r-r6z'Tuple.replace_table..N)rrlr*rr-rm zTuple.replace_table)rr r'rCr:rr'rer) r;r<r=rGr.rrr>rrmrr*r*r r-r\s   r\c@eZdZdddZdS) rZrr r'rIc sld}dfdd|jD}d|}|tjtjfvr,t|dkr*d|nd}t||j fiS) Ndialectrlc3rrrrrr*r-rrz Array.get_sql..z[{}]rz ARRAY[{}]z'{}') rNrorr3r POSTGRESQLREDSHIFTr rrA)r,rrrrZr*rr-rs  z Array.get_sqlNrr-r*r*r*r-rZrZceZdZdfdd ZZS)Bracketr<r r'rCcst|dSr)rr>r r*r-rGrzBracket.__init__)r<r r'rCrr*r*r r-rrcsTeZdZ d"d#fdd Zd$ddZed%ddZed&ddZd'd(d d!Z Z S))NestedCriterionNrrnested_comparatorrleftr rightnestedrArBr'rCcs.t|||_||_||_||_||_dSr))rrGrrrrr)r,rrrrrrAr r*r-rGs  zNestedCriterion.__init__r(cc<|V|jEdH|jEdH|jEdHdSr))rr.rrr+r*r*r-r. zNestedCriterion.nodes_r?cCstdd|j|j|jfDS)NcSrr*rrr*r*r-r6rz0NestedCriterion.is_aggregate..)rrrrr+r*r*r-r>szNestedCriterion.is_aggregaterhrirjcCs4|j|||_|j|||_|j|||_dSU Replaces all occurrences of the specified table with the new table. Useful when reusing fields across queries. :param current_table: The table to be replaced. :param new_table: The table to replace with. :return: A copy of the criterion with the tables replaced. N)rrmrrrlr*r*r-rm!s zNestedCriterion.replace_tableFrrerrIc Ksddj|jjdi||jj|jjdi||jj|jjdi|d}|r0td||j d|S|S)Nz4{left}{comparator}{right}{nested_comparator}{nested})rrrrr)rZrAr*) r3rrrr|rrrrrAr,rrrZr*r*r-r1szNestedCriterion.get_sqlr))rrrrrr rr rr rArBr'rCr:rDrFrrerr r'rI r;r<r=rGr.rr>rrmrrr*r*r r-rs   rcsReZdZd"d#fd d Zd$ddZed%ddZed&ddZd'd(d d!Z Z S))roNrrrr@rrArBr'rCc"t|||_||_||_dS)a A wrapper for a basic criterion such as equality or inequality. This wraps three parts, a left and right term and a comparator which defines the type of comparison. :param comparator: Type: Comparator This defines the type of comparison, such as {quote}={quote} or {quote}>{quote}. :param left: The term on the left side of the expression. :param right: The term on the right side of the expression. N)rrGrrr)r,rrrrAr r*r-rGAs  zBasicCriterion.__init__r(cc,|V|jEdH|jEdHdSr))rr.rr+r*r*r-r.TzBasicCriterion.nodes_r?cCstdd|j|jfDS)NcSrr*rrr*r*r-r6[rz/BasicCriterion.is_aggregate..)rrrr+r*r*r-r>YzBasicCriterion.is_aggregaterhrirjcC$|j|||_|j|||_dSrrrmrrlr*r*r-rm] zBasicCriterion.replace_tablerFrrIrrerr cKsTdj|jj|jjdd|i||jjdd|i|d}|r(t||jfi|S|S)Nz{left}{comparator}{right}rrrrr*)r3rr|rrrrrA)r,rrrrZr*r*r-rlszBasicCriterion.get_sqlr)) rrrr@rr@rArBr'rCr:rDr)rF)rrIrrerr r'rIrr*r*r r-ro@s   rocs`eZdZddfd d Zd d dZed!ddZed"ddZdd#ddZ ed$ddZ Z S)%rNr<r containerr@rArBr'rCcs"t|||_||_d|_dS)a A wrapper for a "IN" criterion. This wraps two parts, a term and a container. The term is the part of the expression that is checked for membership in the container. The container can either be a list or a subquery. :param term: The term to assert membership for within the container. :param container: A list or subquery. FN)rrGr<r _is_negated)r,r<rrAr r*r-rGxs  zContainsCriterion.__init__r(ccrr))r<r.rr+r*r*r-r.rzContainsCriterion.nodes_r?cCr@r)rAr+r*r*r-r>rBzContainsCriterion.is_aggregaterhrirjcC|j|||_dSrr<rmrlr*r*r-rm zContainsCriterion.replace_tablesubqueryrrIcKsNdj|jjdi||jjdddi||jrdndd}t||jfi|S)Nz{term} {not_}IN {container}rTNOT rL)r<rnot_r*)r3r<rrrrrA)r,rrrZr*r*r-rs  zContainsCriterion.get_sqlcC d|_dSNTrr+r*r*r-rwrKzContainsCriterion.negater))r<r rr@rArBr'rCr:rDr)rr rr r'rI)r'r) r;r<r=rGr.rr>rrmrrwrr*r*r r-rws    rcs.eZdZdfdd ZddZddZZS) ExistsCriterionNcst|||_d|_dSNF)rrGrr)r,rrAr r*r-rG  zExistsCriterion.__init__cKs*dj|jjdi||jrddSddS)Nz{not_}EXISTS {container}rrL)rrr*)r3rrrrr*r*r-rs zExistsCriterion.get_sqlcCs d|_|Sr r r+r*r*r-rwszExistsCriterion.negater))r;r<r=rGrrwrr*r*r r-r sr cs8eZdZddfd d ZdddZedddZZS)RangeCriterionNr<r@rr rrArBr'rIcs"t|||_||_||_dSr))rrGr<rr)r,r<rrrAr r*r-rGs  zRangeCriterion.__init__r(ccrr))r<r.rrr+r*r*r-r.rzRangeCriterion.nodes_r?cCr@r)rAr+r*r*r-r>rBzRangeCriterion.is_aggregater)) r<r@rr rr rArBr'rIr:rD)r;r<r=rGr.rr>rr*r*r r-rs  rc@s$eZdZedddZdd d Zd S)rrhrirjr'rCcCrrrrlr*r*r-rmrzBetweenCriterion.replace_tablerr rIcKNdj|jjdi||jjdi||jjdi|d}t||jfi|S)Nz {term} BETWEEN {start} AND {end}r<rrr*r3r<rrrrrArr*r*r-r zBetweenCriterion.get_sqlNrr)r;r<r=rrmrr*r*r*r-rs  rc@r) rrr r'rIcKr)Nz{term} FROM {start} TO {end}rr*rrr*r*r-rrzPeriodCriterion.get_sqlNrr-r*r*r*r-rrrcr)r}Nr<r@r|r rArBr'rCct|||_||_dSr)rrGr<r|r,r<r|rAr r*r-rGrzBitwiseAndCriterion.__init__r(ccrr)r<r.r|r+r*r*r-r.rzBitwiseAndCriterion.nodes_rhrirjcCrrrrlr*r*r-rmrz!BitwiseAndCriterion.replace_tablerrIcK2dj|jjdi||jd}t||jfi|S)Nz({term} & {value})r<r|r*r3r<rr|rrArr*r*r-r  zBitwiseAndCriterion.get_sqlr)r<r@r|r rArBr'rCr:rrrr*r*r r-r}    r}cr)rNr<r@r|r rArBr'rCcrr)rrr r*r-rGrzBitwiseOrCriterion.__init__r(ccrr)rr+r*r*r-r.rzBitwiseOrCriterion.nodes_rhrirjcCrrrrlr*r*r-rmrz BitwiseOrCriterion.replace_tablerrIcKr)Nz({term} | {value})rr*rrr*r*r-r*rzBitwiseOrCriterion.get_sqlr)rr:rrrr*r*r r-rrrcsDeZdZddfdd Zdd d ZedddZddddZZS) rsNr<r@rArBr'rCcrFr)r=r,r<rAr r*r-rG3rIzNullCriterion.__init__r(cc|V|jEdHdSr)r<r.r+r*r*r-r.7zNullCriterion.nodes_rhrirjcCrrrrlr*r*r-rm;rzNullCriterion.replace_tableFrrerr rIcK.dj|jjdi|d}t||jfi|S)Nz{term} IS NULLrCr*r3r<rrrArr*r*r-rIzNullCriterion.get_sqlr))r<r@rArBr'rCr:rrrrr*r*r r-rs2s    rsc@seZdZd d dd Zd S) rzFrrerr r'rIcKr")Nz{term} IS NOT NULLrCr*r#rr*r*r-rQr$zNotNullCriterion.get_sqlNrrr-r*r*r*r-rzPsrzc@s"eZdZdddd Zdd d ZdS)rF subcriterionrerr r'rIc Ks\dj|jj|jjdd||ji||jjdd||ji|d}|r,dj|dS|S)Nz{left} {comparator} {right}r%rz ({criterion})) criterionr*)r3rr|rrneeds_bracketsr)r,r%rrZr*r*r-rYs zComplexCriterion.get_sqlr<r@cCst|to |j|jk Sr))r2rrr>r*r*r-r'erzComplexCriterion.needs_bracketsNr)r%rerr r'rI)r<r@r're)r;r<r=rr'r*r*r*r-rXs  rcsveZdZdZejejgZd$d%fd d Zd&ddZ e d'ddZ e d(ddZ d)ddZd)ddZd*d+d"d#ZZS),rz Wrapper for an arithmetic function. Can be simple with two terms or complex with nested terms. Order of operations are also preserved. Noperatorrrr rrArBr'rCcr)a Wrapper for an arithmetic expression. :param operator: Type: Arithmetic An operator for the expression such as {quote}+{quote} or {quote}/{quote} :param left: The term on the left side of the expression. :param right: The term on the right side of the expression. :param alias: (Optional) an alias for the term which can be used inside a select statement. :return: N)rrGr(rr)r,r(rrrAr r*r-rGqs  zArithmeticExpression.__init__r(ccrr))rr.rr+r*r*r-r.rzArithmeticExpression.nodes_r?cCst|jj|jjgSr))rrr>rr+r*r*r-r>sz!ArithmeticExpression.is_aggregaterhrirjcCr)P Replaces all occurrences of the specified table with the new table. Useful when reusing fields across queries. :param current_table: The table to be replaced. :param new_table: The table to replace with. :return: A copy of the term with the tables replaced. Nrrlr*r*r-rmrz"ArithmeticExpression.replace_tablerecCs$|durdS||jvr dS||jvS)a Returns true if the expression on the left of the current operator needs to be enclosed in parentheses. :param current_op: The current operator. :param left_op: The highest level operator of the left expression. NF) add_order)r,curr_opleft_opr*r*r-left_needs_parenss    z&ArithmeticExpression.left_needs_parenscCs2|durdS|tjkr dS|tjkrdS||jvS)a Returns true if the expression on the right of the current operator needs to be enclosed in parentheses. :param current_op: The current operator. :param right_op: The highest level operator of the right expression. NFT)rrrr*)r,r+right_opr*r*r-right_needs_parenss    z'ArithmeticExpression.right_needs_parensFrrrIc Ksdd|j|jfD\}}dj|jj||j|rdnd|jjdi|||j|r/dnd|jjdi|d}|rIt||j fi|S|S)NcSsg|]}t|ddqS)r(N)r)r3sider*r*r-r6rz0ArithmeticExpression.get_sql..z{left}{operator}{right}rz{})r(rrr*) rrr3r(r|r-rr/rrA)r,rrr,r.arithmetic_sqlr*r*r-rs zArithmeticExpression.get_sqlr)) r(rrr rr rArBr'rCr:rDrrrr)r;r<r=r5rrrr*rGr.rr>rrmr-r/rrr*r*r r-ris      rcsneZdZd!d"fdd Zd#d d Zed$d d Zed%ddZed&ddZ ed'ddZ d(d)dd Z Z S)*CaseNrArBr'rCcstj|dg|_d|_dSNrE)rrG_cases_elserFr r*r-rGs z Case.__init__r(ccsV|V|jD]\}}|EdH|EdHq|jdur)|jEdHdSdSr))r4r.r5r,r&r<r*r*r-r.s z Case.nodes_r?cCs.tdd|jD|jr|jjgSdgS)NcSsg|] \}}|jp |jqSr*rr3r&r<r*r*r-r6sz%Case.is_aggregate..)rr4r5r>r+r*r*r-r>szCase.is_aggregater&r r<cCs|j|||fdSr))r4r$r_r6r*r*r-whenrz Case.whenrhrirjcs<fdd|jD|_|jr|j|_dSd|_dS)r)cs(g|]\}}||gqSr*rr7rr*r-r6s  z&Case.replace_table..N)r4r5rmrlr*rr-rms $zCase.replace_tablecCs|||_|Sr))r_r5r>r*r*r-else_s z Case.else_FrrerrIc sv|jstddfdd|jD}|jr#d|jjd ind}d||d}|r9t||jfiS|S) Nz:At least one 'when' case is required for a CASE statement. c3s:|]\}}dj|jdi|jdidVqdS)zWHEN {when} THEN {then})r8thenNr*)r3rr7rr*r-rs $ zCase.get_sql..z ELSE {}rLzCASE z ENDr*)r4rror5r3rrrA)r,rrcasesr9case_sqlr*rr-rs"z Case.get_sqlr)rr:rD)r&r r<r r'rCr)r<r r'r2rr) r;r<r=rGr.rr>rr8rmr9rrr*r*r r-r2s     r2csPeZdZddfdd Zdd d ZdddZedddZedddZ Z S)rvNr<r rArBr'rCctj|d||_dSr3r=rr r*r-rG&raz Not.__init__r(ccrr)r r+r*r*r-r.*r!z Not.nodes_rrIcKs6d|d<dj|jjdi|d}t||jfi|S)NTr%z NOT {term}rCr*r#rr*r*r-r.sz Not.get_sqlrcs*t|j|ts Sfdd}|S)z Delegate method calls to the class wrapped by Not(). Re-wrap methods on child classes of Term (e.g. isin, eg...) to retain 'NOT ' output. cs.|g|Ri|}t|tfrt|S|Sr))r2r@rv) inner_selfargsrresult item_funcr*r-inner>s zNot.__getattr__..inner)rr<inspectismethod)r,rrDr*rBr- __getattr__3s   zNot.__getattr__rhrirjcCrrrrlr*r*r-rmFrzNot.replace_tabler)r<r rArBr'rCr:r)rrIr'r r) r;r<r=rGr.rrrGrrmrr*r*r r-rv%s   rvcs4eZdZddfdd Zdd d ZdddZZS)rNr<r rArBr'rCcr>r3r=rr r*r-rGVraz All.__init__r(ccrr)r r+r*r*r-r.Zr!z All.nodes_rrIcKs.dj|jjdi|d}t||jfi|S)Nz {term} ALLrCr*r#rr*r*r-r^sz All.get_sqlr)rHr:rrr*r*r r-rUs rc@s2eZdZdddd ZdddZddZddZdS)CustomFunctionNrrIparamsSequence | Noner'rCcCs||_||_dSr))rrJ)r,rrJr*r*r-rGds zCustomFunction.__init__r@r rFunctioncOs||st|j|ddS|j|s/tdj|jddd|jDddd|Ddt|jg|Rd|diS) NrArEzCFunction {name} require these arguments ({params}), ({args}) passedz, cs|]}t|VqdSr)rr3pr*r*r-rpz*CustomFunction.__call__..csrMr)rrNr*r*r-rqrP)rrJr@) _has_paramsrLrrN_is_valid_function_callrr3rorJ)r,r@rr*r*r-__call__hs zCustomFunction.__call__cCs |jduSr))rJr+r*r*r-rQwrHzCustomFunction._has_paramscGst|t|jkSr))r rJ)r,r@r*r*r-rRzrz&CustomFunction._is_valid_function_callr))rrIrJrKr'rC)r@r rr r'rL)r;r<r=rGrSrQrRr*r*r*r-rIcs    rIcsneZdZdfdd Zdd d ZedddZed ddZd!ddZ e ddZ d"ddZ d"ddZ ZS)#rLrrIr@r rr'rCcs<t|d|_fdd|D_|d_dS)NrAcrr*rr3rr+r*r-r6rz%Function.__init__..schema)rrGrNrr@rUr,rr@rr r+r-rGszFunction.__init__r(ccrr))r@r.rr*r*r-r.rzFunction.nodes_r?cCr)aa This is a shortcut that assumes if a function has a single argument and that argument is aggregated, then this function is also aggregated. A more sophisticated approach is needed, however it is unclear how that might work. :returns: True if the function accepts one argument and that argument is aggregate. cSrr*r)r3rr*r*r-r6rz)Function.is_aggregate..)rr@r+r*r*r-r>szFunction.is_aggregaterhrirjcr)rcrr*rrTrr*r-r6rz*Function.replace_table..Nr@rlr*rr-rmrzFunction.replace_tablecKrr)r*rr*r*r-get_special_params_sqlrzFunction.get_special_params_sqlcKs&t|dr|jdddi|St|S)NrrFr*hasattrrrI)rrr*r*r- get_arg_sqls&zFunction.get_arg_sqlc sJjdi}djjdfddjD|r!d|dSddS) Nz{name}({args}{special})rlc3sB|]}t|dr|jddddnj|fiVqdS)rFT)rrNr*)rZrr[rNrjr*r-rs z,Function.get_function_sql..r:rL)rr@specialr*)rXr3rror@)r,rspecial_params_sqlr*rjr-get_function_sqls  zFunction.get_function_sqlcKs|dd}|dd}|dd}|dd}|j|||d}|jdur6dj|jjd ||d||d }|rDt||jfd|i|S|S) NrFrrr)rrrz{schema}.{function})rr)rUfunctionr*)rr^rUr3rrrA)r,rrrrr function_sqlr*r*r-rs     zFunction.get_sqlrrIr@r rr r'rCr:rDr)rr r'r r)r;r<r=rGr.rr>rrmrXrr[r^rrr*r*r r-rL~s      rLcsFeZdZdZfddZeddd Zdd d Zdfdd ZZ S)AggregateFunctionTcs*tj|g|Ri|g|_d|_dSr )rrG_filters_include_filterrVr r*r-rGs zAggregateFunction.__init__filtersr r'rCcGd|_|j|7_dSr )rdrc)r,rer*r*r-filterzAggregateFunction.filterrrIcKs*|jrdjt|jjdi|dSdS)NzWHERE {criterions}) criterionsr*)rdr3rrrcrrr*r*r-get_filter_sqls z AggregateFunction.get_filter_sqlc s<tjdi|}|jdi|}|jr|dj|d7}|S)Nz FILTER({filter_sql})) filter_sqlr*)rr^rjrdr3)r,rrZrkr r*r-r^s z"AggregateFunction.get_function_sql)rer r'rCr)rr ) r;r<r=r>rGrrgrjr^rr*r*r r-rbs   rbcsdeZdZdZdZdfd d Zedd dZedddZdddZ dddZ dfdd Z Z S) AnalyticFunctionFTrrIr@r rr'rCcs<tj|g|Ri|g|_g|_g|_d|_d|_dSr )rrGrc _partition _orderbysrd _include_overrVr r*r-rGs  zAnalyticFunction.__init__rcGrfr )rormr,rr*r*r-overrhzAnalyticFunction.overcs&d|_|jfdd|D7_dS)NTcsg|] }|dfqS)order)rNrrr*r-r6r7z,AnalyticFunction.orderby..)rorn)r,rrr*rr-orderbys zAnalyticFunction.orderbyrrRorient Order | NonecKs4|dur |jdi|Sdj|jdi||jdS)Nz{field} {orient})rrtr*)rr3r|)r,rrtrr*r*r-_orderby_fields zAnalyticFunction._orderby_fieldc slg}jr|djdfddjDdjr1|djdfddjDdd |S) NzPARTITION BY {args}rlc3s2|]}t|dr|jdint|VqdS)rNr*rYrNrr*r-rs0z5AnalyticFunction.get_partition_sql..rWzORDER BY {orderby}c3s(|]\}}j||fiVqdSr))rv)r3rrtrjr*r-rs&)rsr:)rmr$r3rorn)r,rrr*rjr-get_partition_sql s z"AnalyticFunction.get_partition_sqlc s@tjdi|}|jdi|}|}|jr|d|d7}|S)Nz OVER()r*)rr^rwro)r,rr` partition_sqlrZr r*r-r^s z!AnalyticFunction.get_function_sqlrarr r'rC)rr rr r'rC)rrRrtrurr r'rIr) r;r<r=r> is_analyticrGrrqrsrvrwr^rr*r*r r-rls    rlEdgeT WindowFrameAnalyticFunction.EdgecsneZdZGdddZdfd d ZdddZeddddZeddddZd ddZ d!fdd Z Z S)"WindowFrameAnalyticFunctionc@s"eZdZd d ddZd d d ZdS)r}Nr|str | int | Noner'rCcCrDr)rrr*r*r-rG+rHz)WindowFrameAnalyticFunction.Edge.__init__rIcCsdj|jpd|jdS)Nz{value} {modifier} UNBOUNDED)r|modifier)r3r|rr+r*r*r-r.sz(WindowFrameAnalyticFunction.Edge.__str__r))r|rr'rCr)r;r<r=rGrr*r*r*r-Edge*s rrrIr@r rr'rCcs*tj|g|Ri|d|_d|_dSr))rrGframer&rVr r*r-rG4s z$WindowFrameAnalyticFunction.__init__rr& and_bound EdgeT | NonecCs4|js|jr t||_|r||f|_dS||_dSr))rr&AttributeError)r,rr&rr*r*r-_set_frame_and_bounds9s z1WindowFrameAnalyticFunction._set_frame_and_boundsN str | EdgeTcC|d||dS)NROWSrr,r&rr*r*r-rows@z WindowFrameAnalyticFunction.rowscCr)NRANGErrr*r*r-rangeDrz!WindowFrameAnalyticFunction.rangecCs:t|jtsdj|j|jdS|j\}}dj|j||dS)Nz{frame} {bound})rr&z#{frame} BETWEEN {lower} AND {upper})rrr)r2r&r[r3rrr*r*r- get_frame_sqlHs  z)WindowFrameAnalyticFunction.get_frame_sqlc s4tjdi|}|js|js|Sdj||dS)Nz{over} {frame})rqrr*)rrwrr&r3r)r,rryr r*r-rwSs z-WindowFrameAnalyticFunction.get_partition_sqlra)rrIr&rIrrr'rCr))r&rrrr'rCrr) r;r<r=rrGrrrrrrwrr*r*r r-r~)s   r~cs6eZdZdfdd Zedd d Zdd dZZS)IgnoreNullsAnalyticFunctionrrIr@r rr'rCcs$tj|g|Ri|d|_dSr )rrG _ignore_nullsrVr r*r-rG]s z$IgnoreNullsAnalyticFunction.__init__cCr r rr+r*r*r- ignore_nullsarKz(IgnoreNullsAnalyticFunction.ignore_nullsrBcKs|jrdSdS)Nz IGNORE NULLSrrr*r*r-rXesz2IgnoreNullsAnalyticFunction.get_special_params_sqlra)r'rC)rr r'rB)r;r<r=rGrrrXrr*r*r r-r\rErc @s|eZdZejdejdejdejdejdiZ gdZ gdZ e dZ          ddddZd ddZd!ddZdS)"IntervalINTERVAL '{expr} {unit}'zINTERVAL '{expr}' {unit}yearsmonthsdayshoursminutesseconds microseconds)YEARMONTHDAYHOURMINUTESECOND MICROSECONDz6(^0+\.)|(\.0+$)|(^[0\-.: ]+[\-: ])|([\-:. ][0\-.: ]+$)rNrrdrrrrrrquartersweeksrDialects | Nonec  Cs| |_d|_d|_d|_|r||_dS| r| |_dSt|j|j|||||||gD]#\} } } | rLt | }t || t ||jdurI| |_|dk|_| |_q)dS)NFr) rlargestsmallest is_negativerrzipunitslabelsrdsetattrabs)r,rrrrrrrrrrunitlabelr| int_valuer*r*r-rG}s0   zInterval.__init__r'rIcCs|Sr)rr+r*r*r-rrrzInterval.__str__rr c Ks|jp|d}|jdkrt|d}d}nht|dr"t|d}d}n[t|dr/t|d}d}nNdjt|d d t|d d t|d d t|d d t|dd t|dd t|dd d}|jd|}|jred|}|j|j krtdj|j|j dn|j}|dur}d}|j |dj||dS)NrrrrQUARTERrWEEKzB{years}-{months}-{days} {hours}:{minutes}:{seconds}.{microseconds}rrrrrrrrrL-z{largest}_{smallest})rrrr)rr) rrNrrrZr3 trim_patternrrr templates)r,rrrrr*r*r-rs@                zInterval.get_sql) rrrrrrrrrN)rrdrrdrrdrrdrrdrrdrrdrrdrrdrrrr)r;r<r=rrrVERTICAORACLEMYSQLrrrrecompilerrGrrr*r*r*r-rms.   'rc eZdZd d fd d ZZS)rNr<r@exponentrYrArBr'rCctjd|||ddS)NPOWrEr)r,r<rrAr r*r-rGrz Pow.__init__r))r<r@rrYrArBr'rCrr*r*r r-rrrcr)rNr<r@modulusrYrArBr'rCcr)NMODrEr)r,r<rrAr r*r-rGrz Mod.__init__r))r<r@rrYrArBr'rCrr*r*r r-rrrcr)Rolluprr r'rCcstjdg|RdS)NROLLUPrrpr r*r-rGrzRollup.__init__rzrr*r*r r-rrrcs,eZdZdZd fdd Zd d d ZZS) PseudoColumnz Represents a pseudo column (a "column" which yields a value when selected but is not actually a real table column). rrIr'rCcstjdd||_dSr3r)r,rr r*r-rGrazPseudoColumn.__init__rr cKr r))rrr*r*r-rrzPseudoColumn.get_sql)rrIr'rCr)r;r<r=r5rGrrr*r*r r-rsrcs.eZdZdZdZdfdd ZddZZS) AtTimezonez| Generates AT TIME ZONE SQL. Examples: AT TIME ZONE 'US/Eastern' AT TIME ZONE INTERVAL '-06:00' NFcs4t|t|tst|n||_||_||_dSr))rrGr2rRrzoneinterval)r,rrrrAr r*r-rGs  zAtTimezone.__init__cKs>dj|jjdi||jrdnd|jd}t||jfi|S)Nz&{name} AT TIME ZONE {interval}'{zone}'z INTERVAL rL)rrrr*)r3rrrrrrArr*r*r-rs  zAtTimezone.get_sql)FN)r;r<r=r5r>rGrrr*r*r r-rs r)rrdr'rI)i __future__rrErsysrPcollections.abcrrrrrrr enumr typingr r r r pypika.enumsrrrrrrrr pypika.utilsrrrrrrr version_infotyping_extensionsr rr!r"r# __author__ __email__r$r%r@rrrrr(r*r/r7r8r9rr]r_rfrrrXrrrrRrrr\rZrrrorr rrrr}rrsrzrrr2rvrrIrLrbrlr|r~rrrrrrrr*r*r*r-s  ($        : ?  +3 ! :75 !!tH0P <3h