wiaHddlmZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z m Z ddlmZddlmZmZmZmZddlmZmZmZmZmZmZmZmZddlmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%er"ej&d krdd l'm(Z(ndd lm(Z(dd l)m*Z*m+Z+m,Z,d Z-d Z.eddZ/GddZ0Gdde0Z1ddZ2ddZ3Gdde1Z4Gdde4Z5Gdde4Z6Gd d!e5Z7Gd"d#e5Z8Gd$d%e5Z9Gd&d'e6Z:Gd(d)e6Z;Gd*d+e1Z<Gd,d-e1Z=Gd.d/e=Z>Gd0d1e1Z?Gd2d3e1Z@Gd4d5e1ZAGd6d7eAZBGd8d9eAZCGd:d;e1ZDGd<d=eDZEGd>d?eDe?ZFGd@dAe1ZGGdBdCeFZHGdDdEeDZIGdFdGeIZJGdHdIeIZKGdJdKeDZLGdLdMeDZMGdNdOeDZNGdPdQeDZOGdRdSeDZPGdTdUePZQGdVdWePZRGdXdYeDZSGdZd[eDZTGd\d]eDZUGd^d_eUZVGd`daeMZWGdbdce1ZXGdddeeDZYGdfdgeDZZGdhdieDZ[GdjdkZ\GdldmeDZ]Gdndoe]Z^Gdpdqe^Z_edrdsZ`Gdtdue_ZaGdvdwe_ZbGdxdye1ZcGdzd{e]ZdGd|d}e]ZeGd~de]ZfGdde1ZgGdde1ZhdS)) 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"eZdZdZd dZd dZdS) r&NreturnIterator[NodeT]c#K|VdSNselfs ?/var/www/icac/venv/lib/python3.11/site-packages/pypika/terms.pynodes_z Node.nodes_)s type type[NodeT] list[NodeT]cDfd|DS)Nc4g|]}t||Sr-) isinstance).0noder3s r0 zNode.find_..-s(III*T42H2HIIIIr2)r1)r/r3s `r0find_z Node.find_,s%IIIIIIIIr2r)r*)r3r4r)r5)__name__ __module__ __qualname__ is_aggregater1r<r-r2r0r&r&&sGLJJJJJJr2cTeZdZdZdodpdZedqd Zedrd Zdsd Z e dodtdZ e dodudZ dvdZ dwdZdxdZdyd!Zdzd#Zd{d'Zd|d)Zdwd*Zdwd+Zdwd,Zdwd-Zdwd.Zd}d0Zd}d1Zd}d2Zd}d3Zd}d4Zd}d5Zd~d7Zd~d8Z dd<Z!dd@Z"d}dAZ#ddCZ$ddGZ%ddHZ&d~dIZ'dydJZ(ddLZ)ddMZ*dydNZ+ddOZ,ddQZ-ddRZ.ddSZ/ddTZ0ddUZ1ddWZ2ddYZ3ddZZ4dd[Z5dd\Z6dd]Z7dd^Z8dd_Z9dd`Z:ddaZ;dwdbZdwdeZ?dwdfZ@dwdgZAddjZBddkZCddlZDddnZEdS)TermFNalias str | Noner)Nonec||_dSr,rDr/rDs r0__init__z Term.__init__3s  r2strc||_dSr,rHrIs r0as_zTerm.as_6s  r2 set[Table]cRddlm}t||S)Nrr$)pypikar$setr<)r/r$s r0tables_z Term.tables_:s.      4::e$$%%%r2 set[Field]cPt|tSr,)rRr<Fieldr.s r0fields_z Term.fields_@s4::e$$%%%r2 wrapper_clstype[Term] | None@ValueError | NodeT | LiteralValue | Array | Tuple | ValueWrapperct|tr|S|tSt|tr t |St|t r t |S|pt}||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. )r8r& NullValuelistArraytupleTuple ValueWrapper)valrXs r0 wrap_constantzTerm.wrap_constantCs~& c4  J ;;;  c4  #;  c5 ! ! #; "1\ {3r2rb-Term | QueryBuilder | None | str | int | bool5Term | QueryBuilder | NullValue | ValueWrapper | JSONcddlm}t|t|fr|S|t St|t t tfr|pt}||St|S)N)r") queriesr"r8rCr\rKintboolraJSON)rbrXr"s r0 wrap_jsonzTerm.wrap_jsoncs *))))) cD,/ 0 0 J ;;;  cCd+ , , $%5K;s## #Cyyr2 current_table Table | None new_tablec|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/rmros r0 replace_tablezTerm.replace_tabless  r2otherr BasicCriterionc||kSr,r-r/rss r0eqzTerm.eq u}r2 NullCriterionc t|Sr,)ryr.s r0isnullz Term.isnullsT"""r2NotcN|Sr,)r{negater.s r0notnullz Term.notnulls{{}}##%%%r2NotNullCriterionc t|Sr,)rr.s r0 isnotnullzTerm.isnotnulls%%%r2valueriBitwiseAndCriterioncHt|||Sr,)rrcr/rs r0 bitwiseandzTerm.bitwiseands "4););E)B)BCCCr2BitwiseOrCriterioncHt|||Sr,)rrcrs r0 bitwiseorzTerm.bitwiseors !$(:(:5(A(ABBBr2c||kSr,r-rvs r0gtzTerm.gt e|r2c||kSr,r-rvs r0gtezTerm.gterxr2c||kSr,r-rvs r0ltzTerm.ltrr2c||kSr,r-rvs r0ltezTerm.lterxr2c||kSr,r-rvs r0nezTerm.nerxr2exprc^ttj|||Sr,)rtrglobrcr/rs r0rz Term.glob$hmT43E3Ed3K3KLLLr2c^ttj|||Sr,)rtrlikercrs r0rz Term.likerr2c^ttj|||Sr,)rtrnot_likercrs r0rz Term.not_likes%h/t7I7I$7O7OPPPr2c^ttj|||Sr,)rtrilikercrs r0rz Term.ilike$hndD4F4Ft4L4LMMMr2c^ttj|||Sr,)rtr not_ilikercrs r0rzTerm.not_ilikes%h0$8J8J48P8PQQQr2c^ttj|||Sr,)rtrrlikercrs r0rz Term.rlikerr2patternc^ttj|||Sr,)rtrregexrcr/rs r0rz Term.regexs$hndD4F4Fw4O4OPPPr2c^ttj|||Sr,)rtrregexprcrs r0rz Term.regexps$hotT5G5G5P5PQQQr2lowerupperBetweenCriterioncpt|||||Sr,)rrcr/rrs r0betweenz Term.betweens1d&8&8&?&?ASASTYAZAZ[[[r2startendPeriodCriterioncpt|||||Sr,)rrc)r/rrs r0from_toz Term.from_tos1tT%7%7%>%>@R@RSV@W@WXXXr2c^ttj|||Sr,)rtras_ofrcrs r0rz Term.as_ofrr2Allc t|Sr,)rr.s r0all_z Term.all_4yyr2arg%list | tuple | set | frozenset | TermContainsCriterionct|ttttfr#t t fd|DSt |S)Nc:g|]}|Sr-rcr9rr/s r0r;zTerm.isin..s(2^2^2^QV43E3Ee3L3L2^2^2^r2)r8r]r_rR frozensetrr`r/rs` r0isinz Term.isinsZ cD%i8 9 9 a$T52^2^2^2^Z]2^2^2^+_`` ` s+++r2cP||Sr,)rr~rs r0notinz Term.notinsyy~~$$&&&r2c^ttj|||Sr,)rtr bin_regexrcrs r0rzTerm.bin_regexs%h0$8J8J78S8STTTr2c t|Sr,r|r.s r0r~z Term.negaterr2ArithmeticExpressionc ||zSr,r-rvs r0lshiftz Term.lshift u}r2c ||z Sr,r-rvs r0rshiftz Term.rshiftrr2c t|Sr,rr.s r0 __invert__zTerm.__invert__rr2c|Sr,r-r.s r0__pos__z Term.__pos__ r2Negativec t|Sr,)rr.s r0__neg__z Term.__neg__s~~r2c^ttj|||Sr,rraddrcrvs r0__add__z Term.__add__$#JND$:L:LU:S:STTTr2c^ttj|||Sr,rrsubrcrvs r0__sub__z Term.__sub__rr2c^ttj|||Sr,rrmulrcrvs r0__mul__z Term.__mul__rr2c^ttj|||Sr,rrdivrcrvs r0 __truediv__zTerm.__truediv__rr2Powc"t||Sr,)rrvs r0__pow__z Term.__pow__4r2Modc"t||Sr,)rrvs r0__mod__z Term.__mod__rr2c^ttj|||Sr,rrvs r0__radd__z Term.__radd__$#JND4F4Fu4M4MtTTTr2c^ttj|||Sr,rrvs r0__rsub__z Term.__rsub__rr2c^ttj|||Sr,rrvs r0__rmul__z Term.__rmul__rr2c^ttj|||Sr,rrvs r0 __rtruediv__zTerm.__rtruediv__rr2c^ttj|||Sr,rrrrcrvs r0 __lshift__zTerm.__lshift__&#J$5tT=O=OPU=V=VWWWr2c^ttj|||Sr,rrrrcrvs r0 __rshift__zTerm.__rshift__rr2c^ttj|||Sr,rrvs r0 __rlshift__zTerm.__rlshift__&#J$5t7I7I%7P7PRVWWWr2c^ttj|||Sr,rrvs r0 __rrshift__zTerm.__rrshift__ rr2c^ttj|||Sr,)rtrrwrcrvs r0__eq__z Term.__eq__ $hk41C1CE1J1JKKKr2c^ttj|||Sr,)rtrrrcrvs r0__ne__z Term.__ne__r r2c^ttj|||Sr,)rtrrrcrvs r0__gt__z Term.__gt__r r2c^ttj|||Sr,)rtrrrcrvs r0__ge__z Term.__ge__$hlD$2D2DU2K2KLLLr2c^ttj|||Sr,)rtrrrcrvs r0__lt__z Term.__lt__r r2c^ttj|||Sr,)rtrrrcrvs r0__le__z Term.__le__rr2itemslicect|tstd||j|jS)Nz"Field' object is not subscriptable)r8r TypeErrorrrstop)r/rs r0 __getitem__zTerm.__getitem__s<$&& B@AA A||DJ 222r2c0|ddS)N"' quote_charsecondary_quote_charget_sqlr.s r0__str__z Term.__str__$s||s|EEEr2cJt|ddS)NT) with_aliaswith_namespace)hashr#r.s r0__hash__z Term.__hash__'s DLLDLFFGGGr2kwargsc tr,NotImplementedErrorr/r*s r0r#z Term.get_sql*!###r2r,rDrEr)rF)rDrKr)rF)r)rNr)rT)rXrYr)rZ)rbrdr)re)rmrnrornr)rCrsr r)rt)r)ry)r)r|)r)r)rrir)r)rrir)r)rrKr)rt)rrKr)rt)rr rr r)r)rr rr r)r)r)r)rrr)r)rsr r)r)r)rC)r)r)rsr r)r)rsr r)r)rrr)rr)rK)r)rir*r r)rK)Fr>r?r@rArJrrMpropertyrSrW staticmethodrcrlrrrwr{rrrrrrrrrrrrrrrrrrrrrrrrr~rrrrrrrrrrrrrrrrrrrr r rrrrrr$r)r#r-r2r0rCrC0sL  W&&&X& &&&&.2    \ >HL    \     ####&&&&&&&&DDDDCCCCMMMMMMMMQQQQNNNNRRRRNNNNQQQQRRRR\\\\YYYYNNNN,,,, ''''UUUUUUUUUUUUUUUUUUUU        UUUUUUUUUUUUUUUUXXXXXXXXXXXXXXXXLLLLLLLLLLLLMMMMLLLLMMMM3333 FFFFHHHH$$$$$$r2rCidxrir)rKc&t|dzSNrgrKr7s r0idx_placeholder_genr<.s sQw<<r2cd|dzS)Nparamrgr-r;s r0named_placeholder_genr?2s 37  r2cReZdZdZdfd ZedZdd ZddZddZ xZ S) ParameterN placeholder str | intr)rFcVt||_dSr,)superrJ _placeholderr/rB __class__s r0rJzParameter.__init__9s' 'r2c|jSr,)rFr.s r0rBzParameter.placeholder=s   r2r*r rKc *t|jSr,)rKrBr.s r0r#zParameter.get_sqlAs4#$$$r2 param_key param_valuec dSr,r-)r/rKrLr*s r0update_parameterszParameter.update_parametersD r2c |Sr,r-r/rBr*s r0 get_param_keyzParameter.get_param_keyGsr2)rBrCr)rFr4)rKr rLr rBr ) r>r?r@rArJr5rBr#rNrR __classcell__rHs@r0rArA6sL((((((!!X!%%%%    r2rAcJeZdZefd fd Zed dZdZdd ZxZ S) ListParameterrB str | int | Callable[[int], str]r)rFcrt|t|_dSNrB)rErJr] _parametersrGs r0rJzListParameter.__init__L0 [11166r2rKct|jr'|t|jSt |jSr,callablerFlenr\rKr.s r0rBzListParameter.placeholderPE D% & & <$$S)9%:%:;; ;4$%%%r2c |jSr,r\r.s r0get_parameterszListParameter.get_parametersW r2rr c :|j|dSr,)r\appendr/rr*s r0rNzListParameter.update_parametersZs &&&&&r2rBrXr)rFr3rr ) r>r?r@r<rJr5rBrerNrTrUs@r0rWrWKsGZ"""""""&&&X&    ''''''''r2rWcReZdZefdfd ZeddZdZdd Zdd Z xZ S) DictParameterrBrXr)rFcrt|t|_dSrZ)rErJdictr\rGs r0rJzDictParameter.__init___r]r2rKct|jr'|t|jSt |jSr,r_r.s r0rBzDictParameter.placeholdercrbr2c |jSr,rdr.s r0rezDictParameter.get_parametersjrfr2r c |ddSr9r-rQs r0rRzDictParameter.get_param_keyms122r2rKrc ||j|<dSr,rd)r/rKrr*s r0rNzDictParameter.update_parametersps&+###r2rjr3rS)rKr rr ) r>r?r@r?rJr5rBrerRrNrTrUs@r0rmrm^sG\"""""""&&&X&    ,,,,,,,,r2rmceZdZdZdS)QmarkParameterc dS)N?r-r.s r0r#zQmarkParameter.get_sqlussr2Nr>r?r@r#r-r2r0ruruts#r2ruceZdZdZddZdS) NumericParameterz0Numeric, positional style, e.g. ...WHERE name=:1r*r r)rKc 8d|jSNz:{placeholder}r[formatrBr.s r0r#zNumericParameter.get_sql|&&43C&DDDr2Nr4r>r?r@__doc__r#r-r2r0rzrzys4::EEEEEEr2rzceZdZdZddZdS) FormatParameterz1ANSI C printf format codes, e.g. ...WHERE name=%sr*r r)rKc dS)Nz%sr-r.s r0r#zFormatParameter.get_sqlstr2Nr4rr-r2r0rrs.;;r2rceZdZdZddZdS) NamedParameterz%Named style, e.g. ...WHERE name=:namer*r r)rKc 8d|jSr|r}r.s r0r#zNamedParameter.get_sqlrr2Nr4rr-r2r0rrs4//EEEEEEr2rc"eZdZdZd dZd dZd S) PyformatParameterz9Python extended format codes, e.g. ...WHERE name=%(name)sr*r r)rKc 8d|jS)Nz%({placeholder})sr[r}r.s r0r#zPyformatParameter.get_sqls"))d6F)GGGr2rBc |ddS)Nr-rQs r0rRzPyformatParameter.get_param_keys1R4  r2Nr4rS)r>r?r@rr#rRr-r2r0rrsFCCHHHH!!!!!!r2rc@eZdZd fd Zed dZdd ZxZS)rtermrCr)rFcVt||_dSr,rErJrr/rrHs r0rJzNegative.__init__s$  r2 bool | Nonec|jjSr,rrAr.s r0rAzNegative.is_aggregate y%%r2r*r rKc Nd|jjdi|S)Nz-{term}rr-)r~rr#r.s r0r#zNegative.get_sqls/%6TY%6%@%@%@%@AAAr2)rrCr)rFr)rr4)r>r?r@rJr5rAr#rTrUs@r0rrsy&&&X&BBBBBBBBr2rc^eZdZdZddfd Zdd Zedd ZddZ dddZ xZ S)raNrr rDrEr)rFcXt|||_dSr,rErJrr/rrDrHs r0rJzValueWrapper.__init__&  r2r*rKc (|j|jfi|Sr,)get_formatted_valuerr.s r0 get_value_sqlzValueWrapper.get_value_sqls't' ==f===r2c |dpd}t|tr |jdi|St|tr|j|jfi|St|tttfr |j| fi|St|trt||St|tr'tt|St|tjr|jt|fi|S|dSt|S)Nr!nullr-)getr8rCr#r rrrr r isoformatrKrrjruuidUUID)clsrr*r s r0rz ValueWrapper.get_formatted_valuesJZZ 677=2 eT " " + 5=**6** * eT " " B*3*5;AA&AA A edHd3 4 4 H*3*5??+<+<GGGG G eS ! ! 4  33 3 eT " " )99SZZ(( ( eTY ' ' A*3*3u::@@@@ @ =65zzr2 parameterrAtuple[str, str]c P|jdi|}||}||fSNr[r-)r#rRr/rr* param_sqlrKs r0_get_param_datazValueWrapper._get_param_datas;%I%//// ++ +BB )##r2rr r!c ,|%|jd||d|}t||jfd|i|St|jt t fr|j}n|jdd|i|}|j|fi|\}}|jd||d|t||jfd|i|S)Nrr )rKrr-) rrrDr8rrifloatrrN) r/r r!rr*sql value_sqlrrKs r0r#zValueWrapper.get_sqls  $$$p QeppioppC#CUU UfUU U dj3, / / L II**KKjKFKKI3t3IHHHH 9# #SiySSFSSS 4:WW*WPVWWWr2r,rr rDrEr)rFr4rkrrAr)r)NrN) r rEr!rKrrAr*r r)rK) r>r?r@rArJr classmethodrrr#rTrUs@r0rarasL>>>>[&$$$$"&$'# XXXXXXXXXr2rac*eZdZd dfd Zdd ZxZS)ParameterValueWrapperNrrArr rDrEr)rFcZt||||_dSr,)rErJ _parameter)r/rrrDrHs r0rJzParameterValueWrapper.__init__s( &&&#r2rc d|jjdi|}|j|}||fSr)rr#rRrs r0rz%ParameterValueWrapper._get_param_datas?+DO+55f55 O11i1HH )##r2r,)rrArr rDrEr)rFr)r>r?r@rJrrTrUs@r0rrsV$$$$$$$$$$$$$$$r2rceZdZUdZded<d'd(fd Zd)d Zd*dZd+dZe d,d-dZ d.d/dZ d0dZ d0dZ d1dZd1dZd2d!Zd2d"Zd2d#Zd3d%Zd3d&ZxZS)4rkNstr | Selectable | Nonetablerr rDrEr)rFcXt|||_dSr,rrs r0rJz JSON.__init__rr2r*rKc t|tr|j|fi|St|tr|j|fi|St|t r|j|fi|St |Sr,)r8ro _get_dict_sqlr] _get_list_sqlrK _get_str_sqlris r0_recursive_get_sqlzJSON._recursive_get_sqls eT " " 7%4%e66v66 6 eT " " 7%4%e66v66 6 eS ! ! 6$4$U55f55 55zzr2roc fd|D}ddd|dgS)Nc tg|]4\}}dj|fij|fi5S)z {key}:{value})keyr)r~r)r9kvr*r/s r0r;z&JSON._get_dict_sql..so   1  " "'>t'>q'K'KF'K'KSjSWSjklSwSwpvSwSw " x x   r2r{,})itemsjoinr/rr*pairss` ` r0rzJSON._get_dict_sqls^         wwSXXe__c2333r2r]c zfd|D}ddd|dgS)Nc,g|]}j|fiSr-)r)r9rr*r/s r0r;z&JSON._get_list_sql..s/EEE!((55f55EEEr2r[r])rrs` ` r0rzJSON._get_list_sqlsCEEEEEuEEEwwSXXe__c2333r2rr c "t||Sr,)r)rr r*s r0rzJSON._get_str_sqlsUJ///r2rr!c xt||j|}t||jfi|Sr,)rrrrrD)r/r!r*rs r0r#z JSON.get_sql s<D33DJ??AUVVTZ::6:::r2 key_or_indexrCrtc^ttj|||Sr,)rtrGET_JSON_VALUErcr/rs r0get_json_valuezJSON.get_json_value&m:D$BTBTUaBbBbcccr2c^ttj|||Sr,)rtrGET_TEXT_VALUErcrs r0get_text_valuezJSON.get_text_valuerr2 path_jsonc^ttj|||Sr,)rtrGET_PATH_JSON_VALUErlr/rs r0get_path_json_valuezJSON.get_path_json_value$m?t~~V_G`G`aaar2c^ttj|||Sr,)rtrGET_PATH_TEXT_VALUErlrs r0get_path_text_valuezJSON.get_path_text_valuerr2rsc^ttj|||Sr,)rtrHAS_KEYrlrvs r0has_keyz JSON.has_keys#m3T4>>%;P;PQQQr2c^ttj|||Sr,)rtrCONTAINSrlrvs r0containsz JSON.containss#m4dDNN5r?r@r__annotations__rJrrrr6rr#rrrrrrrrrrTrUs@r0rkrks%)E))))444444440000\0;;;;;ddddddddbbbbbbbbRRRRSSSSWWWWKKKKOOOOOOOOr2rkc*eZdZd fd Zddd ZxZS)Valuesfield str | Fieldr)rFctdt|tst|n||_dSr,)rErJr8rVr)r/rrHs r0rJzValues.__init__+s? )3E5)A)ALU5\\\u r2Nr rEr*r rKc Rd|jjdd|i|S)NzVALUES({value})r rr-)r~rr#r/r r*s r0r#zValues.get_sql/s5 ''.@dj.@.a.aJ.aZ`.a.a'bbbr2)rrr)rFr,r rEr*r r)rKr>r?r@rJr#rTrUs@r0rr*seMMMMMMcccccccccr2rc*eZdZd d fd Zd d ZxZS) LiteralValueNrDrEr)rFcXt|||_dSr,)rErJ_valuers r0rJzLiteralValue.__init__4s&  r2r*r rKc 2t|j|jfi|Sr,)rrrDr.s r0r#zLiteralValue.get_sql8s TZBB6BBBr2r,r0r4rrUs@r0rr3s^CCCCCCCCr2rc"eZdZddfd ZxZS) r\NrDrEr)rFcLtd|dS)NrrErJr/rDrHs r0rJzNullValue.__init__=s# '''''r2r,r0r>r?r@rJrTrUs@r0r\r\<sB(((((((((((r2r\c"eZdZddfd ZxZS) SystemTimeValueNrDrEr)rFcLtd|dS)N SYSTEM_TIMEr r s r0rJzSystemTimeValue.__init__Bs# .....r2r,r0rrUs@r0rrAsB///////////r2rceZdZeddZedd Zdd Zdd ZddZddZedd dZ edd!dZ d"dZ dS)# Criterion comparatorrrsEmptyCriterionr)r!cdSr,r-r/rrss r0_comparezCriterion._compareGsORsr2r ComplexCriterioncdSr,r-rs r0rzCriterion._compareJsPSPSr2Self | ComplexCriterioncRt|tr|St|||Sr,)r8rrrs r0rzCriterion._compareMs+ e^ , , K D%888r2cB|tj|Sr,)rrand_rvs r0__and__zCriterion.__and__R}}W\5111r2cB|tj|Sr,)rror_rvs r0__or__zCriterion.__or__Us}}W[%000r2cB|tj|Sr,)rrxor_rvs r0__xor__zCriterion.__xor__Xr!r2r-termsIterable[Term](EmptyCriterion | Term | ComplexCriterionc6t}|D]}||z}|Sr,rr(critrs r0anyz Criterion.any[,  D DLDD r2 Iterable[Any]'EmptyCriterion | Any | ComplexCriterionc6t}|D]}||z}|Sr,r,r-s r0allz Criterion.alldr0r2rKctr,r,r.s r0r#zCriterion.get_sqlmr/r2N)rrrsrr)r!)rrrsr r)r)rrrsr r)r)rsr r)r)r-)r(r)r)r*)r(r1r)r2r3) r>r?r@rrr r$r'r6r/r4r#r-r2r0rrFs RRRXR SSSXS9999 222211112222\\$$$$$$r2rcNeZdZdZeZd dZd dZd dZd d Z d d Z dS)rNr)rTctSr,)rRr.s r0rWzEmptyCriterion.fields_us uu r2rsr c|Sr,r-rvs r0r zEmptyCriterion.__and__x r2c|Sr,r-rvs r0r$zEmptyCriterion.__or__{r9r2c|Sr,r-rvs r0r'zEmptyCriterion.__xor__~r9r2c|Sr,r-r.s r0rzEmptyCriterion.__invert__rr2r1)rsr r)r )r)r ) r>r?r@rArRrSrWr r$r'rr-r2r0rrqsLceeGr2rcJeZdZddfd Zdd ZeddZddZxZS)rVNnamerKrDrErrr)rFct|||_t|trddlm}||}||_dS)NrHrrP)rErJr>r8rKpypika.queriesr$r)r/r>rDrr$rHs r0rJzField.__init__sa u%%% eS ! ! ! , , , , , ,E%LLE.3 r2r*c#bK|V|j!|jEd{VdSdSr,rr1r.s r0r1z Field.nodes_K : !z((** * * * * * * * * * " !r2rmrnroc8|j|kr|n|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. Nrrqs r0rrzField.replace_tables!#'* "="=YY4: r2r*r c |dd}|dd}|dd}t|j|}|jrL|s |jjr>|j}dt|||}t|dd}|rt||fd|i|S|S)Nr&Fr'r z{namespace}.{name}) namespacer>rD) poprr>rrDget_table_namer~getattrr)r/r*r&r'r  field_sql table_name field_aliass r0r#z Field.get_sqlsZZ e44 $4e<<ZZ d33 !$)Z88  : > TZ-= 2244J,33' J??4I dGT22  ]#I{\\z\U[\\ \r2r)r>rKrDrErrr)rFr=rmrnrornr)rFr4 r>r?r@rJr1rrrr#rTrUs@r0rVrVs4444444++++   N N N W Nr2rVc,eZdZd dfd Zd dd ZxZS)IndexNr>rKrDrEr)rFcXt|||_dSr,rErJr>)r/r>rDrHs r0rJzIndex.__init__&  r2r r*r c ,t|j|Sr,)rr>rs r0r#z Index.get_sqlsTY 333r2r,)r>rKrDrEr)rFrrrUs@r0rRrRs[444444444r2rRc6eZdZddfd ZddZ dddZxZS)StarNrrr)rFcNtd|dS)N*rFr )r/rrHs r0rJz Star.__init__s& E*****r2r*c#bK|V|j!|jEd{VdSdSr,rBr.s r0r1z Star.nodes_rCr2Fr&rjr'r rEr*r rKc |jrR|s |jjrD|jjpt|jd}dt ||SdS)N _table_namez{}.*rZ)rrDrKr~r)r/r&r'r r*rHs r0r#z Star.get_sqls` : G> GTZ-= G (NGDJ ,N,NI==y*!E!EFF Fsr2r,)rrr)rFr=)FFN) r&rjr'rjr rEr*r r)rKr>r?r@rJr1r#rTrUs@r0rXrXsv+++++++++++ `dr2rXc`eZdZdfd ZddZdd Zedd ZeddZ xZ S)r`valuesr r)rFcptfd|D_dS)Nc:g|]}|Sr-rrs r0r;z"Tuple.__init__..s'EEEUt))%00EEEr2)rErJr`)r/r`rHs` r0rJzTuple.__init__s9 EEEEfEEE r2r*c#ZK|V|jD]}|Ed{VdSr,)r`r1rs r0r1z Tuple.nodes_sM [ & &E||~~ % % % % % % % % & &r2r*rKc ddfd|jD}t||jfiS)N({})rc32K|]}|jdiVdSNr-r"r9rr*s r0 z Tuple.get_sql..s5$T$T\T\%;%;F%;%;$T$T$T$T$T$Tr2)r~rr`rrDr/r*rs ` r0r#z Tuple.get_sqlsQmmCHH$T$T$T$T $T$T$TTTUUTZ::6:::r2rjc>td|jDS)Ncg|] }|j Sr-rA)r9rbs r0r;z&Tuple.is_aggregate..s$M$M$M#S%5$M$M$Mr2)rr`r.s r0rAzTuple.is_aggregates!#$M$M$M$M$MNNNr2rmrnroc<fd|jD|_dS)rEc<g|]}|Sr-rr)r9rrmros r0r;z'Tuple.replace_table..s)^^^u**=)DD^^^r2N)r`rqs ``r0rrzTuple.replace_tables-_^^^^RVR]^^^ r2)r`r r)rFr=r4r)rjrO) r>r?r@rJr1r#r5rArrrrTrUs@r0r`r`sFFFFFF&&&& ;;;;OOOXO  _ _ _ W _ _ _ _ _r2r`ceZdZddZdS)r^r*r r)rKc Rd}dfd|jD}d|}|tjtjfvr*t|dkrd|nd}t||j fiS)Ndialectrc32K|]}|jdiVdSrgr"rhs r0riz Array.get_sql..s5IIT,$,0000IIIIIIr2z[{}]rz ARRAY[{}]z'{}') rrr`r~r POSTGRESQLREDSHIFTrarrD)r/r*rtr`rs ` r0r#z Array.get_sqls**Y''IIIIT[IIIIImmF## x*H,=> > >03F a+$$V,,,VCTZ::6:::r2Nr4rxr-r2r0r^r^s(;;;;;;r2r^c eZdZdfd ZxZS)Bracketrr r)rFcJt|dSr,r rs r0rJzBracket.__init__s! r2)rr r)rFrrUs@r0ryrys=r2rycfeZdZ ddfd ZddZed dZed!dZd"d#dZ xZ S)$NestedCriterionNrrnested_comparatorrleftr rightnestedrDrEr)rFct|||_||_||_||_||_dSr,)rErJr~rr}rr)r/rr}r~rrrDrHs r0rJzNestedCriterion.__init__sE  $!2  r2r*c#K|V|jEd{V|jEd{V|jEd{VdSr,)rr1r~rr.s r0r1zNestedCriterion.nodes_s :$$&&&&&&&&&9##%%%%%%%%%;%%'''''''''''r2rcXtd|j|j|jfDS)Ncg|] }|j Sr-rmr9rs r0r;z0NestedCriterion.is_aggregate..s$h$h$h4T%6$h$h$hr2)rr~rrr.s r0rAzNestedCriterion.is_aggregates.#$h$hDItz[_[fCg$h$h$hiiir2rmrnroc|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)r~rrrrrqs r0rrzNestedCriterion.replace_table!sSI++M9EE Z--mYGG j..}iHH r2Fr&rjr*rKc d|jjdi||jj|jjdi||jj|jjdi|}|rtd||j d|S|S)Nz4{left}{comparator}{right}{nested_comparator}{nested})r~rrr}r)rrDr-) r~r~r#rrrr}rrrDr/r&r*rs r0r#zNestedCriterion.get_sql1sDKK"",,V,,,$$*$..v.."4:&4;&0000 L    I#H4:HHHH H r2r,)rrr}rr~r rr rr rDrEr)rFr=rrOFr&rjr*r r)rK r>r?r@rJr1r5rArrrr#rTrUs@r0r|r|s! (((( jjjXj  I I I W I         r2r|cdeZdZddfd Zdd Zed dZed!dZd"d#dZ xZ S)$rtNrrr~rCrrDrEr)rFctt|||_||_||_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)rErJrr~r)r/rr~rrDrHs r0rJzBasicCriterion.__init__As6 $  r2r*c#K|V|jEd{V|jEd{VdSr,)rr1r~r.s r0r1zBasicCriterion.nodes_Tsa :$$&&&&&&&&&9##%%%%%%%%%%%r2rcLtd|j|jfDS)Ncg|] }|j Sr-rmrs r0r;z/BasicCriterion.is_aggregate..[s$[$[$[4T%6$[$[$[r2)rr~rr.s r0rAzBasicCriterion.is_aggregateYs(#$[$[DItzCZ$[$[$[\\\r2rmrnroc|j|||_|j|||_dSrr~rrrrqs r0rrzBasicCriterion.replace_table]:I++M9EE Z--mYGG r2rFr rKr&rjr*r c d|jj|jjdd|i||jjdd|i|}|rt ||jfi|S|S)Nz{left}{comparator}{right}r rr~rr-)r~rrr~r#rrrD)r/r r&r*rs r0r#zBasicCriterion.get_sqlls)00,""CCjCFCC$$*$EE EfEE1    ?#C>>v>> > r2r,) rrr~rCrrCrDrEr)rFr=rrO)rF)r rKr&rjr*r r)rKrrUs@r0rtrt@s&&&&& ]]]X]  H H H W Hr2rtc|eZdZddfd Zdd ZeddZeddZdddZ eddZ xZ S)rNrr containerrCrDrEr)rFctt|||_||_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)rErJrr _is_negated)r/rrrDrHs r0rJzContainsCriterion.__init__xs9  " r2r*c#K|V|jEd{V|jEd{VdSr,)rr1rr.s r0r1zContainsCriterion.nodes_sa 9##%%%%%%%%%>((***********r2rc|jjSr,rr.s r0rAzContainsCriterion.is_aggregaterr2rmrnrocF|j|||_dSrrrrrqs r0rrzContainsCriterion.replace_table!I++M9EE r2subqueryr*rKc d|jjdi||jjdddi||jrdnd}t ||jfi|S)Nz{term} {not_}IN {container}rTNOT r)rrnot_r-)r~rr#rrrrD)r/rr*rs r0r#zContainsCriterion.get_sqls|+22"",,V,,,dn,EEdEfEE+33    TZ::6:::r2cd|_dSNTrr.s r0r~zContainsCriterion.negatesr2r,)rr rrCrDrEr)rFr=rrO)rr r*r r)rK)r)r) r>r?r@rJr1r5rArrrr#r~rTrUs@r0rrws!!!!!!! ++++ &&&X&  F F F W F;;;;;     W     r2rc,eZdZdfd ZdZdZxZS)ExistsCriterionNcft|||_d|_dSNF)rErJrr)r/rrDrHs r0rJzExistsCriterion.__init__s0 " r2c bd|jjdi||jrdndS)Nz{not_}EXISTS {container}rr)rrr-)r~rr#rr.s r0r#zExistsCriterion.get_sqlsF)00,dn,66v66tGW=_VV]_1   r2cd|_|Srrr.s r0r~zExistsCriterion.negates r2r,)r>r?r@rJr#r~rTrUs@r0rrs[!!!!!!    r2rcBeZdZddfd Zdd ZeddZxZS)RangeCriterionNrrCrr rrDrEr)rKctt|||_||_||_dSr,)rErJrrr)r/rrrrDrHs r0rJzRangeCriterion.__init__s4   r2r*c#K|V|jEd{V|jEd{V|jEd{VdSr,)rr1rrr.s r0r1zRangeCriterion.nodes_s 9##%%%%%%%%%:$$&&&&&&&&&8??$$$$$$$$$$$r2rc|jjSr,rr.s r0rAzRangeCriterion.is_aggregaterr2r,) rrCrr rr rDrEr)rKr=r)r>r?r@rJr1r5rArTrUs@r0rrsv %%%% &&&X&&&&&r2rc.eZdZed dZd d Zd S)rrmrnror)rFcF|j|||_dSrrrqs r0rrzBetweenCriterion.replace_tablerr2r*r rKc d|jjdi||jjdi||jjdi|}t ||jfi|S)Nz {term} BETWEEN {start} AND {end}rrrr-r~rr#rrrrDrjs r0r#zBetweenCriterion.get_sqls077"",,V,,$$*$..v..  **6**8    TZ::6:::r2NrOr4)r>r?r@rrrr#r-r2r0rrsJ  F F F W F;;;;;;r2rceZdZddZdS)rr*r r)rKc d|jjdi||jjdi||jjdi|}t ||jfi|S)Nz{term} FROM {start} TO {end}rr-rrjs r0r#zPeriodCriterion.get_sqls,33"",,V,,$$*$..v..  **6**4    TZ::6:::r2Nr4rxr-r2r0rrs(;;;;;;r2rcJeZdZddfd Zdd ZeddZddZxZS)rNrrCrr rDrEr)rFcft|||_||_dSr,rErJrrr/rrrDrHs r0rJzBitwiseAndCriterion.__init__-   r2r*c#K|V|jEd{V|jEd{VdSr,rr1rr.s r0r1zBitwiseAndCriterion.nodes_a 9##%%%%%%%%%:$$&&&&&&&&&&&r2rmrnrocF|j|||_dSrrrqs r0rrz!BitwiseAndCriterion.replace_tablerr2r*rKc d|jjdi||j}t ||jfi|S)Nz({term} & {value})rrr-r~rr#rrrDrjs r0r#zBitwiseAndCriterion.get_sql U"))"",,V,,**   TZ::6:::r2r,rrCrr rDrEr)rFr=rOr4rPrUs@r0rr ''''   F F F W F;;;;;;;;r2rcJeZdZddfd Zdd ZeddZddZxZS)rNrrCrr rDrEr)rFcft|||_||_dSr,rrs r0rJzBitwiseOrCriterion.__init__rr2r*c#K|V|jEd{V|jEd{VdSr,rr.s r0r1zBitwiseOrCriterion.nodes_rr2rmrnrocF|j|||_dSrrrqs r0rrz BitwiseOrCriterion.replace_tablerr2r*rKc d|jjdi||j}t ||jfi|S)Nz({term} | {value})rr-rrjs r0r#zBitwiseOrCriterion.get_sql*rr2r,rr=rOr4rPrUs@r0rrrr2rcLeZdZddfd Zdd ZeddZdddZxZS)ryNrrCrDrEr)rFcXt|||_dSr,rr/rrDrHs r0rJzNullCriterion.__init__3rUr2r*c#PK|V|jEd{VdSr,rr1r.s r0r1zNullCriterion.nodes_7; 9##%%%%%%%%%%%r2rmrnrocF|j|||_dSrrrqs r0rrzNullCriterion.replace_table;rr2Fr&rjr*r rKc td|jjdi|}t||jfi|S)Nz{term} IS NULLrr-r~rr#rrDrs r0r#zNullCriterion.get_sqlIsP%%"",,V,,&   TZ::6:::r2r,)rrCrDrEr)rFr=rOrrrPrUs@r0ryry2s&&&&  F F F W F;;;;;;;;;r2ryceZdZd d dZd S) rFr&rjr*r r)rKc td|jjdi|}t||jfi|S)Nz{term} IS NOT NULLrr-rrs r0r#zNotNullCriterion.get_sqlQsP"))"",,V,,*   TZ::6:::r2Nrrrxr-r2r0rrPs-;;;;;;;r2rc eZdZd ddZdd Zd S)rF subcriterionrjr*r r)rKc "d|jj|jjdd||ji||jjdd||ji|}|rd|S|S)Nz{left} {comparator} {right}rrz ({criterion})) criterionr-)r~rrr~r#needs_bracketsr)r/rr*rs r0r#zComplexCriterion.get_sqlYs+22,""YY0C0CDI0N0NYRXYY$$*$\\$2E2Edj2Q2Q\U[\\3    9"))C)88 8 r2rrCcNt|to|j|jk Sr,)r8rrr/rs r0rzComplexCriterion.needs_bracketses$$ 011\$/T_:\6\\r2Nr)rrjr*r r)rK)rrCr)rj)r>r?r@r#rr-r2r0rrXsG     ]]]]]]r2rceZdZdZejejgZddfd ZddZ e d dZ e d!dZ d"dZd"dZd#d$dZxZS)%rz Wrapper for an arithmetic function. Can be simple with two terms or complex with nested terms. Order of operations are also preserved. Noperatorrr~r rrDrEr)rFctt|||_||_||_dS)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)rErJrr~r)r/rr~rrDrHs r0rJzArithmeticExpression.__init__qs6     r2r*c#K|V|jEd{V|jEd{VdSr,)r~r1rr.s r0r1zArithmeticExpression.nodes_rr2rcLt|jj|jjgSr,)rr~rArr.s r0rAz!ArithmeticExpression.is_aggregates!$TY%;TZ=T$UVVVr2rmrnroc|j|||_|j|||_dS)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. Nrrqs r0rrz"ArithmeticExpression.replace_tablerr2rjc2|dS||jvrdS||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_ops r0left_needs_parensz&ArithmeticExpression.left_needs_parenss/ ?5 dn $ $5 $.((r2cd|dS|tjkrdS|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/rright_ops r0right_needs_parensz'ArithmeticExpression.right_needs_parenssB  5 jn $ $5 jn $ $4 4>))r2Fr&r*rKc d|j|jfD\}}d|jj||j|rdnd|jjdi|||j|rdnd|jjdi|}|rt||j fi|S|S)Nc0g|]}t|ddS)rN)rK)r9sides r0r;z0ArithmeticExpression.get_sql..s$aaaWT:t<<aaar2z{left}{operator}{right}rez{})rr~rr-) r~rr~rrrr#rrrD)r/r&r*rrarithmetic_sqls r0r#zArithmeticExpression.get_sqlsaa$)UYU_I`aaa299]( 224='JJT&&PT\\! !++F++"44T]HMMW66SW__" ",,V,, :    J#NDJII&II Ir2r,) rrr~r rr rDrEr)rFr=rrOrqrr)r>r?r@rrrrrrJr1r5rArrrrrr#rTrUs@r0rris 0I*'''' WWWXW  H H H W H))))*****,r2rceZdZddfd ZddZedd ZeddZeddZ ed dZ d!d"dZ xZ S)#CaseNrDrEr)rFcht|g|_d|_dSNrH)rErJ_cases_elser s r0rJz Case.__init__s0 u%%%  r2r*c#K|V|jD]9\}}|Ed{V|Ed{V:|j!|jEd{VdSdSr,)rr1rr/rrs r0r1z Case.nodes_s #{ % %OIt '')) ) ) ) ) ) ) ){{}} $ $ $ $ $ $ $ $ : !z((** * * * * * * * * * " !r2rcltd|jD|jr |jjndgzS)Nc0g|]\}}|jp|jSr-rm)r9rrs r0r;z%Case.is_aggregate..s' \ \ \_YY # 8t'8 \ \ \r2)rrrrAr.s r0rAzCase.is_aggregatesH$ \ \PTP[ \ \ \*.*>tz&&$? @   r2rr rcd|j|||fdSr,)rrhrcrs r0whenz Case.whens1 It'9'9$'?'?@AAAAAr2rmrnrocfd|jD|_|jr|jnd|_dS)rcng|]1\}}||g2Sr-rp)r9rrrmros r0r;z&Case.replace_table..sW    4'' yAA""=)<<    r2N)rrrrrqs ``r0rrzCase.replace_tablese     $(;     LP:_TZ--mYGGG[_ r2c:|||_|Sr,)rcrrs r0else_z Case.else_s''--  r2Fr&rjr*rKc |jstddfd|jD}|jr%d|jjdind}d||d}|rt ||jfiS|S) Nz:At least one 'when' case is required for a CASE statement. c 3xK|]4\}}d|jdi|jdiV5dS)zWHEN {when} THEN {then})rthenNr-)r~r#)r9rrr*s r0rizCase.get_sql..sx   4 & , ,2C)2C2M2Mf2M2MT`TXT`TjTjciTjTj , k k      r2z ELSE {}rzCASE z ENDr-)rrrrr~r#rrD)r/r&r*casesrcase_sqls ` r0r#z Case.get_sqls{ ^ \]] ]    #';     DH:U !!"4$*"4">">v">">???SU-5-%---  D#HdjCCFCC Cr2r,r0r=r)rr rr r)rFrO)rr r)rrr) r>r?r@rJr1r5rArrrrrr#rTrUs@r0rrs ++++   X  BBB WB ``` W`(  Wr2rcbeZdZddfd Zdd Zdd ZeddZeddZ xZ S)r|Nrr rDrEr)rFcZt|||_dSrrrs r0rJz Not.__init__&) u%%% r2r*c#PK|V|jEd{VdSr,rr.s r0r1z Not.nodes_*rr2r*rKc ~d|d<d|jjdi|}t||jfi|S)NTrz NOT {term}rr-rrjs r0r#z Not.get_sql.sR!%~!!'8ty'8'B'B6'B'B!CCTZ::6:::r2r>cht|j|tjsSfd}|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. cj|g|Ri|}t|tfrt|S|Sr,)r8rCr|) inner_selfargsr*result item_funcs r0innerzNot.__getattr__..inner>sGYz;D;;;F;;F&4'** #6{{"Mr2)rKrinspectismethod)r/r>rrs @r0 __getattr__zNot.__getattr__3sO DIt,,  **         r2rmrnrocF|j|||_dSrrrqs r0rrzNot.replace_tableFrr2r,rr rDrEr)rFr=r4)r>rKr)r rO) r>r?r@rJr1r#rrrrrrTrUs@r0r|r|%s&&&&;;;; [$  F F F W F F F F Fr2r|c2eZdZddfd Zdd Zdd ZxZS)rNrr rDrEr)rFcZt|||_dSrrrs r0rJz All.__init__Vr r2r*c#PK|V|jEd{VdSr,rr.s r0r1z All.nodes_Zrr2r*rKc td|jjdi|}t||jfi|S)Nz {term} ALLrr-rrjs r0r#z All.get_sql^sH!!'8ty'8'B'B6'B'B!CCTZ::6:::r2r,rr=r4r^rUs@r0rrUsj&&&&;;;;;;;;r2rc,eZdZdddZdd ZdZdZdS)CustomFunctionNr>rKparamsSequence | Noner)rFc"||_||_dSr,)r>r )r/r>r s r0rJzCustomFunction.__init__ds  r2rr r*Functionc |s)t|j|dS|j|sit d|jdd|jDdd|Dt|jg|Rd|diS)NrDrHzCFunction {name} require these arguments ({params}), ({args}) passedz, c34K|]}t|VdSr,r:r9ps r0riz*CustomFunction.__call__..ps($A$ASVV$A$A$A$A$A$Ar2c34K|]}t|VdSr,r:r&s r0riz*CustomFunction.__call__..qs("8"8a3q66"8"8"8"8"8"8r2)r>r r) _has_paramsr#r>r_is_valid_function_callrr~rr )r/rr*s r0__call__zCustomFunction.__call__hs!! BDIVZZ-@-@AAA A+t+T2 #U\\99$A$AT[$A$A$AAA"8"84"8"8"888]  DDDDD 70C0CDDDr2c|jduSr,)r r.s r0r)zCustomFunction._has_paramsws{$&&r2cLt|t|jkSr,)rar )r/rs r0r*z&CustomFunction._is_valid_function_callzs4yyC ,,,,r2r,)r>rKr r!r)rF)rr r*r r)r#)r>r?r@rJr+r)r*r-r2r0rrcsc E E E E'''-----r2rceZdZdfd Zdd Zedd ZeddZddZ e dZ ddZ ddZ xZS)r#r>rKrr r*r)rFct|d|_fd|D_|d_dS)NrDc:g|]}|Sr-r)r9r>r/s r0r;z%Function.__init__..s'AAA5T''..AAAr2schema)rErJrr>rr1r/r>rr*rHs` r0rJzFunction.__init__sa G,,--- AAAADAAA jj** r2r*c#ZK|V|jD]}|Ed{VdSr,)rr1rs r0r1zFunction.nodes_sM 9 $ $Czz|| # # # # # # # # $ $r2rc>td|jDS)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. cg|] }|j Sr-rm)r9rs r0r;z)Function.is_aggregate..s$K$K$K#S%5$K$K$Kr2)rrr.s r0rAzFunction.is_aggregates#$$K$K$K$K$KLLLr2rmrnroc<fd|jD|_dS)rc<g|]}|Sr-rp)r9r>rmros r0r;z*Function.replace_table..s)ZZZuU(( BBZZZr2Nrrqs ``r0rrzFunction.replace_tables-[ZZZZPTPYZZZ r2c dSr,r-r.s r0get_special_params_sqlzFunction.get_special_params_sqlrOr2c ^t|dr|jdddi|nt|S)Nr#r&Fr-hasattrr#rK)rr*s r0 get_arg_sqlzFunction.get_arg_sqls=:A#y:Q:Q_{s{66e6v666WZ[^W_W__r2c jdi}djdfdjD|rd|zndS)Nz{name}({args}{special})rc3tK|]2}t|dr|jddddn j|fiV3dS)r#FT)r&rNr-)r=r#r>)r9r'r*r/s r0riz,Function.get_function_sql..s~ q),,7IAIHHHHHH))!66v66 r2rr)r>rspecialr-)r:r~r>rr)r/r*special_params_sqls`` r0get_function_sqlzFunction.get_function_sqls8T8BB6BB(//  3ELS---"0   r2c v|dd}|dd}|dd}|dd}||||}|j*d|jjd ||d|| }|rt ||jfd|i|S|S) Nr&Fr'r rt)r'r rtz{schema}.{function})r rt)r1functionr-)rIrCr1r~r#rrD)r/r*r&r'r rt function_sqls r0r#zFunction.get_sqlsZZ e44 $4e<<ZZ d33 **Y--,,NWakr,ss ; "077*t{*\j'\\U[\\%8L  _#L$*^^^W]^^ ^r2r>rKrr r*r r)rFr=rrO)r*r r)r r4)r>r?r@rJr1r5rArrrr:r6r>rCr#rTrUs@r0r#r#~s++++++ $$$$ MMMXM  [ [ [ W [    ``\`    r2r#cNeZdZdZfdZed dZd d Zdfd ZxZ S)AggregateFunctionTc^tj|g|Ri|g|_d|_dSr)rErJ_filters_include_filterr2s r0rJzAggregateFunction.__init__s?/////// $r2filtersr r)rFc4d|_|xj|z c_dSr)rLrK)r/rMs r0filterzAggregateFunction.filters#  r2r*rKc |jr=dt|jjdi|SdS)NzWHERE {criterions}) criterionsr-)rLr~rr4rKr#r.s r0get_filter_sqlz AggregateFunction.get_filter_sqlsQ   j'..)-- :V:V:^:h:hag:h:h.ii i j jr2c tjdi|}|jdi|}|jr|d|z }|S)Nz FILTER({filter_sql})) filter_sqlr-)rErCrRrLr~)r/r*rrTrHs r0rCz"AggregateFunction.get_function_sqlsd&egg&0000(T(22622   I *11Z1HH HC r2)rMr r)rFr4)r*r ) r>r?r@rArJrrOrRrCrTrUs@r0rIrIsL%%%%%  !!! W!jjjjr2rIcteZdZdZdZdfd Zedd Zedd ZddZ ddZ dfd Z xZ S)AnalyticFunctionFTr>rKrr r*r)rFctj|g|Ri|g|_g|_g|_d|_d|_dSr)rErJrK _partition _orderbysrL _include_overr2s r0rJzAnalyticFunction.__init__sU/////// $"r2r(c4d|_|xj|z c_dSr)rZrX)r/r(s r0overzAnalyticFunction.overs! 5 r2cNd|_|xjfd|Dz c_dS)NTc>g|]}|dfS)order)rrhs r0r;z,AnalyticFunction.orderby..s*III4D&**W"5"56IIIr2)rZrY)r/r(r*s `r0orderbyzAnalyticFunction.orderbys4! IIII5IIIIr2rrVorient Order | Nonec n| |jdi|Sd|jdi||jS)Nz{field} {orient})rrar-)r#r~r)r/rrar*s r0_orderby_fieldzAnalyticFunction._orderby_fieldsV > 5=**6** *!((%-))&))<)   r2c g}jrM|ddfdjDjrN|ddfdjDd|S) NzPARTITION BY {args}rc3pK|]0}t|dr |jdint|V1dS)r#Nr-r<)r9r'r*s r0riz5AnalyticFunction.get_partition_sql..sT!t!t_`I9N9N"Z)!)"5"5f"5"5"5TWXYTZTZ!t!t!t!t!t!tr2r8zORDER BY {orderby}c3<K|]\}}j||fiVdSr,)rd)r9rrar*r/s r0riz5AnalyticFunction.get_partition_sql..sB$v$vVcV[]c%8T%8%Q%Q&%Q%Q$v$v$v$v$v$vr2)r`r)rXrhr~rrY)r/r*r(s`` r0get_partition_sqlz"AnalyticFunction.get_partition_sql s ?  LL%,,!t!t!t!tdhds!t!t!ttt-    >  LL$++HH$v$v$v$v$vgkgu$v$v$vvv,    xxr2c xtjdi|}|jdi|}|}|jr |d|dz }|S)Nz OVER()r-)rErCrhrZ)r/r*rF partition_sqlrrHs r0rCz!AnalyticFunction.get_function_sqlsb/uww/99&99 ..8888    - ,M,,, ,C r2rGr(r r)rF)r(r r*r r)rF)rrVrarbr*r r)rKr4) r>r?r@rA is_analyticrJrr\r`rdrhrCrTrUs@r0rVrVsLK###### !!! W! JJJ WJ    $r2rVEdgeT WindowFrameAnalyticFunction.EdgeceZdZGddZdfd ZddZedddZedddZddZ dfd Z xZ S)WindowFrameAnalyticFunctionc eZdZd d dZd dZdS) roNrstr | int | Noner)rFc||_dSr,rrs r0rJz)WindowFrameAnalyticFunction.Edge.__init__+s DJJJr2rKcHd|jpd|jS)Nz{value} {modifier} UNBOUNDED)rmodifier)r~rrwr.s r0r$z(WindowFrameAnalyticFunction.Edge.__str__.s.'..j/K/ r2r,)rrsr)rFr3)r>r?r@rJr$r-r2r0Edgez WindowFrameAnalyticFunction.Edge*sA           r2rxr>rKrr r*r)rFc^tj|g|Ri|d|_d|_dSr,)rErJframer'r2s r0rJz$WindowFrameAnalyticFunction.__init__4s<///////  r2rzr' and_bound EdgeT | Nonecf|js|jrt||_|r||fn||_dSr,)rzr'AttributeError)r/rzr'r{s r0_set_frame_and_boundsz1WindowFrameAnalyticFunction._set_frame_and_bounds9sB : # # "" " +4?eY''% r2N str | EdgeTc4|d||dS)NROWSrr/r'r{s r0rowsz WindowFrameAnalyticFunction.rows@s  ""65)<<<<r?r@rxrJrrrrrrhrTrUs@r0rqrq)s @@@@ ==== W= >>>> W>     WWWWWWWWWWr2rqc@eZdZd fd Zed d Zdd ZxZS)IgnoreNullsAnalyticFunctionr>rKrr r*r)rFcPtj|g|Ri|d|_dSr)rErJ _ignore_nullsr2s r0rJz$IgnoreNullsAnalyticFunction.__init__]s8///////"r2cd|_dSrrr.s r0 ignore_nullsz(IgnoreNullsAnalyticFunction.ignore_nullsas!r2rEc |jrdSdS)Nz IGNORE NULLSrr.s r0r:z2IgnoreNullsAnalyticFunction.get_special_params_sqles   "!>tr2rG)r)rF)r*r r)rE)r>r?r@rJrrr:rTrUs@r0rr\sq###### """ W"r2rc eZdZejdejdejdejdejdiZ gdZ gdZ e j dZ dddZddZddZdS)IntervalINTERVAL '{expr} {unit}'zINTERVAL '{expr}' {unit}yearsmonthsdayshoursminutesseconds microseconds)YEARMONTHDAYHOURMINUTESECOND MICROSECONDz6(^0+\.)|(\.0+$)|(^[0\-.: ]+[\-: ])|([\-:. ][0\-.: ]+$)rNrrirrrrrrquartersweeksrtDialects | Nonec Z| |_d|_d|_d|_|r ||_dS| r | |_dSt |j|j|||||||gD]U\} } } | rMt| }t|| t||j| |_|dk|_| |_VdS)NFr) rtlargestsmallest is_negativerrzipunitslabelsrisetattrabs)r/rrrrrrrrrrtunitlabelr int_values r0rJzInterval.__init__}s      $DM F  DJ F"% J K FD%'< H# # & & D%  &JJ dC NN333<'#(DL'01}D$ %  & &r2r)rKc*|Sr,r"r.s r0r$zInterval.__str__s||~~r2r*r c 6|jp|d}|jdkrt|d}d}n/t |drt|d}d}n t |drt|d}d}ndt|d d t|d d t|d d t|d d t|dd t|dd t|dd }|jd|}|jrd|z}|j|j kr!d|j|j n|j}|d}|j |d||S)NrtrrrQUARTERrWEEKzB{years}-{months}-{days} {hours}:{minutes}:{seconds}.{microseconds}rrrrrrrrr-z{largest}_{smallest})rrrr)rr) rtrrrKr=r~ trim_patternrrr templates)r/r*rtrrs r0r#zInterval.get_sqls,7&**Y"7"7 <= ( (400D DD T: & &" 4,,DDD T7 # # 4))DDDX^^dGQ//tXq11T61--dGQ//i33i33$T>1==_D$((T22D "Tz<4=00 '-- L!]. \ |~!!'+EFFMMSW^bMcccr2) rrrrrrrrrN)rrirrirrirrirrirrirrirrirrirtrr3r4)r>r?r@rrvrwVERTICAORACLEMYSQLrrrrecompilerrJr$r#r-r2r0rrms 75432I W V VE P P PF2:WXXL#'%&%&%&%&%&N+d+d+d+d+d+dr2rc"eZdZd d fd ZxZS) rNrrCexponentrrDrEr)rFcRtd|||dS)NPOWrHr )r/rrrDrHs r0rJz Pow.__init__s* he<<<<rKr)rFcZtd||_dSrrT)r/r>rHs r0rJzPseudoColumn.__init__s) t$$$ r2r*r c |jSr,)r>r.s r0r#zPseudoColumn.get_sqls yr2)r>rKr)rFr4)r>r?r@rrJr#rTrUs@r0rrs[ r2rc.eZdZdZdZdfd ZdZxZS) AtTimezonez| Generates AT TIME ZONE SQL. Examples: AT TIME ZONE 'US/Eastern' AT TIME ZONE INTERVAL '-06:00' NFct|t|tst|n||_||_||_dSr,)rErJr8rVrzoneinterval)r/rrrrDrHs r0rJzAtTimezone.__init__sM )3E5)A)ALU5\\\u    r2c d|jjdi||jrdnd|j}t ||jfi|S)Nz&{name} AT TIME ZONE {interval}'{zone}'z INTERVAL r)r>rrr-)r~rr#rrrrDrjs r0r#zAtTimezone.get_sqlsd8??##--f--$(M9[[r@    TZ::6:::r2)FN)r>r?r@rrArJr#rTrUs@r0rrs]L!!!!!! ;;;;;;;r2r)r7rir)rK)i __future__rrrsysrcollections.abcrrrrr rr enumr typingr r rr pypika.enumsrrrrrrrr pypika.utilsrrrrrrr version_infotyping_extensionsr!r@r"r#r$ __author__ __email__r%r&rCr<r?rArWrmrurzrrrrrarrkrrr\rrrrVrRrXr`r^ryr|rtrrrrrrrryrrrrr|rrr#rIrVrnrqrrrrrrrr-r2r0rs """""" BBBBBBBBBBBB))))))))))888888888888llllllllllllllllllll? '!!*******>>>>>>>>>>   v&&&JJJJJJJJ{${${${${$4{${${$|*'''''I'''&,,,,,I,,,,] EEEEE}EEEmEEEEE]EEE!!!!! !!! B B B B Bt B B B7X7X7X7X7X47X7X7Xt $ $ $ $ $L $ $ $<O<O<O<O<O4<O<O<O~cccccTcccCCCCC4CCC((((( ((( /////l/// ($($($($($($($($VY(00000It000f44444D4445&_____I___B ; ; ; ; ;E ; ; ;e 77777i777t44444Y444n2 2 2 2 2 2 2 2 j     i    &&&&&Y&&&$;;;;;~;;;0;;;;;n;;;;;;;;);;;B;;;;;;;;B;;;;;I;;;<;;;;;};;;]]]]]~]]]"qqqqq4qqqhEEEEE9EEEP-F-F-F-F-F)-F-F-F` ; ; ; ; ;) ; ; ;--------6MMMMMyMMM`899999(999x ABBB0W0W0W0W0W"20W0W0Wf"2"edededededtedededP=====(=== <<<<<(<<< +++++X+++     4   ;;;;;;;;;;r2