ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ U S¤ðWª¶ã3@s” ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlZddlZddl mZddl mZddlmZddlmZzddlmZWnek rÀeZYnXddlmZddlmZdd lmZd Zddd ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;dlmZWn(ek rŒGd?d@„d@ejƒZYnXe dA¡Z!e! "eƒ¡dBZ#e$fdCdD„Z%ej&ddEkZ'ej&ddFkZ(ej&ddE…dGkZ)e(r@ddl*Z*ddHlm+Z+ddIlm,Z,dJdK„Z-e.Z/e0Z1e.Z2e3e*dLƒZ4dMdK„Z5e6Z7d]dNdO„Z8n,e'rde9Z/e2Z1e:Z5dPdQ„Z4e;dRƒnendVdK„Z>zddWl?m@ZAWnek r²dZAYnXzddlBZBWnek rÚeAZBYnXeArôeAjCeBjCkrôeAZBzddXlDmEZEeE F¡Wnek r"YnXzddlGZGddYlGmHZIWnek rVdZGYnXzddlJZKWn>ek r¢zddlLZKWnek rœdZKYnXYnXz(ddZlMmNZNdd[lMmOZOdd\lMmPZPWn2ek rþd^d]d^„ZNd_d`„ZOdadb„ZPYnXz4ddclMmQZQdddlMmRZRddelMmSZSddflMmTZTWn&ek rZdZQZRZSZTYnXeBrŒeB UejVe.¡eB UejWe.¡eB Uej e.¡dgdhdidjdkdlgZXeYeXƒZZdmZ[dndo„Z\dpdqdrdsdtdudvœZ]e] ¡Z^dwe^dk<dxe^dl<dydz„Z_d{d|„Z`Gd}d~„d~eƒZaeadd€dd‚dƒd„d…d†d‡dˆd‰dŠd‹dŒddŽddd‘d’d“d”d•d–d—d˜Zbead™dšd›dœdZcecjdZeecjfZgecjhZidžZjdEZkdFZldŸZmd Znebjoebjpebjqebjrebjsebjtebjuebjvebjwebjxebjyd¡œZzd¢d£„Z{d¤d¥„Z|d¦d§„Z}Gd¨d3„d3e$ƒZ~Gd©d„de$ƒZGdªd«„d«e$ƒZ€Gd¬d„de$ƒZGd®d7„d7eƒZ‚e‚ZƒGd¯d°„d°eƒZ„Gd±d²„d²eƒZ…e…dƒZ†Gd³d´„d´eƒZ‡Gdµd.„d.eƒZˆGd¶d·„d·eˆƒZ‰Gd¸d„deƒZŠGd¹dº„dºeŠƒZ‹Gd»d¼„d¼e‹ƒZŒGd½d=„d=eƒZd¾d„ZŽGd¿d„deƒZGdÀdÁ„dÁeƒZedÂdÃƒZ‘GdÄdÅ„dÅedÆdÇƒƒZ’GdÈdÉ„dÉe$ƒZ“GdÊd„deƒZ”GdËd„de”ƒZ•GdÌd"„d"e”ƒZ–GdÍd„de–ƒZ—GdÎd5„d5e–ƒZ˜GdÏd1„d1e–ƒZ™GdÐdÑ„dÑe™ƒZšGdÒd„de”ƒZ›GdÓd„de›ƒZœGdÔd„de”ƒZd_dÖd×„ZžGdØd„de”ƒZŸGdÙd„deŸƒZ GdÚd8„d8e”ƒZ¡GdÛd „d e”ƒZ¢GdÜd<„d„d>eÜƒZàGd?d@„d@eÜƒZáGdAdB„dBeáƒZâGdCdD„dDe”ƒZãGdEdF„dFe$ƒZäeSdkrÈGdGdH„dHe$ƒZSGdId„deÉƒZåeBrìeÙdJƒZændZæGdKdL„dLe$ƒZçGdMdN„dNeèƒZéGdOd*„d*e%eéƒƒZêdPdQ„ZëdRdS„ZìedTdUƒZíGdVdW„dWeíƒZîdXd0„ZïdYdZ„Zðd[d\„ZñdS(`éN)Úbisect_left)Úbisect_right)Údeque)Ú namedtuple)ÚOrderedDict)Údeepcopy©Úwraps)Úisclassz2.8.4Ú BareFieldÚBigIntegerFieldÚ BlobFieldÚBooleanFieldÚ CharFieldÚCheckÚClauseÚCompositeKeyÚ DatabaseErrorÚ DataErrorÚ DateFieldÚ DateTimeFieldÚDecimalFieldÚDeferredRelationÚDoesNotExistÚDoubleFieldÚDQÚFieldÚFixedCharFieldÚ FloatFieldÚfnÚForeignKeyFieldÚImproperlyConfiguredÚIntegerFieldÚIntegrityErrorÚInterfaceErrorÚ InternalErrorÚJOINÚ JOIN_FULLÚ JOIN_INNERÚJOIN_LEFT_OUTERÚModelÚ MySQLDatabaseÚNotSupportedErrorÚOperationalErrorÚParamÚPostgresqlDatabaseÚprefetchÚPrimaryKeyFieldÚProgrammingErrorÚProxyÚRÚSmallIntegerFieldÚSqliteDatabaseÚSQLÚ TextFieldÚ TimeFieldÚTimestampFieldÚUsingÚ UUIDFieldÚWindow)ÚNullHandlerc@seZdZdd„ZdS)r>cCsdS©N©)ÚselfÚrecordr@r@ú9/opt/alt/python38/lib64/python3.8/site-packages/peewee.pyÚemitiszNullHandler.emitN)Ú__name__Ú __module__Ú__qualname__rDr@r@r@rCr>hsr>ÚpeeweeÚ_metaclass_helper_cCs|t|fiƒSr?)Ú_METACLASS_)ÚmetaÚbaser@r@rCÚwith_metaclassssrMéé)rNé)ÚCallable)ÚreducecCs t|tƒSr?)Ú isinstancerQ)Úcr@r@rCÚ}órUÚprintcCst| d¡ƒS©NÚraw_unicode_escape)ÚbytesÚencode©Úsr@r@rCrU‚rVcCs|j|k r| |¡‚|‚dSr?)Ú __traceback__Úwith_traceback)ÚtpÚvalueÚtbr@r@rCÚreraise„s rccCstj |¡tj d¡dS)NÚ )ÚsysÚstdoutÚwriter\r@r@rCÚprint_Œsrhz4def reraise(tp, value, tb=None): raise tp, value, tbzUnsupported python version.é@BcCs&|jd|j|jddttS)Ngéi)ÚmicrosecondsÚsecondsÚdaysÚ_M©Útr@r@rCrU•rVcCs| ¡Sr?)Ú total_secondsror@r@rCrU—rV)Údbapi2)Úcompat)Ú extensions)Úformat_date_time)Úsort_models_topologically)Ústrip_parensc CsH|p dd„}|D]2}z|tj ||¡ƒWStk r@YqXq|S)NcSs|Sr?r@©Úxr@r@rCrU¾rVz"format_date_time..)ÚdatetimeÚstrptimeÚ ValueError)raÚformatsÚpost_processÚfmtr@r@rCru½srucsTtˆƒ‰tƒ‰g‰‡‡‡‡fdd„‰dd„}tˆ|ddD]}ˆ|ƒq:ttˆƒƒS)z@Sort models topologically so that parents will precede children.csD|ˆkr@|ˆkr@ˆ |¡|jj ¡D]}ˆ|jƒq&ˆ |¡dSr?)ÚaddÚ_metaÚreverse_relÚvaluesÚmodel_classÚappend)ÚmodelÚforeign_key©ÚdfsÚmodelsÚorderingÚseenr@rCr‰Ës z&sort_models_topologically..dfscSs|jj|jjfSr?)rÚnameÚdb_table)Úmr@r@rCrUÒrVz+sort_models_topologically..T)ÚkeyÚreverse)ÚsetÚsortedÚlistÚreversed)rŠÚnamesrr@rˆrCrvÆs rvcCsò|r|ddkr|Sd}}t|ƒ}||krf||dkrf||ddkrf|d7}|d7}|d8}q$qfq$|rØd}d}t|||ƒD]N}||dkrš|d7}n||dkr®|d8}|dkrÂ|d7}d}||kr€qÐq€||8}|dkrî|||…S|S)Nrú(éú))ÚlenÚrange)r]ÚctÚiÚlÚ unbalanced_ctÚrequiredr@r@rCrw×s6 rw)Ú_DictQueryResultWrapper)Ú_ModelQueryResultWrapper)Ú_SortedFieldList)Ú_TuplesQueryResultWrapperÚyearÚmonthÚdayÚhourÚminuteÚsecond)ú%Y-%m-%d %H:%M:%Sú%Y-%m-%d %H:%M:%S.%fú%Y-%m-%dú%H:%M:%Sú%H:%M:%S.%fú%H:%McCs(|tkst‚|sdSt|tƒ}t||ƒSr?)ÚDATETIME_LOOKUPSÚAssertionErrorruÚSQLITE_DATETIME_FORMATSÚgetattr©Úlookup_typeÚdatetime_stringÚdtr@r@rCÚ_sqlite_date_parts r¹z%Yz%Y-%mrz%Y-%m-%d %Hz%Y-%m-%d %H:%Mr«)r¥r¦r§r¨r©rªz%Y-%m-%d %H:%iz%Y-%m-%d %H:%i:%ScCs,|tkst‚|sdSt|tƒ}| t|¡Sr?)ÚSQLITE_DATE_TRUNC_MAPPINGr²rur³Ústrftimerµr@r@rCÚ_sqlite_date_trunc&s r¼cCst ||tj¡dk Sr?)ÚreÚsearchÚI)Úregexrar@r@rCÚ_sqlite_regexp-srÁc@seZdZdd„ZdS)ÚattrdictcCs||Sr?r@©rAÚattrr@r@rCÚ__getattr__1szattrdict.__getattr__N)rErFrGrÅr@r@r@rCrÂ0srÂÚandÚorú+ú-Ú*ú/ú&ú|ú^ú%ú=ú<ú<=ú>ú>=ú!=Úinznot inÚiszis notÚlikeÚilikeÚbetweenÚregexpú||)ÚANDÚORÚADDÚSUBÚMULÚDIVÚBIN_ANDÚBIN_ORÚXORÚMODÚEQÚLTÚLTEÚGTÚGTEÚNEÚINÚNOT_INÚISÚIS_NOTÚLIKEÚILIKEÚBETWEENÚREGEXPÚCONCATÚINNERz LEFT OUTERzRIGHT OUTERÚFULL)röÚ LEFT_OUTERÚRIGHT_OUTERr÷r˜éé)ÚeqÚltÚlteÚgtÚgteÚnerÖr×rØrÙrÛcCs| ¡}| |¡|Sr?)ÚcopyÚupdate)ÚsourceÚ overridesÚmergedr@r@rCÚ merge_dictrs rcs‡fdd„}ˆ|_|S)zÍ Method decorator that will "clone" the object before applying the given method. This ensures that state is mutated in a more predictable fashion, and promotes the use of method-chaining. cs| ¡}ˆ|f|ž|Ž|Sr?©Úclone)rAÚargsÚkwargsr ©Úfuncr@rCÚinner}szreturns_clone..inner)Ú call_local©r rr@rrCÚ returns_clonewsrcs‡fdd„}|S)zu Method decorator to indicate a method is not allowed to be called. Will raise a `NotImplementedError`. cstdˆt|ƒjfƒ‚dS)Nz!%s is not allowed on %s instances)ÚNotImplementedErrorÚtyperE©rAr rrr@rCr‰sÿznot_allowed..innerr@rr@rrCÚnot_allowed„srcsHeZdZdZddgZdd„Zdd„Zdd „Zd d„Z‡fdd „Z ‡Z S)r3zg Proxy class useful for situations when you wish to defer the initialization of an object. ÚobjÚ _callbackscCsg|_| d¡dSr?)rÚ initialize©rAr@r@rCÚ__init__•szProxy.__init__cCs||_|jD]}||ƒqdSr?)rr)rArÚcallbackr@r@rCr™s zProxy.initializecCs|j |¡|Sr?)rr…)rArr@r@rCÚattach_callbackžszProxy.attach_callbackcCs|jdkrtdƒ‚t|j|ƒS)NzCannot use uninitialized Proxy.)rÚAttributeErrorr´rÃr@r@rCrÅ¢s zProxy.__getattr__cs$||jkrtdƒ‚tt|ƒ ||¡S)NzCannot set attribute on proxy.)Ú __slots__rÚsuperr3Ú__setattr__©rArÄra©Ú __class__r@rCr §s zProxy.__setattr__)rErFrGÚ__doc__rrrrrÅr Ú __classcell__r@r@r"rCr3Žsc@s8eZdZeƒZd dd„Zdd„Zdd„Zedd „ƒZ dS)rNcCs(g|_|dk r$| ¡|_|j |¡dSr?)ÚfieldsÚlowerÚ_rel_model_nameÚ_unresolvedr€)rAÚrel_model_namer@r@rCr¯s zDeferredRelation.__init__cCs|j |||f¡dSr?)r&r…)rAr„Úfieldrr@r@rCÚ set_fieldµszDeferredRelation.set_fieldcCs(|jD]\}}}||_| ||¡qdSr?)r&Ú rel_modelÚadd_to_class)rAr-r†r+rr@r@rCÚ set_model¸szDeferredRelation.set_modelcCs>ttjƒ}|D]*}|j|j ¡kr| |¡tj |¡qdSr?)r”rr)r(rEr'r/Údiscard)Ú model_clsÚ unresolvedÚdrr@r@rCÚresolve½s zDeferredRelation.resolve)N) rErFrGr’r)rr,r/Ústaticmethodr4r@r@r@rCr¬s c@seZdZddd„ZdS)Ú_CDescriptorNcCs|dk rt|jƒS|Sr?)ÚEntityÚ_alias©rAÚinstanceÚ instance_typer@r@rCÚ__get__Çs z_CDescriptor.__get__)N)rErFrGr<r@r@r@rCr6Æsr6c@seZdZdZeƒZdZdd„Zed5dd„ƒZ d d „Z dd„Zed d„ƒZ ed6dd„ƒZedd„ƒZedd„ƒZedd„ƒZdd„Zdd„Zd7dd„ZeejƒZeejƒZeejƒZeejƒZeejƒZeej ƒZ!Z"eej#ƒZ$eejddZ%eejddZ&eejddZ'eej ddZ(Z)eejddZ*eejddZ+eej#ddZ,dd „Z-d!d"„Z.eej/ƒZ0eej1ƒZ2eej3ƒZ4eej5ƒZ6eej7ƒZ8eej9ƒZ:eej;ƒZeej?ƒZ@eejAƒZBd#d$„ZCd%d&„ZDd8d'd(„ZEd)d*„ZFd+d,„ZGd-d.„ZHd/d0„ZId1d2„ZJd3d4„ZKdS)9ÚNodez=Base-class for any part of a query which shall be composable.ÚnodecCsd|_d|_d|_d|_dS©NF)Ú_negatedr8Ú_bind_toÚ _orderingrr@r@rCrÓsz Node.__init__NFcs‡‡‡fdd„}|S)Ncs&ˆp|j}ˆrt|ƒ}tˆ||ƒ|Sr?)rErÚsetattr)ÚmethodÚmethod_name©r Úclsrr@rCÚ decoratorÛs zNode.extend..decoratorr@)rGrr rHr@rFrCÚextendÙszNode.extendcCs t|ƒƒSr?)rrr@r@rCÚ clone_baseãszNode.clone_basecCs,| ¡}|j|_|j|_|j|_|j|_|Sr?)rJr@r8rBrA)rAÚinstr@r@rCr æsz Node.clonecCs|j|_dSr?)r@rr@r@rCÚ __invert__îszNode.__invert__cCs ||_dSr?©r8)rAÚar@r@rCÚaliasòsz Node.aliascCs ||_dS)zÓ Bind the results of an expression to a specific model type. Useful when adding expressions to a select, where the result of the expression should be placed on a joined instance. N)rA)rAÚbtr@r@rCÚbind_toöszNode.bind_tocCs d|_dS)NÚASC©rBrr@r@rCÚascÿszNode.asccCs d|_dS)NÚDESCrSrr@r@rCÚdescsz Node.desccCs| ¡Sr?)rTrr@r@rCÚ__pos__szNode.__pos__cCs| ¡Sr?)rVrr@r@rCÚ__neg__ szNode.__neg__cs‡‡fdd„}|S)zŸ Lightweight factory which returns a method that builds an Expression consisting of the left-hand and right-hand operands, using `op`. csˆrt|ˆ|ƒSt|ˆ|ƒSr?)Ú Expression©rAÚrhs©ÚinvÚopr@rCrszNode._e..innerr@)r^r]rr@r\rCÚ_e szNode._eT)r]cCs$|dkrt|tjdƒSt|tj|ƒSr?)rYÚOPrïrçrZr@r@rCÚ__eq__'szNode.__eq__cCs$|dkrt|tjdƒSt|tj|ƒSr?)rYr`rðrìrZr@r@rCÚ__ne__+szNode.__ne__cCst|tj|ƒSr?)rYr`rírZr@r@rCÚin_=szNode.in_cCst|tj|ƒSr?)rYr`rîrZr@r@rCÚnot_in?szNode.not_incCs |rt|tjdƒSt|tjdƒSr?)rYr`rïrð)rAÚis_nullr@r@rCreAszNode.is_nullcCst|tjd|ƒS)Nz%%%s%%©rYr`ròrZr@r@rCÚcontainsEsz Node.containscCst|tjd|ƒS)Nz%s%%rfrZr@r@rCÚ startswithGszNode.startswithcCst|tjd|ƒS)Nz%%%srfrZr@r@rCÚendswithIsz Node.endswithcCst|tjt|tdƒ|ƒƒS)NrÝ)rYr`rórr4)rAÚlowÚhighr@r@rCrÚKszNode.betweencCst|tj|ƒSr?)rYr`rô)rAÚ expressionr@r@rCrÛMszNode.regexpcCst|tj|ƒSr?)rYr`rõrZr@r@rCÚconcatOszNode.concat)NF)N)F)T)LrErFrGr$r6rTÚ _node_typerÚclassmethodrIrJr rrLrOrQrTrVrWrXr_r`rÝÚ__and__rÞÚ__or__rßÚ__add__ràÚ__sub__ráÚ__mul__râÚ__div__Ú__truediv__råÚ__xor__Ú__radd__Ú__rsub__Ú__rmul__Ú__rdiv__Ú__rtruediv__Ú__rand__Ú__ror__Ú__rxor__rarbrèÚ__lt__réÚ__le__rêÚ__gt__rëÚ__ge__ríÚ __lshift__rïÚ __rshift__rñÚ__mod__ròÚ__pow__rãÚbin_andräÚbin_orrcrdrergrhrirÚrÛrmr@r@r@rCr=Îsp r=cs,eZdZdZdZ‡fdd„Zdd„Z‡ZS)r7z2An unescaped SQL string, with optional parameters.Úsqlcs||_||_tt|ƒ ¡dSr?)raÚparamsrr7r)rArar‹r"r@rCrVszSQL.__init__cCst|jf|jžŽSr?)r7rar‹rr@r@rCrJ[szSQL.clone_base©rErFrGr$rnrrJr%r@r@r"rCr7Rscs4eZdZdZdZ‡fdd„Zdd„Zdd„Z‡ZS) r7z/A quoted-name or entity, e.g. "table"."column".Úentitycstt|ƒ ¡||_dSr?)rr7rÚpath)rArŽr"r@rCrcszEntity.__init__cCs t|jŽSr?)r7rŽrr@r@rCrJgszEntity.clone_basecCsttd|j|fƒŽSr?)r7ÚfilterrŽrÃr@r@rCrÅjszEntity.__getattr__) rErFrGr$rnrrJrÅr%r@r@r"rCr7_s r7csTeZdZdZdZedƒZ‡fdd„Zeddd„ƒZ d d „Z ddd „Zdd„Z‡Z S)ÚFunczAn arbitrary SQL function call.r )ÚcountÚsumcs6||_||_|r| ¡|jknd|_tt|ƒ ¡dSr?)rÚ argumentsr'Ú _no_coerceÚ_coercerrr)rArr“r"r@rCrrsz Func.__init__TcCs ||_dSr?)r•)rAÚcoercer@r@rCr–xszFunc.coercecCst|jf|jžŽ}|j|_|Sr?)rrr“r•)rAÚresr@r@rCrJ|szFunc.clone_baseNcCsJt|tƒr|dkr|}|dkr0t||d ¡}n t|jƒ}t|tdƒ|ƒS)N)Úpartition_byÚorder_byÚOVER)rSr=Ú__sql__r7r8r)rAr˜r™ÚwindowrŠr@r@rCÚoversÿ z Func.overcs‡fdd„}|S)Ncstˆf|ž|ŽSr?)r©r r©rÄr@rCÚdecŒszFunc.__getattr__..decr@)rArÄr r@rŸrCrÅ‹szFunc.__getattr__)T)NNN)rErFrGr$rnr’r”rrr–rJrrÅr%r@r@r"rCrms rcs.eZdZdZdZd‡fdd„ Zdd„Z‡ZS) rYz0A binary expression, e.g `foo + 1` or `bar < 7`.rlFcs*tt|ƒ ¡||_||_||_||_dSr?)rrYrÚlhsr^r[Úflat)rAr¡r^r[r¢r"r@rCr˜s zExpression.__init__cCst|j|j|j|jƒSr?)rYr¡r^r[r¢rr@r@rCrJŸszExpression.clone_base)FrŒr@r@r"rCrY”srYcs.eZdZdZdZd‡fdd„ Zdd„Z‡ZS) r.zÃ Arbitrary parameter passed into a query. Instructs the query compiler to specifically treat this value as a parameter, useful for `list` which is special-cased for `IN` lookups. ÚparamNcs||_||_tt|ƒ ¡dSr?)raÚadaptrr.r)rArar¤r"r@rCrªszParam.__init__cCst|j|jƒSr?)r.rar¤rr@r@rCrJ¯szParam.clone_base)NrŒr@r@r"rCr.¢sc@seZdZdZdS)ÚPassthroughÚpassthroughN)rErFrGrnr@r@r@rCr¥²sr¥cs4eZdZdZdZdZdZ‡fdd„Zdd„Z‡Z S) rz8A SQL clause, one or more Node objects joined by spaces.Úclauseú Fcs@d|kr|d|_d|kr$|d|_tt|ƒ ¡t|ƒ|_dS)NÚglueÚparens)r©rªrrrr”Únodes)rAr«rr"r@rCr¼s zClause.__init__cCst|jŽ}|j|_|j|_|Sr?)rr«r©rª©rAr r@r@rCrJÄs zClause.clone_base) rErFrGr$rnr©rªrrJr%r@r@r"rCrµsc@seZdZdZdZdS)ÚCommaClausez5One or more Node objects joined by commas, no parens.ú, N)rErFrGr$r©r@r@r@rCrÊsrc@seZdZdZdZdS)ÚEnclosedClausezAOne or more Node objects joined by commas and enclosed in parens.TN)rErFrGr$rªr@r@r@rCr¯Îsr¯cs.eZdZd‡fdd„ Zdd„Zdd„Z‡ZS) r=Ncs*tt|ƒ ¡||_||_|jp"d|_dS)NÚw)rr=rr˜r™r8)rAr˜r™r"r@rCrÓszWindow.__init__cCsPg}|jr$| ttdƒt|jŽƒ¡|jrD| ttdƒt|jŽƒ¡tt|ŽƒS)NzPARTITION BYúORDER BY)r˜r…rr7rr™r¯)rAÚover_clausesr@r@rCr›ÙsþþzWindow.__sql__cCst|j|jƒSr?)r=r˜r™rr@r@rCrJåszWindow.clone_base)NN)rErFrGrr›rJr%r@r@r"rCr=ÒscCstd|ƒS)Nz CHECK (%s)©r7)rar@r@rCrèscs(eZdZdZ‡fdd„Zdd„Z‡ZS)rz:A "django-style" filter expression, e.g. {'foo__eq': 'x'}.cstt|ƒ ¡||_dSr?)rrrÚquery©rAr´r"r@rCríszDQ.__init__cCstf|jŽSr?)rr´rr@r@rCrJñsz DQ.clone_base)rErFrGr$rrJr%r@r@r"rCrëscs eZdZdZ‡fdd„Z‡ZS)Ú_StripParensrwcstt|ƒ ¡||_dSr?)rr¶rr>)rAr>r"r@rCr÷sz_StripParens.__init__)rErFrGrnrr%r@r@r"rCr¶ôsr¶ÚJoinMetadata©Ú src_modelÚ dest_modelÚsrcÚdestrÄÚprimary_keyr‡Ú is_backrefrOÚis_self_joinÚ is_expressionc@s:eZdZddd„Zdd„Zdd„Zdd „Zed d„ƒZdS) ÚJoinNcCsXt|tƒst|tƒrdS|j ||¡}|dk r6|dfS|j ||¡}|dk rT|dfSdS)N©NNFT)rSÚSelectQueryrÚ rel_for_modelÚreverse_rel_for_model)rArr¼r+Úfk_fieldr‚r@r@rCÚget_foreign_key szJoin.get_foreign_keycCs|jp tjSr?)Ú join_typer&rörr@r@rCÚ get_join_typeszJoin.get_join_typecCs$t|tƒr|jSt|tƒr |jS|Sr?)rSÚ ModelAliasr„rÃ)rAÚmodel_or_aliasr@r@rCÚmodel_from_aliass zJoin.model_from_aliasc CsB| |j¡}| |j¡}t|jtƒr,|jjp.d}t|jttt fƒ}t|jt tfƒrX|jpZd}|rt|}|j|j jk}n6| |||j¡\}}|dkrª|jdk rª| ||¡\}}|dk rº|j}nd}|s|dk râ|rÚ|j j} n|j} n.z|jjj} Wntk r|j j} YnXnd} t|||j|j|p,| ||||||k|dS)Nr¸)rÌr»r¼rSÚonr=r8rYrr7rÚ FieldProxyrrr&rÇÚto_fieldrŽr¡rr·) rAr»r¼Ú join_aliasrÀÚon_fieldrÆr¾r½Útarget_attrr@r@rCÚ_join_metadatasJ õzJoin._join_metadatacCst|dƒs| ¡|_|jS)NÚ_cached_metadata)ÚhasattrrÓrÔrr@r@rCÚmetadataPs z Join.metadata)N) rErFrGrÇrÉrÌrÓÚpropertyrÖr@r@r@rCrÁ s 1rÁÚ_Join)r»r¼rÈrÍc@s&eZdZdd„Zddd„Zdd„ZdS) ÚFieldDescriptorcCs||_|jj|_dSr?)r+rÚatt_name©rAr+r@r@rCrYszFieldDescriptor.__init__NcCs|dk r|j |j¡S|jSr?)Ú_dataÚgetrÚr+r9r@r@rCr<]szFieldDescriptor.__get__cCs||j|j<|j |j¡dSr?)rÜrÚÚ_dirtyr€©rAr:rar@r@rCÚ__set__bszFieldDescriptor.__set__)N)rErFrGrr<ràr@r@r@rCrÙVs rÙcsœeZdZdZdZdZdZdZd#‡fdd„ Zd d „Z dd„Z d d„Zdd„Zdd„Z dd„Zdd„Zdd„Zdd„Zd$dd„Zdd„Zdd „Zd!d"„Z‡ZS)%rzA column on a table.rr+ÚunknownFNc sŒ||_||_||_||_||_||_||_||_| |_| |_ ||_ ||_tj d7_ tj |_|jrhdpjd|jf|_d|_tt|ƒ ¡dS)Nr˜rNF)ÚnullÚindexÚuniqueÚverbose_nameÚ help_textÚ db_columnÚdefaultÚchoicesr½ÚsequenceÚconstraintsÚschemarÚ_field_counterÚ_orderÚ _sort_keyÚ _is_boundrr) rArârãrärårærçrèrér½rêrërìr"r@rCrms"zField.__init__cKsft|ƒf|j|j|j|j|j|j|j|j|j |j |j|jdœ|—Ž}|j rZ|j|_|j|_|j |_ |S)N)rârãrärårærçrèrér½rêrërì)rrârãrärårærçrèrér½rêrërìrðrr„)rArrKr@r@rCrJ‡s*ô ózField.clone_basecCsZ||_||_|jp|j|_|js4t dd|¡ ¡|_|j |¡t ||t |ƒƒd|_dS)z± Hook that replaces the `Field` attribute on a class with a named `FieldDescriptor`. Called by the metaclass during construction of the `Model`. ú_+r¨TN)rr„rçrår½ÚsubÚtitlerÚ add_fieldrCrÙrð©rAr„rr@r@rCr.œszField.add_to_classcCs |jjjSr?)r„rÚdatabaserr@r@rCÚget_database¬szField.get_databasecCs| ¡}| ¡ ¡ |¡Sr?)Úget_db_fieldr÷ÚcompilerÚget_column_type)rAÚ field_typer@r@rCrú¯szField.get_column_typecCs|jSr?)Údb_fieldrr@r@rCrø³szField.get_db_fieldcCsdSr?r@rr@r@rCÚ get_modifiers¶szField.get_modifierscCs|Sr?r@©rArar@r@rCr–¹szField.coercecCs|dkr|S| |¡S)z5Convert the python value for storage in the database.N©r–rþr@r@rCÚdb_value¼szField.db_valuecCs|dkr|S| |¡S)z/Convert the database value to a pythonic value.Nrÿrþr@r@rCÚpython_valueÀszField.python_valuecCs |rt|jjj|jƒSt|jƒSr?)r7r„rrŽrç)rAÚ with_tabler@r@rCÚ as_entityÄszField.as_entitycCs0| ¡}|r(td|d tt|ƒ¡fƒSt|ƒS)z2Return the column type, e.g. VARCHAR(255) or REAL.ú%s(%s)r®)rýr7ÚjoinÚmapÚstr)rAÚcolumn_typeÚ modifiersr@r@rCÚ__ddl_column__ÉsÿzField.__ddl_column__cCsj| ¡| |¡g}|js&| tdƒ¡|jr:| tdƒ¡|jrT| td|jƒ¡|jrf| |j¡|S)z8Return a list of Node instances that defines the column.zNOT NULLúPRIMARY KEYzDEFAULT NEXTVAL('%s')) rr râr…r7r½rêrërI)rArÚddlr@r@rCÚ__ddl__Ñsz Field.__ddl__cCst|jd|jjƒS©NÚ.)Úhashrr„rErr@r@rCÚ__hash__ÞszField.__hash__)FFFNNNNNFNNN)F)rErFrGr$rírîrnrürrJr.r÷rúrørýr–rrrr r rr%r@r@r"rCrfs:ý cs.eZdZdZd‡fdd„ Z‡fdd„Z‡ZS)rÚbareNcs$tt|ƒj||Ž|dk r ||_dSr?)rrrr–)rAr–r rr"r@rCräszBareField.__init__cstt|ƒjfd|ji|—ŽS)Nr–)rrrJr–©rArr"r@rCrJészBareField.clone_base)N)rErFrGrürrJr%r@r@r"rCrásc@seZdZdZeZdS)r"ÚintN)rErFrGrürr–r@r@r@rCr"ìsc@seZdZdZdS)rÚbigintN©rErFrGrür@r@r@rCrðsc@seZdZdZdS)r5ÚsmallintNrr@r@r@rCr5óscs eZdZdZ‡fdd„Z‡ZS)r1r½csd|d<tt|ƒj||ŽdS)NTr½)rr1rrr"r@rCrùszPrimaryKeyField.__init__)rErFrGrürr%r@r@r"rCr1öscs eZdZdZ‡fdd„Z‡ZS)Ú_AutoPrimaryKeyFieldNcs4||jkrtdt|ƒ|fƒ‚tt|ƒ ||¡dS)Nz%s must be named `%s`.)Ú_column_namer|rrrr.rõr"r@rCr.s z!_AutoPrimaryKeyField.add_to_class)rErFrGrr.r%r@r@r"rCrýsrc@seZdZdZeZdS)rÚfloatN)rErFrGrürr–r@r@r@rCrsc@seZdZdZdS)rÚdoubleNrr@r@r@rCr scsFeZdZdZd‡fdd„ Z‡fdd „Zd d„Zdd „Zdd„Z‡Z S)rÚdecimalé rûFNcs6||_||_||_|ptjj|_tt|ƒj||ŽdSr?) Ú max_digitsÚdecimal_placesÚ auto_roundrÚDefaultContextÚroundingrrr)rArrr r"r rr"r@rCrs zDecimalField.__init__cs(tt|ƒjf|j|j|j|jdœ|—ŽS)N)rrr r")rrrJrrr r"rr"r@rCrJsüûzDecimalField.clone_basecCs|j|jgSr?)rrrr@r@rCrýszDecimalField.get_modifierscCsTtj}|s|dkr|S|dƒS|jrP|dƒ|j}|j}|t|ƒƒj||dS|S)Nrr)r")rÚDecimalr rr"rÚquantize)rAraÚDÚexpr"r@r@rCr"szDecimalField.db_valuecCs*|dk r&t|tjƒr|St t|ƒ¡SdSr?)rSrr#rrþr@r@rCr,szDecimalField.python_value)rrûFN) rErFrGrürrJrýrrr%r@r@r"rCrsÿ úutf-8cCs*t|tƒr|St|tƒr"| |¡St|ƒSr?)rSÚunicode_typeÚstring_typeÚdecode)r]Úencodingr@r@rCÚcoerce_to_unicode2s r,cs>eZdZdZd‡fdd„ Z‡fdd„Zdd„Zd d „Z‡ZS)rÚstringéÿcs||_tt|ƒj||ŽdSr?)Ú max_lengthrrr)rAr/r rr"r@rCr<szCharField.__init__cstt|ƒjfd|ji|—ŽS)Nr/)rrrJr/rr"r@rCrJ@s ÿþzCharField.clone_basecCs|jr|jgpdSr?)r/rr@r@rCrýEszCharField.get_modifierscCst|pdƒS©NÚ©r,rþr@r@rCr–HszCharField.coerce)r.) rErFrGrürrJrýr–r%r@r@r"rCr9s cs eZdZdZ‡fdd„Z‡ZS)rÚ fixed_charcs tt|ƒ |¡}|r| ¡}|Sr?)rrrÚstriprþr"r@rCrNszFixedCharField.python_value)rErFrGrürr%r@r@r"rCrKsc@seZdZdZdd„ZdS)r8ÚtextcCst|pdƒSr0r2rþr@r@rCr–WszTextField.coerceN)rErFrGrür–r@r@r@rCr8Tscs4eZdZdZeZ‡fdd„Zdd„Zdd„Z‡Z S)r Úblobcs0t|jjtƒr|jj |j¡tt|ƒ ||¡Sr?) rSrrör3rÚ_set_constructorrr r.rõr"r@rCr.^szBlobField.add_to_classcCs| ¡|_dSr?)Úget_binary_typeÚ_constructor)rArör@r@rCr7cszBlobField._set_constructorcCs,t|tƒr| d¡}t|tƒr(| |¡S|SrX)rSr(r[Ú basestringr9rþr@r@rCrfs zBlobField.db_value) rErFrGrüÚbinary_constructr9r.r7rr%r@r@r"rCr Zs c@s eZdZdZdd„Zdd„ZdS)r<ÚuuidcCs6t|tjƒr|jSzt |¡jWS|YSXdSr?)rSr<ÚUUIDÚhexrþr@r@rCrpszUUIDField.db_valuecCs&t|tjƒr|S|dkrdSt |¡Sr?)rSr<r=rþr@r@rCrxszUUIDField.python_valueN)rErFrGrürrr@r@r@rCr<mscs‡fdd„}|S)Ncs|jjj ˆ|¡Sr?)r„rröÚextract_dater©Ú date_partr@rCr ~sz_date_part..decr@)rAr r@r@rCÚ _date_part}srBcs.eZdZdZd‡fdd„ Z‡fdd„Z‡ZS)Ú_BaseFormattedFieldNcs$|dk r||_tt|ƒj||ŽdSr?)r}rrCr)rAr}r rr"r@rCr„sz_BaseFormattedField.__init__cstt|ƒjfd|ji|—ŽS)Nr})rrCrJr}rr"r@rCrJ‰s ÿþz_BaseFormattedField.clone_base)N)rErFrGr}rrJr%r@r@r"rCrC‚srCc@sjeZdZdZdddgZdd„ZeedƒƒZeedƒƒZ eed ƒƒZ eed ƒƒZeedƒƒZeedƒƒZ d S)rrzr¬r«rcCs|rt|tƒrt||jƒS|Sr?)rSr:rur}rþr@r@rCr–szDateTimeField.python_valuer¥r¦r§r¨r©rªN)rErFrGrür}rr×rBr¥r¦r§r¨r©rªr@r@r@rCrŽsýc@sFeZdZdZdddgZdd„ZeedƒƒZeedƒƒZ eed ƒƒZ d S)rÚdaterr«r¬cCs@|r$t|tƒr$dd„}t||j|ƒS|r.)rSr:rur}rzrD©rAraÚppr@r@rCrªszDateField.python_valuer¥r¦r§N)rErFrGrür}rr×rBr¥r¦r§r@r@r@rCr¢sýc@sJeZdZdZdddddgZdd„Zeed ƒƒZeed ƒƒZ eedƒƒZ dS) r9Útimer¯r®r°r¬r«cCs`|r8t|tƒr$dd„}t||j|ƒSt|tjƒr8| ¡S|dk r\t|tjƒr\tjj| ¡S|S)NcSs| ¡Sr?)rGrxr@r@rCrUÃrVz(TimeField.python_value..)rSr:rur}rzrGÚ timedeltaÚminrEr@r@rCrÀs zTimeField.python_valuer¨r©rªN)rErFrGrür}rr×rBr¨r©rªr@r@r@rCr9¶sûcsFeZdZdd„edƒDƒZ‡fdd„Zdd„Zdd „Zd d„Z‡Z S)r:cCsg|]}d|‘qS)rr@©Ú.0rr@r@rCÚ ÑszTimestampField.écsœ| dd¡pd|_|j|jkr×sz*TimestampField.__init__..ÚutcFrè)ÚpoprNÚvalid_resolutionsr|rrPrzÚutcfromtimestampÚ fromtimestampÚ_convÚutcnowÚnowÚ setdefaultrr:r)rAr rÚ_dtÚ_defaultr"r@rCrÓsÿzTimestampField.__init__cCs|jdkr|jStjS©Nr˜)rNrürrr@r@rCrøàsÿzTimestampField.get_db_fieldcCs |dkrdSt|tjƒrn4t|tjƒrr˜)rSrzrDr¥r¦r§rÚroundrNrPÚcalendarÚtimegmÚutctimetuplerGÚmktimeÚ timetupleÚmicrosecond)rAraÚ timestampr@r@rCrçs zTimestampField.db_valuecCsp|dk rlt|tttfƒrl|dkr$dS|jdkrbd|j}t||jƒ\}}||}| |¡j|dS| |¡S|S)Nrr˜ri)rb)rSrrÚlongrNÚdivmodrUÚreplace)rAraÚticks_to_microsecondÚticksrkr@r@rCrûs zTimestampField.python_value) rErFrGr›rRrrørrr%r@r@r"rCr:Ïs c@seZdZdZeZdS)rÚboolN)rErFrGrürir–r@r@r@rCrscs:eZdZdZ‡fdd„Zdd„Zddd„Zd d „Z‡ZS)ÚRelationDescriptorzEForeign-key abstraction to replace a related PK with a related model.cs||_tt|ƒ |¡dSr?)r-rrjr)rAr+r-r"r@rCrszRelationDescriptor.__init__cCsn|j |j¡}|dk s"|j|jkrZ|j|jkrN|j |jj|k¡}||j|j<|j|jS|jjsj|jj‚|Sr?) rÜrÝrÚÚ _obj_cacher-r+rÏrâr)rAr:Úrel_idrr@r@rCÚget_object_or_idsz#RelationDescriptor.get_object_or_idNcCs|dk r| |¡S|jSr?)rmr+r9r@r@rCr<s zRelationDescriptor.__get__cCs|t||jƒr2t||jjjƒ|j|j<||j|j<n8|j |j¡}||j|j<||krj|j|jkrj|j|j=|j |j¡dSr?)rSr-r´r+rÏrrÜrÚrkrÝrÞr€)rAr:raÚ orig_valuer@r@rCrà"sÿ zRelationDescriptor.__set__)N) rErFrGr$rrmr<ràr%r@r@r"rCrjs rjc@s"eZdZdZdd„Zddd„ZdS)ÚReverseRelationDescriptorz.callbackz%s_idÚ_idrñr¨rAcs.|jdˆjjˆfˆjˆdt||ƒ‚dS)Nz%s.%s)r+ÚbackrefÚobj_id_name)rrrr}r)ÚmsgÚcontext©r„rr†rAr@rCÚinvalid’sýz-ForeignKeyField.add_to_class..invalidzVThe related_name of %(field)s ("%(backref)s") conflicts with a field of the same name.zWThe related_name of %(field)s ("%(backref)s") is already in use by another foreign key.zRThe object id descriptor of %(field)s conflicts with a field named %(obj_id_name)sz]Model attribute "%(obj_id_name)s" would be shadowed by the object id descriptor of %(field)s.T)rSr-r3rrr,rr„rçrår½ròrórrôr~r}rÏrr´r½Úvalidate_backrefsr&r‚Ú__dict__rCrr€rrðÚrel)rAr„rrrŠr@r‰rCr.qsR þzForeignKeyField.add_to_classcs$t|jtƒs|j ¡Stt|ƒ ¡S)zr Overridden to ensure Foreign Keys use same column type as the primary key they point to. )rSrÏr1rørr rr"r@rCrø±s zForeignKeyField.get_db_fieldcs$t|jtƒs|j ¡Stt|ƒ ¡Sr?)rSrÏr1rýrr rr"r@rCrýºs zForeignKeyField.get_modifierscCs|j |¡Sr?)rÏr–rþr@r@rCr–¿szForeignKeyField.coercecCs t||jƒr| ¡}|j |¡Sr?)rSr-Ú _get_pk_valuerÏrrþr@r@rCrÂszForeignKeyField.db_valuecCst||jƒr|S|j |¡Sr?)rSr-rÏrrþr@r@rCrÇszForeignKeyField.python_value)NNNNN)rErFrGrrJrr€rr~r.rørýr–rrr%r@r@r"rCr Hs ÿ @ c@sFeZdZdZdZdd„Zdd„Zddd„Zd d „Zdd„Z d d„Z dS)rz+A primary key composed of multiple columns.NcGs ||_dSr?)Úfield_names)rArr@r@rCrÑszCompositeKey.__init__cCs||_||_t|||ƒdSr?)rr„rCrõr@r@rCr.ÔszCompositeKey.add_to_classcs$ˆdk r t‡fdd„|jDƒƒS|S)Ncsg|]}tˆ|ƒ‘qSr@)r´©rKÚ field_name©r:r@rCrLÛsÿz(CompositeKey.__get__..)Útuplerr9r@r’rCr<Ùs ÿzCompositeKey.__get__cCsdSr?r@rßr@r@rCràßszCompositeKey.__set__cs&‡fdd„tˆj|ƒDƒ}ttj|ƒS)Ncs"g|]\}}ˆjjj||k‘qSr@)r„rr&)rKr+rarr@rCrLãsÿz'CompositeKey.__eq__..)ÚziprrRÚoperatorÚand_)rAÚotherÚexpressionsr@rrCraâs ÿzCompositeKey.__eq__cCst|jj|jfƒSr?)rr„rErrr@r@rCrçszCompositeKey.__hash__)N)rErFrGr$rêrr.r<ràrarr@r@r@rCrÍs c@sDeZdZdZddd„Zdd„Zddd „Zd d„Zdd „Zdd„Z dS)ÚAliasMaprprcCsi|_||_dSr?)Ú _alias_mapÚ_counter)rAÚstartr@r@rCrîszAliasMap.__init__cCs d|jS)Nz©ršrr@r@rCÚ__repr__òszAliasMap.__repr__NcCs:||jkrdS|jd7_|p.d|j|jf|j|<dS)Nr˜z%s%s)ršr›Úprefix)rArrOr@r@rCr€õs zAliasMap.addcCs||jkr| |¡|j|Sr?)ršr€©rArr@r@rCÚ__getitem__ûs zAliasMap.__getitem__cCs ||jkSr?rr r@r@rCÚ__contains__szAliasMap.__contains__cCs.|r*|j ¡D]\}}||kr||j|<q|Sr?)ršÚitems)rAÚ alias_maprrOr@r@rCrs zAliasMap.update)r)N) rErFrGrŸrržr€r¡r¢rr@r@r@rCr™ës r™c2@sŽeZdZddddddddd dd d dddd dœZejdejdejdejdej dej dejdejdej dejdejdejdejdejdejdejdejdejd ejd!ejd"ejd#ejd$ejd%ejd&ejd'iZej d(ej!d)ej"d*ej#d+iZ$e%Z&d‹d/d0„Z'd1d2„Z(d3d4„Z)d5d6„Z*d7d8„Z+d9d:„Z,d;d<„Z-d=d>„Z.d?d@„Z/dAdB„Z0dCdD„Z1dEdF„Z2dGdH„Z3dIdJ„Z4dKdL„Z5dMdN„Z6dOdP„Z7dQdR„Z8dSdT„Z9dŒdUdV„Z:ddXdY„Z;dŽdZd[„Zdd`da„Z?dbdc„Z@eAfddde„ZBdfdg„ZCdhdi„ZDdjdk„ZEdldm„ZFdndo„ZGd‘dpdq„ZHeGdrƒZId’dtdu„ZJeGdvƒZKd“dwdx„ZLeGdyƒZMd”dzd{„ZNeGd|ƒZOd}d~„ZPdd€„ZQeGdƒZRd•d‚dƒ„ZSeGd„ƒZTd…d†„ZUeGd‡ƒZVdˆd‰„ZWeGdŠƒZXd.S)–Ú QueryCompilerr1ÚBIGINTÚBLOBÚSMALLINTÚDATEÚDATETIMEÚDECIMALÚREALÚCHARÚINTEGERÚVARCHARÚTEXTÚTIME)rrr6rirDrzrrr3rrr½rr-r5rGrÐrÑrÒrÓrÔrÕrízNOT INrïzIS NOTrÌrÍrñròrórÈrÉrÊrËú#rÝrÞrÏrôrÜz INNER JOINzLEFT OUTER JOINzRIGHT OUTER JOINz FULL JOINú"ú?NcCsJ||_||_t|j|piƒ|_t|j|p*iƒ|_| ¡|_t dgƒ|_ dS)Nr£)Ú quote_charÚ interpolationrÚ field_mapÚ _field_mapÚop_mapÚ_op_mapÚ get_parse_mapÚ _parse_mapr’Ú_unknown_types)rArµr¶Úfield_overridesÚop_overridesr@r@rCrHs zQueryCompiler.__init__cCs2|j|j|j|j|j|j|j|j|j|j |j dœS)N)rlr£r¦r r§rr+rŠÚselect_queryÚcompound_select_queryrw)Ú_parse_expressionÚ_parse_paramÚ_parse_passthroughÚ_parse_funcÚ _parse_clauseÚ _parse_entityÚ_parse_fieldÚ _parse_sqlÚ_parse_select_queryÚ_parse_compound_select_queryÚ_parse_strip_parensrr@r@rCr»QsõzQueryCompiler.get_parse_mapcCsd|j||jfS)Nz%s%s%s)rµ)rAr]r@r@rCÚquotebszQueryCompiler.quotecCs||jkr|j|S| ¡Sr?)r¸Úupper)rAÚfr@r@rCrúeszQueryCompiler.get_column_typecCs |j|Sr?)rº)rAÚqr@r@rCÚget_ophszQueryCompiler.get_opcCst| ¡dd„dS)NcSs |djS©Nr)rï)rr@r@rCrUlrVz.QueryCompiler._sorted_fields..©r)r“r£)rAÚ field_dictr@r@rCÚ_sorted_fieldskszQueryCompiler._sorted_fieldscCs|j|gfSr?)r¶©rAr>r¤Úconvr@r@rCÚ_parse_defaultnszQueryCompiler._parse_defaultc Cs”t|jtƒr|j}| |j||¡\}}| |j||¡\}}|jtjkrd|dkrd|sd|jr\dndgfS|jrndnd}||| |j¡|f} | ||fS)Nz()z0 = 1z(0 = 1)ú%s %s %sú (%s %s %s)) rSr¡rÚ parse_noder[r^r`rír¢rÑ) rAr>r¤r×r¡Úlparamsr[ÚrparamsÚtemplaterŠr@r@rCrÂqszQueryCompiler._parse_expressioncCs*|jr| | |j¡|d¡S|j|jgfSr?)r¤rÛrar¶rÖr@r@rCrÄ|sz QueryCompiler._parse_passthroughcCs^|jr0|r|j|jkrd}| | |j¡||¡S|dk rL| | |j¡|¡S|j|jgfSdSr?)r¤rrÛrar¶rÖr@r@rCrÃszQueryCompiler._parse_paramcCs8|jr |pd}| |j||¡\}}d|jt|ƒf|fS)Nr)r•Úparse_node_listr“rrw©rAr>r¤r×rŠr‹r@r@rCrÅ‹szQueryCompiler._parse_funccCs2| |j|||j¡\}}|jr*dt|ƒ}||fS©Nú(%s))rßr«r©rªrwràr@r@rCrÆsÿzQueryCompiler._parse_clausecCsd t|j|jƒ¡gfSr)rrrÍrŽrÖr@r@rCrÇ—szQueryCompiler._parse_entitycCs|jt|jƒfSr?)rar”r‹rÖr@r@rCrÉšszQueryCompiler._parse_sqlcCs<|r(d | ||j¡| |j¡f¡}n| |j¡}|gfSr)rrÍr„rç)rAr>r¤r×rŠr@r@rCrÈs þzQueryCompiler._parse_fieldcCsèd}|jj|kr0|jj|kr0|j|j}}d}n|j|j}}d}| ¡}|j|kr\|j|_| ||¡\} } | || ||¡¡\}}|rž||| | f\} }}}n| | ||f\} }}}|jjrÌd| |j |f}nd| |j |f}|||fS)NrÁTFz((%s) %s (%s))rÚ) r[rnr¡Úalias_map_classr›Úgenerate_selectÚcalculate_alias_mapröÚcompound_select_parenthesesr•)rAr>r¤r×ÚcsqÚfirst_qÚsecond_qr]Únew_mapÚfirstÚfirst_prªÚsecond_pržÚlpÚrÚrprŠr@r@rCrË¦s* þz*QueryCompiler._parse_compound_select_querycCsV| ¡}|js6|r$t|tƒr$|j}n |jjj}|f|_| ||¡\}}dt |ƒ|fSrá)r Ú_explicit_selectionrSr rÏr„rr½Ú_selecträrw)rAr>r¤r×r Úselect_fieldròr‹r@r@rCrÊÅs z!QueryCompiler._parse_select_querycCs | |j||¡\}}t|ƒ|fSr?)rÛr>rwràr@r@rCrÌÐsz!QueryCompiler._parse_strip_parenscCsht|ddƒ}d}||jkrP|j||||ƒ\}}||jkoJ|jdkoJ|dk}nt|tttfƒr|| |||¡\}}d|}nât|t ƒrÚ|j }|rÊt|tƒrÊ|j}t|tƒr¶| |¡} qÒ| t||jƒ¡} n| ¡} | g}n„t|ƒrìt|t ƒsøt|tƒr| ¡ ||¡} | | ||¡\}}n@|dk rH| |¡} | | |d¡\}}}n| ||d¡\}}d}|||fS)NrnFrâT)r´r¼r½r¤rSr”r“r’rßr*r¶r rÏrrrŽr rvrÊrrOrÛÚ_parserØ)rAr>r¤r×Ú node_typerárŠr‹rÏrarÚ_r@r@rCrôÔs@ ÿþ ÿ zQueryCompiler._parsec sÌ| ||ˆ¡\}}}|r6ˆdk r6|r6‡fdd„|Dƒ}t|tƒr||jrNd|}|jrfd |d|jf¡}|jr|d ||jf¡}|rÄtdd„|DƒƒrÄg}g}t|ƒD] \} } t| tƒr¢| | ¡\}}q¢||fS)Ncsg|]}ˆ |¡‘qSr@)rrJ©r×r@rCrLþsz,QueryCompiler.parse_node..zNOT %sr¨ÚAScss|]}t|tƒVqdSr?)rSr=)rKÚpr@r@rCrOsz+QueryCompiler.parse_node..) rôrSr=r@r8rrBÚanyÚ enumeraterÛ) rAr>r¤r×rŠr‹ráÚclean_paramsÚ clean_sqlÚidxr£ÚcsqlÚcparamsr@r÷rCrÛûs" zQueryCompiler.parse_noder®c CsFg}g}|D]*}| |||¡\}} | |¡| | ¡q| |¡|fSr?)rÛr…rIr) rAr«r¤r×r©rŠr‹r>Únode_sqlÚnode_paramsr@r@rCrßs zQueryCompiler.parse_node_listcCs˜| ¡}|dk r|j|_| |j|jjj¡|j ¡D]V\}}| ||jj¡|D]8}t|j t ƒrv| |j |j j¡qR| |j |j jj¡qRq6| |¡Sr?) rãr›r€r„rÚtable_aliasÚ_joinsr£rSr¼r=rOr)rAr´r¤rêr¹Ú joined_modelsÚjoin_objr@r@rCråsz!QueryCompiler.calculate_alias_mapcCs| t|Ž|¡Sr?)rÛr)rAÚclausesr¤r@r@rCÚbuild_query*szQueryCompiler.build_querycCsZg}tƒ}|g}|rV| ¡}||ks||kr0q| |¡||D]}|} |j} t|jtttt fƒrv|j ¡ ¡}nl|j}|j r|j} |j}n|j} |j}|j}|rÚt| |jƒ}t||jjƒ}|j rÐ||}}||k}ntdƒ‚t| tƒrò| }n| | ¡| ¡ || ¡}| ¡}||jkr2t|j|ƒ}nt|ƒ}| t||tdƒ|ƒ¡qBq|S)Nz Missing required join predicate.ÚON)r’rQr€r¼rSrÍrYrrr7r rOrÖr¾r»r‡r´rrÏr|r=r…rrÉÚjoin_mapr7)rAÚjoinsr„r¤rrŒrÐÚcurrrr»r¼Ú constraintrÖÚfk_modelÚpk_modelÚfkr¡r[Údest_nrÈÚjoin_sqlr@r@rCÚgenerate_joins-sN ÿzQueryCompiler.generate_joinscCs.|j}|jj}| ||¡}t|tƒr0t|ƒg}n’|jsBtdƒg}n*tdƒg}|jdkrl|tdƒt |jŽg7}t |jŽ}d|_| |tdƒf¡|jdkr²| | ¡ ||¡¡n| t|jŽ¡|jdk rô| tdƒ¡| tdd „|jDƒŽ¡| |j||¡}|r| |¡|jdk r4| td ƒ|jg¡|jrT| tdƒt|jŽg¡|jrp| tdƒ|jg¡|jr| td ƒt|jŽg¡|jdk s¬|jrÖ|jrÖ|jdk r¾|jn|j}| td|ƒ¡|jdk rö| td|jƒ¡|j\} } | r"| rdnd}| t|ƒ¡| ||¡S)NÚSELECTzSELECT DISTINCT)TFr r®ÚFROMÚWINDOWcSs&g|]}tt|jƒtdƒ| ¡ƒ‘qS)rø)rr7r8r›)rKrœr@r@rCrL}süýz1QueryCompiler.generate_select..ÚWHEREzGROUP BYÚHAVINGr±zLIMIT %sz OFFSET %szFOR UPDATE NOWAITz FOR UPDATE)r„rrörårSÚCompoundSelectr¶Ú _distinctr7r¯rròr©rIÚ_fromr…rrOrÚ_windowsrrÚ_whereÚ _group_byÚ_havingÚ _order_byÚ_limitÚ_offsetÚ limit_maxÚ_for_updater)rAr´r¤r†ÚdbrÚ select_clauseÚjoin_clausesÚlimitÚ for_updateÚno_waitÚstmtr@r@rCräbsT û zQueryCompiler.generate_selectc Cs|j}| ¡}| ||jj¡|jr0d|j}nd}t|ƒ| ¡tdƒg}g}| |j ¡D]D\}}t |ttfƒs~t ||jd}| t|jddtj|dd¡qZ| t|Ž¡|jrÈ| td ƒ|jg¡|jdk rôt|jŽ} d | _| tdƒ| g¡| ||¡S)NzUPDATE OR %sÚUPDATEÚSET©r¤F©rT)r¢rr®Ú RETURNING)r„rãr€rrŽÚ_on_conflictr7rrÕÚ_updaterSr=r*r.rr…rYr`rçrrrIÚ _returningrr©r) rAr´r†r¤Ú statementrrr+raÚreturning_clauser@r@rCÚgenerate_update¡s2 ü zQueryCompiler.generate_updatecCs|dd„|DƒŽS)NcSsg|]}|jdd‘qS)Fr/©r©rKr+r@r@rCrLÁsz3QueryCompiler._get_field_clause..r@)rAr&Úclause_typer@r@rCÚ_get_field_clauseÀsÿzQueryCompiler._get_field_clausecCsÊ|j}|j}| ¡}| ||jj¡|jr4|jj}n|jrFd|j}nd}t |ƒ| ¡g}|jdk rŽ|jr|| | |j¡¡| t|jƒ¡nØ|jdk rfgg}}d} | ¡D]n} | sÒt| ¡t d¡d}d} g}|D]4}| |} t| ttfƒst| |jd} | | ¡qÚ| t|Ž¡q°|rF| | |¡t dƒt|Žg¡n |jjjrf| |j |j¡¡|j r| t d ƒ|j| !¡td g¡n.|j"dk r¾t#|j"Ž}d|_$| t d ƒ|g¡| %||¡S)NzINSERT OR %s INTOzINSERT INTOFrïrÓTr.ÚVALUESr0)r9r®)&r„rrãr€rŽÚ_upsertröÚ upsert_sqlr1r7rÚ_queryÚ_fieldsr…r:r¶Ú_rowsÚ _iter_rowsr“Úkeysr•Ú attrgetterrSr=r*r.rr¯rIrÚauto_incrementÚdefault_insert_clauseÚis_insert_returningÚget_primary_key_fieldsr3rr©r)rAr´r†rKr¤r4rr&Ú value_clausesÚhave_fieldsÚrow_dictrƒr+rar5r@r@rCÚgenerate_insertÄsl ÿý ÿþþ zQueryCompiler.generate_insertcCsf|j}tdƒ| ¡g}|jr0| tdƒ|jg¡|jdk r\t|jŽ}d|_| tdƒ|g¡| |¡S)NzDELETE FROMrr®r0) r„r7rrrIr3rr©r)rAr´r†rr5r@r@rCÚgenerate_deletes zQueryCompiler.generate_deletecCs | | ¡¡}| |¡}t|ŽSr?)rúrør r)rAr+rrr@r@rCÚfield_definition s zQueryCompiler.field_definitioncCsjtdƒt| ¡ƒtdƒ|j ¡t|j ¡ƒg}|jrH| td|jƒ¡|jrb| td|jƒ¡t|ŽS)NzFOREIGN KEYÚ REFERENCESzON DELETE %szON UPDATE %s) r7r¯rr-rÏrzr…r{r)rAr+rr@r@rCÚforeign_key_constraints ûz$QueryCompiler.foreign_key_constraintcs‡fdd„}|S)Ncst|ˆƒ}| |||Ž¡Sr?)r´rÛ)rAr rr©Ú function_namer@rCr"s z/QueryCompiler.return_parsed_node..innerr@)rQrr@rPrCÚreturn_parsed_nodesz QueryCompiler.return_parsed_nodecCsN|pd|jj|j|jjjf}| |¡}ttdƒ| ¡tdƒt|ƒf|j žŽS)Nzfk_%s_%s_refs_%szALTER TABLEzADD CONSTRAINT) rrŽrçr-rOrr7rr7r«)rAr„r+r Ú fk_clauser@r@rCÚ_create_foreign_key'sý üûz!QueryCompiler._create_foreign_keyrTFc sÚ|rdnd}|j‰gg}}ˆjrP‡fdd„ˆjjDƒ}| ttdƒt|Žƒ¡ˆjD]4}| | |¡¡t |tƒrV|jsV| | |¡¡qV|jjr¾|jjD] }t |tƒs²t|ƒ}| |¡qœtt|ƒ| ¡t||ŽƒS)NzCREATE TABLE IF NOT EXISTSzCREATE TABLEcsg|]}ˆj| ¡‘qSr@)r&r©rKrÏ©rKr@rCrL;sÿz/QueryCompiler._create_table..r)rÚ composite_keyr½rr…rr7r¯Údeclared_fieldsrMrSr ryrOrër=r) rAr„Úsafer4ÚcolumnsrëÚpk_colsr+r r@rVrCÚ _create_table5s2 ÿÿ ýzQueryCompiler._create_tabler\cCs6|rdnd}t|ƒ| ¡g}|r.| tdƒ¡t|ŽS)NzDROP TABLE IF EXISTSz DROP TABLEÚCASCADE©r7rr…r)rAr„Ú fail_silentlyÚcascader4rr@r@rCÚ_drop_tablePs zQueryCompiler._drop_tableracCs<tdƒ| ¡g}|r"| tdƒ¡|r4| tdƒ¡t|ŽS)NzTRUNCATE TABLEzRESTART IDENTITYr]r^)rAr„Úrestart_identityr`rr@r@rCÚ_truncate_tableXszQueryCompiler._truncate_tablerccCsRd|d |¡f}t|ƒdkrNt | d¡¡ ¡}d|dd…|dd…f}|S)Nz%s_%sröé@r'é7é)rršÚhashlibÚmd5r[Ú hexdigest)rAÚtablerZrãÚ index_hashr@r@rCÚ index_namebs zQueryCompiler.index_namecGs^|jj}|rdnd}| |dd„|Dƒ¡}tt|ƒt|ƒtdƒ| ¡tdd„|DƒŽf|žŽS)NzCREATE UNIQUE INDEXzCREATE INDEXcSsg|] }|j‘qSr@©rçrUr@r@rCrLlsz/QueryCompiler._create_index..r cSsg|]}| ¡‘qSr@r7r8r@r@rCrLrs)rrŽrlrr7r7rr¯)rAr„r&rär|Útbl_namer4rlr@r@rCÚ _create_indexisûúzQueryCompiler._create_indexrocCs<|jj}|rdnd}| |dd„|Dƒ¡}tt|ƒt|ƒƒS)NzDROP INDEX IF EXISTSz DROP INDEXcSsg|] }|j‘qSr@rmrUr@r@rCrLysz-QueryCompiler._drop_index..)rrŽrlrr7r7)rAr„r&r_rnr4rlr@r@rCÚ_drop_indexvszQueryCompiler._drop_indexrpcCsttdƒt|ƒƒS)NzCREATE SEQUENCE©rr7r7©rAÚ sequence_namer@r@rCÚ_create_sequence}szQueryCompiler._create_sequencertcCsttdƒt|ƒƒS)Nz DROP SEQUENCErqrrr@r@rCÚ_drop_sequenceszQueryCompiler._drop_sequenceru)r³r´NN)NN)Nr®)N)N)N)N)F)FF)FF)F)YrErFrGr·r`rçrèrérêrërìrírîrïrðrãrärñròrórßràrárârårÝrÞrærôrõr¹r&rörørùr÷r r™rãrr»rÍrúrÑrÕrØrÂrÄrÃrÅrÆrÇrÉrÈrËrÊrÌrôrÛrßrårrrär6r¯r:rKrLrMrOrRrTÚcreate_foreign_keyr\Úcreate_tableraÚ drop_tablercÚtruncate_tablerlroÚcreate_indexrpÚ drop_indexrtÚcreate_sequenceruÚ drop_sequencer@r@r@rCr¥sðçüÿ ' 5 ?> ÿ r¥c@seZdZddd„ZdS)ÚSqliteQueryCompilerFcCs| ¡ ¡Sr?)ÚdeleterŠ)rAr„rbr`r@r@rCry‡sz"SqliteQueryCompiler.truncate_tableN)FF)rErFrGryr@r@r@rCr~†sÿr~c@s eZdZdd„Zdd„ZeZdS)ÚResultIteratorcCs||_d|_dSrÒ)ÚqrwÚ_idx)rArr@r@rCrszResultIterator.__init__cCsf|j|jjkr|jj|j}n6|jjsP|j ¡}|jj |¡|jjd7_nt‚|jd7_|Sr[)r‚rÚ_ctÚ _result_cacheÚ _populatedÚiterater…Ú StopIterationr r@r@rCÚnext‘s zResultIterator.nextN)rErFrGrrˆÚ__next__r@r@r@rCr€Œsr€c@sdeZdZdZddd„Zdd„Zedd„ƒZd d „Zdd„Z d d„Z dd„Zdd„ZeZ ddd„ZdS)ÚQueryResultWrapperzí Provides an iterator over the results of a raw Query, additionally doing two things: - converts rows from the database into python representations - ensures that multiple iterations do not result in multiple queries NcCsP||_||_d|_d|_g|_d|_d|_|dk r@|\|_|_nd|_|_dS)NrF) r†Úcursorrƒr‚r„r…Ú_initializedÚcolumn_metaÚ join_meta)rAr†r‹rKr@r@rCr¦szQueryResultWrapper.__init__cCs|jrt|jƒSt|ƒSdSr?)r…Úiterr„r€rr@r@rCÚ__iter__¶s zQueryResultWrapper.__iter__cCs| ¡|jSr?)Ú fill_cacherƒrr@r@rCr‘¼szQueryResultWrapper.countcCs|jSr?)r‘rr@r@rCÚ__len__ÁszQueryResultWrapper.__len__cCs|Sr?r@©rAÚrowr@r@rCÚprocess_rowÄszQueryResultWrapper.process_rowcCsV|j ¡}|s2d|_t|jddƒs,|j ¡t‚n|jsL| |jj¡d|_| |¡S)NTr) r‹Úfetchoner…r´Úcloser‡rŒrÚdescriptionr•r“r@r@rCr†Çs zQueryResultWrapper.iterateccs| ¡VqdSr?)r†rr@r@rCÚiteratorÓszQueryResultWrapper.iteratorcCsh|j|jkr*|j|j}|jd7_|S|jr4t‚| ¡}|j |¡|jd7_|jd7_|Sr[)r‚rƒr„r…r‡r†r…)rArKrr@r@rCrˆ×szQueryResultWrapper.nextcCs`|p tdƒ}|dkrtdƒ‚|j|_|js\||jkr\zt|ƒWq$tk rXYq\Yq$Xq$dS)NÚInfrz"Negative values are not supported.)rr|rƒr‚r…rˆr‡©rAÚnr@r@rCr‘æszQueryResultWrapper.fill_cache)N)N)rErFrGr$rrr×r‘r’r•r†r™rˆr‰r‘r@r@r@rCrŠŸs rŠc@s$eZdZdd„Zdd„Zdd„ZdS)ÚExtQueryResultWrappercCs”t|ƒ}g|_}|jdk rht|jƒ}t|jƒD](\}}| ||¡s0| ||d|¡q0||krldSnd}t||ƒD]}| ||d|¡qvdSrÒ)ršr×rrûÚ_initialize_nodeÚ_initialize_by_namer›)rAr˜Ún_colsr×Ún_metarr>r@r@rCròs z ExtQueryResultWrapper.initializecCsH|jjj}||kr2||}|j ||j|jf¡n|j ||df¡dSr?)r†rrZr×r…rr)rArrÚ model_colsr+r@r@rCrŸ s z)ExtQueryResultWrapper._initialize_by_namecCsŽt|tƒr*|j ||jp|j|jf¡dSt|tƒrŠt|j ƒrŠ|j d}t|tƒrŠ|jpb|jpb|j}|j rp|jprd}|j |||f¡dSdS)NTrF)rSrr×r…r8rrrršr“r•)rAr>rÚargrr r@r@rCrž s z&ExtQueryResultWrapper._initialize_nodeN)rErFrGrrŸržr@r@r@rCrñsrc@seZdZdd„ZdS)ÚTuplesQueryResultWrappercst‡fdd„t|ƒDƒƒS)Ncs8g|]0\}}ˆj|ddkr"|nˆj|d|ƒ‘qS)rNNr÷)rKrÚcolrr@rCrL sÿz8TuplesQueryResultWrapper.process_row..)r“rûr“r@rrCr• sÿz$TuplesQueryResultWrapper.process_rowN©rErFrGr•r@r@r@rCr¤ sr¤c@seZdZdd„ZdS)ÚNaiveQueryResultWrappercCsJ| ¡}|jD].\}}}t|||dk r2|||ƒn||ƒq| ¡|Sr?)r†r×rCÚ_prepare_instance)rAr”r:rÚcolumnrÏr@r@rCr•! s &z#NaiveQueryResultWrapper.process_rowNr¦r@r@r@rCr§ sr§c@seZdZdd„ZdS)ÚDictQueryResultWrappercCs:i}|jD]*\}}}|dk r(|||ƒn||||<q |Sr?r÷)rAr”r—rr©rÏr@r@rCr•, s"z"DictQueryResultWrapper.process_rowNr¦r@r@r@rCrª+ srªc@s>eZdZdd„Zdd„Zdd„Zdd„Zdd d„Zdd „Zd S)ÚModelQueryResultWrappercCs4| ¡\|_}tdd„|jDƒƒ|_| |¡|_dS)Ncss|]}t|tƒr|VqdSr?)rSr)rKr¥r@r@rCrO8 s ÿz5ModelQueryResultWrapper.initialize..)Úgenerate_column_mapÚ column_mapr’rÚ_col_setÚgenerate_join_listÚ join_list)rAr˜Ú model_setr@r@rCr6 sz"ModelQueryResultWrapper.initializec Csäg}t|jgƒ}t|jƒD]À\}}d}}t|tƒrrt|tƒrT|j}|j}|jj }n|j }}|j }|jpn|j}nL|j dkrˆ|j}}n |j }}t|tƒrª|jrª|j}nt|tƒr¾|jd}| ||||f¡| |¡q||fS©Néÿÿÿÿ)r’r†rûrrSrrÎÚ_model_aliasÚfield_instancerr„r8rrAr=r7rŽr…r€) rArrŠrr>rÄr×rÚconstructorr@r@rCr¬< s, z+ModelQueryResultWrapper.generate_column_mapcCs´g}|j}|jg}|r°| ¡}||kr(q||D]|}|j}|j|ksN|j|kr0|jdk r‚|j|jk}|j|jk} |jj o~|p~| } nd} }} | || || f¡| |j¡q0q|Sr?)rŽr†rQrÖr¼rºr‡r®r½râr…)rArŠr°rÚstackÚcurrentrrÖÚ fk_presentÚ pk_presentÚcheckr@r@rCr¯X s2 ÿüz*ModelQueryResultWrapper.generate_join_listcCs.| |¡}| |¡}|D]}| ¡q|dSrÒ)Úconstruct_instancesÚfollow_joinsr¨)rAr”Ú collectedÚ instancesrr@r@rCr•u s z#ModelQueryResultWrapper.process_rowNcCsŒi}t|jƒD]x\}\}}}}|dk r0||kr0q||} ||krJ|ƒ||<||} |dkrj|jj|d}t| ||dkr|| n|| ƒƒq|SrÒ)rûrr‹r˜rC)rAr”rBÚcollected_modelsrrr¶rÄr×rar:r@r@rCr¼| s z+ModelQueryResultWrapper.construct_instancesc CsN||jg}|jD]4\}}}}||j}z||j}Wntk rV||j}YnXd} |rŠ|rv|j |jj ¡} n|rŠ|j |j j ¡} | sq|j dk } | oº|j|jkoºt||j j ƒdk}|rØt ||j j |j|jƒ|jr0| o|jdk ot||j j ƒdk o|j |jj ¡dk}|r0t ||jj |ƒt ||j|ƒ| |¡q|S©NT)r†r°r»r¼ÚKeyErrorrºrÜrÝr‡rr½rÄr´rCr¾r…) rAr¾ÚpreparedrÖÚ check_nullr¹rºrKÚjoined_instÚhas_fkÚmpkÚcan_populate_joined_pkÚcan_populate_joined_fkr@r@rCr½‹ sX ÿý ýÿþüýz$ModelQueryResultWrapper.follow_joins)N) rErFrGrr¬r¯r•r¼r½r@r@r@rCr«5 s r«Ú JoinCache©rÖrÄcs8eZdZ‡fdd„Z‡fdd„Zdd„Zdd„Z‡ZS) ÚAggregateQueryResultWrappercsg|_tt|ƒj||ŽdSr?)Ú_rowrrÌrrr"r@rCrÀ sz$AggregateQueryResultWrapper.__init__cs¶tt|ƒ |¡tƒ|_|jD]\}}}}|j |¡qtƒ|_i|_i|_ i|_ |jD]˜\}}}}|jrt|j j}n|j}|jp„|j}|rš|j |j¡n&|j |jtƒ¡|j |j |j¡|j |ji¡t||jpÜ|d|j |j|j<qXi|_i}t|jƒD]^\}\}} } }||jkrD|j |g¡|j| || f¡| |g¡|| || f¡q|jD]D}||jkr€ql|j |d¡}|D]} |j| || ¡q’qldS)NrËr@)rrÌrr’Ú all_modelsrr€Úmodels_with_aggregateÚback_referencesÚsource_to_destÚdest_to_sourcer°r¾r‡r}rÄr¿r»rXr¼rÊrOÚcolumns_to_comparerûr…rÝrI)rAr˜rrörÖrÚr¾Úkey_to_columnsrþr„Úcol_namerËÚsourcesÚjoined_modelr"r@rCrÄ sL þ ÿz&AggregateQueryResultWrapper.initializecCsDi}|j ¡D]0\}}g||<|D]\}}|| ||¡q"q|Sr?)rÓr£r…)rAr”rŠr„Úcolumn_datarþrÕr@r@rCÚread_model_dataú sz+AggregateQueryResultWrapper.read_model_datac Cs8|jr|j ¡}n |j ¡}|sDd|_t|jddƒs>|j ¡t‚n|js^| |jj ¡d|_dd„}i}| |¡}||j}| ¡D]"\}}tƒ||<|||||ƒ<q†| |¡}|j ¡} | dkrÊq~tƒ} | | ¡}| ¡D]\}} ||| krâ| |¡qâ| s|j | ¡q~|j| }| | |¡}| ¡D]D\}}d}|j ¡D]}|dk rLd}qL|s6|||||ƒ<q6q´|jg}|g}|r | ¡}||jkrªqŒ|j|D]d}z|j||j\}}Wntk rîYq´YnX|js|jr¬|| ¡D]}t||gƒq|j|kr0q´||j ¡D]j\}}|dkrTq>z|||j|jj}Wntk rŠYq>YnXt||ƒ |¡| |¡q>n`|r|j|krÂq´|| ¡D]<\}}||j|j|jj}t||jj|ƒ| |¡qÎ| |j¡q´qŒ|D]}| ¡q$|S)NTrcs,ˆjjr$t‡fdd„ˆjjjDƒƒSˆ ¡S)Ncsg|]}ˆj|‘qSr@)rÜrr’r@rCrL sÿzHAggregateQueryResultWrapper.iterate.._get_pk..)rrWr“r½rrŽr’r@r’rCÚ_get_pk s þz4AggregateQueryResultWrapper.iterate.._get_pkF) rÍrQr‹r–r…r´r—r‡rŒrr˜r¼r†r£rrÙr’r€r…rÎrÜrƒrŽrÑr¼rÂr¾r¿rCr‡rr¨)rAr”rÚÚidentity_mapÚ_constructedÚprimary_instancerËr:Ú model_dataÚcur_rowÚduplicate_modelsÚcur_row_datar„ÚdataÚdifferent_modelsÚ new_instancesÚall_nonerar·r¿r¸rrÖrÄÚpkrKrÅr@r@rCr† s¦ ÿÿýz#AggregateQueryResultWrapper.iterate)rErFrGrrrÙr†r%r@r@r"rCrÌ¿ s6rÌcsÎeZdZdZdZ‡fdd„Zdd„Zdd„Zd d „Zdd„Z d+dd„Z dd„Zedd„ƒZ edd„ƒZed,dd„ƒZed-dd„ƒZd.dd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&d'„Zd/d)d*„Z‡ZS)0ÚQueryz?Base class representing a database query on one or more tables.Tcs@tt|ƒ ¡||_|jj|_d|_||_|jgi|_d|_ dSrÁ) rrçrr„rrörÞÚ _query_ctxrr©rAr„r"r@rCrv s zQuery.__init__cCs| ¡\}}d|j||fS)NrÙ)rŠr„©rArŠr‹r@r@rCrž szQuery.__repr__cCs t|ƒ|jƒ}|j|_| |¡Sr?)rr„röÚ_clone_attributesrµr@r@rCr … szQuery.clonecCs,|jdk r|j ¡|_| ¡|_|j|_|Sr?)rr Ú_clone_joinsrrèrµr@r@rCrëŠ s zQuery._clone_attributescCstdd„|j ¡DƒƒS)Ncss|]\}}|t|ƒfVqdSr?)r”)rKÚmcÚjr@r@rCrO’ sz%Query._clone_joins..)Údictrr£rr@r@rCrì‘ sÿzQuery._clone_joinsNcCs,ttj|ƒ}|dkr|S|p tj}|||ƒSr?)rRr•r–)rAÚinitialr˜ÚconjunctionÚreducedr@r@rCÚ_add_query_clauses• s zQuery._add_query_clausescCsxg}|D]j}t|tƒr"| |¡qt|tƒr8| |¡qt|tƒrR| | ¡¡qt|ƒrt|t ƒr| |j j¡q|Sr?)rSr=r…rçrÊrIÚget_proxy_fieldsr rvr*rrX)rAr Úaccumr£r@r@rCÚ_model_shorthandœ s zQuery._model_shorthandcGs| |j|¡|_dSr?)rór©rAr˜r@r@rCrq© szQuery.wherecGs| |j|tj¡|_dSr?)rórr•Úor_r÷r@r@rCÚorwhere s ÿz Query.orwherecCsŠ|j}|s8t|tƒp(t|ƒo(|j |¡}|rNtdƒ‚nt|tƒrN|jj|}|j |g¡|j | t||||ƒ¡t|tƒs†||_dS)Nz#A join condition must be specified.) rèrSrÃr rÚ rel_existsr|r:r&rrXr…rÁ)rAr¼rÈrÍr»Úrequire_join_conditionr@r@rCr² s þ z Query.joincCs|p|j|_dS)z"Change or reset the query context.N)r„rèrér@r@rCÚswitchÂ szQuery.switchcKsN|j}|j |g¡D]}|j|kr|Sq| |¡j|fd|i|—Ž |¡S)NrÍ)rèrrÝr¼rür)rAÚlmÚrmrÍÚjoin_kwargsÚctxrr@r@rCÚensure_joinÇ s zQuery.ensure_joincCs¶g}g}ttf}t| ¡ƒD]\}}|j}d|kr`| dd¡dtkr`| dd¡\}}t|}ntj}| d¡D](} t || ƒ} t| |ƒrp| j}| | ¡qp| t| ||ƒ¡q||fS)NÚ__r˜)r ror“r£r„ÚrsplitÚ DJANGO_MAPr`rçÚsplitr´rSr-r…rY)rAÚqdictrõrÚrelationshiprrarr^ÚpieceÚ model_attrr@r@rCÚconvert_dict_to_nodeÎ s zQuery.convert_dict_to_nodecOsHtƒ}|r$|ttjdd„|DƒƒM}|r6|tf|ŽM}t|gƒ}tƒ}|rÖ| ¡}t|t ƒs^qFd|j fd|jffD]`\}}t|tƒrÈ| |j ¡\} } | | ¡ttj| ƒ}|j|_|j|_t|||ƒqr| |¡qrqF|j}| ¡} |D]T}t|tƒr|j|j} }|}n"t|tƒr.|jj|j} }|j}| | ||¡} qè| |¡S)NcSsg|]}| ¡‘qSr@r)rKrNr@r@rCrLå sz Query.filter..r¡r[)r=rRr•r–rrr’ÚpopleftrSrYr¡r[r r´rr@r8rCr…r r r„r-ror+rrq)rAr rÚdq_noderÐÚdq_joinsrÚsiderr´rrlr+rýrþÚ field_objr@r@rCrá s> zQuery.filtercCs |j ¡Sr?)rörùrr@r@rCrù szQuery.compilercCst‚dSr?©rrr@r@rCrŠsz Query.sqlcCs| ¡\}}|j |||j¡Sr?)rŠröÚexecute_sqlÚrequire_commitrêr@r@rCÚ_executeszQuery._executecCst‚dSr?rrr@r@rCÚexecutesz Query.executeFcCs6|r| ¡ ¡}n| ¡ ¡}|r.|s.|dS|SdSrÒ)Útuplesrërr–)rAÚas_tupleÚconvertr”r@r@rCÚscalarszQuery.scalar)N)NN)N)N)FF)rErFrGr$rrržr rërìrórörrqrùrrürr rrùrŠrrrr%r@r@r"rCrçr s2 (rçcsteZdZdZ‡fdd„Zdd„ZedƒZedƒZedƒZ e dd d„ƒZe ddd „ƒZdd„Z dd„Zdd„Z‡ZS)ÚRawQueryzh Execute a SQL query, returning a standard iterable interface that returns model instances. cs6||_t|ƒ|_d|_d|_d|_tt|ƒ |¡dSr?) Ú_sqlr”Ú_paramsÚ_qrÚ_tuplesÚ_dictsrrr)rAr†r´r‹r"r@rCr%s zRawQuery.__init__cCs*t|j|jf|jžŽ}|j|_|j|_|Sr?)rr„rrrrrµr@r@rCr -szRawQuery.cloneÚjoiningrqrüTcCs ||_dSr?©r©rArr@r@rCr7szRawQuery.tuplescCs ||_dSr?©r©rAÚdictsr@r@rCr$;szRawQuery.dictscCs|j|jfSr?)rrrr@r@rCrŠ?szRawQuery.sqlcCsX|jdkrR|jr|j t¡}n |jr2|j t¡}n|j t¡}||j| ¡dƒ|_|jSr?) rrröÚget_result_wrapperÚRESULTS_TUPLESrÚ RESULTS_DICTSÚ RESULTS_NAIVEr„r)rAÚQRWr@r@rCrBs zRawQuery.executecCst| ¡ƒSr?©rrrr@r@rCrMszRawQuery.__iter__)T)T)rErFrGr$rr rrrqrürrr$rŠrrr%r@r@r"rCr srcKs8| dd¡}|rtdƒ‚|r,|p"g|p*dS|r4|SdS)NrIFz,"extend" is the only valid keyword argument.)rQr|)ÚorigÚnew_valrrIr@r@rCÚallow_extendPsr-csäeZdZdZ‡fdd„Z‡fdd„Zdd„ZeeƒZedƒZ ed ƒZ ed ƒZdd„Zd d„Z dd„ZeeƒZedd„ƒZedd„ƒZedd„ƒZedd„ƒZedd„ƒZedd„ƒZedd„ƒZedZd d!„ƒZed[d#d$„ƒZed\d&d'„ƒZed]d(d)„ƒZed^d*d+„ƒZed_d,d-„ƒZed`d.d/„ƒZedad1d2„ƒZdbd3d4„Z dcd5d6„Z!ddd7d8„Z"ded9d:„Z#dfd;d<„Z$d=d>„Z%d?d@„Z&dgdBdC„Z'dhdDdE„Z(dFdG„Z)dHdI„Z*dJdK„Z+dLdM„Z,dNdO„Z-dPdQ„Z.dRdS„Z/dTdU„Z0dVdW„Z1e2rÜdXdY„Z3‡Z4S)irÃrÀcs‚tt|ƒ |¡|jj|_|j|Žd|_d|_d|_ d|_ d|_d|_d|_ d|_d|_d|_d|_d|_d|_d|_d|_dS)NF)FF)rrÃrröÚ commit_selectrÚ_SelectQuery__selectrrrr rr!r"rr$Ú_naiverrÚ_aggregate_rowsr8r)rAr„Ú selectionr"r@rCr\s$ zSelectQuery.__init__cstt|ƒ |¡}|j|_t|jƒ|_|jdk rhg|_|jD],}t|tƒrZ|j | ¡¡q:|j |¡q:|jdk r~t|jƒ|_|jr|j ¡|_|j dk r¦t|j ƒ|_ |jdk r¼t|jƒ|_|j|_|j|_|j|_|j|_|j|_|j|_|j|_|j|_|j|_|Sr?)rrÃrërñr”ròrrSr=r…r rrr rr!r"rr$r0rrr1r8)rAr´rÏr"r@rCrëps6 zSelectQuery._clone_attributescs‡fdd„}|S)Ncs0|jjjj}ˆ|kr tdˆƒ‚t|j|ˆ|ƒS)Nz!Your database does not support %s)r„rröÚcompound_operationsr|r)rAr—Ú supported_ops©r•r@rCrsÿz&SelectQuery.compound_op..innerr@)r•rr@r5rCÚcompound_opŽszSelectQuery.compound_opÚUNIONÚ INTERSECTÚEXCEPTcCs4|j tdƒ¡ t||@ƒ d¡¡ ¡}||B|S)NrÊrö)r„rpr7Úfrom_r¯rOr™)rAr[Úwrapped_rhsr@r@rCrw›sÿzSelectQuery.__xor__cCst d¡||ƒS)Nú UNION ALL)rÃÚ_compound_op_staticrZr@r@rCÚ union_all¡szSelectQuery.union_allcGs,t|ƒdk|_|p|jjj}| |¡|_dSrÒ)ršrñr„rrXrörò©rAr2r@r@rCÚ__select¤szSelectQuery.__selectcGs|rt|ƒnd|_dSr?)r”r)rAr r@r@rCr:ªszSelectQuery.from_cOs|r| |¡nd|_dSr?)rörrr@r@rCÚgroup_by®szSelectQuery.group_bycGs| |j|¡|_dSr?)rórr÷r@r@rCÚhaving²szSelectQuery.havingcOst|jt|ƒf|Ž|_dSr?)r-r r”rr@r@rCr™¶szSelectQuery.order_bycOst|jt|ƒf|Ž|_dSr?)r-rr”)rAÚwindowsrr@r@rCrœºszSelectQuery.windowcCs ||_dSr?)r!)rAÚlimr@r@rCr(¾szSelectQuery.limitcCs ||_dSr?)r")rAÚoffr@r@rCÚoffsetÂszSelectQuery.offsetécCs$|dkr|d8}||_|||_dS©Nrr˜)r!r")rAÚpageÚpaginate_byr@r@rCÚpaginateÆszSelectQuery.paginateTcCs ||_dSr?)r)rAÚis_distinctr@r@rCÚdistinctÍszSelectQuery.distinctFcCs||f|_dSr?)r$)rAr)Únowaitr@r@rCr)ÑszSelectQuery.for_updatecCs ||_dSr?)r0)rAÚnaiver@r@rCrOÕszSelectQuery.naivecCs ||_dSr?r r!r@r@rCrÙszSelectQuery.tuplescCs ||_dSr?r"r#r@r@rCr$ÝszSelectQuery.dictscCs ||_dSr?)r1)rAÚaggregate_rowsr@r@rCrPászSelectQuery.aggregate_rowsNcCs ||_dSr?rM)rArOr@r@rCrOåszSelectQuery.aliascCsx|dkrt |jj¡ d¡}|j|kr4| |j¡}n| ¡}| |j|¡}|j sbdd„|jDƒ|_ t|jƒ|f|_|S)Nr‘cSsg|]}| ¡‘qSr@)rO)rKryr@r@rCrLòsz(SelectQuery.annotate..) rÚCountrr½rOrèrür„r rrròr“)rAr-Ú annotationr´r@r@rCÚannotateés zSelectQuery.annotatecCs*|dkrt tdƒ¡}| ¡}|g|_|S)NrÊ)rrQr7r™rò)rAÚaggregationr´r@r@rCÚ _aggregateös zSelectQuery._aggregatecCs| |¡j|dS)N©r)rUr)rArTrr@r@rCÚ aggregateýszSelectQuery.aggregatecCs4|js|js|js|jr$|j|dS|jddp2dS)N©Úclear_limitFrVr)rrr!r"Ú wrapped_countrW©rArYr@r@rCr‘szSelectQuery.countcCsJ| ¡}|rd|_|_| ¡\}}d|}|jj|f|žŽ}| ¡pHdS)Nz+SELECT COUNT(1) FROM (%s) AS wrapped_selectr)r™r!r"rŠr„Úrawr)rArYr rŠr‹ÚwrappedÚrqr@r@rCrZszSelectQuery.wrapped_countcCs$| dd¡}tdƒg|_t| ¡ƒS)Nr˜Ú1)rKr7ròrirr¬r@r@rCÚexistsszSelectQuery.existscCsH| dd¡}zt| ¡ƒWStk rB|j d| ¡¡‚YnXdS)Nr˜z:Instance matching query does not exist: SQL: %s PARAMS: %s)rKrˆrr‡r„rrŠr¬r@r@rCrÝsÿÿzSelectQuery.getr˜cCs<| ¡}| |¡|jd|…}|r8|dkr4|dS|SdS©Nr˜r)rr‘r„)rArœr—rŠr@r@rCÚpeeks zSelectQuery.peekcCs"|j|kr||_d|_|j|dS)NT)rœ)r!rÞrbr›r@r@rCrë&s zSelectQuery.firstcCs| ¡ |¡Sr?)rùrärr@r@rCrŠ,szSelectQuery.sqlcCsT|j}|jD]B}t|tƒr*|j|kr*dSt|tƒr|jdk r|j|krdSqdS)NFT)r„ròrSrr=rA)rAr„r>r@r@rCÚverify_naive/s zSelectQuery.verify_naivecCs|j|jfSr?)ròrrr@r@rCÚget_query_meta9szSelectQuery.get_query_metacCsf|jr|j t¡S|jr$|j t¡S|js8|jr8| ¡rD|j t ¡S|j rV|j t¡S|j t¡SdSr?) rrör%r&rr'r0rrcr(r1ÚRESULTS_AGGREGATE_MODELSÚRESULTS_MODELSrr@r@rCÚ_get_result_wrapper<szSelectQuery._get_result_wrappercCsN|js|jdkrD|j}| ¡}| ¡}||| ¡|ƒ|_d|_|jS|jSdSr?)rÞrr„rdrgr)rAr„Ú query_metaÚ ResultWrapperr@r@rCrHszSelectQuery.executecCst| ¡ƒSr?r*rr@r@rCrSszSelectQuery.__iter__cCst| ¡ ¡ƒSr?©rrr™rr@r@rCr™VszSelectQuery.iteratorcCsN| ¡}t|tƒr|j}n|}|dk r:|dkr6|dnd}| |¡|j|SrH)rrSÚsliceÚstopr‘r„)rArar—rãr@r@rCr¡Ys zSelectQuery.__getitem__cCst| ¡ƒSr?)ršrrr@r@rCr’dszSelectQuery.__len__cCst|ƒSr?)Úidrr@r@rCrhszSelectQuery.__hash__)rG)T)TF)T)T)T)T)N)N)N)NT)F)F)r˜)r˜)5rErFrGrnrrër6r5r=rqrprsrwr>r/rrpr:rArBr™rœr(rFrKrMr)rOrr$rPrOrSrUrWr‘rZr`rÝrbrërŠrcrdrgrrr™r¡r’ÚPY3rr%r@r@r"rCrÃYs| rÃc@s$eZdZdd„Zdd„Zdd„ZdS)ÚNoopSelectQuerycCs|j ¡dfS©Nr@)röÚget_noop_sqlrr@r@rCrŠlszNoopSelectQuery.sqlcCsdS)NrÂr@rr@r@rCrdoszNoopSelectQuery.get_query_metacCs|j t¡Sr?)rör%r&rr@r@rCrgrsz#NoopSelectQuery._get_result_wrapperN)rErFrGrŠrdrgr@r@r@rCroksrocsPeZdZdZd‡fdd„ Z‡fdd„Zddd „Zd d„Zdd „Zdd„Z ‡Z S)rrÁNcs(||_||_||_tt|ƒ |g¡dSr?)r¡r•r[rrr)rAr„r¡r•r[r"r@rCrxszCompoundSelect.__init__cs,tt|ƒ |¡}|j|_|j|_|j|_|Sr?)rrrër¡r•r[rµr"r@rCrë~s z CompoundSelect._clone_attributesFcCs|j|dS)NrX)rZr[r@r@rCr‘…szCompoundSelect.countcCs |j ¡Sr?)r¡rdrr@r@rCrdˆszCompoundSelect.get_query_metacCs|j ¡o|j ¡Sr?)r¡rcr[rr@r@rCrc‹szCompoundSelect.verify_naivecCsˆ|jr|j t¡S|jr$|j t¡S|jr6|j t¡S|jj pD|j j }|jjpZ|j jpZ|j}|sl|rl| ¡rx|j t ¡S|j t¡SdSr?)rrör%r&rr'r1rer¡rr[r0rcr(rf)rAÚ has_joinsÚis_naiver@r@rCrgŽsz"CompoundSelect._get_result_wrapper)NNN)F)rErFrGrnrrër‘rdrcrgr%r@r@r"rCrus rcsteZdZ‡fdd„Z‡fdd„Zdd„Zeedd„ƒƒZeedd d„ƒƒZeeddd „ƒƒZ dd„Z dd„Z‡ZS)Ú_WriteQuerycs,d|_d|_d|_d|_tt|ƒ |¡dSr?)r3rrrrrtrrér"r@rCržs z_WriteQuery.__init__cs6tt|ƒ |¡}|jr2t|jƒ|_|j|_|j|_|Sr?)rrtrër3r”rrrµr"r@rCrë¥sz_WriteQuery._clone_attributescs‡fdd„}|S)Ncs0|jjj}|js tdt|ƒƒ‚ˆ|f|ž|ŽS)Nz/RETURNING is not supported by your database: %s)r„rrör5r|r)rAr rr%©rDr@rCr®s ÿz-_WriteQuery.requires_returning..innerr@)rDrr@rurCÚrequires_returningsz_WriteQuery.requires_returningcGs>t|ƒdkr |ddkr d|_n|s.|jjj}| |¡|_dSra)ršr3r„rrXrör?r@r@rCÚ returning¶s z_WriteQuery.returningTcCs ||_dSr?r r!r@r@rCrÀsz_WriteQuery.tuplescCs ||_dSr?r"r#r@r@rCr$Åsz_WriteQuery.dictscCs:|jdk r.|jr|j t¡S|jr.|j t¡S|j t¡Sr?)r3rrör%r&rr'r(rr@r@rCr%Ês z_WriteQuery.get_result_wrappercCs2| ¡}|j|jgif}||j| ¡|ƒ|_|jSr?)r%r3r„rr)rArirKr@r@rCÚ_execute_with_result_wrapperÒsz(_WriteQuery._execute_with_result_wrapper)T)T) rErFrGrrërvrrwrr$r%rxr%r@r@r"rCrts rtcs`eZdZd‡fdd„ Z‡fdd„Zeddd„ƒZedƒZd d „Z dd„Z d d„Zdd„Z‡Z S)ÚUpdateQueryNcs ||_d|_tt|ƒ |¡dSr?)r2r1rryr)rAr„rr"r@rCrÚszUpdateQuery.__init__cs(tt|ƒ |¡}t|jƒ|_|j|_|Sr?)rryrërïr2r1rµr"r@rCrëßszUpdateQuery._clone_attributescCs ||_dSr?©r1©rAÚactionr@r@rCÚon_conflictåszUpdateQuery.on_conflictrcCs| ¡ |¡Sr?)rùr6rr@r@rCrŠëszUpdateQuery.sqlcCs@|jdk r|jdkr| ¡S|jdk r,|jS|j | ¡¡SdSr?©r3rrxröÚ rows_affectedrrr@r@rCrîs zUpdateQuery.executecCs |jjjjstdƒ‚t| ¡ƒS)NzwUPDATE queries cannot be iterated over unless they specify a RETURNING clause, which is not supported by your database.)r„rrör5r|rrrr@r@rCröszUpdateQuery.__iter__cCst| ¡ ¡ƒSr?rjrr@r@rCr™ýszUpdateQuery.iterator)N)N)rErFrGrrërr}rrrŠrrr™r%r@r@r"rCryÙsrycseZdZd‡fdd„ Zdd„Z‡fdd„Zed ƒZed ƒZe ddd „ƒZ e ddd„ƒZe ddd„ƒZe dd„ƒZdd„Zdd„Zdd„Z‡ZS)ÚInsertQueryNFcsftt|ƒ |¡d|_|dk p$|dk |_d|_|dk r>||_n|pDig|_||_||_||_ d|_ dSr?)rr€rr<Ú_is_multi_row_insertÚ_return_id_listr@r?r>Ú_validate_fieldsr1)rAr„rÔÚrowsr&r´Úvalidate_fieldsr"r@rCr szInsertQuery.__init__c #s¼|jj}|jr |j‰‡fdd„}|j}|j}|jD]„}| ¡}tƒ}|D]B}|jrZ||ƒ||j krp|j |} n|} |||| <| | ¡qH|r°|D]} | |kr”|| ƒ|| <q”|Vq2dS)Ncs|ˆkrtd|ƒ‚dS)Nz"%s" is not a recognized field.)rÂ)r+©Úvalid_fieldsr@rCÚvalidate_field sz.InsertQuery._iter_rows..validate_field)r„rrƒr‡Ú _default_dictÚ_default_callablesr@rr’r&r€) rAÚ model_metarˆÚdefaultsÚ callablesrJÚ field_rowrŒrr+r@r†rCrA s, zInsertQuery._iter_rowscsTtt|ƒ |¡}|j|_|j|_|j|_|j|_|j|_|j|_|j |_ |j |_ |Sr?)rr€rër@r<rr?r>r‚rƒr1rµr"r@rCrë/ szInsertQuery._clone_attributesrzwhere clauseTcCs ||_dSr?)r<)rAÚupsertr@r@rCr> szInsertQuery.upsertcCs ||_dSr?rzr{r@r@rCr}B szInsertQuery.on_conflictcCs ||_dSr?)r‚)rAÚreturn_id_listr@r@rCrF szInsertQuery.return_id_listcCs|jjr|jr|jrdSdS©NTF)röÚinsert_returningrr‚rr@r@rCrFJ szInsertQuery.is_insert_returningcCs| ¡ |¡Sr?)rùrKrr@r@rCrŠQ szInsertQuery.sqlcCsPg}d}|j}|jD]*}t|j|ƒ |j¡ ¡}|r| |¡q|rH|S|SdSr?)r‚r@r€r„rr<rr…)rAÚid_listÚlast_idrr”r@r@rCÚ_insert_with_loopT s ÿzInsertQuery._insert_with_loopcCsâ|jo"|jdko"|jdko"|jj}|r0| ¡S|jdk rL|jdkrL| ¡S|jdk r\|jS| ¡}|jsÀ|jj r°| ¡}|jj}dd„t | ¡|ƒDƒ}|jjjr¨|S|dS|j ||j¡S|jrÚtt d¡| ¡ƒSdSdS)NcSsg|]\}}| |¡‘qSr@)r)rKr+r©r@r@rCrLw sÿz'InsertQuery.execute..rT)rr>r3röÚinsert_manyr•rrxrr’r–r„rr”rGrWÚlast_insert_idr‚rr•Ú itemgetterÚfetchall)rAÚinsert_with_loopr‹Úpk_rowrKÚ clean_datar@r@rCrd s8ÿþü ý zInsertQuery.execute)NNNNF)T)N)T)rErFrGrrArërrrqrrr}rr×rFrŠr•rr%r@r@r"rCr€ s(ÿ r€c@s$eZdZedƒZdd„Zdd„ZdS)ÚDeleteQueryrcCs| ¡ |¡Sr?)rùrLrr@r@rCrŠ‡ szDeleteQuery.sqlcCs@|jdk r|jdkr| ¡S|jdk r,|jS|j | ¡¡SdSr?r~rr@r@rCrŠ s zDeleteQuery.executeN)rErFrGrrrŠrr@r@r@rCr„ srÚ IndexMetadata)rrŠrZrärjÚColumnMetadata)rÚ data_typerâr½rjÚForeignKeyMetadata)r©Ú dest_tableÚdest_columnrjc@seZdZdS)ÚPeeweeExceptionN©rErFrGr@r@r@rCr¤ž sr¤c@seZdZdS)r!Nr¥r@r@r@rCr!Ÿ sc@seZdZdS)rNr¥r@r@r@rCr sc@seZdZdS)rNr¥r@r@r@rCr¡ sc@seZdZdS)r#Nr¥r@r@r@rCr#¢ sc@seZdZdS)r$Nr¥r@r@r@rCr$£ sc@seZdZdS)r%Nr¥r@r@r@rCr%¤ sc@seZdZdS)r,Nr¥r@r@r@rCr,¥ sc@seZdZdS)r-Nr¥r@r@r@rCr-¦ sc@seZdZdS)r2Nr¥r@r@r@rCr2§ sc@s*eZdZdgZdd„Zdd„Zdd„ZdS) ÚExceptionWrapperÚ exceptionscCs ||_dSr?)r§)rAr§r@r@rCr szExceptionWrapper.__init__cCsdSr?r@rr@r@rCÚ __enter__° rVzExceptionWrapper.__enter__cCsH|dkrdS|j|jkrD|j|j}tr.|}n|j}t|||Ž|ƒdSr?)rEr§ÚPY26r rc)rAÚexc_typeÚ exc_valueÚ tracebackÚnew_typeÚexc_argsr@r@rCÚ__exit__± szExceptionWrapper.__exit__N)rErFrGrrr¨r¯r@r@r@rCr¦ª sr¦cseZdZ‡fdd„Z‡ZS)Ú_BaseConnectionLocalcs4tt|ƒjf|Žd|_d|_d|_g|_g|_dSrÁ)rr°rÚ autocommitÚclosedÚconnÚ context_stackÚtransactionsrr"r@rCr½ sz_BaseConnectionLocal.__init__)rErFrGrr%r@r@r"rCr°¼ sr°c@seZdZdS)Ú_ConnectionLocalNr¥r@r@r@rCr¶Å sr¶c @s|eZdZdZeZddddgZdZdZdZ iZ dZdZdZ dZdZdZdZiZd ZgZdZdZdZdZdZdZeeeeeee e!e"d œ Z#d}dd„Z$d d„Z%dd„Z&dd„Z'dd„Z(dd„Z)dd„Z*dd„Z+dd„Z,dd„Z-dd „Z.e/d!d"„ƒZ0e/d#d$„ƒZ1d%d&„Z2d'd(„Z3d)d*„Z4d+d,„Z5d-d.„Z6d~d/d0„Z7d1d2„Z8d3d4„Z9d5d6„Z:d7d8„Z;d9d:„Z„Z>d?d@„Z?ddAdB„Z@dCdD„ZAdEdF„ZBdGdH„ZCdIdJ„ZDdKdL„ZEd€dMdN„ZFdOdP„ZGddQdR„ZHd‚dSdT„ZIdƒdUdV„ZJd„dWdX„ZKd…dYdZ„ZLd[d\„ZMd†d]d^„ZNd‡d_d`„ZOdˆdadb„ZPd‰dcdd„ZQdŠdedf„ZRdgdh„ZSd‹didj„ZTdŒdkdl„ZUddmdn„ZVdŽdodp„ZWdqdr„ZXdsdt„ZYdudv„ZZdwdx„Z[dydz„Z\d{d|„Z]dS)ÚDatabaseFr7r8r9r<Tr´Nr³) ÚConstraintErrorrrr#r$r%r,r-r2c Ksni|_|rtƒ|_ntƒ|_|j|f|Žt ¡|_||_||_ ||_ t|j|pRiƒ|_t|j |pdiƒ|_ dSr?)Úconnect_kwargsr¶Ú_localr°ÚinitÚ threadingÚLockÚ _conn_lockr±ÚautorollbackÚuse_speedupsrr¾r¿) rAröÚthreadlocalsr±r&Úopsr¿rÀr¹r@r@rCrì s zDatabase.__init__cKs0| ¡s| ¡|dk|_||_|j |¡dSr?)Ú is_closedr—ryrör¹r)rArör¹r@r@rCr»þ s z Database.initcCs t|jƒSr?)r¦r§rr@r@rCÚexception_wrapperszDatabase.exception_wrapperc Csd|jT|jrtdƒ‚| ¡2|j|jf|jŽ|j_d|j_ | |jj¡W5QRXW5QRXdS)NzBError, database not properly initialized before opening connectionF)r¾ryÚ ExceptionrÄÚ_connectrör¹rºr³r²Úinitialize_connectionrr@r@rCÚconnects ÿþzDatabase.connectcCsdSr?r@©rAr³r@r@rCrÇszDatabase.initialize_connectionc CsN|j>|jrtdƒ‚| ¡| |jj¡d|j_W5QRXW5QRXdS)NzBError, database not properly initialized before closing connectionT)r¾ryrÅrÄÚ_closerºr³r²rr@r@rCr—s zDatabase.closecCs:|jjr"|jjdj}|dk r"|S|jjr2| ¡|jjSr²)rºr´Ú connectionr²rÈr³rÉr@r@rCÚget_conn szDatabase.get_conncCs|jjSr?)rºr²rr@r@rCrÃ)szDatabase.is_closedcCs| ¡ ¡Sr?)rÌr‹rr@r@rCÚ get_cursor,szDatabase.get_cursorcCs| ¡dSr?)r—rÉr@r@rCrÊ/szDatabase._closecKst‚dSr?r)rArörr@r@rCrÆ2szDatabase._connectcCst|j|ƒ|_dSr?)rr¾)rGr&r@r@rCÚregister_fields5szDatabase.register_fieldscCst|j|ƒ|_dSr?)rr¿)rGrÂr@r@rCÚregister_ops9szDatabase.register_opscCsl|tkr|jrtStS|tkr"tS|tkr8|jr4tStS|t krN|jrJt StS|tkrZt S|jrdtStSdSr?)r(rÀr¢r§rfr«r&r¤r¤r'r¡rªrerÌ)rAÚwrapper_typer@r@rCr%=s& ÿ ÿ ÿ ÿzDatabase.get_result_wrappercCs|jjr|jSdSr?)rrDÚ lastrowid)rAr‹r†r@r@rCr—OszDatabase.last_insert_idcCs|jSr?)Úrowcount)rAr‹r@r@rCrSszDatabase.rows_affectedcCs| |j|j|j|j¡Sr?)Úcompiler_classrµr¶r¾r¿rr@r@rCrùVsþzDatabase.compilercCs|j| ¡ |¡ŽSr?)rrùrÛ)rAr§r@r@rCr[szDatabase.executec Cs„t ||f¡| ¡d| ¡}z| ||p.d¡Wn,tk r`| ¡rZ|jrZ| ¡‚YnX|rv| ¡rv| ¡W5QRX|Srp) ÚloggerÚdebugrÄrÍrrÅÚget_autocommitr¿ÚrollbackÚcommit)rArŠr‹rr‹r@r@rCr^s zDatabase.execute_sqlcCsdSr?r@rr@r@rCÚbeginmszDatabase.begincCs| ¡ ¡dSr?)rÌrØrr@r@rCrØpszDatabase.commitcCs| ¡ ¡dSr?)rÌr×rr@r@rCr×sszDatabase.rollbackcCs||j_dSr?)rºr±)rAr±r@r@rCÚset_autocommitvszDatabase.set_autocommitcCs |jjdkr| |j¡|jjSr?)rºr±rÚrr@r@rCrÖyszDatabase.get_autocommitcCs|jj |¡dSr?)rºr´r…©rAÚtransactionr@r@rCÚpush_execution_context~szDatabase.push_execution_contextcCs|jj ¡dSr?)rºr´rQrr@r@rCÚpop_execution_contextszDatabase.pop_execution_contextcCst|jjƒSr?)ršrºr´rr@r@rCÚexecution_context_depth„sz Database.execution_context_depthcCst||dS)N)Úwith_transaction)ÚExecutionContext)rAràr@r@rCÚexecution_context‡szDatabase.execution_contextcCs|jj |¡dSr?)rºrµr…rÛr@r@rCÚpush_transactionŠszDatabase.push_transactioncCs|jj ¡dSr?)rºrµrQrr@r@rCÚpop_transactionszDatabase.pop_transactioncCst|jjƒSr?)ršrºrµrr@r@rCÚtransaction_depthszDatabase.transaction_depthcCst|ƒSr?©rÜrr@r@rCrÜ“szDatabase.transactioncstˆƒ‡‡fdd„ƒ}|S)Nc s*ˆ ¡ˆ||ŽW5QR£SQRXdSr?rærž©r rAr@rCr—s z)Database.commit_on_success..innerr)rAr rr@rçrCÚcommit_on_success–szDatabase.commit_on_successcCs|js t‚t||ƒSr?)Ú savepointsrÚ savepoint©rAÚsidr@r@rCrêszDatabase.savepointcCst|ƒSr?)Ú_atomicrr@r@rCÚatomic¢szDatabase.atomiccCst‚dSr?r©rArìr@r@rCÚ get_tables¥szDatabase.get_tablescCst‚dSr?r©rArjrìr@r@rCÚget_indexes¨szDatabase.get_indexescCst‚dSr?rrñr@r@rCÚget_columns«szDatabase.get_columnscCst‚dSr?rrñr@r@rCÚget_primary_keys®szDatabase.get_primary_keyscCst‚dSr?rrñr@r@rCÚget_foreign_keys±szDatabase.get_foreign_keyscCst‚dSr?r)rAÚseqr@r@rCÚsequence_exists´szDatabase.sequence_existscCs| ¡}|j| ||¡ŽSr?)rùrrw)rAr„rYÚqcr@r@rCrw·szDatabase.create_tablecCst||ddS)N)r_)Úcreate_model_tables)rArŠrYr@r@rCÚ create_tables»szDatabase.create_tablescsH| ¡}t|ttfƒs"td|ƒ‚‡fdd„|Dƒ}|j| ˆ||¡ŽS)Nz=Fields passed to "create_index" must be a list or tuple: "%s"cs&g|]}t|tƒrˆjj|n|‘qSr@©rSr:rr&rU©r„r@rCrLÃsÿz)Database.create_index..)rùrSr”r“r|rrz)rAr„r&rärøÚfobjsr@rürCrz¾sÿ þzDatabase.create_indexcsH| ¡}t|ttfƒs"td|ƒ‚‡fdd„|Dƒ}|j| ˆ||¡ŽS)Nz;Fields passed to "drop_index" must be a list or tuple: "%s"cs&g|]}t|tƒrˆjj|n|‘qSr@rûrUrür@rCrLÍsÿz'Database.drop_index..)rùrSr”r“r|rr{)rAr„r&rYrørýr@rürCr{Èsÿ þzDatabase.drop_indexcCs| ¡}|j| |||¡ŽSr?)rùrrv)rAr„r+r rør@r@rCrvÒsÿzDatabase.create_foreign_keycCs"|jr| ¡}|j| |¡ŽSdSr?)Ú sequencesrùrr|©rArörør@r@rCr|×szDatabase.create_sequencecCs| ¡}|j| |||¡ŽSr?)rùrrx)rAr„r_r`rør@r@rCrxÜsÿzDatabase.drop_tablecCst|||ddS)N)r_r`)Údrop_model_tables)rArŠrYr`r@r@rCÚdrop_tablesászDatabase.drop_tablescCs| ¡}|j| |||¡ŽSr?)rùrry)rAr„rbr`rør@r@rCryäsÿzDatabase.truncate_tablecCs"tt|ƒƒD]}| ||¡qdSr?)r•rvry)rArŠrbr`r†r@r@rCÚtruncate_tablesêszDatabase.truncate_tablescCs"|jr| ¡}|j| |¡ŽSdSr?)rþrùrr}rÿr@r@rCr}îszDatabase.drop_sequencecCst t|tdƒ|ƒ¡S©Nr©rÚEXTRACTrr4©rArAÚ date_fieldr@r@rCr?ószDatabase.extract_datecCst ||¡Sr?)rÚ DATE_TRUNCrr@r@rCÚ truncate_dateöszDatabase.truncate_datecCstdƒS)NzDEFAULT VALUESr³rér@r@rCrEùszDatabase.default_insert_clausecCsdS)NzSELECT 0 WHERE 0r@rr@r@rCrqüszDatabase.get_noop_sqlcCstSr?)r;rr@r@rCr8ÿszDatabase.get_binary_type)TTNNFT)NT)T)N)N)N)N)N)N)F)F)F)F)N)FF)FF)FF)FF)^rErFrGr.r¥rÓr3ræÚdistinct_onÚdrop_cascader¾Úforeign_keysr)Úfor_update_nowaitr–r’r¶r#r¿rµÚreserved_tablesr5rérþÚsubquery_delete_same_tabler=Úwindow_functionsr#rrr$r%r,r-r2r§rr»rÄrÈrÇr—rÌrÃrÍrÊrÆrorÎrÏr%r—rrùrrrÙrØr×rÚrÖrÝrÞrßrârãrärårÜrèrêrîrðròrórôrõr÷rwrúrzr{rvr|rxrryrr}r?r rErqr8r@r@r@rCr·È sÆ÷ÿ ÿ r·csØeZdZeZddddœZdZeo(ejdkZ dZ ejdej diZd Zd*‡fdd„ Zd d„Zdd„Zdd„Zd+dd„Zd,dd„Zd-dd„Zd.dd„Zd/dd„Zd0dd„Zd1d d!„Zd2d"d#„Zd$d%„Zd&d'„Zd(d)„Z‡ZS)3r6r®r°)rirr<F)rOrMérr³ÚGLOBrñzINSERT OR REPLACE INTONcsF|pg|_| dd¡}|r*|j d|f¡tt|ƒj|f|ž|ŽdS)NÚjournal_mode)Ú_pragmasrQr…rr6r)rAröÚpragmasr rrr"r@rCrs zSqliteDatabase.__init__cKsJtstdƒ‚tj|f|Ž}d|_z| |¡Wn| ¡‚YnX|S)Nz&pysqlite or sqlite3 must be installed.)Úsqlite3r!rÈÚisolation_levelÚ_add_conn_hooksr—)rArörr³r@r@rCrÆszSqliteDatabase._connectcCs8| |¡| ddt¡| ddt¡| ddt¡dS)NrArNÚ date_truncrÛ)Ú_set_pragmasÚcreate_functionr¹r¼rÁrÉr@r@rCr&s zSqliteDatabase._add_conn_hookscCs<|jr8| ¡}|jD]\}}| d||f¡q| ¡dS)NzPRAGMA %s = %s;)rr‹rr—)rAr³r‹Úpragmarar@r@rCr,s zSqliteDatabase._set_pragmasÚDEFERREDcCs|jd|dddS)NzBEGIN %sF©r©r)rAÚ lock_typer@r@rCrÙ3szSqliteDatabase.begincCstdƒ‚dS)NzBSQLite does not support ALTER TABLE statements to add constraints.)r-)rAr„r+r r@r@rCrv6sz!SqliteDatabase.create_foreign_keycCs| dd¡}dd„| ¡DƒS)Nz