]jL N d dl mZ d dl mZ d dlmZ d dlmZ d dlmZ d dl m
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZ d dlm Z n# e $ r d dl m Z Y nw xY w d d l m Z n # e $ r d d l!m Z n
# e $ r dZ Y nw xY wY nw xY w d dl"Z"e re j# e"j# k re Z"n
# e $ r e Z"Y nw xY w d d
l$m%Z% e%j& n # e $ r Y nw xY w d dl'Z'd d l'm(Z) d d l'm*Z+ n
# e $ r dZ+Y nw xY wn# e $ r dxZ'Z+Y nw xY w d d
l,m-Z. e. n # e/$ r Y nw xY w d d l0m*Z1 n
# e $ r dZ1Y nw xY wdZ2dZ3dZ4g dZ5 d dlm6Z6 n # e $ r G d dej7 Z6Y nw xY w ej8 d Z9e9: e6 ej; d dk r$e<Z=e>Z?e@ZAejB ZBeCZDeEeFeGeHfZI eJd d ZKnOd dlLZL d dlmMZM n# e $ r d dl mMZM Y nw xY wd dlmNZN d ZDe>Z=eOZ?ePZAe>ZQeRZSeEeFeGeHeTfZI eUeLd ZKejV ZBd d ZWej; d k re
j
jX ZXe
j
jY ZYnd ZXd ZYe"r e"jZ ej[ e> e"jZ e
j\ e> e"jZ e
j e> ej; d k rAd Z]d! Z^d" Z_ e"jZ e
j
e] e"j` d#e^ e"j` d$e_ e"j# Zand%Za eHd& Zbd'Zcd(d)d*d+d,d-d&Zded Zed.eed/< d0eed1< d2 Zfd3 Zgd4 Zh G d5 d6ei Zj ek Zl ejd
i d7d7d8d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdUdVdWdXdXdYdZd[d[d\d\d]d]d^d^d_d_d`dadbdcZm ejejn ejo ejp ejq ejr ejs ejt dd de df dg dh Zu ejd
i didjdkdldldldmdmdndodpdpdqdqdrdrdsdsdtdudvdwdxdwdydjdododzdzd{d{d|dzd}dmd~d~Zv ejddddddddd Zw ejddddd Zx ejdd ZydZzdZ{dZ|dZ}dZ~d ZdZdZ ej d Z ej d ZdZekfdZd Zd Zd Zd Zd Zd Zd Z G d dek Z G d dek Z G d de Z G d dek Z G d dek Z G d d e j dd Zd Z G d dek Zd Zd Z G d dek Z G d dek Z G d dek Z G d dek Z G d de Z G d de Z G d dek Zd Zewj dfdZ G d de Z G d dek Z G dÄ dee Z G dń de Z G dDŽ dee Z G dɄ dee Z G d˄ de Z G d̈́ de Z G dτ de Z G dф dek Z G dӄ dek Z G dՄ de Z G dׄ de Z G dل de Z G dۄ dek Z G d݄ dee Z G d߄ de Z G d de Zd Z G d de Z G d de Zd dZd dZ G d de Z G d de Z G d de Z G d de Zd dZ G d de Z edd Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d e ZƐd Zǐd Z G d de Z G d de Z eɐd Z G d d e Z̐d
Z G d d e Zΐd
Z G d de ZАd Z G d de Z G d deҦ Z G d deҦ ZԐd dZ G d deԦ Z G d deee֦ Z G d d eצ Z G d d eצ Z G d d!eԦ Z G d" d#eڦ Z G d$ d%eڦ Z G d& d'eڦ Z G d( d)e Z G d* d+eަ Zߐd
d-Z G d. d/e/ Z G d0 d1e Z G d2 d3e Z G d4 d5e Z G d6 d7e Z G d8 d9e Z G d: d;e Z G d< d=e Z G d> d?e Z G d@ dAe Z G dB dCek ZeeeeeeeeeeeedD Z ee Z e j dEdF Z e j dGdH Z e j dIdJ Z e j dKdL Z G dM dNek Z G dO dPeej Z G dQ dRek Z G dS dTek Z G dU dVe ZdW Z G dX dYe Z G dZ d[e Z G d\ d]e Z G d^ d_ek Z G d` daek Z G db dcek Z G dd deek Z G df dgek Z G dh die Z G dj dke Z G dl dme Z G dn doek Z G dp dqek Z G dr dse Z G dt duek Z G dv dwek Z G dx dye Z G dz d{e Z
G d| d}e Z G d~ de Z G d de Z
G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d dee Z G d dek Z G d de Z G d de Z G d de Z G d de Z d Z d dZ!d Z" G d de Z# G d de# Z$ G d de# Z% G d de# Z&d Z' G d de Z( G d de Z) G d de Z* G d de Z+ G d de Z, G d de Z- G d dek Z. G d de Z/ G d dÐe Z0 G dĄ dŐe/ Z1 G dƄ dǐe/ Z2 G dȄ dɐe/ Z3 G dʄ dek Z4 G d̄ dek Z5 G d΄ dek Z6 G dЄ dѐe6 Z7 G d҄ de/ Z8 G dԄ dՐe9 Z: G dք dek Z; G d d ee:e Z< G dڄ de Z= G d܄ dݐe Z>dބ Z? G d߄ dek Z@ G d de@eӦ ZA G d de@ ZB G d deBeئ ZCd ZD G d deBe٦ ZE G d deE ZF G d de@ ZG G d deGeۦ ZH G d deGeܦ ZI G d deGeݦ ZJ G d deE ZKd ZL G d de ZM G d deM ZN G d deN ZO G d deO ZP G d d eN ZQ G d deM ZR G d d e j dd ZSd ZTd ZUdS ( ) bisect_left) bisect_rightcontextmanager)deepcopywraps)isclassN)Mapping)dbapi2)compat)
extensions)errors)
register_uuidFz3.17.9)KAnyFieldAsIs AutoField BareField BigAutoField BigBitFieldBigIntegerFieldBinaryUUIDFieldBitField BlobField BooleanFieldCaseCast CharFieldCheckchunkedColumn CompositeKeyContextDatabase
DatabaseError
DatabaseProxy DataError DateField
DateTimeField DecimalFieldDeferredForeignKeyDeferredThroughModel
DJANGO_MAP DoesNotExist DoubleFieldDQEXCLUDEDFieldFixedCharField
FloatFieldfnForeignKeyField
IdentityFieldImproperlyConfiguredIndex IntegerFieldIntegrityErrorInterfaceError
InternalErrorIPFieldJOINManyToManyFieldModel
ModelIndex
MySQLDatabaseNotSupportedErrorOPOperationalErrorPostgresqlDatabasePrimaryKeyFieldprefetch
PREFETCH_TYPEProgrammingErrorProxyQualifiedNames
SchemaManagerSmallIntegerFieldSelectSQLSqliteDatabaseTable TextField TimeFieldTimestampFieldTuple UUIDFieldValue
ValuesListWindow) NullHandlerc e Zd Zd ZdS )r\ c d S N )selfrecords =/opt/imunify360/venv/lib64/python3.11/site-packages/peewee.pyemitzNullHandler.emit s D N)__name__
__module__ __qualname__rd r` re rc r\ r\ s# re r\ peewee z4def reraise(tp, value, tb=None): raise tp, value, tbc t j | t j d d S )N
)sysstdoutwritess rc print_rr s4
re )Callable)reducec , t | t S r_ )
isinstancers )cs rc <lambda>rx s *Q11 re printc B |j |ur| | |r_ )
__traceback__with_traceback)tpvaluetbs rc reraiser s) b ( (&&r** * re ) c t j | t j j d S )N)tztzinfo)datetime
fromtimestamptimezoneutcreplace)tss rc utcfromtimestampr s3 ! rh&7&; <<%% 're c t j t j j d S )Nr )r nowr r r r` re rc utcnowr s/ !X&*++%% 're c , | d S N ) isoformatds rc datetime_adapterr s C(8(8!8re c j t j t t | d S )N -)r datemapintsplitr s rc convert_dater s" HM3sAGGDMM3J3J$K Kre c | d \ }}t t | d \ }}} |j d }t t |d d \ }}} t | dk r;t d |d }
nd}
t
j |||||| |
S ) N r .r :rj z{:0<6.6} )r r r lenformatdecoder ) tr timeymr t_fullhourminutesecondusecs rc convert_timestampr s JD$#tzz$ / /00GAq! TZ%%F#&sF1IOOD,A,A#B#B D&&6{{a :,,VAY-=-=-?-?@@AA$Q1dFFDII Ire r timestampr r r )yearmonthdayr r r )%Y-%m-%d %H:%M:%S%Y-%m-%d %H:%M:%S.%f%Y-%m-%d%H:%M:%S %H:%M:%S.%f%H:%Mz%Y-01-01 00:00:00z%Y-%m-01 00:00:00z%Y-%m-%d 00:00:00z%Y-%m-%d %H:00:00z%Y-%m-%d %H:%M:00r z%Y-%m-%d %H:%i:00r z%Y-%m-%d %H:%i:%Sr c j | t v sJ |sd S t |t }t || S r_ )__date_parts__format_date_time__sqlite_datetime_formats__getattr lookup_typedatetime_stringdts rc _sqlite_date_partr s@ . ( ( ( ( /+F G GB 2{ # ##re c | t v sJ |sd S t |t }| t | S r_ )__sqlite_date_trunc__r r strftimer s rc _sqlite_date_truncr sI / / / / / /+F G GB
;;,[9 : ::re c : t j | t d S r_ )warningswarnDeprecationWarningrp s rc __deprecated__r s M!'(((((re c & e Zd Zd Zd Zd Zd ZdS )attrdictc N | | S # t $ r t | w xY wr_ )KeyErrorAttributeErrorra attrs rc __getattr__zattrdict.__getattr__ s: ': ' ' ' && & 's
$c || |< d S r_ r` ra r r~ s rc __setattr__zattrdict.__setattr__ s UT
re c 0 | | | S r_ updatera rhss rc __iadd__zattrdict.__iadd__ s T[[ - - -d{re c N t | }| | |S r_ )r r )ra r r s rc __add__zattrdict.__add__ s A
axre N)rf rg rh r r r r r` re rc r r s< ' ' '
;:::::GGGGGre r ANDORADD+SUB-MUL*DIV/BIN_AND&BIN_OR|XOR#MOD%EQ=LT<LTEz<=GT>GTEz>=NEz!=INNOT_INzNOT INISIS_NOTzIS NOTLIKEILIKEBETWEENREGEXPIREGEXPCONCATz||BITWISE_NEGATION~c 8 t | t j | S r_ )
ExpressionrE r lrs rc rx rx H s z!RUA.. re c 8 t | t j | S r_ )r
rE r r s rc rx rx I s Arw22 re c 8 t | t j | S r_ )r
rE r r s rc rx rx J s *Q!44 re c 8 t | t j | S r_ )r
rE r r s rc rx rx K s :aA66 re ) eqltltegtgteneinislikeilikeregexpAUTOINTEGERBIGAUTOBIGINTBLOBBOOLSMALLINTCHARDATEDATETIMEDECIMALDEFAULT DOUBLEREALFLOATINTTEXTTIMEUUIDUUIDBVARCHARz
INNER JOINzLEFT OUTER JOINzRIGHT OUTER JOINz FULL JOINzFULL OUTER JOINz
CROSS JOINz NATURAL JOINLATERALzLEFT JOIN LATERAL) INNER
LEFT_OUTER RIGHT_OUTERFULL
FULL_OUTERCROSSNATURALr2 LEFT_LATERALr r )TUPLEDICT NAMED_TUPLE CONSTRUCTORMODEL)WHEREr? z(.)_*([A-Z][a-z]+)z([a-z0-9])_*([A-Z])_metaclass_helper_c ( | t |fi S r_ )
MODEL_BASE)metabases rc with_metaclassrJ s 4
TGR ( ((re c \ | }|r| | |S r_ )copyr )source overridesmergeds rc
merge_dictrP s.
[[]]F !
i Mre c t | dk r| d S d fd| D S )Nr r .c : g | ]}| S r` join).0part quote_charss rc
<listcomp>zquote.<locals>.<listcomp> s% ===TYY{++===re )r rU )pathrX s `rc quoter[ sO
4yyA~~Aw||K((( 88======= > >>re c J t | ot | t S r_ )r
issubclassrA )os rc rx rx s WQZZ8Jq%$8$8 re c L | !t | t t f r| n| fS d S r_ )rv listtupler~ s rc ensure_tuplerc s/ "54-88FuuuhF re c V | &t | t r| nt | S d S r_ )rv NodeEntityrb s rc
ensure_entityrg s/ "5$//BuuVE]]B re c t d| }t d| S )Nz\1_\2)SNAKE_CASE_STEP1subSNAKE_CASE_STEP2lower)rq firsts rc make_snake_casern s9 1 - -E % 0 0 6 6 8 88re c # K t }d t t | g|z d|iD D ](}|d |u r|| | d = |V )d S )Nc 3 4 K | ]}t | V d S r_ )r` )rV gs rc <genexpr>zchunked.<locals>.<genexpr> s@ C Ca$q'' C C C C C Cre fillvalue)object izip_longestiterindex)itnmarkergroups rc r r s
XXFC C<$r((a $B:@$B $B C C C 9 ekk&))**+ re c e Zd Zd ZdS )_callable_context_managerc @ t fd }|S )Nc L 5 | i |cd d d S # 1 swxY w Y d S r_ r` argskwargsr5 ra s rc innerz1_callable_context_manager.__call__.<locals>.inner s
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+s r ra r5 r s `` rc __call__z"_callable_context_manager.__call__ 9 r + + + + +
+ re N)rf rg rh r r` re rc r~ r~ s# re r~ c p e Zd ZdZdZd Zd Zd Zd Z ed Z ed Z
d Z fd
Z xZ
S ) rL z;
Create a proxy or placeholder for another object.
obj
_callbacksc > g | _ | d d S r_ )r
initializera s rc __init__zProxy.__init__ s! re c > || _ | j D ]
} || d S r_ r )ra r callbacks rc r zProxy.initialize s3 H HSMMMM re c : | j | |S r_ )r append)ra r s rc attach_callbackzProxy.attach_callback s x(((re c fd}|S )Nc f | j t d t | j |i |S Nz Cannot use uninitialized Proxy.r r r )ra r r methods rc r z Proxy.passthrough.<locals>.inner s; x $%FGGG,748V,,d=f== =re r` r r s ` rc passthroughzProxy.passthrough s# > > > > > re __enter____exit__c X | j t d t | j | S r r r s rc r zProxy.__getattr__ s+ 8 !BCC Ctx&&&re c || j vrt d t t | || S )Nz Cannot set attribute on proxy.) __slots__r superrL r )ra r r~ __class__s rc r zProxy.__setattr__ s? t~ % % !ABB BUD!!--dE:::re )rf rg rh __doc__r r r r r r r r r
__classcell__r s @rc rL rL s &I
K((I{:&&H' ' '
; ; ; ; ; ; ; ; ;re rL c J e Zd ZdZdZd Zd Zd Zd Zd Z e
d Z d S )
r& zL
Proxy implementation specifically for proxying `Database` objects.
)r r _Modelc t | S r_ ConnectionContextr s rc connection_contextz DatabaseProxy.connection_context &&&re c " t | g|R i |S r_ _atomicra r r s rc atomiczDatabaseProxy.atomic t-d---f---re c t | S r_ _manualr s rc
manual_commitzDatabaseProxy.manual_commit t}} re c " t | g|R i |S r_ _transactionr s rc transactionzDatabaseProxy.transaction D242226222re c t | S r_
_savepointr s rc savepointzDatabaseProxy.savepoint $ re c t d s- G fdd }t dt fd|i _ j S )Nr c e Zd Z ZdS )!DatabaseProxy.Model.<locals>.MetaNrf rg rh databaser s rc Metar 4re r BaseModelhasattrtyperA r ra r s ` rc rA zDatabaseProxy.Model U tX&& F ' ' ' ' ' ' ' ' ' ' {UHvtnEEDK{re N) rf rg rh r r r r r r r propertyrA r` re rc r& r& s 0I' ' '. . . 3 3 3
X re r& c e Zd ZdS )ModelDescriptorNrf rg rh r` re rc r r re r c T e Zd ZdZd Zed Zd Zd dZd Z d Z
d Z d
Z d S )
AliasManager)_counter_current_index_mappingc X d| _ d| _ g | _ | d S Nr )r r r pushr s rc r zAliasManager.__init__ s)
re c , | j | j dz
S Nr )r r r s rc mappingzAliasManager.mapping s }T 01 455re c h || j vr | xj dz
c_ d| j z | |< | j | S )Nr zt%d)r r ra rM s rc addzAliasManager.add s< % % MMQ MM 4=0DL|F##re Fc |rHt t | j D ]&}|| j | v r| j | | c S '| | S r_ )reversedranger r r )ra rM any_depthidxs rc getzAliasManager.get sm 6 d&9 : :;;
6
6T]3 /// =-f5555 0xx re c , | | S r_ )r r s rc __getitem__zAliasManager.__getitem__$ s xx re c || j |< d S r_ )r )ra rM aliass rc __setitem__zAliasManager.__setitem__' s $ V re c | xj dz
c_ | j t | j k r | j i d S d S r )r r r r r s rc r zAliasManager.push* sR q T]!3!3 3 3 M $ $ $ $ $ 4 3re c Z | j dk rt d | xj dz c_ d S )Nr z&Cannot pop() from empty alias manager.)r
ValueErrorr s rc popzAliasManager.pop/ s9 ! # # EFF F q re NF)
rf rg rh r r r r r r r r r r r` re rc r r s :I 6 6 X6$ $ $ % % %% % %
! ! ! ! !re r c 2 e Zd Zedf fd ZddZd Z xZS )StateFc Z t t | | ||| S r_ )r r __new__)clsscope parenthesesr r s rc r z
State.__new__7 s' UC ((e[&IIIre Nc || j n|}|r6| j r/| j }| | n |r|}n| j }t ||fi |S r_ )r settingsrL r r )ra r r r r s rc r zState.__call__: sz #m
%dm %}))++H OOF # # # #
% HH}HUK448444re c 6 | j | S r_ )r r )ra attr_names rc r zState.__getattr__H s } +++re NN)rf rg rh SCOPE_NORMALr r r r r s @rc r r 5 sk 'U J J J J J J 5 5 5 5 , , , , , , ,re r _State)r r r c , t fd }|S )Nc ; Z K | ddi|5 | V d d d d S # 1 swxY w Y d S Nr r` r` )ra r r s rc r z __scope_context__.<locals>.innerM s
T
(
(
(
(
( JJJ s $$r )r r s ` rc __scope_context__r L s- ^ Lre c " e Zd ZdZd Zd Zd Zed Zed Z ed Z
d Z e e
Z e e Z e e Z e e Z e e Zd Zd
Zed Zd Zd
Z ddZ d Z d Z d Z dS )r# )stack_sql_values
alias_managerstatec x g | _ g | _ g | _ t | _ t di || _ d S Nr` )r r r r r r r )ra r s rc r zContext.__init__W s<
)^^&&X&&
re c . t di | j j S r )r# r r r s rc as_newzContext.as_new^ s --,---re c 8 |d | S r get_sort_keyra items rc column_sort_keyzContext.column_sort_keya s Aw##D)))re c | j j S r_ )r r r s rc r z
Context.scoped s
z re c | j j S r_ )r r r s rc r zContext.parenthesesh s
z%%re c | j j S r_ )r subqueryr s rc r zContext.subqueryl s
z""re c |r!| d | j k r|d= | j | j | j di || _ | S r )r r r r r )ra rN s rc r zContext.__call__p s` # w//4:=='"
$*%%% TZ,,),,
re c > | j r| d | S )N()r literalr s rc r zContext.__enter__~ s$ LL re c z | j r| d | j | _ d S )N))r r r r r ra exc_typeexc_valexc_tbs rc r zContext.__exit__ s6 LL Z^^%%
re c # v K | j d V | j d S r_ )r r r r s rc
push_aliaszContext.push_alias s? !!!
re c t |t t f r| | S t | r |j j | S | t | S r_ ) rv re r# __sql__is_model_metatablesqlrY ra r s rc r) z Context.sql sh cD'? + + (;;t$$ $
c]] (9?**400 088E#JJ'' 're c : | j | | S r_ )r r )ra keywords rc r zContext.literal s !!! re NTc |r || }n(|&| j j r| j | }t |t r: | d 5 | | cd d d S # 1 swxY w Y nPt | rA| 5 | | cd d d S # 1 swxY w Y | j j r"| t | S | j
| |r!| | j j pd n| S )N converter?)
r r/ rv re r) r& scope_columnvalue_literalsr _query_val_transformr r param)ra r~ r/ add_params rc r~ z
Context.value s 0 Ie$$EE
4:#7
J((//E eT " " '%%%
'
'xx
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
e__ '
""$$
'
'xx
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
' : $ =<< 4U ; ;<< < E"""8AKt||DJ , 3444tKs$ A::A>A>)C CCc |j | j |j | j |S r_ )r extendr ra ctxs rc r% zContext.__sql__ s5 """ 4<(((
re c P | | S r_ )r) queryra nodes rc parsez
Context.parse s xx~~##%%%re c D d | j | j fS )Nr( )rU r r r s rc r; z
Context.query s wwty!!4<//re NT)!rf rg rh r r r
r r r r r r r r scope_normal SCOPE_SOURCE scope_source SCOPE_VALUES scope_values SCOPE_CTE scope_cte SCOPE_COLUMNr1 r r r r# r) r r~ r% r> r; r` re rc r# r# T s FI' ' '. . .* * * X & & X& # # X# %$\22L$$\22L$$\22L!!),,I$$\22L
& & &
! ! ^!
( ( ( L L L L2
& & &0 0 0 0 0re r# c h t | dd }|| }nt }| | \ }}|s|S |j j pd}|dk r| dd }|t t t | z S )N _databaser0 %s) r get_sql_contextr# r) r; r r4 r ra r r3 )r; dbr9 r) paramsr4 s rc query_to_stringrO s
T * *B ~ ""ii''%..&&((KC
IO "sE ||kk#t$$ s/8899 99re c t | t t j t j t j f rd| z } nt | t
rB | d } n%# t $ r | d } Y nw xY wd| z } n<t | t rdt | z } n| d} nt | } | S )Nz'%s'utf8raw_unicode_escaperK NULL)
rv text_typer r r
bytes_typer UnicodeDecodeErrorr str)vs rc r3 r3 s !i!2HM m% & & QJ Az " " / AA! / / /-..AAA / QJ As 3q66M
FF Hs A* * B B c L e Zd ZdZdZd Zd Zed Zd
dZ d Z
d Z d S ) re TFc | j | j }| j |_ |S r_ )r r __dict__rL r* s rc clonez
Node.clone s3 n$$T^44}))++
re c t r_ NotImplementedErrorr8 s rc r% z Node.__sql__ !!re c fd}|S )Nc H | } |g|R i | |S r_ r\ )ra r r r\ r s rc r zNode.copy.<locals>.inner s5 JJLLE F5 *4 * * *6 * * *Lre r` r s ` rc rL z Node.copy s# re c V || j k r | }||_ |S | S r_ )_coercer\ )ra re r\ s rc coercez Node.coerce s- dl " "JJLLE #EML re c dS NFr` r s rc is_aliasz
Node.is_alias s ure c | S r_ r` r s rc unwrapz Node.unwrap re NT) rf rg rh re __isabstractmethod__r\ r% staticmethodrL rf ri rk r` re rc re re s G
" " " \ re re c " e Zd ZdZd Zd ZeZdS )
ColumnFactoryr= c || _ d S r_ rr r< s rc r zColumnFactory.__init__
re c , t | j | S r_ )r! r= r s rc r zColumnFactory.__getattr__ di&&&re Nrf rg rh r r r r r` re rc rq rq s6 I ' ' ' KKKre rq c e Zd ZdZddZdS )_DynamicColumnr` Nc ( |t | S | S r_ )rq ra instance
instance_types rc __get__z_DynamicColumn.__get__ s ** * re r_ rf rg rh r r~ r` re rc ry ry s- I re ry c e Zd ZdZddZdS )_ExplicitColumnr` Nc . |t d|z | S )NzM%s specifies columns explicitly, and does not support dynamic column lookups.r r{ s rc r~ z_ExplicitColumn.__get__# s. *,456 6
6 re r_ r r` re rc r r s- I re r c e Zd Zd Zd ZdS )Starc || _ d S r_ )rM r s rc r z
Star.__init__,
re c v | t | j d S )Nz.*)r) rM rM r r8 s rc r% z Star.__sql__. s, ww~dk2233;;DAAAre Nrf rg rh r r% r` re rc r r + s7 B B B B Bre r c e Zd Z e Zd
fd Zej d Zd Z e
d Z e j
dfdZd
dZdd Zd
Zd Zd Z xZS )SourceNc d t t | || _ d S r_ )r r r _alias)ra r r s rc r zSource.__init__5 s*
fd$$&&& re c || _ d S r_ r ra names rc r z Source.alias9
re c H |st d f}t | f| S )Nr )rQ rP ra columnss rc selectz
Source.select= s) "3xxkGtgw'''re c t | S r_ )r r s rc __star__zSource.__star__B s Dzzre c & t | ||| S r_ Join)ra dest join_typeons rc rU z Source.joinF s D$ 2...re c : t | |t j | S r_ )r r? r4 ra r r s rc left_outer_joinzSource.left_outer_joinI s D$444re Fc * t || ||| S N) recursiver materializedCTEra r r r r s rc ctez
Source.cteL $ 4G ,. . . .re c < | j r| j fS |j | fS r_ )r r r8 s rc r zSource.get_sort_keyP s' ; "K> !!$'))re c |j t k rV| j r| j |j | < | d t
|j | |S N AS )r rB r r r r) rf r8 s rc apply_aliaszSource.apply_aliasU s_ 9 $ ${
6*.+!$' KK # #F3+<T+B$C$C D D D
re c | j r| j |j | < | t |j | S r_ )r r r) rf r8 s rc apply_columnzSource.apply_column^ s= ; 2&*kC d #wwvc / 566777re r_ FNN)rf rg rh ry rw r re rL r r r r r? r3 rU r r r r r r r s @rc r r 2 s A
Y Y( ( (
X $(:$ / / / /5 5 5 5. . . .* * *
8 8 8 8 8 8 8re r c e Zd Z fdZej d Zd Zd Zd Z d Z
d Z d Z e e
j Z e e
j Z e e
j Z e e
j Z xZS ) _HashableSourcec p t t | j |i | | d S r_ )r r r _update_hashra r r r s rc r z_HashableSource.__init__e s= -ot$$-t>v>>> re c < || _ | d S r_ )r r r s rc r z_HashableSource.aliasi s! re c 8 | | _ d S r_ ) _get_hash_hashr s rc r z _HashableSource._update_hashn s ^^%%
re c D t | j | j | j f S r_ )hashr _pathr r s rc r z_HashableSource._get_hashq s T^TZ=>>>re c | j S r_ )r r s rc __hash__z_HashableSource.__hash__t s
zre c t |t r| j |j k S t | t j | S r_ )rv r r r
rE r ra others rc __eq__z_HashableSource.__eq__w 7 e_ - - -:, ,$u---re c t |t r| j |j k S t | t j | S r_ )rv r r r
rE r r s rc __ne__z_HashableSource.__ne__| r re c fd}|S )Nc & t | | S r_ r
ra r ops rc r z!_HashableSource._e.<locals>.inner s dB,, ,re r` )r r s ` rc _ez_HashableSource._e s! - - - - - re )rf rg rh r re rL r r r r r r r rE r __lt__r __le__r __gt__r __ge__r r s @rc r r d s
Y Y & & &? ? ? . . .
. . .
RYYF
RZZF
RYYF
RZZFFFFFre r c < t fd }|S )Nc b | g|R i |}| j r| | j S |S r_ )rJ bind)ra r r resultmeths rc r z __bind_database__.<locals>.inner sE d,T,,,V,, > /;;t~.. .
re r )r r s ` rc __bind_database__r s3
4[[ [
Lre c fd}|S )Nc 4 r|| }} t | | S )N)r r )ra r invertedr s rc r z__join__.<locals>.method s) & %DD%95555re r` )r r r s `` rc __join__r s) 6 6 6 6 6 6 Mre c b e Zd Z eej Z eej Z eej Z
eej Z eej
Z eej d Z eej d Z eej d Z eej d Z eej
d ZdS ) BaseTableTr N)rf rg rh r r? r3 __and__r4 r r5 __sub__r7 __or__r8 __mul____rand____radd____rsub____ror____rmul__r` re rc r r s htz""Ght''Ght'((G
Xdo
&
&Fhtz""Gx
T222Hx$777Hx(4888Hht666Gx
T222HHHre r c & e Zd Zd Zd Zd Zd ZdS )_BoundTableContextc " || _ || _ d S r_ )r( r )ra r( r s rc r z_BoundTableContext.__init__ s
re c @ t fd }|S )Nc | t j j 5 | i |cd d d S # 1 swxY w Y d S r_ )r r( r r s rc r z*_BoundTableContext.__call__.<locals>.inner s #DJ
>>
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+s 155r r s `` rc r z_BoundTableContext.__call__ r re c | j j | _ | j | j | j j $| j j | j | j S r_ )r( rJ _orig_databaser r _modelr s rc r z _BoundTableContext.__enter__ sS "j 2
&&& : ( J " "4= 1 1 1zre c | j | j | j j &| j j | j d S d S r_ )r( r r r r s rc r z_BoundTableContext.__exit__ sN
+,,, : ( J " "4#6 7 7 7 7 7 ) (re Nrf rg rh r r r r r` re rc r r sP ! ! ! 8 8 8 8 8re r c e Zd Z d
fd Zd ZddZddZd Zed Z edd Z
edd Z edd
Z ed Z
d Z xZS )rS Nc || _ || _ || _ || _ |r||fn|f| _ || _ || _ t t | | |7t | _ |D ]!}t | |t | | "|r'| j r| n| j } t | | | _ d S d | _ d S Nr )rf _columns _primary_key_schemar r rJ r rS r r rw setattrr! r primary_key) ra r r r schemar r rJ columncol_srcr s rc r zTable.__init__ s
' '-:fd^^D7
"
eT##%#000 $&&DF!
<
<ffT6&:&:;;;; $ "m7ddG &w < <D #D re c t t | j | j | j | j | j | j | j S )N)r r r r r rJ )rS rf r r r r r rJ r s rc r\ z Table.clone s= MM )<+;n& & & &re c || _ | S r_ rJ ra r s rc r z
Table.bind ! re c " t | | S r_ )r r s rc bind_ctxzTable.bind_ctx s !$111re c P t | j | j | j | j f S r_ )r r r r r r s rc r zTable._get_hash s! T^TZdkJKKKre c ^ |s j r fd j D }t f| S )Nc 0 g | ]}t | S r` )r! )rV r ra s rc rY z Table.select.<locals>.<listcomp> s# HHHvdF++HHHre )r rP r s ` rc r z Table.select sC I4= IHHHH$-HHHGtgw'''re c |rC|i n|}| j r| n| j }| D ]\ }}||t || < t | || S Ninsertr )r rw itemsr Insert)ra r r r srckeyr~ s rc r z Table.insert sp 2!>RRvF -3$$TVC $llnn
2
2
U,1wsC(())d67;;;;re c V | || d S )Nr
REPLACEr on_conflict)ra r r r s rc r z
Table.replace s( vw77 Y'' )re c |rC|i n|}| D ](\ }}| j r| n| j }||t || < )t | | S )Nr )r r rw r Update)ra r r r r~ r s rc r z Table.update sn 2!>RRvF $llnn
2
2
U "m7dd,1wsC(())d6****re c t | S r_ )Deleter s rc deletez Table.delete s d||re c B |j t k r!| t | j S | j r| j |j | < |j t k r4| | t | j S | | S r_ )
r rD r) rf r r r rB r r r8 s rc r% z
Table.__sql__ s 9 $ $7764:.// / ; 2&*kC d # 9 $ $##CGGFDJ,?$@$@AA A $$S)) )re )NNNNNNr_ r )rf rg rh r r\ r r r r r r r r r r% r r s @rc rS rS s6 DH48$ $ $ $ $ $. & & & 2 2 2 2L L L ( ( (
< < < < ) ) ) )
+ + + +
*
*
*
*
*
*
*re rS c < e Zd Zej ddf fd Zd Zd Z xZS )r Nc t t | | || _ || _ || _ || _ d S r )r r r lhsr r _on)ra r r r r r r s rc r z
Join.__init__# sD
dD"""///"re c || _ | S r_ )r )ra predicates rc r zJoin.on* s re c | | j d| j z | j | j -| d | j |S )N %s ON )r) r r r r r r8 s rc r% z Join.__sql__. sd
#dh--
'&4>)
*
*
#dh--- 8 KK # #DH - - -
re ) rf rg rh r? r3 r r r% r r s @rc r r " sd +/:$d re r c L e Zd Zd fd Zd Zej d Zd Z xZ S )rZ Nc v || _ || _ t t | | d S r )r r r rZ r )ra valuesr r r s rc r zValuesList.__init__9 s8
j$ ((u(55555re c ^ t | j t | j | j f S r_ )r r idr r r s rc r zValuesList._get_hash> s% T^R %5%5t{CDDDre c || _ d S r_ )r )ra namess rc r zValuesList.columnsA s
re c | j r| j |j | < |j t k s|j t k r ||j 5 | d t d | j D }d d d n # 1 swxY w Y |j t k rz| d t |j | | j r3d | j D }| t | n-| t |j | |S )Nr zVALUES c , g | ]}t | S r` EnclosedNodeListrV rows rc rY z&ValuesList.__sql__.<locals>.<listcomp>M s4 +J +J +J58+C00+J +J +Jre r c , g | ]}t | S r` )rf rV rw s rc rY z&ValuesList.__sql__.<locals>.<listcomp>S s A A Aaq A A Are )
r r r rB r r r r)
CommaNodeListr rf r r. )ra r9 entitiess rc r% zValuesList.__sql__E s ; 2&*kC d # 9 $ $ \(A(AS_!4555
M
M **M +J +J<@L+J +J +J K K L L
M
M
M
M
M
M
M
M
M
M
M
M
M
M
M yL(( F##''s/@/F(G(GHHH= 8 A A4= A A AHGG ,X 6 6777 GGF3,T233 4 4 4
s ABB !B r )
rf rg rh r r re rL r r% r r s @rc rZ rZ 8 s{ 6 6 6 6 6 6
E E E
Y Y re rZ c J e Zd Z d fd Zd Zd Zd ZeZd ZeZ d Z
xZ S )
r FNc || _ || _ || _ || _ | d |D }|| _ d|_ t
t | | d S )Nc Z g | ](}t |t rt | n|)S r` rv
basestringrf r2 s rc rY z CTE.__init__.<locals>.<listcomp>c sA ) ) ) %/q*$=$=Dvayyy1 ) ) )re r` r ) r _query
_recursive
_materializedr _cte_listr r r )ra r r; r r r r s rc r z CTE.__init__\ sy # ) ) ) ') ) )G
c4!!!-----re c |st d t | f| | | j j } | | j j }n# t $ r Y nw xY w|S )NzFselect_from() must specify one or more columns from the CTE to select.) r rP with_cter r: rJ objectsmodelr ra r r; s rc select_fromzCTE.select_fromi s 8 7 8 8
8 ))(4..$t{,-- MM$+"344EE D s A4 4
B Bc ^ t | j | j t | j f S r_ )r r r r' r: r s rc r z
CTE._get_hashw s# T^T["T[//BCCCre c | | j }t | j ||z | j | j S r_ r: r\ r r r; r ra r r\ s rc union_allz
CTE.union_allz 3 !!##4; T_dmLLLre c | | j }t | j ||z | j | j S r_ rF rG s rc unionz CTE.union rI re c |j t k r'| t | j S | 5 | j |j | < | t | j | j r:| d t | j | d | j
r| d n | j
du r| d | d 5 | | j d d d n # 1 swxY w Y d d d n # 1 swxY w Y |S )Nr r z
MATERIALIZED FzNOT MATERIALIZED Tr+ )
r rF r) rf r r# r r r r. r< rA r: r8 s rc r% z CTE.__sql__ s 9 ! !776$+..// /
^^
% %&*kC d # GGF4;'' ( ( (}
F C $$%5dm%D%DEEE KK !
1 O,,,,#u,, /000!!d!33
%
% $$$
%
%
%
%
%
%
%
%
%
%
%
%
%
%
% % % % % % % % % % % % % % % %
s7 C E(*E E(E E(E E((E,/E,r ) rf rg rh r rC r rH r rK r r% r r s @rc r r [ s =A " . . . . . . D D DM M M GM M M F re r c e Zd ZdZej dd Zd Zd Zd Z d Z
d dZ e Z d dZ
e
Zd Zd d Z eej Z eej Z eej Z eej Z eej Z eej xZ Z eej Z eej d
Z! eej d
Z" eej d
Z# eej d
xZ$Z% eej d
Z& eej d
Z' eej d
Z(d Z)d Z* eej+ Z, eej- Z. eej/ Z0 eej1 Z2 eej3 Z4 eej5 Z6 eej7 Z8 eej9 Z: eej7 Z; eej9 Z< eej= Z> eej? Z@ eej3 ZA eejB ZC eejD ZE eejF ZGd dZHd ZId ZJd ZKd ZLd ZMd ZNd ZOdZPd ZQd ZRd ZSdS )
ColumnBaseNc || _ d S r_ )
_converter)ra r/ s rc r/ zColumnBase.converter s
#re c * |rt | | S | S r_ )Aliasra r s rc r zColumnBase.alias s &u%% % re c | S r_ r` r s rc unaliaszColumnBase.unalias rl re c " t | | S r_ )BindTo)ra r s rc bind_tozColumnBase.bind_to s dD!!!re c " t | | S r_ )r )ra as_types rc castzColumnBase.cast s D'"""re c & t | || S N) collationnulls)Ascra r^ r_ s rc asczColumnBase.asc s 49E::::re c & t | || S r] )Descra s rc desczColumnBase.desc s DIU;;;;re c t | S r_ )Negatedr s rc
__invert__zColumnBase.__invert__ r re Fc fd}|S )z
Lightweight factory which returns a method that builds an Expression
consisting of the left-hand and right-hand operands, using `op`.
c L rt || S t | | S r_ r )ra r invr s rc r z ColumnBase._e.<locals>.inner s/
1!#r4000 dB,, ,re r` )r rk r s `` rc r z
ColumnBase._e s)
- - - - - - re T)rk c X | t j n t j }t | || S r_ )rE r r r
r s rc r zColumnBase.__eq__ s% kRUUru$C(((re c X | t j n t j }t | || S r_ )rE r r r
r s rc r zColumnBase.__ne__ s% +RYY25$C(((re c X |r t j n t j }t | |d S r_ )rE r r r
)ra is_nullr s rc ro zColumnBase.is_null s&
,RUU29$D)))re c | d dk s2| d dk s| d dk r~| dd dd dd }t t ||z d t d
t dd f S ||z S ) N_r r \z\\z\_z\%Fr. ESCAPE)findr NodeListrY rQ )ra rq templates rc _escape_like_exprz ColumnBase._escape_like_expr s 66#;;! qvvc{{a / /166$<<13D3D $''//U;;CCCOOA hle444H
de,,, . / /
/ !|re c t |t r5t dt j t |t j d }n| |d }t | t j | S )Nr z%%%s%%rv re r
rE r rw r r s rc containszColumnBase.contains sg c4 8 S") 'RY < <> >CC ((h77C$#...re c t |t r t |t j d }n| |d }t | t j | S )Nr z%s%%ry r s rc
startswithzColumnBase.startswith R c4 6 S")S11CC((f55C$#...re c t |t r t dt j | }n| |d }t | t j | S )Nr z%%%sry r s rc endswithzColumnBase.endswith r} re c
r t | t j t |t d |f S )Nr )r
rE r ru rQ )ra lohis rc betweenzColumnBase.between s+ $
Hb#e**b5I,J,JKKKre c 8 t | t j | S r_ StringExpressionrE r r s rc concatzColumnBase.concat s bi555re c t |t r=|j |j t d | |j |j S | |k S )Nz4BETWEEN range must have both a start- and end-point.)rv slicestartstopr r r s rc r zColumnBase.__getitem__ s\ dE " " 7z!TY%6 ". / / /<<
DI66 6t|re c > t t d | f S )NDISTINCTru rQ r s rc distinctzColumnBase.distinct s Z $/000re c D t | t d|z f S )N
COLLATE %sr ra r^ s rc collatezColumnBase.collate! s" s<)#; < <=>>>re c dS r r` r8 s rc r zColumnBase.get_sort_key$ s rre r_ r r rm )Trf rg rh rP re rL r/ r rU rX r[ rb __pos__re __neg__rh r rE r r r r r r r r r r r __div__ __truediv__r __xor__r r r __rdiv__ __rtruediv__r r __rxor__r r r r r r r r r r r
__lshift__r
__rshift__r __mod__r __pow__r r r bin_andr bin_orin_r not_inr r r iregexpro rw rz r| r r r r __iter__r r r r` re rc rN rN s J Y$ $ $ Y$
" " "# # #; ; ; ;G< < < <G bjjG
RYYFbjjGbjjGbjjG BrvJJ&GkbjjGr"&d###Hr"&d###Hr"&d###H bT 2 2 22H|r"&d###HbD!!!Gr"&d###H) ) )) ) ) RYYF
RZZF
RYYF
RZZFBEJBEJbkkGbllG
2bg;;D BrxLLEbnnG
R ]]F
"RU))C
R ]]F
R ]]FbnnG* * * *
/ / // / / / / / L L L6 6 6 H1 1 1? ? ? re rN c & e Zd Zd Zd Zd Zd ZdS )r! c " || _ || _ d S r_ )rM r )ra rM r s rc r zColumn.__init__) s re c x |j t k r| j fS | j | | j fz S r_ )r rD r rM r r8 s rc r zColumn.get_sort_key- s8 9 $ $I< ;++C00DI<? ?re c 8 t | j | j f S r_ )r rM r r s rc r zColumn.__hash__3 s T[$),---re c p |j t k r'| t | j S | 5 | | j d t | j cd d d S # 1 swxY w Y d S NrR )r rD r) rf r r1 rM r r8 s rc r% zColumn.__sql__6 s 9 $ $776$),,-- -!!##
P
Pwwt{++33C88<<VDI=N=NOO
P
P
P
P
P
P
P
P
P
P
P
P
P
P
P
P
P
Ps AB++B/2B/N)rf rg rh r r r r% r` re rc r! r! ( sX @ @ @ . . .P P P P Pre r! c e Zd Zd Zd Zd ZdS ) WrappedNodec l || _ t |dd | _ t |dd | _ d S )Nre TrP )r= r re rP r< s rc r zWrappedNode.__init__? s3 tY55 !$ d;;re c 4 | j S r_ )r= ri r s rc ri zWrappedNode.is_aliasD s y!!###re c 4 | j S r_ )r= rk r s rc rk zWrappedNode.unwrapG s y !!!re N)rf rg rh r ri rk r` re rc r r > sA < < <
$ $ $" " " " "re r c e Zd ZdZd Zd ZdS )
EntityFactoryrr c || _ d S r_ rr r< s rc r zEntityFactory.__init__M rt re c , t | j | S r_ )rf r= r s rc r zEntityFactory.__getattr__O rv re N)rf rg rh r r r r` re rc r r K s7 I ' ' ' ' 're r c e Zd ZdZddZdS )_DynamicEntityr` Nc 2 |t |j S | S r_ )r r r{ s rc r~ z_DynamicEntity.__get__U s 11 1 re r_ r r` re rc r r S s- I re r c e Zd Z e Z fdZd Zed Zej d Zd
dZ
d Z d Z d Z
xZS ) rR c f t t | | || _ d S r_ )r rR r r )ra r= r r s rc r zAlias.__init__^ s,
eT##D))) re c * t | j S r_ )r r r s rc r zAlias.__hash__b DK re c | j S r_ r r s rc r z
Alias.namee s
{re c || _ d S r_ r ra r~ s rc r z
Alias.nameh
re Nc > || j S t | j | S r_ )r= rR rS s rc r z Alias.aliasl s! =9 E** *re c | j S r_ rr r s rc rU z
Alias.unaliasr
yre c dS r@ r` r s rc ri zAlias.is_aliasu s tre c |j t k rR| | j d t | j S | t | j S r )r rB r) r= r rf r r8 s rc r% z
Alias.__sql__x sd 9 $ $S^^ WV__S ,,--
/
776$+..// /re r_ )rf rg rh r rw r r r r setterr rU ri r% r r s @rc rR rR [ s A ! ! ! X [ [ + + + + 0 0 0 0 0 0 0re rR c $ e Zd Z fdZd Z xZS )rW c f t t | | || _ d S r_ )r rW r r )ra r= r r s rc r zBindTo.__init__ s,
fd$$T*** re c 6 | | j S r_ r) r= r8 s rc r% zBindTo.__sql__ s wwty!!!re rf rg rh r r% r r s @rc rW rW sG " " " " " " "re rW c e Zd Zd Zd ZdS )rg c | j S r_ rr r s rc rh zNegated.__invert__ r re c \ | d | j S )NzNOT )r r) r= r8 s rc r% zNegated.__sql__ s$ {{6""&&ty111re Nrf rg rh rh r% r` re rc rg rg s2 2 2 2 2 2re rg c & e Zd Zd Zd Zd Zd ZdS ) BitwiseMixinc , | | S r_ )r r s rc r zBitwiseMixin.__and__ s ||E"""re c , | | S r_ )r r s rc r zBitwiseMixin.__or__ s {{5!!!re c P | | S r_ )r bin_negatedr s rc r zBitwiseMixin.__sub__ s ||E - - / /000re c t | S r_ )BitwiseNegatedr s rc rh zBitwiseMixin.__invert__ s d###re N)rf rg rh r r r rh r` re rc r r sP # # #" " "1 1 1$ $ $ $ $re r c e Zd Zd Zd ZdS )r c | j S r_ rr r s rc rh zBitwiseNegated.__invert__ r re c |j j r+|j j | j | j }n| j }| | | j S r_ )r
operationsr r r r) r= )ra r9 op_sqls rc r% zBitwiseNegated.__sql__ sX 9 Y)--dgtw??FFWF{{6""&&ty111re Nr r` re rc r r s2 2 2 2 2 2re r c e Zd ZddZd ZdS )rY NTc R || _ || _ |ot | j t | _ | j rng | _ | j D ]a}t |t r| j | 2| j t || j `d S d S r_ ) r~ r/ rv multi_typesmultir% re r rY )ra r~ r/ unpackr s rc r zValue.__init__ s
"C
4:{ C C
: D DK
D
D dD)) DK&&t,,,,K&&uT4>'B'BCCCC
D D
D
Dre c | j r'| t | j S | | j | j S r_ )r r) r. r% r~ r/ r8 s rc r% z
Value.__sql__ sA : :77+DK8899 9yyT^444re r@ r r` re rc rY rY s;
D
D
D
D5 5 5 5 5re rY c e Zd Zd ZdS )
ValueLiteralsc |d 5 | | j cd d d S # 1 swxY w Y d S )NT)r2 r r8 s rc r% zValueLiterals.__sql__ s
S
%
%
% & &7749%% & & & & & & & & & & & & & & & & & &s 488Nrf rg rh r% r` re rc r r # & & & & &re r c $ t | d S NFr )rY rb s rc r r s u % % %%re c $ e Zd Z fdZd Z xZS )r c t t t | | || _ d| _ d S rh )r r r _castre )ra r= r[ r s rc r z
Cast.__init__ s3
dD""4(((
re c | d | j d| j z S )NzCAST(z AS %s))r r) r= r r8 s rc r% z Cast.__sql__ s8 !!TY TZ/00 2re r r s @rc r r sG
2 2 2 2 2 2 2re r c 4 e Zd Zd fd ZddZd Zd Z xZS )OrderingNc t t | | || _ || _ || _ |r(| dvrt d|z d S d S )N)rm lastz<Ordering nulls= parameter must be "first" or "last", got: %s)r r r directionr^ r_ rl r )ra r= r r^ r_ r s rc r zOrdering.__init__ s
h &&t,,,""
8U[[]]*;;; /16 7 8 8
8 8 8;;re c 8 t | j | j | S r_ )r r= r r s rc r zOrdering.collate s 4>9===re c | dk rd\ }}n-| dk rd\ }}nt d t d | j |ff| S )Nr )r r rm )r r z&unsupported value for nulls= ordering.)rl r r r= ro )ra r_ ifnullnotnulls rc _null_ordering_casez Ordering._null_ordering_case su ;;==F " " "OFGG
[[]]g
%
% "OFGG EFF FDDI - - / /8:GDDDre c | j rL|j j s@| | | j d | | j d| j z | j r | d| j z | j r)|j j r | d| j z |S )N, %sz COLLATE %sz NULLS %s) r_ r nulls_orderingr) r r r= r r^ r8 s rc r% zOrdering.__sql__ s : Hci 6 H GGD,,TZ88 9 9 A A$ G G G ""54>#9::: > 8 KK
6 7 7 7 : 2#)2 2 KK dj0 1 1 1
re r r_ )rf rg rh r r r r% r r s @rc r r sr 8 8 8 8 8 8> > > >E E E re r c & t | d|| S )NASCr r= r^ r_ s rc r` r` s D%E 2 22re c & t | d|| S )NDESCr r s rc rd rd s D&)U 3 33re c e Zd ZddZd ZdS )r
Fc > || _ || _ || _ || _ d S r_ )r r r flat)ra r r r r s rc r zExpression.__init__ s" re c | j dd}| j x}}t |t r| }t |t
r*|j r#|j |d< t |t |d< nd |d< |j j
r+|j j
| j | j }n| j } |d i |5 | j t j k p| j t j k }|rn| | j d dk r8| | j t j k rdnd cd d d S | j }|9| j t j k s| j t j k rt- d }| | j d
|z | cd d d S # 1 swxY w Y d S ) NT)r in_exprr/
is_fk_exprr ()z0 = 1z1 = 1rS r! r` )r r rv r rk r2 re db_valuer6 r r r r rE r r r
r> r r r r rQ r) )ra r9 rN r= raw_noder op_inr s rc r% zExpression.__sql__
s3 (, MdCC ("x h , , %??$$D dE " " *x'7 *%)]Ik "&0&G&GIl # #%)Ik " 9 Y)--dgtw??FFWF
S
9
Gru$<29(<E
M ++DH55a8D@@{{dg.>.>77GLL
(C{25 0 0DGry4H4H&kkS]] WVf_--SXX
s BG4#BG44G8;G8Nr r r` re rc r
r
s7 " " " " " re r
c e Zd Zd Zd ZdS )r c , | | S r_ )r r s rc r zStringExpression.__add__0 s {{3 re c 8 t |t j | S r_ r )ra r s rc r zStringExpression.__radd__2 s RY555re N)rf rg rh r r r` re rc r r / s2 6 6 6 6 6re r c , e Zd Zd Zd Zd Zd Zd ZdS )rf c ( d |D | _ d S )Nc > g | ]}|| d d S )""")r )rV rW s rc rY z#Entity.__init__.<locals>.<listcomp>8 s+ GGG$$Gdll3--GGGre )r )ra rZ s rc r zEntity.__init__7 s GG$GGG
re c & t | j |gz S r_ )rf r r s rc r zEntity.__getattr__: s tzTF*++re c * t | j S r_ )ra r r8 s rc r zEntity.get_sort_key= s TZ re c \ t | j j t | j f S r_ )r r rf ra r r s rc r zEntity.__hash__@ s$ T^,eDJ.?.?@AAAre c j | t | j |j j pd S )Nr )r r[ r r r8 s rc r% zEntity.__sql__C s) {{5SY_-DEEFFFre N)rf rg rh r r r r r% r` re rc rf rf 6 sj H H H, , ,! ! !B B BG G G G Gre rf c e Zd ZddZd ZdS )rQ Nc " || _ || _ d S r_ r) rN ra r) rN s rc r z SQL.__init__H s re c | | j | j r"| j D ]}| |dd |S NF)r5 )r r) rN r~ ra r9 r4 s rc r% z SQL.__sql__L sQ DH ; 9
9
9 %% 8888
re r_ r r` re rc rQ rQ G s7 re rQ c t d| z }|s|S t t d t | |f S )Nz
CHECK (%s)
CONSTRAINT)rQ ru rf )
constraintr checks rc r r T sD z) * *E S &&t e< = ==re c e Zd Z ed Zd dZd Zej d d Z ej d Z
ej d d Z d
d Z d
Z
dS )Function)sumcountavgr[ array_aggTNc || _ || _ d | _ d | _ || _ |r$| | j v r d| _ d S || _ d S rh )r arguments_filter _order_by
_python_valuerl no_coerce_functionsre )ra r r+ rf python_values rc r zFunction.__init__^ sY " ) "DJJLLD$<<< DLLL!DLLLre c fd}|S )Nc t | fi |S r_ )r% )r r r s rc decoratorz'Function.__getattr__.<locals>.decoratorj s D$11&11 1re r` )ra r r3 s ` rc r zFunction.__getattr__i s" 2 2 2 2 2re c || _ d S r_ )r, )ra wheres rc filterzFunction.filtern
re c || _ d S r_ r- )ra orderings rc order_byzFunction.order_byr
!re c || _ d S r_ )r. )ra funcs rc r0 zFunction.python_valuev s !re c t |t r||}|t | }nt ||||||d }t | t d |f S )NT) partition_byr; r end
frame_typeexclude_inlineOVER)rv r[ WindowAliasru rQ ) ra r@ r; r rA rB windowrC r= s rc overz
Function.overz ss lF + + "!F v&&DD|h %3:")49 9 9D s6{{D1222re c | | j t | j s| d n| j }| j rIt | }t
|d t d t | j f |d< |dt | j 5 | t d |D d d d n # 1 swxY w Y | j r@| d | j d |S ) Nr rt ORDER BYT) in_functionfunction_arg_countc \ g | ])}t |t r|nt |d *S r )rv re rY )rV args rc rY z$Function.__sql__.<locals>.<listcomp> sE *% *% *% 'sD 1 1HSSuS%7H7H*% *% *%re z FILTER (WHERE r ) r r r r+ r- r` ru rQ r3 r) r. r, )ra r9 r s rc r% zFunction.__sql__ s DI 4>"" ' KK >D ~
EDzz#T"Xs:%24>%B%B%D E ER #dn:M:MNNN
'
'( *% *% #*% *% *% & & ' ' '
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
< J KK) * * . .t| < < D DS I I I
s ;-C44C8;C8)TNr_ NNNNNNN)rf rg rh setr/ r r re rL r6 r; r0 rH r% r` re rc r% r% [ s # JKK " " " "
Y Y
Y" " Y"
Y" " " Y" FJ37 3 3 3 3 re r% c l e Zd Z ed Z ed Z ed Z ed ZdZdZ dZ
d fd
Z dd Z e
j d Ze
j d
Ze
j d Ze
j dd Ze
j dd Zedd Zedd Zd Z xZS )r[ z CURRENT ROWGROUPTIESz NO OTHERSGROUPSRANGEROWSNFc
t t | |$t |t st | }|$t |t st | }t | | _ t | | _ || _ || _ | j | j t d |pd| _ | | _ || _
|| _ || _ d S )Nz(Cannot specify WINDOW end without start.w)r r[ r rv rQ rc r@ r; r rA r r rD rB _extends_exclude) ra r@ r; r rA rB extendsrC r rD r s rc r zWindow.__init__ s fd$$&&& Zs%;%; JJE ?:c3#7#7?c((C ( 6 6$X..
: $("6 GHH Hls $
re c |pd| _ | S NrX r rS s rc r z Window.alias s ls re c ( t j | _ d S r_ )r[ rU rB r s rc as_rangezWindow.as_range s ,re c ( t j | _ d S r_ )r[ rV rB r s rc as_rowszWindow.as_rows s +re c ( t j | _ d S r_ )r[ rT rB r s rc as_groupszWindow.as_groups s -re c || _ d S r_ )rY ra rG s rc r[ zWindow.extends s
re c \ t |t rt | }|| _ d S r_ )rv r9 rQ rZ )ra frame_exclusions rc rC zWindow.exclude s, oz 2 2 3 !/ 2 2O'
re c H | t d S t d| z S )NzUNBOUNDED FOLLOWINGz %d FOLLOWINGrQ rb s rc followingzWindow.following ) =,-- ->E)***re c H | t d S t d| z S )NzUNBOUNDED PRECEDINGz %d PRECEDINGri rb s rc precedingzWindow.preceding rk re c |j t k r6| j s/| | j | d |d 5 g }| j j| j }t
|t rt |j }n$t
|t rt | }|
| | j r6| t d t | j f | j r6| t d t | j f | j Q| j J| j pd}| t d|z | j t d | j f ni| j 1| t | j pd | j f n1| j *|
t d | j z | j )| t d
| j f | t) | d d d n # 1 swxY w Y |S ) Nr Tr+ z PARTITION BYrJ rV z
%s BETWEENr z%s UNBOUNDED PRECEDINGEXCLUDE)r rB rD r r rY rv r[ rQ r9 r r@ r7 r3 r; r rA rB rZ r) ru )ra r9 partsextframes rc r% zWindow.__sql__ s 9 $ $T\ $ KK $ $ $ KK
ST
"
"
" % %E}(m c6** # cj//CC Z00 # c((C S!!!
7 ''!$"344 6 7 7 7 }
3
OO!$-00 2 3 3 3 z%$(*> 16 u,--JJJH
' c$/";V < <dj IJJJJ , S!9DO!K L LMMM}( c)nndm <=== GGHUOO $ $ $= % % % % % % % % % % % % % % %>
s HI I$'I$) NNNNNNNNFr_ )rf rg rh rQ CURRENT_ROWrR rS NO_OTHERSrT rU rV r r re rL r_ ra rc r[ rC ro rj rm r% r r s @rc r[ r[ s #m$$K CLLE 3v;;DK I F E DIMDH *
Y' ' Y'
Y& & Y&
Y( ( Y(
Y Y
Y( ( ( Y(
+ + + \+
+ + + \+
$ $ $ $ $ $ $re r[ c e Zd Zd Zd Zd ZdS )rF c || _ d S r_ )rG re s rc r zWindowAlias.__init__ r re c || j _ | S r_ )rG r )ra window_aliass rc r zWindowAlias.alias s ) re c D | | j j pd S r] )r rG r r8 s rc r% zWindowAlias.__sql__ s {{4;-4555re N)rf rg rh r r r% r` re rc rF rF sA 6 6 6 6 6re rF c e Zd ZddZd ZdS ) _InFunctionTc " || _ || _ d S r_ )r= rK )ra r= rK s rc r z_InFunction.__init__ s &re c || j 5 | | j cd d d S # 1 swxY w Y d S )NrK )rK r) r= r8 s rc r% z_InFunction.__sql__# s
ST -
.
.
. & &7749%% & & & & & & & & & & & & & & & & & &s
9= =Nrm r r` re rc r{ r{ s7 ' ' ' '& & & & &re r{ c e Zd ZddZd ZdS )r Nc 0 || _ || _ || _ d S r_ )r expression_tuplesdefault)ra r r r s rc r z
Case.__init__) s "!2 re c L t d g}| j | | j | j D ]E\ }}| t d |t d t | f F| j 6| t d t | j f | t d |d 5 | t | cd d d S # 1 swxY w Y d S )NCASEWHENTHENELSEENDFr~ ) rQ r r r r7 r{ r r) ru )ra r9 clausesexprr~ s rc r% z Case.__sql__. sS v;;- > % NN4> * * * 1 > >KD% NNCKK KKU);); =
>
>
>
> < # NNCKKT\)B)BC D D Ds5zz"""
SU
#
#
# . .778G,,-- . . . . . . . . . . . . . . . . . .s *"DD D r_ r r` re rc r r ( s7
. . . . .re r c e Zd ZddZd ZdS ) ForUpdateNc |du rdn|}| d r |d d }d}|| _ |%t |t t
t f s|f}|| _ || _ d S )NTz
FOR UPDATEnowaiti) rl r _exprrv r` rP ra _of_nowait)ra r ofr s rc r zForUpdate.__init__= s} #t|||| ::<< * * 9DF
>*R$U1C"D"D>B re c | | j | j :| d t | j | j r| d |S )Nz OF z NOWAIT)r r r r) r3 r r8 s rc r% zForUpdate.__sql__I si DJ 8 KK # #M$($;$; < < < < # KK " " "
re r r r` re rc r r < s7
re r c e Zd ZddZd ZdS )ru r Fc F || _ || _ || _ |rt | j dk rmt | j d t
rO| j d j s?| j d f| _ d| j d _ d S d S d S d S d S )Nr r T)nodesglueparensr rv r
r r\ )ra r r r s rc r zNodeList.__init__S s
&c$*oo** djmZ 0 0 +z!}! + *Q---//1DJ!%DJqM & &******re c t | j }|dk r | j r| d n|S || j 5 t |dz
D ]<}| | j | | | j =| | j |dz
d d d n # 1 swxY w Y |S )Nr r r+ r )r r r r r r) r )ra r9 n_nodesis rc r% zNodeList.__sql__^ s dj// a<<(, <3;;t$$$ <
ST[
)
)
) - -7Q;''
'
'
1
&&& DI&&&& GGDJw{+ , , , - - - - - - - - - - - - - - -
s
A3C C
C
N)r Fr r` re rc ru ru R s7 & & & & re ru c " t | d S )Nr ru r s rc r3 r3 j s E4 re c $ t | dd S )Nr Tr r s rc r. r. n s E4 & &&re c " e Zd ZdZd Zd ZeZdS )
_Namespace_namec || _ d S r_ r r s rc r z_Namespace.__init__t s
re c " t | | S r_ )NamespaceAttributer s rc r z_Namespace.__getattr__v s !$---re Nrw r` re rc r r r s6 I . . . KKKre r c e Zd Zd Zd ZdS )r c " || _ || _ d S r_ )
_namespace
_attribute)ra namespace attributes rc r zNamespaceAttribute.__init__{ s ##re c | | j j dz t | j S r )r r r r) rf r r8 s rc r% zNamespaceAttribute.__sql__ s8 .455VDO,,-- /re Nr r` re rc r r z s2 $ $ $/ / / / /re r r1 c D e Zd Z fdZej d Zd Z xZS )r0 c r t t | || _ d| _ d S rh )r r0 r r; _negatedra r; r s rc r z DQ.__init__ s/
b$ """
re c | j | _ d S r_ )r r s rc rh z
DQ.__invert__ s M)
re c @ t di | j }| j |_ |S r )r0 r; r r< s rc r\ zDQ.clone s% DJ
re ) rf rg rh r re rL rh r\ r r s @rc r0 r0 sd
Y* * Y* re r0 c t | S r_ r- )as rc rx rx s #A&& re c e Zd Zd ZdS )rM c | 5 | | j cd d d S # 1 swxY w Y d S r_ )r1 r) r= r8 s rc r% zQualifiedNames.__sql__ s
& &7749%% & & & & & & & & & & & & & & & & & &s <A A Nr r` re rc rM rM r re rM c t | t rF| t | j | j t | j | j S t | t rt | S | S r_ )
rv r
r
qualify_namesr r r r rN rM rr s rc r r su $
## $~~mDH 5 5tw +DH 5 5tyB B B D* % % $ d### Kre c e Zd Z d dZd Zd Zej d Zej d d Z ej d Z
ej d Z ej d Z ej d
Z
dS )
OnConflictNc || _ || _ t | | _ || _ ||t d t | | _ || _ || _ d S )NzIonly one of "conflict_target" and "conflict_constraint" may be specified.) _action_updaterc _preserve_wherer _conflict_target_conflict_where_conflict_constraint)ra actionr preserver5 conflict_targetconflict_whereconflict_constraints rc r zOnConflict.__init__ su %h// &+>+J G H H
H ,_ = = - $7!!!re c 8 |j | | S r_ )r conflict_statementra r9 r; s rc get_conflict_statementz!OnConflict.get_conflict_statement s y++D%888re c 8 |j | | S r_ )r conflict_updater s rc get_conflict_updatez OnConflict.get_conflict_update s y((u555re c || _ d S r_ )r r s rc r zOnConflict.preserve s
re c |r&|r$t |t st d |pi }|r| | || _ d S )NzGCannot mix data with keyword arguments in the OnConflict update method.)rv dictr r r )ra _datar s rc r zOnConflict.update sg :V :Jud$;$; : 9 : :
: ! LL re c h | j | j f|z }t t j | | _ d S r_ r rt operatorand_ra expressionss rc r5 zOnConflict.where / ; " ;.;6K X]K88 re c " d | _ || _ d S r_ r r )ra constraintss rc r zOnConflict.conflict_target s $(! + re c h | j | j f|z }t t j | | _ d S r_ )r rt r r r s rc r zOnConflict.conflict_where s5 + /1K?K %hm[ A A re c " || _ d | _ d S r_ r )ra r" s rc r z OnConflict.conflict_constraint s $.! $ re rO r_ )rf rg rh r r r re rL r r r5 r r r r` re rc r r s FJ6:%) 8 8 8 8 9 9 96 6 6
Y! ! Y!
Y Y
Y9 9 Y9
Y, , Y,
YB B YB
Y% % Y% % %re r c > t d fd }|S )Nc f || j n|}|st dj z | |g|R i |S )Nz8Query must be bound to a database in order to call "%s".)rJ r< rf )ra r r r r s rc r z database_required.<locals>.inner sc %-%54>>8 D "139?"C D D
DvdH6t666v666re r_ r r s ` rc database_requiredr s8
6]]7 7 7 7 7 ]7 Lre c e Zd Zej Zd fd ZddZ fdZe j
dd Z e j
dd Z e j
dd Z
e j
dd Zd
Zd Zd Zed
Zd ZddZd Zd Zd Zd Zd Z xZS ) BaseQueryNc || _ d | _ d | _ d | _ t t
| j di | d S r )rJ _cursor_wrapper _row_type _constructorr r r )ra rJ r r s rc r zBaseQuery.__init__ sJ " # 'i '11&11111re c || _ | S r_ r r s rc r zBaseQuery.bind r re c d t t | }d |_ |S r_ )r r r\ r r s rc r\ zBaseQuery.clone s+ i&&,,.. $ re Tc 0 |r t j nd | _ | S r_ )ROWr> r )ra as_dicts rc dictszBaseQuery.dicts s %,6$ re c 0 |r t j nd | _ | S r_ )r r= r )ra as_tuples rc tupleszBaseQuery.tuples s &.8D re c 0 |r t j nd | _ | S r_ )r r? r )ra
as_namedtuples rc namedtupleszBaseQuery.namedtuples s ,9C t re c > |r t j nd | _ || _ | S r_ )r r@ r r ra constructors rc r@ zBaseQuery.objects s! ,7A T ' re c F | j p| j }|t j k rt | S |t j k rt
| S |t j k rt | S |t j k rt || j S t d|z Nz Unrecognized row type: "%s".)
r default_row_typer r> DictCursorWrapperr=
CursorWrapperr? NamedTupleCursorWrapperr@ ObjectCursorWrapperr r ra cursorrow_types rc _get_cursor_wrapperz BaseQuery._get_cursor_wrapper s >:T%: sx $V,, ,
"
" (( (
(
(*622 2
(
(&vt/@AA A ;h FGG Gre c t r_ r^ r8 s rc r% zBaseQuery.__sql__' r` re c | j r| j }nt }| | S r_ )rJ rL r# r> )ra contexts rc r) z
BaseQuery.sql* s< > n4466GG iiG}}T"""re c , | | S r_ )_executer s rc executezBaseQuery.execute1 s }}X&&&re c t r_ r^ r s rc r zBaseQuery._execute5 r` re c j t | | S r_ )rw r iteratorr s rc r zBaseQuery.iterator8 s( DLL**3355666re c l | j ,| j st d | d S d S )Nz Query has not been executed.)r rJ r r r s rc _ensure_executionzBaseQuery._ensure_execution; s> '>
A !?@@@ LLNNNNN ( 're c R | t | j S r_ )r
rw r r s rc r zBaseQuery.__iter__A s% D()))re c | t |t r|j }n|}|
|dk r|dz nd}| j | | j j | S Nr r )r
rv r r r
fill_cache row_cache)ra r~ rx s rc r zBaseQuery.__getitem__E sw eU # # JEEE !&!EAIIE ''...#-e44re c R | t | j S r_ )r
r r r s rc __len__zBaseQuery.__len__P s% 4'(((re c t | S r_ )rO r s rc __str__zBaseQuery.__str__T s t$$$re r_ rm ) rf rg rh r r> r r r r\ re rL r r r r@ r r% r) r r r r r
r r r r r r s @rc r r s x2 2 2 2 2 2
Y Y
Y Y
Y Y
Y Y
H H H " " "# # # ' ' '" " "7 7 7 7 * * * 5 5 5) ) )% % % % % % %re r c , e Zd Zd fd Zd Zd Z xZS )RawQueryNc d t t | j di | || _ || _ d S r )r r r r _params)ra r) rN r r s rc r zRawQuery.__init__Y s8 &h &00000 re c | | j | j r!| j D ]}| |d |S r )r r r r~ r s rc r% zRawQuery.__sql__^ sO DI < 2
2
2 %5 1111
re c | | j /| | }| | | _ | j S r_ r r r ra r r s rc r zRawQuery._executee = ' %%d++F#'#;#;F#C#CD ##re r )rf rg rh r r% r r r s @rc r r X s[
$ $ $ $ $ $ $re r c 2 e Zd Zd fd Zej d Zej d Zej d Zej d Z ej d Z
ej dd Z ej dd Z ej dd Z
d Zd
Z xZS )QueryNc t t | j di | || _ || _ || _ || _ d | _ d S r )r r! r r r- _limit_offsetr= )ra r5 r; limitoffsetr r s rc r zQuery.__init__m sM #eT#--f--- ! re c || _ d S r_ )r= )ra cte_lists rc r? zQuery.with_ctew r< re c h | j | j f|z }t t j | | _ d S r_ r r s rc r5 z Query.where{ r re c h | j | j f|z }t t j | | _ d S r_ )r rt r or_r s rc orwherez
Query.orwhere s/ ; " ;.;6K X\;77 re c || _ d S r_ r9 ra r% s rc r; zQuery.order_by s
re c , | j pd|z pd | _ d S r r9 r. s rc order_by_extendzQuery.order_by_extend s >/R69Bdre c || _ d S r_ )r# r s rc r% z Query.limit r re c || _ d S r_ )r$ r s rc r& z Query.offset r7 re c > |dk r|dz }|| _ ||z | _ d S r )r# r$ )ra page paginate_bys rc paginatezQuery.paginate s+ !88 AID! k) re c | j r:| d t | j | j | j N|j j rB| j |j j n| j }| d | | j -| d | j |S )Nz
ORDER BY z LIMIT z OFFSET )r- r r) r3 r# r$ r limit_max)ra r9 r% s rc _apply_orderingzQuery._apply_ordering s > 2
gl##c-//000 ; "t|'?'*y': (@+/;+>CI''DKE KK " " & &u - - - < # KK
# # ' ' 5 5 5
re c N | j rt d | j D }| d 5 | |rdnd t | j d d d d n # 1 swxY w Y |S )Nc 3 $ K | ] }|j V d S r_ )r; )rV r s rc rr z Query.__sql__.<locals>.<genexpr> s$ EEsCNEEEEEEre Fr zWITH RECURSIVE zWITH r )r= anyrG r r) r3 )ra r9 r s rc r% z
Query.__sql__ s > EEdnEEEEEI ..
'yE++gFF#mDN3344'#,,,
s ABB !B )NNNNr_ )r3 )rf rg rh r re rL r? r5 r, r; r0 r% r& r7 r: r% r r s @rc r! r! l sU
Y" " Y"
Y9 9 Y9
Y8 8 Y8
Y Y
YC C YC
Y Y
Y Y
Y* * * Y*
re r! c 0 t fd }|S )Nc 2 r|| }} t | | S r_ )CompoundSelectQuery)ra r r operations rc r z#__compound_select__.<locals>.method s& & %D"4E:::re )r )rB r r s `` rc __compound_select__rC s4 ; ; ; ; ; ; Mre c e Zd Z ed xZZ ed xZZ ed xZZ ed xZ
Z edd Z edd Z
edd Z edd Zd ZdS ) SelectQuery UNION ALLUNION INTERSECTEXCEPTTr c |st d t | f| | j }t | dd | | j }|S )Nz/select_from() must specify one or more columns.rA )r rP r rJ r r@ rA rB s rc rC zSelectQuery.select_from sg P NOO O))$t~&& 4$ ' ' 3MM$*--E re N)rf rg rh rC rH r rK r intersectr except_r r r r r rC r` re rc rE rE s --k:::I((111EF--k:::I++H555Gg"";>>>H!!'D999G"";>>>H""8d;;;H re rE c e Zd Zd Zd Zed
d Zed
d Zedd Zed Z edd Z
ed
Z ed Z d S )
SelectBasec V t | j | j pt | f S r_ )r r r r' r s rc r zSelectBase._get_hash s$ T^T[%<BtHH=>>>re c | | j /| | }| | | _ | j S r_ r r s rc r zSelectBase._execute r re r c d | | d | }|r|dk r|d n|S d S Nr r )r )ra r rz rowss rc peekzSelectBase.peek sD ||H%%bqb) / 1ff477$ . / /re c b | j |k r|| _ d | _ | || S )N)rz )r# r rT )ra r rz s rc rm zSelectBase.first s4 ;! DK#'D yyQy'''re Fc |r'| | S | | }|r
|s|d n|S r )r rT r )ra r r r r0 s rc scalarzSelectBase.scalar sY /::<<$$X.. .kkmm ** 6X6s1vv36re c # r K | | D ] }|d V
d S r )r r )ra r r0 s rc scalarszSelectBase.scalars sD ;;==((22 Ca&LLLL re c | d }|rd x|_ |_ |j @|j 9|j 2|j +|j dur"| t d }n# t $ r Y nw xY wt |gt t d g | S )N_wrappedT1)r; r r# r$ _having _group_by_windows _distinct_simple_distinctr rQ r rP r5 COUNTrW )ra r clear_limitr\ s rc r' zSelectBase.count s
%%j11 0+/ /EL5= }$ )@~%%/*A%T11 SXX.. D ugS 2 2 344;;HEEEs AB
B
Bc | t d }d|_ d |_ t | S )Nr\ r )r rQ r# r$ boolrW )ra r r\ s rc existszSelectBase.exists s= SXX&&
ELLNN###re c j d | _ | | d S # t $ r Y d S w xY wr )r r
IndexErrorr s rc r zSelectBase.get sH # <<))!, , DD s $
22Nr FFr )
rf rg rh r r r rT rm rW rY r' rf r r` re rc rN rN s ? ? ?$ $ $ / / / /
( ( ( ( 7 7 7 7 F F F F $ $ $ re rN c ` e Zd Z fdZed Zed Zd Zd Z fdZ
xZ S )rA c t t | || _ || _ || _ d S r_ )r rA r r r r )ra r r r r s rc r z CompoundSelectQuery.__init__ s9
!4((11333re c | j j S r_ )r
_returningr s rc rn z CompoundSelectQuery._returning% s
x""re c t | d ft d f | }t | S )Nr r\ )rP r% rQ r re rW )ra r r; s rc rf zCompoundSelectQuery.exists) sJ
1
'#c((55::8DDELLNN###re c f | j | j fS r_ )r
get_query_keyr r s rc _get_query_keyz"CompoundSelectQuery._get_query_key. s) &&(($(*@*@*B*BCCre c |j j }|r |t k rdS |t k rdS |t k r0|j j s |j j rdS t |t S d S NFT) r compound_select_parenthesesCSQ_PARENTHESES_NEVERCSQ_PARENTHESES_ALWAYSCSQ_PARENTHESES_UNNESTEDr rK rv rA )ra r9 subq csq_settings rc _wrap_parensz CompoundSelectQuery._wrap_parens1 s i;
=k-B B B5
2
2
24
4
4
4y
CI$9
u
"$(;<<< < 5
4re c |j t k r| | S t t | | |j p|j t k } || 5 | || j }|
|d 5 | | j d d d n # 1 swxY w Y | d| j
z | 5 | || j }|
|d 5 | | j d d d n # 1 swxY w Y d d d n # 1 swxY w Y | 5 | | d d d n # 1 swxY w Y d d d n # 1 swxY w Y | | S )Nr+ F)r r r! )r rH r r rA r% r rB r{ r rA r) r r r# r rE r: r )ra r9 outer_parens
lhs_parens
rhs_parensr s rc r% zCompoundSelectQuery.__sql__C s 9 $ $$$S)) ) !4((00555|B \(A
S\
*
*
* * * **399J!!j5!II
"
"!!!
"
"
"
"
"
"
"
"
"
"
"
"
"
"
" KK( ) ) ) !!
&
& ! . .sDH = =
%%*u%MM & &GGDH%%%& & & & & & & & & & & & & & &
&
&
&
&
&
&
&
&
&
&
&
&
&
&
& !!##
*
*$$S)))
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*! * * * * * * * * * * * * * * *& $$$s 23G%C G C GC 4G3E9;E" E9"E& &E9)E& *E9- G9E= =G E= GF:. G:F> >GF> GGG) rf rg rh r r rn r rf rr r{ r% r r s @rc rA rA s # # X# $ $ $D D D= = =$% % % % % % % % %re rA c e Zd Z d fd Z fdZej d ZeZej d Z e
d Z e j d Z ej d Z
ej ej dfd Zdd
Zej d Zd Zej d
Zej d Zej d Zej dd Zej dd Zd ZddZ fdZ xZ S ) rP Nc t t | j di | t |t rt | n|pg | _ || _ || _ || _ d | _
|| _ || _ | | _
|
| _ d x| _ | _ |r$t |t" r|| _ n|| _ d | _ d S r )r rP r rv ra r`
_from_listrn r^ r] r_ _for_update_for_update_of_for_update_nowait_lateralr` ra re r )
ra from_listr group_byhavingr windows
for_update
for_update_ofr lateralr r s
rc r zSelect.__init__b s %fd$..v....8E.J.J *4 ??? )1.0
!!
% +"(
155. *(D))
*(0%%!) # re c t t | }|j rt |j |_ |S r_ )r rP r\ r r` ra r\ r s rc r\ z Select.clonez sA fd##))++ 6 #E$4 5 5E re c || _ d S r_ rn )ra r r s rc r zSelect.columns s
!re c > t | j |z | _ d S r_ )ra rn r s rc
select_extendzSelect.select_extend s 007:re c | j S r_ r r s rc selected_columnszSelect.selected_columns s
re c || _ d S r_ r r s rc r zSelect.selected_columns s
re c . t | | _ d S r_ )r` r ra sourcess rc from_z Select.from_ s w--re c | j st d | j }| j t |||| d S )NNo sources to join on.)r r r r r )ra r r r r s rc rU z Select.join sX 7 566 6""$$ tD$ 2 > >?????re c D | |t j | S r_ rU r? r4 r s rc r zSelect.left_outer_join s yyt333re c g }|D ]it t r=j st d | fdj D T| j|| _ d S )NQCannot pass a table to group_by() that does not have columns explicitly declared.c 0 g | ]}t | S r` r rV col_namer s rc rY z#Select.group_by.<locals>.<listcomp> 9 !B !B !B%- ")!:!: !B !B !Bre )rv rS r r r7 r r^ ra r groupingr s @rc r zSelect.group_by s ( (F&%((
( 2$ &1 2 2 2 !B !B !B !B17 !B !B !B C C C C ''''!re c H t | j pd |z } | j | S )z$@Node.copy used from group_by() callr` )ra r^ r )ra r% r s rc group_by_extendzSelect.group_by_extend s* -2..7 t}h''re c h | j | j f|z }t t j | | _ d S r_ )r] rt r r r s rc r z
Select.having s/ < # </K7K hm[99 re c t | dk r#|d du s
|d du r|d | _ d S d| _ || _ d S )Nr r TF)r ra r` r s rc r zSelect.distinct sT w<<1 '!*"4"4
e8K8K$+AJD ! ! !$)D ! $DNNNre c |r|nd | _ d S r_ )r_ )ra r s rc rG z
Select.window s #*4
re Tc @ |s||rd}|| _ || _ || _ d S r@ )r r r )ra r r r s rc r zSelect.for_update s5 r~~ J% "( re c || _ d S r_ )r )ra r s rc r zSelect.lateral s
re c | j S r_ r r s rc rr zSelect._get_query_key s
{re Fc P | t | j S r_ )r) r3 rn ra r9 is_subquerys rc __sql_selection__zSelect.__sql_selection__ s ww}T_55666re c z |j t k r| | S | j r%|j t k r| d |j }d d|p|j t k dd}|j j r|j j dk rd|d< |j
di |5 t t |
| | d | j s| j i| d | j rM| d t# | j d
| 5 | || }d d d n # 1 swxY w Y | j rh| d 5 | d t+ | j d d d n # 1 swxY w Y | j -| d
| j | j r:| d t+ | j | j -| d | j | j <| d | t+ | j | | | j rc|j j st; d | d
| t= | j | j | j d d d n # 1 swxY w Y |j j s|j j! r | j" |S | # | S )NzLATERAL FT)r/ rK r r r r zSELECT z DISTINCT zON r r+ FROM WHERE z
GROUP BY z HAVING z WINDOW z3FOR UPDATE specified but not supported by database.r` )$r rH r r rB r r r rK rL rA r rP r% ra r` r) r. rC r r r3 r r^ r] r_ r: r r r r r r r r r )ra r9 r r r s rc r% zSelect.__sql__ sX 9 $ $$$S)) ) = $SY, 6 6 KK
# # #l &E39 +D
9 )SY%AQ%F%F#(E-
S
&
&
&
& , < , <
&$ ' ' , , , KK " " "$
$(B K(((> $ gennc*4>::;; gclll!!##
?
?,,S+>>
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
N%%%%88 N NKK))--mDO.L.LMMMN N N N N N N N N N N N N N N {& I&&**4;777~
M L))--mDN.K.KLLL|' J''++DL999}( J'''
dm44555
% % %
<y+ 5$ &4 5 5 5 C $"2D4G"&"9; ; < < <W, < , < , < , < , < , < , < , < , < , < , < , < , < , < , <b 9 SY%6 %)[%8J $$$s\ C M<(F ? M< F M<F M<3;G:. M<:G> >M<G> E.M<<N N )
NNNNNNNNNNr_ TNNrm r ) rf rg rh r r\ re rL r r r r r r r r? r3 rU r r r r r rG r r rr r r% r r s @rc rP rP a s> >BFJ:>$ $ $ $ $ $0
Y" " Y"
F Y; ; Y; X
Y( ( Y(
Y#':$ @ @ @ Y@ 4 4 4 4
Y " " Y " ( ( (
Y: : Y:
Y% % Y%
Y5 5 Y5
Y) ) ) Y)
Y Y 7 7 7 7F% F% F% F% F% F% F% F% F%re rP c p e Zd Zd fd Zd
dZej d Zd Zd Z d Z
d Z d
Z fd Z
xZS ) _WriteQueryNc z || _ || _ |rdnd| _ t t | j di | d S )NTFr` )r( rn _return_cursorr r r )ra r( returningr r s rc r z_WriteQuery.__init__
sK
#&/ :ddU)k4 )33F33333re Fc * t || ||| S r r r s rc r z_WriteQuery.cte&
r re c * || _ |rdnd| _ d S NTF)rn r )ra r s rc r z_WriteQuery.returning*
s #&/ :ddUre c | j rf| 5 | d t | j d d d n # 1 swxY w Y |S )Nz RETURNING )rn rC r r) r3 r8 s rc apply_returningz_WriteQuery.apply_returning/
s ? O!!##
O
O M**..}T_/M/MNNN
O
O
O
O
O
O
O
O
O
O
O
O
O
O
O
s ;A##A'*A'c | j r| | }n| | }| || S r_ )rn execute_returningr
handle_resultr s rc r z_WriteQuery._execute5
sJ ? ,++H55FF %%d++F!!(F333re c | | j /| | }| | | _ | j S r_ r r s rc r z _WriteQuery.execute_returning<
r re c > | j r|S | | S r_ )r
rows_affectedr s rc r z_WriteQuery.handle_resultB
s& M%%f---re c 8 | j j |j | j < d S r_ )r( rf r r8 s rc _set_table_aliasz _WriteQuery._set_table_aliasG
s (,
(;$*%%%re c t t | | | | |S r_ )r r r% r ra r9 r s rc r% z_WriteQuery.__sql__J
s<
k4 ((---
c"""
re r_ r )rf rg rh r r re rL r r r r r r r% r r s @rc r r
s 4 4 4 4 4 4 . . . .
Y; ; Y; 4 4 4$ $ $ . . .
< < < re r c J e Zd Zd fd Zej d Z fdZ xZS )r Nc f t t | j |fi | || _ d | _ d S r_ )r r r r _from)ra r( r r r s rc r zUpdate.__init__T
s: $fd$U55f555
re c || _ d S r_ )r r s rc r z Update.from_Y
s
re c
t t | | | d 5 | d g }t | j |j D ]\ }}t |t s=t |t r| | }nQt |d }n?t |t r*t |t r| | }t |t st! | }| t% |t' d |f | | j d t- | | j rh| d 5 | d
t- | j d d d n # 1 swxY w Y | j rY| 5 | d | j d d d n # 1 swxY w Y | | | | cd d d S # 1 swxY w Y d S ) NTr= zUPDATE r Fr r z SET r+ r r ) r r r% rE r sortedr r r rv re r2 to_valuerY rA r6 r r ru rQ r) r( r3 r rC r rA r: r )ra r9 r krX r s rc r% zUpdate.__sql__]
sN
fd##C(((
t
,
, " - " - KK " " " K t| 1 1 3 39LMMM
?
?1!!T** &!!U++ 3 JJqMM !!E 2 2 2 5)) &jO.L.L &
1
A!!U++ )%a((A""8QC!,<#=#=>>>>
c$*oogg c- ,,---z
I%%%%88 I IKK))--mDJ.G.GHHHI I I I I I I I I I I I I I I {
<%%'' < <KK **..t{;;;< < < < < < < < < < < < < < < % % %'',,E" - " - " - " - " - " - " - " - " - " - " - " - " - " - " - " - " - " -s[ F K ;H# K#H' 'K*H' + K .J7 KJ K
J ,KK Kr_ ) rf rg rh r re rL r r% r r s @rc r r S
ss
Y Y %- %- %- %- %- %- %- %- %-re r c e Zd ZdZdZdZ G d de Zd fd Zd Z e
j dd
Z e
j dd Z
e
j dd Ze
j d
Zd Zd Zd Zd Zd Zd Z fdZ fdZd Z xZS )r
r r rj c e Zd ZdS ) Insert.DefaultValuesExceptionNr r` re rc DefaultValuesExceptionr
r re r Nc t t | j |fi | || _ || _ || _ d | _ d| _ d S rh )r r
r _insertr _on_conflict _query_type _as_rowcount)ra r( r r r r r s rc r zInsert.__init__
sT $fd$U55f555
' !re c t d )Nz*INSERT queries cannot have a WHERE clause.r^ r s rc r5 z Insert.where
s !"NOOOre Tc || _ d S r_ )r )ra r s rc as_rowcountzInsert.as_rowcount
s (re c 6 |rt d nd | _ d S )NIGNOREr r )ra ignores rc on_conflict_ignorezInsert.on_conflict_ignore
s" 4: DJx 0 0 0re c 6 |rt d nd | _ d S Nr r )ra r s rc on_conflict_replacezInsert.on_conflict_replace
s" 5< FJy 1 1 1$re c 4 |s|r t |i |nd | _ d S r_ r r s rc r zInsert.on_conflict
s4 =A 'V 'Z 8 8 8 8"&
re c r | j s| d | | j f| S )NError: no data to insert.)r r _generate_insertr8 s rc _simple_insertzInsert._simple_insert
s< | K--.IJJ J$$dl_c:::re c i S r_ r` r s rc get_default_datazInsert.get_default_data
s re c P j j r fd j j D S d S )Nc Z g | ]'}|j j k t j | (S r` )r( r r )rV colra s rc rY z.Insert.get_default_columns.<locals>.<listcomp>
s> 7 7 7dj 555 DJ,,555re )r( r r s `rc get_default_columnszInsert.get_default_columns
sI : 77 7 7 7
8K 7 7 7
7 7 7re c , t | }| j }| }|s& t | }n## t $ r | d w xY wt
|t s&| }|t d ng }|D ]A}t
|t rt | j | }|
| Bt | } t | | z
D ]}
|
|
t |fd }t! j t |f | }ng } t } |D ]Y}t
|t rt | j | }
n|}
|
|
| |
Z| }t |fd D ]}
|
| vr|
|
t }t }i }|D ]}||j g}t
|t( rp|j |j k r|
|j |j r| | t
|t. r| | |||< t3 | d d |D }g }|D ]=}g }t
|t }t7 | D ]\ }\ }} |r-|| D ] } || } n# t8 $ r Y w xY wt8 n|| }n[# t8 t: f$ rG ||v r"|| }t= | r
| }n ||v rd }nt d|j z Y nw xY wt
|t> rt
|t@ r||v rtC ||d
}|
| |
t3 | ?|s| d " d
5 tG | cd d d S # 1 swxY w Y d S )NzError: no rows to insert.z!Bulk insert must specify columns.c . | S r_ r r r9 s rc rx z)Insert._generate_insert.<locals>.<lambda>
8H8H8M8M re r c . | S r_ r r s rc rx z)Insert._generate_insert.<locals>.<lambda>
r re z VALUES c N g | ]"}|t |t r|j nd f#S r_ )rv r2 r
)rV r s rc rY z+Insert._generate_insert.<locals>.<listcomp>
sB # # #
65(A(AKV__t L # # #re zMissing value for %s.F)r/ r r Tr= )$rw r r next
StopIterationr rv r r r r9 r r( r rP r itertoolschainr r r2 column_namenullr6 r) r. r enumerater rh callable_re rA rY rE r3 )ra r r9 rows_iterr defaultsr0 accumr
column_setr
clean_columnsseen
column_obj fk_fieldsnullable_columns
value_lookupslookupscolumns_converters
all_valuesr% is_dictr r/ lookupvals ` rc r zInsert._generate_insert
s LL - ((** ( (
O9oo
O
O
O112MNNN
O c7++
O 2244?$%HIII # ! ) )F!&*55 =!(V!<!<LL(((( !ZZ
MMJ 6 & &CLL%%%% ,M,M,M,MNNN!cV i@@II M55D!
%
% fj11 (!(V!<!<JJ!'J $$Z000$$$$#G h,M,M,M,MNNN
(
(d??NN3'''EE 55
, ,F v{+G&%((
*;&"444NN6#5666; 1$((000 fo66 * MM&)))$+M& ! ! ))**22:>>> # #! # # #
# 8 # 8CF g..G*34F*G*G
#
#&&FIP % '4F&; + +F (&)&k"'% $, 1 1 1TT 1 #+N #( "!f *- P P P )) &v .$S>> ("%#%%C #333 " ()@6;)N O OOP "#t,, HC1G1G H1791D1D yGGGC
c"""" .v 6 6 7 7 7 7 K--.IJJ J
t
,
, 6 677=4455 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6sT A A M-L75M7
M MM MAN0/N0"R R
R
c | t | j d | j S r )r) r. r r r r8 s rc
_query_insertzInsert._query_insert' s< %dm4455 T\"" $re c n | j s| d S | j | S NzDEFAULT VALUES)rJ r default_values_insertr8 s rc _default_valueszInsert._default_values- s5 ~ 1;; /00 0~33C888re c D t t | | | 5 d }| j | j || }| |pt d d | j d t | j t rU| j
sN | | n%# | j $ r | | Y nw xY wt j | _ ntt | j t& t f r'| | t j | _ n,| | j | t j | _ | j E| j || }|(| d | | | cd d d S # 1 swxY w Y d S )NINSERTz INTO r )r r
r% rE r r r) rQ r r( rv r r r r r r SIMPLEr rE r QUERYr MULTIr r )ra r9 stmtr r s rc r% zInsert.__sql__2 s1
fd##C(((
- -D ,(??TJJ
c$'#h--((gh c$*oogclll$,00
0
0.'',,,,2 . . .((-----.#)= DL;*<==
0""3'''#)< %%dlC888#)< , *>>sDII%KK$$((000'',,; - - - - - - - - - - - - - - - - - -s7 B(H'C=<H= D H D C)HH Hc | j %|j r | j j r| j j f| _ t t
| | S # | j $ r Y d S w xY wr_ )rn returning_clauser( r r r
r r )ra r r s rc r zInsert._executeS sw ? "x'@ "z& # #z 6 8DO &&//99 9* DD s 'A
A%$A%c | j r|S | j r| | S | || j S r_ )r r r last_insert_idr r s rc r zInsert.handle_result\ sJ M 2))&11 1&&vt/?@@@re NNNrm )rf rg rh r r r Exceptionr r r5 re rL r r r r r r r r r r r% r r r r s @rc r
r
s
F
E
E11111111" " " " " "P P P
Y) ) ) Y)
YE E E YE
YG G G YG
Y( ( Y(; ; ;
7 7 7
p6 p6 p6d$ $ $ 9 9 9
- - - - -B A A A A A A Are r
c e Zd Z fdZ xZS )r c " t t | | | d 5 | d | j | j Y| 5 | d | j d d d n # 1 swxY w Y | | |
| cd d d S # 1 swxY w Y d S )NTr= DELETE FROM r ) r r r% rE r r) r( r rA r: r r s rc r% zDelete.__sql__e sv
fd##C(((
t
,
, - - KK ' ' + +DJ 7 7 7{&%%'' < <KK **..t{;;;< < < < < < < < < < < < < < <
% % %'',, - - - - - - - - - - - - - - - - - -s7 A D .C7 DC D
C ,DD D)rf rg rh r% r r s @rc r r d s8
-
-
-
-
-
-
-
-
-re r c e Zd Z d dZej d
d Zej d Zej d d Zd Z dS ) r9 FNc || _ t |t st | n|| _ || _ || _ || _ || _ || _ d S r_ )
r rv rS rf _table _expressionsr _unique_safe_using)ra r r( r uniquesafer5 usings rc r zIndex.__init__s sQ
+5eU+C+CNfUmmm '
re Tc || _ d S r_ )r, )ra r, s rc r/ z
Index.safe} s
re c h | j | j f|z }t t j | | _ d S r_ r r s rc r5 z Index.where r re c || _ d S r_ )r- )ra r- s rc r0 z Index.using s
re c | j rdnd}| d 5 | | | j r| d |j j r_t
| j t rE| j j r9t | j j | j }t | j j }nt | j }| j }|
| | j )|j j r | d| j z | d
| d | j )|j j s | d | j z |
t! d
| j D | j -| d
| j d d d n # 1 swxY w Y |S ) NzCREATE UNIQUE INDEX z
CREATE INDEX Tr= IF NOT EXISTS z USING %sr" r z USING %s c Z g | ](}t |t rt | n|)S r` )rv r9 rQ )rV r s rc rY z!Index.__sql__.<locals>.<listcomp> sA &/ &/ &/ (j 9 9CD t&/ &/ &/re r )r+ rE r r, r index_schema_prefixrv r) rS r rf r rf r) r- index_using_precedes_tabler. r* r )ra r9 statement
index_name
table_names rc r% z
Index.__sql__ s* .2lO**
t
,
, ! 8 ! 8 KK " " "z
. ,--- y,
)$+u--
)26+2E
) #DK$7 D D
#DK$8 9 9
#DJ / /
![
GGJ {&y3 ' K$+ 5666
gfooc*oogclll{&y3 ' K$+ 5666 GG$ &/ &/ -&/ &/ &/ 0 0
1
1
1 {& I&&**4;777C! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8 ! 8F
s G
G;;G?G?)FFNNrm r_ )
rf rg rh r re rL r/ r5 r0 r% r` re rc r9 r9 r s DI#'
Y Y
Y9 9 Y9
Y Y % % % % %re r9 c * e Zd Z d fd Zd Z xZS )rB FTNc || _ || || }|1|D ].}t |t rt |d r|j }/t
t | ||j j
||||| d S )N
index_type)r r( r r. r/ r5 r0 ) r _generate_name_from_fieldsrv r2 r r> r rB r r' r( )
ra rA fieldsr. r/ r5 r0 r fieldr s
rc r zModelIndex.__init__ s <225&AAD =
-
- eU++ -|0L0L - ! ,E
j$ ((+# ) re c d g }|D ]}t |t r.| | d Et |t r)t |t
s| }t |t
r| |j |st d t j
ddd | }|j }|j
r|j n|j }t! d ||f S )Nr zJUnable to generate a name for the index, please explicitly specify a name.[^\w]+r( rq )rv r9 r r re r2 rk r r rerj rU r' legacy_table_namesr r; _truncate_constraint_name)ra rA r@ r rA clean_field_namesrH prefixs rc r? z%ModelIndex._generate_name_from_fields s 4 4E%,,
4 U[[]]1 -.... eT** +:eU3K3K + !LLNNE eU++ 4LL!2333 ; : ; ;
; F9b#((5// B B{ " 5J4?(6;L2M)N)NOOOre )FTNNN)rf rg rh r r? r r s @rc rB rB sY EI"& $P P P P P P Pre rB @ c t | |k rSt j | d }| d |dz
d|d d } | S )Nutf-8rC rq )r hashlibmd5encode hexdigest)r" maxlen name_hashs rc rF rF si
: K
1 1' : :;;EEGG *=VaZ= 9 9 99RaR==I
re c e Zd Z fdZ xZS )PeeweeExceptionc |r3t |d t r|d |dd c| _ } t t | j | d S r )rv r# origr rT r )ra r r s rc r zPeeweeException.__init__ sY 0JtAw 22 0 "1gtABBxODIt-ot$$-t4444re rf rg rh r r r s @rc rT rT s8 5 5 5 5 5 5 5 5 5re rT c e Zd ZdS )r8 Nr r` re rc r8 r8 r re r8 c e Zd ZdS )r% Nr r` re rc r% r% r re r% c e Zd ZdS )r' Nr r` re rc r' r' r re r' c e Zd ZdS )r; Nr r` re rc r; r; r re r; c e Zd ZdS )r< Nr r` re rc r< r< r re r< c e Zd ZdS )r= Nr r` re rc r= r= r re r= c e Zd ZdS )rD Nr r` re rc rD rD r re rD c e Zd ZdS )rF Nr r` re rc rF rF r re rF c e Zd ZdS )rK Nr r` re rc rK rK r re rK c $ e Zd ZdZd Zd Zd ZdS )ExceptionWrapper
exceptionsc || _ d S r_ rc )ra rd s rc r zExceptionWrapper.__init__ s
$re c d S r_ r` r s rc r zExceptionWrapper.__enter__ re c |d S t 6|j | j vr(t |t j r|j d }n<t 5|j | j vr't |t j r
|j d }|j | j v r3| j |j }|j }t | ||g|R | d S d S r ) pg_errorsrf rd r] Error __bases__
pg3_errorsr r )ra r exc_value tracebacknew_typeexc_argss rc r zExceptionWrapper.__exit__ s F X%6do%M%M(IO44 &N )!,HH
# DO 3 3(J$455 4 )!,H / /x'89H ~H Hhhy <8 < < <i H H H H H 0 /re N)rf rg rh r r r r r` re rc rb rb sE I% % % I I I I Ire rb ) ConstraintErrorr% r' r; r< r= rD rF rK TransactionRollbackErrorUndefinedFunctionUniqueViolation
IndexMetadata)r r) r r. r( ColumnMetadata)r data_typer r r( r ForeignKeyMetadata)r
dest_table dest_columnr( ViewMetadata)r r) c * e Zd Z fdZd Zd Z xZS )_ConnectionStatec p t t | j di | | d S r )r r} r reset)ra r r s rc r z_ConnectionState.__init__, s8 . %%.88888
re c > d| _ d | _ g | _ g | _ d S r@ )closedconnr9 transactionsr s rc r z_ConnectionState.reset0 s% re c > || _ d| _ g | _ g | _ d S rh )r r r9 r ra r s rc set_connectionz _ConnectionState.set_connection6 s% re )rf rg rh r r r r r s @rc r} r} + sV re r} c e Zd ZdS )_ConnectionLocalNr r` re rc r r = r re r c e Zd ZdZd Zd ZdS ) _NoopLockr` c | S r_ r` r s rc r z_NoopLock.__enter__@ s re c d S r_ r` r s rc r z_NoopLock.__exit__A rg re N)rf rg rh r r r r` re rc r r > s' I$$$77777re r c * e Zd ZdZd Zd Zd Zd ZdS )r rM c || _ d S r_ r ra rM s rc r zConnectionContext.__init__F s bDGGGre c n | j r| j d S d S r_ )rM is_closedconnectr s rc r zConnectionContext.__enter__G s: 7 GOO re c 8 | j d S r_ )rM closer s rc r zConnectionContext.__exit__J s 47==?????re c @ t fd }|S )Nc p t j 5 | i |cd d d S # 1 swxY w Y d S r_ )r rM r s rc r z)ConnectionContext.__call__.<locals>.innerL s "47++
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ +//r r s `` rc r zConnectionContext.__call__K r re N)rf rg rh r r r r r r` re rc r r D sL I((( CBB re r c e Zd ZeZi Zi ZdZdZdZ e
Z dZ dZ
dZdZdZdZdZdZdZdZ dAdZd Zd Zd Zd
Zd ZdBd Z d
Z d Z d Z d Z d Z!d Z"d Z#dCdZ$dCdZ%dDdZ&d Z'd Z(d Z)d Z*d Z+dDd Z,d Z-d Z.d Z/d Z0d! Z1d" Z2d# Z3d$ Z4d% Z5d& Z6d' Z7d( Z8d) Z9d* Z:d+ Z;d, Z<d- Z=d. Z>dDd/Z?dDd0Z@dDd1ZAdDd2ZBdDd3ZCdDd4ZDd5 ZEd6 ZFd7 ZGd8 ZHd9 ZId: ZJd; ZKd< ZLdEd=ZMdEd>ZNd? ZOePd@ ZQdS )Fr$ r0 r NFTc $ t t | j | _ t t | j | _ |r| j | |r| j | || _ || _ |r,t | _ t j
| _ n&t | _ t! | _ |rt# d |t# d i | _ | j |fi | d S )NzPeewee no longer uses the "autorollback" option, as we always run in autocommit-mode now. This changes psycopg2's semantics so that the conn is not left in a transaction-aborted state.a^ Peewee no longer uses the "autocommit" option, as the semantics now require it to always be True. Because some database-drivers also use the "autocommit" parameter, you are receiving a warning so you may update your code and remove the parameter, as in the future, specifying autocommit could impact the behavior of the database driver you are using.)rP FIELD field_types _field_typesrE r _operationsr autoconnect thread_safer _state threadingLock_lockr} r r connect_paramsinit) ra r r autorollbackr r
autocommitr r s rc r zDatabase.__init__h s& 'ud.> ? ?%b$/:: 2 $ $[ 1 1 1 0 # #J / / /&& %*,,DK" ))DJJ*,,DK"DJ J I
J
J
J
! <
=
=
= ! (%%f%%%%%re c | s| || _ | j | t | | _ d S r_ )r r r r r re deferred)ra r r s rc r z
Database.init sS ~~ JJLLL
""6*** NN*
re c | r| | }| j j | | | S r_ )r r r r r9 r r r8 s rc r zDatabase.__enter__ sX >> LLNNNkkmm s###
re c | j j } | ||| | j j s| d S d S # | j j s| w w xY wr_ )r r9 r r r )ra r r r! r9 s rc r zDatabase.__exit__ s| ko!!## LL7F 3 3 3;?
4;?
s A #A>c t | S r_ r r s rc r zDatabase.connection_context r re c t r_ r^ r s rc _connectzDatabase._connect r` re c | j 5 | j rt d | j j s |r d d d dS t d | j t 5 | j | | j
| | j j |
| j j d d d n # 1 swxY w Y d d d n # 1 swxY w Y dS )N@Error, database must be initialized before opening a connection.FzConnection already opened.T)r r r< r r rF r __exception_wrapper__r r server_version_set_server_versionr _initialize_connection)ra
reuse_if_opens rc r zDatabase.connect s
Z > >}
E$ &D E E E;%
E !
> > > > > > > > ''CDDD K &
>
> **4==??;;;&.,,T[-=>>>++DK,<===
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> > > > > > > > > > > > > > > > ts; &C?/C?*A2C( C?(C, ,C?/C, 0C??DDc d S r_ r` r s rc r z Database._initialize_connection re c d| _ d S r )r r s rc r z Database._set_server_version s re c | j 5 | j rt d | rt d | j j } |r>t 5 | | j j d d d n # 1 swxY w Y | j
n # | j
w xY w|cd d d S # 1 swxY w Y d S )Nr z7Attempting to close database while transaction is open.) r r r< in_transactionrF r r r _closer r )ra is_opens rc r zDatabase.close s
Z }
E$ &D E E E""$$
?& (> ? ? ? +,,G
$ 6. 6 6 DK$45556 6 6 6 6 6 6 6 6 6 6 6 6 6 6 !!#### !!#### sN AC B* B9 B*B B* B
B*C*CCC Cc . | d S r_ )r r s rc r zDatabase._close s
re c | j j S r_ r r r s rc r zDatabase.is_closed s
{!!re c | j j S r_ r r s rc is_connection_usablez Database.is_connection_usable s ;%%%re c j | r| | j j S r_ )r r r r r s rc
connectionzDatabase.connection s, >> LLNNN{ re c |t d | r+| j r| nt d | j j S )N,"commit" has been deprecated and is a no-op.z&Error, database connection not opened.)r r r r r< r r r )ra commit named_cursors rc r zDatabase.cursor sk I J J J >> O
O $%MNNN{ &&(((re c |t d t ||f t 5 | }| ||pd d d d n # 1 swxY w Y |S Nr r` )r loggerdebugr r r )ra r) rN r r s rc execute_sqlzDatabase.execute_sql s I J J J c6]###
" . .[[]]F NN3 " - - - . . . . . . . . . . . . . . .
s -A..A25A2c |t d | j di |}| | \ }}| || S r )r rL r) r; r )ra r; r context_optionsr9 r) rN s rc r zDatabase.execute sd I J J J"d"55_55ggenn**,, V V,,,re c
| j | j | j | j | j | j | j | j | j | j | j
| j d S )N) r r r4 r[ ru r r r r7 r8 r9 r ) r r r4 r[ ru r r r r7 r8 r9 r r s rc get_context_optionsz Database.get_context_options sU , *ZZ+/+K"&"9 # 3 /#'#;*.*I " 1
re c r | }|r| | | j di |S r )r r
context_class)ra r r s rc rL zDatabase.get_sql_context
sF **,, , NN? + + +!t!,,G,,,re c t r_ r^ ra r r; s rc r zDatabase.conflict_statement
r` re c t r_ r^ r s rc r zDatabase.conflict_update
r` re c |j rYt d }t d |j D }|j $t |t d |j g }n:t d }|j }t
|t rt | }g }|j rx|j D ]p}t t d t | fd }t t | t d |f }| | q|j r|j
D ]\ } }
t
|
t sgt
| t rt |j | } t
| t" r| |
}
n!t' |
d
}
nt) |
}
| t t | t d |
f ||t d t+ | g} |j r6| t d t) |j f t | S ) N ON CONFLICTc Z g | ](}t |t rt | n|)S r` r8 rV r s rc rY z6Database._build_on_conflict_update.<locals>.<listcomp>
sA '9 '9 '9 *#z : :Cs '9 '9 '9re rB zON CONFLICT ON CONSTRAINTr1 rR r r Fr z
DO UPDATE SET)r rQ r. r ru r rv r9 rf r rg r r r re r r( r2 r rY rM r3 r r7 ) ra r r; r targetupdatesr excluded
expressionr rX rp s rc _build_on_conflict_updatez"Database._build_on_conflict_update
sw ' (}%%D% '9 '9&7'9 '9 '9 : :F *6!63w<<#.#>#@ A A 233D 5F&*--
( +%/
+
+#S__mF6K6K$L), . . . %}V'<'<c#hh'/'1 2 2
z****
J#+1133
J
J1!!T**
* "!Z00 4 #EK 3 3!!U++ 3 JJqMM !!E 2 2 2&q))Ax q)9)93s88Q(G H HIIIIvs? 3 3]75K5KL M LL#g,,{7I(J(JK L L L re c |j S r_ ) lastrowidra r
query_types rc r! zDatabase.last_insert_idE
s re c |j S r_ )rowcountra r s rc r zDatabase.rows_affectedH
s
re c , | d S r r r8 s rc r z Database.default_values_insertK
s {{+,,,re c N | S r_ )r r r s rc
session_startzDatabase.session_startN
s !!++---re c | }n# t $ r Y dS w xY w| | dS NFbeginT)pop_transactionrh r r ra txns rc session_commitzDatabase.session_commitQ
sa &&((CC 55
,,..
///t
%%c | }n# t $ r Y dS w xY w| | dS r )r rh rollbackr r s rc session_rollbackzDatabase.session_rollbackY
sa &&((CC 55 4..00 111tr c 4 t | j j S r_ )re r r r s rc r zDatabase.in_transactiona
s DK,---re c D | j j | d S r_ )r r r )ra r s rc push_transactionzDatabase.push_transactiond
s! '' 44444re c > | j j S r_ )r r r r s rc r zDatabase.pop_transactiong
s {'++---re c 4 t | j j S r_ )r r r r s rc transaction_depthzDatabase.transaction_depthj
s 4;+,,,re c B | j j r| j j d S d S Nrt )r r r s rc top_transactionzDatabase.top_transactionm
s) ; # 0;+B/ / 0 0re c " t | g|R i |S r_ r r s rc r zDatabase.atomicq
r re c t | S r_ r r s rc r zDatabase.manual_committ
r re c " t | g|R i |S r_ r r s rc r zDatabase.transactionw
r re c t | S r_ r r s rc r zDatabase.savepointz
r re c | r| t 5 | d d d d d S # 1 swxY w Y d S )NBEGINr r r r r r s rc r zDatabase.begin}
s >> LLNNN
" + + KKMM ! !' * * * + + + + + + + + + + + + + + + + + +s (A%%A),A)c t 5 | d d d d d S # 1 swxY w Y d S )NROLLBACKr r r r s rc r zDatabase.rollback
s
" . . KKMM ! !* - - - . . . . . . . . . . . . . . . . . . (=AAc t 5 | d d d d d S # 1 swxY w Y d S )NCOMMITr
r s rc r zDatabase.commit
s
" , , KKMM ! !( + + + , , , , , , , , , , , , , , , , , ,r c # K t || D ]8}| 5 |D ]}|V d d d n # 1 swxY w Y 9d S r_ )r r )ra ry rz r| r s rc batch_commitzDatabase.batch_commit
s R^^ E
C IIII
s
A A A c t | r|}|j j }|j j }|| | v S )N)r )r& r' r; r
get_tables)ra r; r rA s rc table_existszDatabase.table_exists
sD J ( E /J['FT__F_ ; ;;;re c t r_ r^ )ra r s rc r zDatabase.get_tables
r` re c t r_ r^ ra r( r s rc get_indexeszDatabase.get_indexes
r` re c t r_ r^ r s rc get_columnszDatabase.get_columns
r` re c t r_ r^ r s rc get_primary_keyszDatabase.get_primary_keys
r` re c t r_ r^ r s rc get_foreign_keyszDatabase.get_foreign_keys
r` re c t r_ r^ )ra seqs rc sequence_existszDatabase.sequence_exists
r` re c D t | D ]} |j di | d S r ) sort_models create_table)ra modelsoptionsrA s rc
create_tableszDatabase.create_tables
s? (( * *E E ) ) ) ) ) ) * *re c ^ t t | D ]} |j di | d S r )r r!
drop_table)ra r# r rA s rc drop_tableszDatabase.drop_tables
sG k& 1 122 ' 'E E & &v & & & & ' 're c t r_ r^ ra date_part
date_fields rc extract_datezDatabase.extract_date
r` re c t r_ r^ r* s rc
truncate_datezDatabase.truncate_date
r` re c t r_ r^ ra r, s rc to_timestampzDatabase.to_timestamp
r` re c t r_ r^ r1 s rc from_timestampzDatabase.from_timestamp
r` re c 4 t S r_ )r5 randomr s rc r6 zDatabase.random
s yy{{re c @ |D ]}| | || d S )N) bind_refs
bind_backrefs)r )ra r# r8 r9 rA s rc r z
Database.bind
s: O OE JJty
J N N N N O Ore c & t || || S r_ _BoundModelsContext)ra r# r8 r9 s rc r zDatabase.bind_ctx
s "64MJJJre c | t t d t d S )N0r) rP r rQ r5 r8 s rc get_noop_selectzDatabase.get_noop_select
s@ wwvxx''C1177CAABBBre c t d s- G fdd }t dt fd|i _ j S )Nr c e Zd Z ZdS ) Database.Model.<locals>.MetaNr r s rc r rC
r re r r r r s ` rc rA zDatabase.Model
r re )TFNNNTr r r_ TT)Rrf rg rh r# r r r r4 r[ r rv ru r r7 r8 r9 r r safe_create_indexsafe_drop_index sequencestruncate_tabler r r r r r r r r r r r r r r r r r rL 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/ r2 r4 r6 r r r@ r rA r` re rc r$ r$ S sM MKJ E EN #8 J !& IN OIN@E?C !$& $& $& $&L+ + + ' ' '" " " $
" " " "& & &
) ) ) ) - - - -
- - - " " "" " "+ + + Z - - -. . . . . .5 5 5. . .- - -0 0 0. . . 3 3 3 + + + . . ., , , < < < <" " " "" " " "" " " "" " " "" " " "" " "* * *' ' '" " "" " "" " "" " " O O O OK K K KC C C X re r$ c 8 fd} fd}t || S )Nc . | S r_ pragmar s rc r~ z__pragma__.<locals>.__get__
s {{4 re c 0 | | S r_ rK )ra r~ r s rc __set__z__pragma__.<locals>.__set__
s {{4'''re )r )r r~ rN s ` rc
__pragma__rO
sE ! ! ! ! !( ( ( ( ( GW % %%re c e Zd Zej ej ej ej ej ej dZdddZ dZ
dZ e Z
dZ fdZdJ fd Zd Zd
Zd Zd Zd Zedd fdZ ed Z ed Z ed Z ed Z ed Z ed Z ed Z ed Z ed Z! ed Z" ed Z# ed Z$e%d Z&e&j' d Z&d Z(d! Z)d" Z*d# Z+dKd$Z,dKd%Z-dLd&Z.dLd'Z/ dMd(Z0dMd)Z1dKd*Z2dKd+Z3dLd,Z4dLd-Z5d. Z6d/ Z7d0 Z8d1 Z9d2 Z:d3 Z;d4 Z<d5 Z=d6 Z>d7 Z?dLd8Z@d9 ZAdLd:ZBd; ZCd< ZDdLd=ZEdLd>ZFdLd?ZGdLd@ZHdLdAZIdLdBZJdC ZKdD ZLdE ZMdF ZNdG ZOdH ZPdI ZQ xZRS )NrR )r r r! r) r" r/ GLOBr )r r Trt Fc | dd | _ t t | j |g|R i | i | _ i | _ i | _ i | _ g | _ t | _ i | _ |
t dd |
t dd | j dk | _ d S )Npragmasr` r+ rj
date_trunc)r r )r _pragmasr rR r _aggregates _collations
_functions_window_functions_table_functionsrP _extensions _attachedregister_functionr r r r )ra r r r r s rc r zSqliteDatabase.__init__
s
9b11
,nd##,XGGGGGGG !# " 55 0+qAAA 1<CCC " 1Z ?re Nr< c D ||| _ t | j t r+t | j | _ |&t
dk rt
j d || _ || _ t t | j |fi | d S )N)r # r z.RETURNING clause requires Sqlite 3.35 or newer)
rV rv r r` r __sqlite_version__r r r _timeoutr rR r )ra r rS timeoutr r r s rc r zSqliteDatabase.init
s #DM dmT * * 8 !4!4!6!6 7 7DM '!J..
NOOO$4D !
(nd##(<<V<<<<<re c d S r_ r` r s rc r z"SqliteDatabase._set_server_version r re c t t d t j | j f| j d d| j } | | n# | xY w|S )Nz SQLite driver not installed!)rc isolation_level)sqlite3r8 r r rb r _add_conn_hooksr r s rc r zSqliteDatabase._connect s ?&'EFF Ft} Ldm/3L L7;7JL L & & & & JJLLL s A A)c | j r| | | j r| | | | | | | | | j dk r| | | j r | j D ]}|
| | j r| | d S d S )N)r r )
r] _attach_databasesrV _set_pragmas_load_aggregates_load_collations_load_functionsr _load_window_functionsr[ registerr\ _load_extensions)ra r table_functions rc rh z SqliteDatabase._add_conn_hooks s > ) " "4 ( ( ( = $ d # # # d### d### T""" * , , ' ' - - - ."&"7
.
. ''---- ( ! !$ ' ' ' ' ' ( (re c | }| j D ]!\ }}| d|d|d "| d S )NzPRAGMA z = ;)r rV r r )ra r r rL r~ s rc rl zSqliteDatabase._set_pragmas% s[ !] @ @MFE NNN> ? ? ? ? re c | }| j D ]!\ }}| d|d|d "| d S )NATTACH DATABASE "" AS "r )r r] r r r )ra r r r rM s rc rk z SqliteDatabase._attach_databases+ sg ,,.. H HHD" NNNRRRF G G G G re c V |d|d|}d|z }|t urN|d|pdz z
}|rAt | j pd }|||< t | | _ n|rt d | | }|r|d S d S )Nr ".z PRAGMA %sz = %sr r` z/Cannot specify a permanent pragma without value)SENTINELr rV r` r r r fetchone)ra r r~ permanentr r) rS r0 s rc rL zSqliteDatabase.pragma1 s %vvss+CC 7ejq) )C
6 t} 233 $ $W]]__ 5 5
P NOO O s##,,.. q6M re
cache_size foreign_keys journal_modejournal_size_limit mmap_size page_sizeread_uncommitted synchronouswal_autocheckpointapplication_id user_version data_versionc | j S r_ )rb r s rc rc zSqliteDatabase.timeoutN s
} re c | j |k rd S || _ | s | d|dz z d S d S )NzPRAGMA busy_timeout=%d;i )rb r r )ra secondss rc rc zSqliteDatabase.timeoutR s` =G # # F
~~ K
6'D. I J J J J J K Kre c x | j D ] \ }\ }}| ||| d S r_ )rW r create_aggregatera r r klass
num_paramss rc rm z SqliteDatabase._load_aggregates] sO )-)9)?)?)A)A ; ; %D%5* ! !$
E : : : : ; ;re c p | j D ]\ }}| || d S r_ )rX r create_collation)ra r r r5 s rc rn z SqliteDatabase._load_collationsa sG (..00 , ,HD" ! !$ + + + + , ,re c | | j D ]!\ }\ }}}|rd|ini } |j |||fi | "d S )N
deterministic)rY r create_function)ra r r r5 n_paramsr r s rc ro z SqliteDatabase._load_functionse sk 37?3H3H3J3J ? ? /D/2x 9FNo}55BF D x > >v > > > > ? ?re c x | j D ] \ }\ }}| ||| d S r_ )rZ r create_window_functionr s rc rp z%SqliteDatabase._load_window_functionsj sS )-)?)E)E)G)G A A %D%5* ' 'j% @ @ @ @ A Are c ||f| j |p|j < | s)| | d S d S r_ )rW rf rl r rm r ra r r r s rc register_aggregatez!SqliteDatabase.register_aggregaten sg <A:;N7 !5!5!7!78~~ 5 ! !$//"3"3 4 4 4 4 4 5 5re c fd}|S )Nc 6 | | S r_ )r r r r ra s rc r3 z+SqliteDatabase.aggregate.<locals>.decoratort s # #E4 < < <Lre r` ra r r r3 s ``` rc aggregatezSqliteDatabase.aggregates 0 re c p|j fd}||_ || j < | s)| | d S d S )Nc N | t dz fz }t | S )Nz
collate %s)rQ ru )r r r s rc
_collationz5SqliteDatabase.register_collation.<locals>._collation{ s+ #lT&9":":!<<KK(( (re )rf r^ rX r rn r )ra r5 r r s ` rc register_collationz!SqliteDatabase.register_collationy s~ "r{ ) ) ) ) ) " !# ~~ 5 ! !$//"3"3 4 4 4 4 4 5 5re c fd}|S )Nc 4 | | S r_ )r )r5 r ra s rc r3 z+SqliteDatabase.collation.<locals>.decorator s # #B - - -Ire r` ra r r3 s `` rc r^ zSqliteDatabase.collation s* re c |||f| j |p|j < | s)| | d S d S r_ )rY rf r ro r )ra r5 r r r s rc r^ z SqliteDatabase.register_function s\ 02J
/N+ ,~~ 4 !2!2 3 3 3 3 3 4 4re c fd}|S )Nc 8 | | S r_ )r^ )r5 r r r ra s rc r3 z&SqliteDatabase.func.<locals>.decorator s" " "2tZ G G GIre r` )ra r r r r3 s ```` rc r> zSqliteDatabase.func s6 re c |p|j }||f| j |< | s)| | d S d S r_ )rf rl rZ r rp r r s rc register_window_functionz'SqliteDatabase.register_window_function sl -u~++--(-z': t$~~ ; ' '(9(9 : : : : : ; ;re c fd}|S )Nc 6 | | S r_ )r r s rc r3 z1SqliteDatabase.window_function.<locals>.decorator s ) )%z B B BLre r` r s ``` rc window_functionz SqliteDatabase.window_function r re c |||_ | j | | s)| | d S d S r_ )r r[ r r rq r )ra r r s rc register_table_functionz&SqliteDatabase.register_table_function sd EJ $$U+++~~ . NN4??,, - - - - - . .re c fd}|S )Nc 4 | | S r_ )r )r r ra s rc r3 z0SqliteDatabase.table_function.<locals>.decorator s ( ( 5 5 5Lre r` r s `` rc rs z SqliteDatabase.table_function s* re c | j |= d S r_ )rW r s rc unregister_aggregatez#SqliteDatabase.unregister_aggregate T " " "re c | j |= d S r_ )rX r s rc unregister_collationz#SqliteDatabase.unregister_collation r re c | j |= d S r_ )rY r s rc unregister_functionz"SqliteDatabase.unregister_function s OD ! ! !re c | j |= d S r_ )rZ r s rc unregister_window_functionz)SqliteDatabase.unregister_window_function s "4 ( ( (re c t | j D ]\ }}|j |k r ndS | j | dS rt )r r[ r r )ra r r r s rc unregister_table_functionz(SqliteDatabase.unregister_table_function sZ #D$9:: JCzT!! " 5 !!#&&&tre c n | d | j D ]}| | d S r@ )enable_load_extensionr\ load_extension)ra r extensions rc rr z SqliteDatabase._load_extensions sI ""4((( ) + +I * * * * + +re c | j | | s@| }| d | | d S d S r@ )r\ r r r r r )ra r r s rc r z SqliteDatabase.load_extension sr Y'''~~ +??$$D & &t , , , * * * * * + +re c : | j | d S r_ )r\ remove)ra r s rc unload_extensionz SqliteDatabase.unload_extension s *****re c || j v r%| j | |k rdS t d|z || j |< | s | d|d|d dS )NFz schema "%s" already attached.rw rx r T)r] rF r r )ra filenamer s rc attachzSqliteDatabase.attach s 4> ! !~d#x// u"#BT#IJJ J 't ~~ P xxx N O O Otre c || j vrdS | j |= | s| d|z dS )NFzDETACH DATABASE "%s"T)r] r r r s rc detachzSqliteDatabase.detach sO t~ % %5 N4 ~~ < 3d : ; ; ;tre c | j s|j S |t j k r, |d d S # t t
t f$ r Y nw xY w|S r )r r r
r rh r TypeErrorr s rc r! z SqliteDatabase.last_insert_id sb $ # #
6=
(
(
ay|# )4
s
. AAc J |j S # t $ r |j j cY S w xY wr_ r r r r s rc r z SqliteDatabase.rows_affected ; *? " * * *=) ) ) ) * ""c B |rd|z nd}| | d S )NzBEGIN %sr r )ra lock_typer9 s rc r zSqliteDatabase.begin s0 .7DJ**W #####re c t 5 | j j cd d d S # 1 swxY w Y d S r_ )r r r r r s rc r zSqliteDatabase.commit s
" - -;#**,, - - - - - - - - - - - - - - - - - - 377c t 5 | j j cd d d S # 1 swxY w Y d S r_ )r r r r r s rc r zSqliteDatabase.rollback s
" / /;#,,.. / / / / / / / / / / / / / / / / / /r c x |pd}| d|z d }d | D S )Nmainz>SELECT name FROM "%s".sqlite_master WHERE type=? ORDER BY name)r( c g | ]\ }|S r` r` r/ s rc rY z-SqliteDatabase.get_tables.<locals>.<listcomp> s 222222re r fetchall)ra r r s rc r zSqliteDatabase.get_tables sR !6!! #9;A#BCMO O22 1 12222re c P d|pdz }d | |d D S )NzCSELECT name, sql FROM "%s".sqlite_master WHERE type=? ORDER BY namer c g | ] }t | S r` r{ r/ s rc rY z,SqliteDatabase.get_views.<locals>.<listcomp> s OOOs c"OOOre )viewr )ra r r) s rc get_viewszSqliteDatabase.get_views s: #)#3V5OOd.>.>sI.N.NOOOOre c ^
|pd}d|z }| |df }t |
t | d|dd }| D ]:}|d }t |d dk }|r | ;i t
D ]?}| d|d |d }d
| D |< @
fd t
D S ) Nr zVSELECT name, sql FROM "%s".sqlite_master WHERE tbl_name = ? AND type = ? ORDER BY namerx PRAGMA "z".index_list("")r rj z".index_info("c g | ]
}|d S )rj r` r/ s rc rY z.SqliteDatabase.get_indexes.<locals>.<listcomp># s (M(M(MCQ(M(M(Mre c R g | ]#}t || | |v $S r` ru )rV r
index_columns index_to_sqlr( unique_indexess rc rY z.SqliteDatabase.get_indexes.<locals>.<listcomp>% sS . . .
T" d#&
. . .re )r r r rP r r r ) ra r( r r; r r0 r is_uniquer: r r r s ` @@@rc r zSqliteDatabase.get_indexes
s !6ADJK!!%%)9::FOO - -.. !!!#)66555#2 3 3??$$ ) )Cq6DCF q(I
) ""4(((
.. N NJ%%%'-vvzzz'; < <F(M(M6??;L;L(M(M(MM* % %. . . . . . . |,,. . . .re c | d|pddd }fd| D S )Nr r ".table_info("r c g | ]B}t |d |d |d t |d |d CS )r rj r r< r; )rv re )rV r
r( s rc rY z.SqliteDatabase.get_columns.<locals>.<listcomp>1 sW , , , qtQqTqt8T!A$ZZ!MM , , ,re r ra r( r r s ` rc r zSqliteDatabase.get_columns. si !!!#)#3V#3#3UUU#< = =, , , , **, , , ,re c | d|pdd|d }d t d | D S )Nr r r r c g | ]
}|d S ri r` r/ s rc rY z3SqliteDatabase.get_primary_keys.<locals>.<listcomp>7 s MMM3AMMMre c | d S r r` )r
s rc rx z1SqliteDatabase.get_primary_keys.<locals>.<lambda>7 s
1R5 re r r6 r r s rc r z SqliteDatabase.get_primary_keys4 s] !!!#)#3V#3#3UUU#< = =MM& &//:K:K"L"LMMMMre c | d|pddd }fd| D S )Nr r z".foreign_key_list("r c X g | ]&}t |d |d |d 'S )r rj r; rx rV r0 r( s rc rY z3SqliteDatabase.get_foreign_keys.<locals>.<listcomp>< C . . . #3q63q63q65AA . . .re r r s ` rc r z SqliteDatabase.get_foreign_keys9 si !!!#)#3V#3#3UUU#< = =. . . .!??,,. . . .re c t j S r_ )rg Binaryr s rc get_binary_typez SqliteDatabase.get_binary_type? s
~ re c |j r|j nd}|r-|dvr+t d|j z S d S d S )Nr( )nothingr z INSERT OR %s)r rl rQ upperra r r; r s rc r z!SqliteDatabase.conflict_statementB sk 0;0CK$**,,, Ef$999~ (;(A(A(C(CCDD D E E99re c | j dk r<t |j |j |j |j |j f rt d |j r|j nd}|r|dvrd S |dk rt d S |j s|j st d |j rt d |j st d | || S )
N)r r zFSQLite does not support specifying which values to preserve or update.r( )r r r( r zON CONFLICT DO NOTHINGzIf you are not performing any updates (or preserving any INSERTed values), then the conflict resolution action should be set to "NOTHING".zMSQLite does not support specifying named constraints for conflict resolution.zISQLite requires that a conflict target be specified when doing an upsert.) r r> r r r r r r r rl rQ r )ra ocr; r s rc r z SqliteDatabase.conflict_updateG s= + + bj")R5H') * * , 6 7 7
7 (*z9!!###r f$=== F Y /00 0
@BL
@ * + +
+
$ @ D E E
E$ @ ? @ @
@ --b%888re c F t ||t S N)r0 )r5 r+ r r* s rc r- zSqliteDatabase.extract_datec s ||Iz|DDDre c F t ||t S r )r5 rT simple_date_timer* s rc r/ z SqliteDatabase.truncate_datef s$ }}Y
*: < < <re c ^ t d| d S )NrK integer)r5 r r[ r1 s rc r2 zSqliteDatabase.to_timestampj s$ {{4,,11)<<<re c 8 t |d S )N unixepoch)r5 r r1 s rc r4 z SqliteDatabase.from_timestampm s {{:{333re )Nr< Nr r_ )Nrt N)Srf rg rh r r r, r+ r- r r r7 r9 ra r rH r r r r rh rl rk r{ rL rO r~ r r r r r r r r r r r r rc r rm rn ro rp r r r r^ r^ r> r r r rs 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/ r2 r4 r r s @rc rR rR
s :) +I
K J I'NN @ @ @ @ @ = = = = = =
( ( ( !)E$ L))J :n--L :n--L#$899
;''I
;''I!z"455 *]++K#$899 Z 011N :n--L :n--L
X
^K K ^K; ; ;, , ,? ? ?
A A A5 5 5 5
5 5 5 5 ;=(,4 4 4 4 ; ; ; ; . . . . $ $ $$ $ $# # #* * * + + +
+ + ++ + + * * * $ $ $ $- - -/ / /3 3 3 3 P P P P
. . . .B, , , , N N N N
. . . . E E E
9 9 98E E E< < <= = =4 4 4 4 4 4 4re rR c
e Zd Zdddddddddd Zd
d d Zd
ZeZdZdZ dZ
dZ dZ d( fd Z
d Zd Zd Zd)dZd Zd)dZd)dZd)dZd)dZd)dZd)d Zd)d Zd Zd Zd Z d! Z d" Z d# Z d$ Z d% Z!d& Z"d' Z# xZ$S )*rG SERIAL BIGSERIALBYTEABOOLEAN TIMESTAMPNUMERICDOUBLE PRECISIONr/ ) r r r r! r% r& r) r/ r0 r z~*)r r rK TFNc t || _ || _ || _ t t | j |fi | d S r_ )_register_unicode _encoding_isolation_levelr rG r )ra r register_unicodeencodingrf r r s rc r zPostgresqlDatabase.init sF !1 ! / , $'',X@@@@@@@re c D t t d | j }| j d r | d| j n| d| j t j di |}| j r>t j
t j | t j
t j | | j
r| | j
| j r| | j d|_ |S )Nz Postgres driver not installed!z
postgresql://dsndbnameTr` )psycopg2r8 r rL r r|
setdefaultr r
pg_extensions
register_typeUNICODE UNICODEARRAYr set_client_encodingr set_isolation_levelr )ra rN r s rc r zPostgresqlDatabase._connect s &'GHH H $))++ = # #O 4 4 7 eT] 3 3 3 3 h
6 6 6 ))&)) ! J '
(=t D D D '
(BD I I I > 5 $ $T^ 4 4 4 < $ $T%: ; ; ; re c F |j | _ | j dk r d| _ d S d S )Nia T)r rE r s rc r z&PostgresqlDatabase._set_server_version s1 " 1 % ' '%)D " " " ( 're c z | j j rdS | j j }|t j k S rh )r r r get_transaction_statusr TRANSACTION_STATUS_INERROR)ra
txn_statuss rc r z'PostgresqlDatabase.is_connection_usable s: ; 5
[%<<>>
M DDDre c |t j k r|n
|d d S # t t t f$ r Y d S w xY wr )r
r rh r r r s rc r! z!PostgresqlDatabase.last_insert_id sN '6= 8 866fQil JHi0 DD s " ==c J |j S # t $ r |j j cY S w xY wr_ r r s rc r z PostgresqlDatabase.rows_affected r r c | r| |rd|z }nd}t 5 | | d d d d S # 1 swxY w Y d S )Nz$BEGIN TRANSACTION ISOLATION LEVEL %sr r )ra rf r s rc r zPostgresqlDatabase.begin s >> LLNNN 9OKDDD
" ( ( KKMM ! !$ ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s (A//A36A3c t d}| ||pdf }d | D S )NzSSELECT tablename FROM pg_catalog.pg_tables WHERE schemaname = %s ORDER BY tablenamepublicc g | ]\ }|S r` r` rV r( s rc rY z1PostgresqlDatabase.get_tables.<locals>.<listcomp> s 666&%666re r ra r r; r s rc r z PostgresqlDatabase.get_tables sD <!!%&*<H)>??66FOO$5$56666re c t d}| ||pdf }d | D S )Nz\SELECT viewname, definition FROM pg_catalog.pg_views WHERE schemaname = %s ORDER BY viewnamer/ c Z g | ](\ }}t || d )S )z ;)r{ strip)rV view_namer) s rc rY z0PostgresqlDatabase.get_views.<locals>.<listcomp> sB ; ; ;$Y Y &(9(9:: ; ; ;re r r2 s rc r z PostgresqlDatabase.get_views sQ ;!!%&*<H)>??; ;(.(9(9; ; ; ;re c ~ d}| |d|pdf }fd| D S )Na
SELECT
i.relname, idxs.indexdef, idx.indisunique,
array_to_string(ARRAY(
SELECT pg_get_indexdef(idx.indexrelid, k + 1, TRUE)
FROM generate_subscripts(idx.indkey, 1) AS k
ORDER BY k), ',')
FROM pg_catalog.pg_class AS t
INNER JOIN pg_catalog.pg_index AS idx ON t.oid = idx.indrelid
INNER JOIN pg_catalog.pg_class AS i ON idx.indexrelid = i.oid
INNER JOIN pg_catalog.pg_indexes AS idxs ON
(idxs.tablename = t.relname AND idxs.indexname = i.relname)
WHERE t.relname = %s AND t.relkind = %s AND idxs.schemaname = %s
ORDER BY idx.indisunique DESC, i.relname;r
r/ c g | ]@\ }}}}t || d | d | AS )z ;,)ru rstripr )rV r r) r r r( s rc rY z2PostgresqlDatabase.get_indexes.<locals>.<listcomp> sd H H H1D#y' dCJJt$4$4gmmC6H6H '0 0 H H Hre r ra r( r r; r s ` rc r z PostgresqlDatabase.get_indexes sj
9 !!%%f6H)IJJH H H H5;__5F5FH H H Hre c d}| ||pdf }t | | fd| D S )Nz
SELECT column_name, is_nullable, data_type, column_default
FROM information_schema.columns
WHERE table_name = %s AND table_schema = %s
ORDER BY ordinal_positionr/ c
N g | ]!\ }}}}t |||d k |v | "S YESrv rV r r r dfpksr( s rc rY z2PostgresqlDatabase.get_columns.<locals>.<listcomp> K = = =&D$B tR UBOO = = =re r rP r r )ra r( r r; r rC s ` @rc r z PostgresqlDatabase.get_columns s )
!!%%1C8)DEE$''v6677= = = = =*0//*;*;= = = =re c | d}d}| ||||pdf }d | D S )Na
SELECT kc.column_name
FROM information_schema.table_constraints AS tc
INNER JOIN information_schema.key_column_usage AS kc ON (
tc.table_name = kc.table_name AND
tc.table_schema = kc.table_schema AND
tc.constraint_name = kc.constraint_name)
WHERE
tc.constraint_type = %s AND
tc.table_name = %s AND
tc.table_schema = %s PRIMARY KEYr/ c g | ]\ }|S r` r` )rV pks rc rY z7PostgresqlDatabase.get_primary_keys.<locals>.<listcomp> s 000sr000re r )ra r( r r; ctyper s rc r z#PostgresqlDatabase.get_primary_keys sO
( !!%%8J()KLL00foo / /0000re c | d}| ||pdf }fd| D S )Na%
SELECT DISTINCT
kcu.column_name, ccu.table_name, ccu.column_name
FROM information_schema.table_constraints AS tc
JOIN information_schema.key_column_usage AS kcu
ON (tc.constraint_name = kcu.constraint_name AND
tc.constraint_schema = kcu.constraint_schema AND
tc.table_name = kcu.table_name AND
tc.table_schema = kcu.table_schema)
JOIN information_schema.constraint_column_usage AS ccu
ON (ccu.constraint_name = tc.constraint_name AND
ccu.constraint_schema = tc.constraint_schema)
WHERE
tc.constraint_type = 'FOREIGN KEY' AND
tc.table_name = %s AND
tc.table_schema = %sr/ c X g | ]&}t |d |d |d 'S )r r rj r r s rc rY z7PostgresqlDatabase.get_foreign_keys.<locals>.<listcomp> r re r )ra r( r r) r s ` rc r z#PostgresqlDatabase.get_foreign_keys s` ( !!#v/A'BCC. . . .!??,,. . . .re c ~ | d|f }t | d S )Nz
SELECT COUNT(*) FROM pg_class, pg_namespace
WHERE relkind='S'
AND pg_class.relnamespace = pg_namespace.oid
AND relname=%sr )r re r| )ra sequenceress rc r z"PostgresqlDatabase.sequence_exists s@ " %-; 0 0
CLLNN1%&&&re c t j S r_ )r r r s rc r z"PostgresqlDatabase.get_binary_type" s
re c d S r_ r` r s rc r z%PostgresqlDatabase.conflict_statement% re c |j r|j nd}|dv ryt d g}|j r1| t d |j D | t d t
| S |r|dk rt d |j s|j st d |j s|j
st d | || S )
Nr( )r r r c Z g | ](}t |t rt | n|)S r` r8 r s rc rY z6PostgresqlDatabase.conflict_update.<locals>.<listcomp>- sA /4 /4 /4 $.c:#>#>GF3KKKC/4 /4 /4re z
DO NOTHINGr z\The only supported actions for conflict resolution with Postgresql are "ignore" or "update".zIf you are not performing any updates (or preserving any INSERTed values), then the conflict resolution action should be set to "IGNORE".zKPostgres requires that a conflict target be specified when doing an upsert.) r rl rQ r r r. ru r r r r r )ra r r; r rp s rc r z"PostgresqlDatabase.conflict_update( sU ')z9!!###r * * * ''(E"
6 - /4 /4 ! 2/4 /4 /4 5 5 6 6 6
LL\** + + +E?? "
@(** ) * *
* @BL @ ) * *
* % @)@ @ ? @ @
@ --b%888re c p t t |t d |f S NFROMr5 EXTRACTru rQ r* s rc r- z PostgresqlDatabase.extract_dateA s) zz(Is6{{J#GHHIIIre c 8 t || S r_ )r5
DATE_TRUNCr* s rc r/ z PostgresqlDatabase.truncate_dateD s }}Y
333re c . | d| S )NEPOCH)r- r1 s rc r2 z PostgresqlDatabase.to_timestampG s *555re c 6 t | S r_ )r5 r2 r1 s rc r4 z!PostgresqlDatabase.from_timestampJ s z***re c | t t d t d S )Nr> falser? r8 s rc r@ z"PostgresqlDatabase.get_noop_selectN s@ wwvxx''C1177G EEFFFre c 6 | d|z d S )Nzset time zone "%s";r )ra r s rc
set_time_zonez PostgresqlDatabase.set_time_zoneQ s" .9:::::re r r_ )%rf rg rh r r r4 rw ru r r r rE rG r r r r r! r r r r r r r r r r r r r- r/ r2 r4 r@ rb r r s @rc rG rG q s$ $ K D11J E"8 JN I=A !A A A A A A .* * *
E E E * * * ( ( ( (7 7 7 7 ; ; ; ;H H H H( = = = =1 1 1 1 . . . .*' ' ' 9 9 92J J J4 4 46 6 6+ + +G G G; ; ; ; ; ; ;re rG c e Zd Zddddddddd Zd
d d d
ddZdZdZeZdZ dZ
dZ dZ dZ
dZ fdZd Zd Zd Zd Zd Zd-d Zd-d Zd-d Zd-d Zd-d!Zd-d"Zd-d#Zd$ Z d% Z d& Z d' Z d( Z d) Z!d* Z"d+ Z#d, Z$ xZ%S ).rC zINTEGER AUTO_INCREMENTzBIGINT AUTO_INCREMENTr! r r r+ z VARCHAR(40)z
VARBINARY(16))r r r! r& r) r+ r/ r0 z LIKE BINARYr z
REGEXP BINARYr r )r r r r r rK z``Tl FPIPES_AS_CONCATc d| j dd}| | d|v r t r| d |d< t t
| j |fi | d S )NrQ T)charsetsql_mode use_unicodepasswordpasswd)rg r mysql_passwdr r rC r )ra r r rN r s rc r zMySQLDatabase.initp s
! !
f L %zz* 5 5F8 'mT""';;F;;;;;re c n t t d t j d| j dd| j }|S )NzMySQL driver not installed!T)rM r r` )mysqlr8 r r r r s rc r zMySQLDatabase._connectz sG =&'DEE E} 4
$ 4 4 # 24 4 re c |j }n$# t $ r | }Y nw xY w| | | _ d S r_ )r r get_server_info_extract_server_version)ra r version_raws rc r z!MySQLDatabase._set_server_version s] 1 -KK 1 1 1 ..00KKK 1 " : :; G Gs
++c F | }d|v rt j d| }nt j d| }|Dt d | d d D S t
j d|z dS ) Nmariaz(1\d\.\d+\.\d+)z(\d\.\d+\.\d+)c 3 4 K | ]}t | V d S r_ )r )rV nums rc rr z8MySQLDatabase._extract_server_version.<locals>.<genexpr> s( NNcSNNNNNNre r rR z'Unable to determine MySQL version: "%s"r )rl rD searchra groupsr r r )ra version match_objs rc rp z%MySQLDatabase._extract_server_version s --// g "4g>>II "3W==I NNY-=-=-?-?-B-H-H-M-MNNNNN N
?'IJJJyre c | j j rdS | j j }t |d r3| j d dk rd}nd} |j | n# t $ r Y dS w xY wdS )NFpingr rC r` r T)r r r r r r{ r# )ra r r s rc r z"MySQLDatabase.is_connection_usable s ; 5{ 4 "1%**
4
uu
ts
A
AAc , | d S )Nz () VALUES ()r r8 s rc r z#MySQLDatabase.default_values_insert s {{>***re Nc | r| t 5 | }|r| d|z | d d d d d S # 1 swxY w Y d S )Nz"SET TRANSACTION ISOLATION LEVEL %sr r )ra rf curss rc r zMySQLDatabase.begin s >> LLNNN
" " ";;==D
. A , - . . . LL ! ! ! " " " " " " " " " " " " " " " " " "s ABBBc F d}d | |d D S )NzySELECT table_name FROM information_schema.tables WHERE table_schema = DATABASE() AND table_type != %s ORDER BY table_namec g | ]\ }|S r` r` r1 s rc rY z,MySQLDatabase.get_tables.<locals>.<listcomp> s GGG&%GGGre )VIEWr )ra r r; s rc r zMySQLDatabase.get_tables s0 ' HGD$4$4UI$F$FGGGGre c l d}| | }d | D S )NztSELECT table_name, view_definition FROM information_schema.views WHERE table_schema = DATABASE() ORDER BY table_namec g | ] }t | S r` r r/ s rc rY z+MySQLDatabase.get_views.<locals>.<listcomp> s @@@s c"@@@re r r2 s rc r zMySQLDatabase.get_views s= G !!%((@@foo.?.?@@@@re c r | dz }t i | D ]h}|d s |d |d g |d |d ifdD S )NSHOW INDEX FROM `%s`r rj r; c F g | ] }t |d | |v S r_ r )rV r indexesr( r. s rc rY z-MySQLDatabase.get_indexes.<locals>.<listcomp> sA % % % dD'$- OO % % %re )r rP r r r r )ra r( r r r0 r r. s ` @@rc r zMySQLDatabase.get_indexes s !!"85"@AA??$$ + +Cq6
#
3q6""" s1vr * * * CFO " "3q6 * * * *% % % % % % #% % % %re c d}| |f }t | fd| D S )Nz
SELECT column_name, is_nullable, data_type, column_default
FROM information_schema.columns
WHERE table_name = %s AND table_schema = DATABASE()
ORDER BY ordinal_positionc
N g | ]!\ }}}}t |||d k |v | "S r> r@ rA s rc rY z-MySQLDatabase.get_columns.<locals>.<listcomp> rD re rE )ra r( r r) r rC s ` @rc r zMySQLDatabase.get_columns sy )
!!#x00$''..//= = = = =*0//*;*;= = = =re c | d|z }d t d | D S )Nr c g | ]
}|d S )r; r` r/ s rc rY z2MySQLDatabase.get_primary_keys.<locals>.<listcomp> s. L L L3A L L Lre c | d dk S )Nrj PRIMARYr` )r0 s rc rx z0MySQLDatabase.get_primary_keys.<locals>.<lambda> s 3q6Y#6 re r r s rc r z MySQLDatabase.get_primary_keys sZ !!"85"@AAL L668I8IJJL L L Lre c v d}| |f }fd| D S )Na@
SELECT column_name, referenced_table_name, referenced_column_name
FROM information_schema.key_column_usage
WHERE table_name = %s
AND table_schema = DATABASE()
AND referenced_table_name IS NOT NULL
AND referenced_column_name IS NOT NULLc < g | ]\ }}}t ||| S r` r )rV r ry rz r( s rc rY z2MySQLDatabase.get_foreign_keys.<locals>.<listcomp> sC F F F/
K
vz; F FF F Fre r r; s ` rc r z MySQLDatabase.get_foreign_keys s` : !!%%22F F F F39??3D3DF F F Fre c t j S r_ )rm r r s rc r z MySQLDatabase.get_binary_type s
|re c |j sd S |j }|dk rt d S |dk rt d S |dk rt d d S )Nr r r z
INSERT IGNOREr zWUn-supported action for conflict resolution. MySQL supports REPLACE, IGNORE and UPDATE.)r rl rQ r r s rc r z MySQLDatabase.conflict_statement s "*FF $**,, Y y>> !
x
'' '
x
J K K
K
re c |j s|j s|j rt d g }|j r| j pd}|d dk r|dk r
t j }n t j }|j D ][}t | }t t | t d || f }| | \|j
r|j
D ]\ } }
t |
t sft | t" rt% |j | } t | t( r| |
}
nt- |
d }
| t t | t d |
f |r+t t d t/ | f S d S )
NzfMySQL does not support the specification of where clauses or conflict targets for conflict resolution.r r
)r r r r Fr zON DUPLICATE KEY UPDATE)r r r r r r r5 VALUEVALUESrg ru rQ r r r rv re r9 r r( r2 r rY r3 ) ra r r; r rx VALUE_FNr entityr r rX s rc r z MySQLDatabase.conflict_update s ,!= , + , + , ,
, + )1TGqzR Gz$9$9 8 9%/
+
+&v.. %!&))HH HV$$'& ' '
z**** J#+1133
J
J1!!T** 3 "!Z00 4 #EK 3 3!!U++ 3 JJqMM !!E 2 2 2x q)9)93s88Q(G H HIIII 6S!: ; ; *7 3 3 5 6 6
6 6 6re c t t t | t d |f S rV rX r* s rc r- zMySQLDatabase.extract_date! s/ zz(C NNCKK#LMMNNNre c \ t |t | t S r )r5 DATE_FORMAT__mysql_date_trunc__r r* s rc r/ zMySQLDatabase.truncate_date$ s* ~~j*>y*I+; = = =re c 6 t | S r_ )r5 UNIX_TIMESTAMPr1 s rc r2 zMySQLDatabase.to_timestamp( s ,,,re c 6 t | S r_ )r5
FROM_UNIXTIMEr1 s rc r4 z MySQLDatabase.from_timestamp+ s
+++re c 4 t S r_ )r5 randr s rc r6 zMySQLDatabase.random. s wwyyre c , | d S )NzDO 0r r8 s rc r@ z MySQLDatabase.get_noop_select1 s {{6"""re r_ )&rf rg rh r r r4 r[ rx ru r r8 r9 rE rF rg r r r rp r r r r r r r r r r r r r- r/ r2 r4 r6 r@ r r s @rc rC rC U s# (* $ " "K ! J
E E": J!% I O H< < < < < H H H
+ + +" " " "H H H H A A A A
%
%
%
% = = = =L L L L
F F F F
K
K
K)6 )6 )6VO O O= = =- - -, , , # # # # # # #re rC c & e Zd Zd Zd Zd Zd ZdS )r c || _ d S r_ r r s rc r z_manual.__init__9 s
re c @ t fd }|S )Nc p t j 5 | i |cd d d S # 1 swxY w Y d S r_ )r rM r s rc r z _manual.__call__.<locals>.inner= s !!
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+r r r s `` rc r z_manual.__call__< r re c | j }|$t |t st d | j | d S )Nz?Cannot enter manual commit block while a transaction is active.)rM r rv r r r )ra tops rc r z_manual.__enter__C s[ g%%'' ?:c7#;#;? 6 7 7
7 &&&&&re c Z | j | urt d d S )Nz>Transaction stack corrupted while exiting manual commit block.)rM r r r s rc r z_manual.__exit__J s: 7 " " $ $D 0 0 4 5 5
5 1 0re Nr r` re rc r r 8 sP ' ' '5 5 5 5 5re r c & e Zd Zd Zd Zd Zd ZdS )r c & || _ ||f| _ d S r_ )rM _transaction_argsra rM r r s rc r z_atomic.__init__Q s "& re c @ t fd }|S )Nc j \ }}t j g|R i |5 | i |cd d d S # 1 swxY w Y d S r_ )r r rM r r r r r5 ra s rc r z _atomic.__call__.<locals>.innerV s )DAq*1*****
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 6::r r s `` rc r z_atomic.__call__U 9 r + + + + +
+ re c d | j dk r"| j \ }} | j j |i || _ nYt | j t rt d | j | _ | j
S )Nr z=Cannot enter atomic commit block while in manual commit mode.) rM r r r _helperrv r r r r r r s rc r z_atomic.__enter__] s 7 $ $ & &! + + 1LD&.47.???DLL
//117
;
; / 3 4 4
4 7,,..DL|%%'''re c : | j ||| S r_ )r r r s rc r z_atomic.__exit__h s |$$Xw???re Nr r` re rc r r P sU 0 0 0 ( ( (@ @ @ @ @re r c < e Zd Zd Zd Zd Zd
dZd
dZd Zd Z d S ) r c & || _ ||f| _ d S r_ )rM _begin_argsr s rc r z_transaction.__init__m s &>re c @ t fd }|S )Nc j \ }}t j g|R i |5 | i |cd d d S # 1 swxY w Y d S r_ )r r rM r s rc r z$_transaction.__call__.<locals>.innerr s #DAq dg////Q//
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+r r r s `` rc r z_transaction.__call__q r re c > | j \ }} | j j |i | d S r_ )r rM r r s rc _beginz_transaction._beginy s- ' f
t&v&&&&&re Tc h | j |r| d S d S r_ )rM r r ra r s rc r z_transaction.commit} s7 KKMMMMM re c h | j |r| d S d S r_ )rM r r r s rc r z_transaction.rollback s9 KKMMMMM re c | j dk r| | j | | S r )rM r r r r s rc r z_transaction.__enter__ sC 7 $ $ & &! + + KKMMM &&& re c T | j } |r |dk r| d n8|dk r2 | d n# | d xY w| j d S # | j w xY wNr F)rM r r r r )ra r r r! depths rc r z_transaction.__exit__ s ))++
&
EQJJ
e$$$$!KK&&&&MM%((( G # # % % % % %DG # # % % % %s# $B A B A..B B'Nrm
rf rg rh r r r r r r r r` re rc r r l s * * * ' ' '
& & & & &re r c < e Zd Zd
dZd Zd Zd dZd Zd Zd Z dS ) r Nc || _ |pdt j j z | _ | j | j j | _ d S )Nrq )rM uuiduuid4hexsidrU r[
quoted_sid)ra rM r s rc r z_savepoint.__init__ s@ 0#
00 (--
66re c @ t fd }|S )Nc p t j 5 | i |cd d d S # 1 swxY w Y d S r_ )r rM r s rc r z"_savepoint.__call__.<locals>.inner s DG$$
+
+r4*6**
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+r r r s `` rc r z_savepoint.__call__ r re c J | j d| j z d S )Nz
SAVEPOINT %s;rM r r r s rc r z_savepoint._begin s% Odo =>>>>>re Tc z | j d| j z |r| d S d S )NzRELEASE SAVEPOINT %s;)rM r r r r s rc r z_savepoint.commit s< 3do EFFF $++----- re c J | j d| j z d S )NzROLLBACK TO SAVEPOINT %s;r r s rc r z_savepoint.rollback s& 7$/ IJJJJJre c . | | S r_ )r r s rc r z_savepoint.__enter__ s
re c |r| d S | d d S # | xY w)NFr )r r r s rc r z_savepoint.__exit__ sS MMOOOOO
% (((((
s 2 A r_ rm r r` re rc r r s 7 7 7 7
? ? ? K K K re r c H e Zd Zd Zd Zd Zd Zd Zd
dZd Z d Z
dd Z d S )r c Z || _ d| _ d| _ d| _ d| _ g | _ d S )Nr F)r r' rx initialized populatedr r s rc r zCursorWrapper.__init__ s1
re c V | j rt | j S t | S r_ )r rw r ResultIteratorr s rc r zCursorWrapper.__iter__ s* > ('' ' d###re c T t |t rF|j }||dk r| n| | | j | S t |t
r*| |dk r|nd | j | S t
d )Nr z6CursorWrapper only supports integer and slice indexes.)rv r r r r r r )ra r r s rc r zCursorWrapper.__getitem__ s dE " " )9D|taxx!!!!%%%>$' '
c
"
" ) OOD1HHDD! 4 4 4>$' ' ( ) )
)re c 8 | | j S r_ )r r' r s rc r zCursorWrapper.__len__ s zre c d S r_ r` r s rc r zCursorWrapper.initialize r re Tc P | j }|'d| _ | j t | j s| d| _ | xj dz
c_ | | }|r| j
| |S )NTr ) r r| r r r r r r' process_rowr r )ra cacher0 r s rc iteratezCursorWrapper.iterate s k""$$ ; !DN K ! $ OO #D
a
!!#&& * N ! !& ) ) )
re c |S r_ r` ra r0 s rc r zCursorWrapper.process_row s
re c # ^ K | d V n# t $ r Y dS w xY w+)z1Efficient one-pass iteration over the result set.TFN)r r r s rc r zCursorWrapper.iterator sR
ll5))))))
s
++r c * |pt d }|dk rt d t | }| j |_ | j sF|| j k r= | n# t $ r Y d S w xY w| j s|| j k 9d S d S d S d S )NInfr z"Negative values are not supported.)floatr r r' rx r r r )ra rz r s rc r zCursorWrapper.fill_cache s
u q55 ABB B!$'' . a$*nn
. a$*nnnn nn s A* *
A87A8Nrm r ) rf rg rh r r r r r r r r r r` re rc r r s $ $ $
)
)
)
re r c " e Zd Zd ZeZd ZeZdS )r c h | j j }d |D | _ t | | _ d S )Nc g | ]A}|d |d d dz d d BS r rR r N()"`rfindr5 rV r s rc rY z9DictCursorWrapper._initialize_columns.<locals>.<listcomp> sX . . . !QqTZZ__q 0 1 1288@@ . . .re )r descriptionr r ncolsra r s rc _initialize_columnsz%DictCursorWrapper._initialize_columns s? k- . .!,. . . %%
re c i }t | j D ])}| | j | || *|S r_ )r r r r )ra r0 r r s rc _row_to_dictz DictCursorWrapper._row_to_dict sH tz"" 7 7A dl1os1v 6 6 6 6
re N)rf rg rh r r r r r` re rc r r s: & & & %J KKKre r c e Zd Zd Zd ZdS )r c f | j j }t j dd |D | _ d S )NRowc g | ]A}|d |d d dz d d BS r r r s rc rY z6NamedTupleCursorWrapper.initialize.<locals>.<listcomp>& s[ :K :K :K9:AaD1C 1$%% & , ,V 4 4:K :K :Kre )r r collections
namedtuple tuple_classr s rc r z"NamedTupleCursorWrapper.initialize$ sL k- &1% :K :K>I:K :K :K L Lre c | j | S r_ r r s rc r z#NamedTupleCursorWrapper.process_row) s t %%re N)rf rg rh r r r` re rc r r # s5 L L L
& & & & &re r c $ e Zd Z fdZd Z xZS )r c f t t | | || _ d S r_ )r r r r )ra r r r s rc r z ObjectCursorWrapper.__init__. s0
!4((11&999&re c F | | } | j di |S r )r r )ra r0 row_dicts rc r z ObjectCursorWrapper.process_row2 s. $$S)) t ++(+++re rf rg rh r r r r s @rc r r - sG ' ' ' ' ', , , , , , ,re r c $ e Zd Zd Zd Zd ZeZdS )r c " || _ d| _ d S r )cursor_wrapperrx )ra r s rc r zResultIterator.__init__8 s ,
re c | S r_ r` r s rc r zResultIterator.__iter__< rl re c | j | j j k r| j j | j }nD| j j s1| j | j j | j }nt | xj dz
c_ |S r )rx r r' r r r r r* s rc r zResultIterator.next? sz :+1 1 1%/
;CC$. ' ' ) ) )%/
;CC
a
re N)rf rg rh r r r __next__r` re rc r r 7 sB HHHre r c " e Zd Zd ZddZd ZdS )
FieldAccessorc 0 || _ || _ || _ d S r_ )rA rA r ra rA rA r s rc r zFieldAccessor.__init__O s
re Nc R | |j | j S | j S r_ )__data__r r rA r{ s rc r~ zFieldAccessor.__get__T s) $((33 3zre c b ||j | j < |j | j d S r_ )r r _dirtyr ra r| r~ s rc rN zFieldAccessor.__set__Y s/ ',$)$DI&&&&&re r_ )rf rg rh r r~ rN r` re rc r r N sF
' ' ' ' 're r c 2 e Zd Z fdZd ZddZd Z xZS )ForeignKeyAccessorc t t t | ||| |j | _ d S r_ )r r r rel_model)ra rA rA r r s rc r zForeignKeyAccessor.__init___ s3
$''00tDDD re c |j | j }|| j |j v rq| j |j vrC| j j r7| j | j j |k }||j | j < |j | j | S | j j s| j j r | j j |S r_ )
r r r __rel__rA lazy_loadr rel_fieldr r. )ra r| r~ r s rc get_rel_instancez#ForeignKeyAccessor.get_rel_instancec s !%%di00 X-= = =y 000TZ5I0n(()=)FGG.1 +#'' 599 9 .TZ%9 ..- - re Nc > || | S | j S r_ )r rA r{ s rc r~ zForeignKeyAccessor.__get__n s$ ((22 2zre c t || j r<t || j j j |j | j < ||j | j < nQ|j | j }||j | j < ||k s|| j |j v r
|j | j = |j
| j d S r_ ) rv r r rA r r r r r r r )ra r| r fk_values rc rN zForeignKeyAccessor.__set__s s c4> * * 0+23
8L8Q+R+RH di (*-H TY ' ' (,,TY77H+.H di (x3;yH ,,, $TY/DI&&&&&re r_ )rf rg rh r r r~ rN r r s @rc r r ^ sj ) ) ) ) )
'
'
'
'
'
'
're r c e Zd Zd ZddZdS )BackrefAccessorc D || _ |j | _ |j | _ d S r_ )rA r rA ra rA s rc r zBackrefAccessor.__init__ s
_
re Nc |T| j j j }| j | j t
|| k S | S r_ )rA r r r r r5 r )ra r| r} r s rc r~ zBackrefAccessor.__get__ sN :',DNVXXU4:4)@)@@AA
C re r_ )rf rg rh r r~ r` re rc r r s7 % % %
re r c & e Zd ZdZd ZddZd ZdS )ObjectIdAccessorz(Gives direct access to the underlying idc || _ d S r_ )rA r" s rc r zObjectIdAccessor.__init__ s
re Nc |q|j | j j }|I| j j |j v r6|j | j j }t || j j j }|S | j S r_ )r r rA r r r r )ra r| r} r~ rel_objs rc r~ zObjectIdAccessor.__get__ sm %))$*/::E} H4D!D!D"*4:?; )=)BCCLzre c < t || j j | d S r_ )r rA r r s rc rN zObjectIdAccessor.__set__ s $*/511111re r_ )rf rg rh r r r~ rN r` re rc r% r% sL 22 2 2 2 2 2re r% c e Zd ZdZdZeZdZdZdZ dZ
ddZ d Z d Z
dd Zed
Zd Zd Zd
Zd Zd Zd Zd Zd Zd ZdS )r2 r FNr' Tc |t d |}|| _ || _ || _ || _ || _ || _ || _ || _ | | _ |
| _
| | _ | | _ |
| _
|p| j | _ || _ t" xj dz
c_ t" j | _ | j rdpd| j f| _ d S )NzL"db_column" has been deprecated in favor of "column_name" for Field objects.r rj )r r rx r. r r r r rN r^ unindexedchoices help_text verbose_namedefault_index_typer> _hiddenr2 _field_counter_order _sort_key)ra r rx r. r r r r rN r^ r, r- r. r/ r> db_columnr1 s rc r zField.__init__ s
>
?
?
?#K
& &&
"" " ($?(? ! * *0q5A Cre c J t | j dz | j j z S r )r r rA rf r s rc r zField.__hash__ s DIOdj&99:::re c t | d r>t | dd r-dt | j d| j j d| j dS dt | j z S )NrA r r : rR r z<%s: (unbound)>)r r r rf rA r r s rc __repr__zField.__repr__ su 4 ! ! /gdFD&A&A / /$(JJ$7$7$7$(J$7$7$7$(III/
/ !4::#666re c || _ |x| _ | _ | j p|| _ |r(t ||| || | d S d S r_ )rA r safe_namer r accessor_classra rA r
set_attributes rc r z
Field.bind sf
%)) DN +3t I E4!4!4UD$!G!G H H H H H I Ire c J t | j j j | j S r_ )r! rA r' r( r r s rc r z Field.column s dj&,d.>???re c |S r_ r` r s rc adaptz Field.adapt s re c 4 ||n| | S r_ rA r s rc r
zField.db_value
uu4::e+<+<<re c 4 ||n| | S r_ rC r s rc r0 zField.python_value rD re c 0 t || j d S r )rY r
r s rc r zField.to_value s UDM%8888re c | j S r_ )r4 r8 s rc r zField.get_sort_key s
~ re c 6 | | j S r_ )r) r r8 s rc r% z
Field.__sql__ s wwt{###re c d S r_ r` r s rc
get_modifierszField.get_modifiers r re c 8 |r7|j j r+|j j | j | j }n| j }| }|r6|r4d d |D }t
|d|d S t
| S )Nr c , g | ]}t | S r` rW )rV r s rc rY z&Field.ddl_datatype.<locals>.<listcomp> s )D)D)DQ#a&&)D)D)Dre r r )r r r
field_typerJ rU rQ )ra r9 column_type modifiersmodifier_literals rc ddl_datatypezField.ddl_datatype s *39( * )/33DO48OE EKK /K&&(( $9 $ #yy)D)D))D)D)D E E ;;;0@0@0@ABB B{## #re c t | j g}| | }|r| | | j r"| t d | j s"| t d | j r"| t d | j r*| t d| j z | j r|
| j | j r*| t d| j z t | S )N UNINDEXEDzNOT NULLrG zDEFAULT NEXTVAL('%s')r )
rf r rR r r, rQ r r rN r r7 r^ ru )ra r9 r rw s rc ddlz Field.ddl s1 ())*%%c** $ LL # # # > + LL[)) * * *y * LLZ ) ) ) - LL]++ , , , = G LL 4t} DEE F F F + LL) * * * > = LL\DN :;; < < < re )FFFNNFNNNFNNNNNFrm )rf rg rh r2 r3 r r< auto_incrementr0 rN r r r r9 r r r rA r
r0 r r r% rJ rR rU r` re rc r2 r2 s; N
F"NN J
FJN>BIM?C). D D D D@; ; ;7 7 7I I I I @ @ X@ = = == = =9 9 9 $ $ $
$ $ $ re r2 c e Zd ZdZdS )r ANYNrf rg rh rN r` re rc r r s JJJre r c e Zd ZdZd ZdS )r: r, c F t | S # t $ r |cY S w xY wr_ )r r r s rc rA zIntegerField.adapt s7 u:: LLL Nrf rg rh rN rA r` re rc r: r: s( J re r: c e Zd ZdZdS )r r NrY r` re rc r r % JJJre r c e Zd ZdZdS )rO r" NrY r` re rc rO rO ) s JJJre rO c & e Zd ZdZdZ fdZ xZS )r Tr c | d du r t dt | z d|d< t t | j |i | d S )Nr Fz %s must always be a primary key.T)r r r r r r r s rc r zAutoField.__init__1 sf ::m $ $ - - ?$t** LMM M $} 'i '888888re )rf rg rh rV rN r r r s @rc r r - sB NJ9 9 9 9 9 9 9 9 9re r c e Zd ZdZdS )r r NrY r` re rc r r 8 s JJJre r c $ e Zd ZdZd fd Z xZS )r7 z$INT GENERATED BY DEFAULT AS IDENTITYFc Z |rd| _ t t | j di | d S )Nz INT GENERATED ALWAYS AS IDENTITYr` )rN r r7 r )ra generate_alwaysr r s rc r zIdentityField.__init__? s< A @DO+mT""+55f55555re r )rf rg rh rN r r r s @rc r7 r7 < sB 7J6 6 6 6 6 6 6 6 6 6re r7 c e Zd Z fdZ xZS )rH c f t d t t | j |i | d S )Nz"PrimaryKeyField" has been renamed to "AutoField". Please update your code accordingly as this will be completely removed in a subsequent release.)r r rH r r s rc r zPrimaryKeyField.__init__F sH E F F F .ot$$-t>v>>>>>re rW r s @rc rH rH E s8 ? ? ? ? ? ? ? ? ?re rH c e Zd ZdZd ZdS )r4 r+ c F t | S # t $ r |cY S w xY wr_ )r r r s rc rA zFloatField.adaptP s7 << LLL r\ Nr] r` re rc r4 r4 M s( J re r4 c e Zd ZdZdS )r/ r) NrY r` re rc r/ r/ W r_ re r/ c : e Zd ZdZ d
fd Zd Zd Zd Z xZS ) r* r& r r< FNc || _ || _ || _ |pt j j | _ t j d | j z | _ t t | j
|i | d S )Nr )
max_digitsdecimal_places
auto_rounddecimalDefaultContextroundingDecimal_expr r* r )ra rn ro rp rs r r r s rc r zDecimalField.__init__^ so $ ,$ CG$:$C
OB''T-@,@A *lD!!*D;F;;;;;re c | j | j gS r_ )rn ro r s rc rJ zDecimalField.get_modifiersg s !455re c t j }|s||n
|d S | j r9 |t | }| | j | j S |S )Nr )rs )rq rt rp rT quantizeru rs )ra r~ D
decimal_values rc r
zDecimalField.db_valuej sk O 4 !M55qqtt 3 ? M Ai . . / /M ))$)dm)LL L re c |=t |t j r|S t j t | S d S r_ )rv rq rt rT r s rc r0 zDecimalField.python_values sA % 11
?9U#3#344 4 re )r r< FN) rf rg rh rN r rJ r
r0 r r s @rc r* r* [ su JCH < < < < < <6 6 6 5 5 5 5 5 5 5re r* c e Zd Zd Zd Zd ZdS ) _StringFieldc t |t r|S t |t r| d S t | S )NrK )rv rT rU r r s rc rA z_StringField.adapt{ sK eY ' ' )L
z
*
* )<<(( ( re c 8 t | t j | S r_ r r s rc r z_StringField.__add__ s %5dBIu%M%M Mre c 8 t |t j | S r_ r r s rc r z_StringField.__radd__ s &6ubi&N&N Nre N)rf rg rh rA r r r` re rc r} r} z s4 NMMNNNNNre r} c * e Zd ZdZd fd Zd Z xZS )r r1 c V || _ t t | j |i | d S r_ )
max_lengthr r r )ra r r r r s rc r zCharField.__init__ s2 $'i '888888re c $ | j r| j gpd S r_ )r r s rc rJ zCharField.get_modifiers s 4DO#4<<re )r )rf rg rh rN r rJ r r s @rc r r sQ J9 9 9 9 9 9= = = = = = =re r c " e Zd ZdZ fdZ xZS )r3 r# c t t | | }|r| }|S r_ )r r3 r0 r5 )ra r~ r s rc r0 zFixedCharField.python_value s: nd++88?? "KKMME re )rf rg rh rN r0 r r s @rc r3 r3 s= J re r3 c e Zd ZdZdS )rT r- NrY r` re rc rT rT s JJJre rT c 0 e Zd ZdZd Zd fd Zd Z xZS )r r c X |t | _ d S | | _ d S r_ ) bytearrayr r r s rc _db_hookzBlobField._db_hook s0 )D ( 8 8 : :D re Tc t | _ |j j rct |j j t
r%|j j | j n | |j j |j j | j t t | ||| S r_ )
r r r' r rv rL r r _db_hooksr r r r ra rA r r> r s rc r zBlobField.bind s % ; 4%+.66
4 $44T]CCCC
ek 2333
$$T]333Y%%**5$
FFFre c t |t r| d }t |t r| | S |S )NrR )rv rT rO rU r r s rc r
zBlobField.db_value sQ eY ' ' 7LL!566E eZ ( ( ,$$U++ + re rm )rf rg rh rN r r r
r r s @rc r r sf J; ; ; G G G G G G re r c & e Zd Z fdZddZ xZS )r c | dd t t | j |i | d| _ d S )Nr r r )r r r r _BitField__current_flagr s rc r zBitField.__init__ sI )Q'''&h &7777 re Nc || j }| xj dz c_ n
|dz | _ G fddt | | S )Nr c B e Zd Z fdZd Zd ZddZd Zd Z xZ S ) %BitField.flag.<locals>.FlagDescriptorc h || _ || _ t | d S r_ )_field_valuer r )ra rA r~ FlagDescriptorr s rc r z.BitField.flag.<locals>.FlagDescriptor.__init__ s3 # # nd++4466666re c B | j | j S r_ )r r r r s rc clearz+BitField.flag.<locals>.FlagDescriptor.clear s {**DK<888re c @ | j | j S r_ )r r r r s rc rP z)BitField.flag.<locals>.FlagDescriptor.set s {))$+666re Nc ^ || S t || j j pd}|| j z dk S r )r r r r )ra r| r} r~ s rc r~ z-BitField.flag.<locals>.FlagDescriptor.__get__ s8 # K $+*:;;@q +11re c |dvrt d t || j j pd}|r || j z }n || j z }t || j j | d S )NTFz"Value must be either True or Falser )r r r r r r )ra r| is_setr~ s rc rN z-BitField.flag.<locals>.FlagDescriptor.__set__ sv ..$%IJJJ $+*:;;@q *T[(EEdk\)E$+"2E:::::re c n | | j | j dk S r )r) r r r r8 s rc r% z-BitField.flag.<locals>.FlagDescriptor.__sql__ s+ wwt{ 2 24; ? ?1 DEEEre r_ )
rf rg rh r r rP r~ rN r% r )r r s @rc r r s
7
7
7
7
7
7
9
9
9
7
7
7
2
2
2
2
;
;
;
F
F
F
F
F
F
Fre r )r rN )ra r~ r s @rc flagz
BitField.flag s ='E A % "'1*D F F F F F F FZ F F F2 ~dE***re r_ )rf rg rh r r r r s @rc r r sL
+ + + + + + + +re r c e Zd Zd Zd Zd Zd Zd Zd Zd Z e Z
d Z eZ d Z
d
Zd Zd Zd
Zd Zd Zd Zej d dk rd ZdS d ZdS )BigBitFieldDatac
|| _ || _ | j j | j }|st }n$t |t st | }|x| _ | j j | j < d S r_ )r| r r r r rv _buffer)ra r| r r~ s rc r zBigBitFieldData.__init__ sz
&**4955 % KKEEE9-- % e$$E;@@ t}-di888re c 8 | j d S r_ )r r r s rc r zBigBitFieldData.clear s re c t |d \ }}t | j }||k r#| j d|dz |z
z ||fS )NrC r )divmodr r r7 ra r byte_num byte_offsetcur_sizes rc _ensure_lengthz BigBitFieldData._ensure_length s] &sA +t|$$ x L HqLH+D E F F F$$re c f | | \ }}| j |xx d|z z cc< d S r r r ra r r r s rc set_bitzBigBitFieldData.set_bit sC $ 3 3C 8 8 + X 1 #34 re c h | | \ }}| j |xx d|z z cc< d S r r r s rc clear_bitzBigBitFieldData.clear_bit sF $ 3 3C 8 8 + X A$4"55 re c | | \ }}| j |xx d|z z cc< t | j | d|z z S r )r r re r s rc
toggle_bitzBigBitFieldData.toggle_bit s\ $ 3 3C 8 8 + X 1 #34 DL*a;.>?@@@re c t |d \ }}t | j }||k rdS t | j | d|z z S )NrC Fr )r r r re r s rc r zBigBitFieldData.is_set sR &sA +t|$$ x 5DL*a;.>?@@@re c b |r| | d S | | d S r_ )r r )ra r r~ s rc r zBigBitFieldData.__setitem__ s6 #= T )=)=)=)=)=re c * t | j S r_ )r r r s rc r zBigBitFieldData.__len__ s 4< re c , t |t r|j }n4t |t t t
f r|}nt
d t | t | z
}|dk r | j d|z |S )NIncompatible data-typer r ) rv r r bytesr
memoryviewr r r7 )ra r datadiffs rc _get_compatible_dataz$BigBitFieldData._get_compatible_data s e_ - - 7=DD
y* =
>
> 7DD 566 64yy3t99$ !88T\((4 888 re c t |t r|j }n4t |t t t
f r|}nt
d t dt t | t | z }t j
| j |d }t | D ]\ }\ }} ||| ||< |S )Nr r r )rs ) rv r r r r r r maxr r zip_longestr ) ra r r r bufry r r bs rc _bitwise_opzBigBitFieldData._bitwise_op# s e_ - - 7=DD
y* =
>
> 7DD 566 6#c$iiU"<"<<==
"4<
C
C
C"2 IAv1R1XXCFF
re c B | |t j S r_ )r r r r s rc r zBigBitFieldData.__and__0 s x}555re c B | |t j S r_ )r r r+ r s rc r zBigBitFieldData.__or__2 x|444re c B | |t j S r_ )r r xorr s rc r zBigBitFieldData.__xor__4 r re c # ^ K | j D ]"}t d D ]}|d|z z rdndV #d S )NrC r r )r r )ra r js rc r zBigBitFieldData.__iter__7 s[ 1 1A1XX
1
1 aL0aaq0000
1 1 1re c * t | j S r_ )reprr r s rc r9 zBigBitFieldData.__repr__< s DL!!!re r r c * t | j S r_ rU r r s rc r zBigBitFieldData.__str__? dl++ +re c * t | j S r_ r r s rc __bytes__zBigBitFieldData.__bytes__B r re N)rf rg rh r r r r r r r r r __delitem__r r r r r r r r9 rm version_infor r r` re rc r r sT A A A % % %5 5 56 6 6A A A
A A A K> > >K! ! ! 6 6 65 5 55 5 51 1 1
" " "
Q , , , , , , , , , ,re r c & e Zd ZddZ fdZ xZS )BigBitFieldAccessorNc > || j S t || j S r_ )rA r r r{ s rc r~ zBigBitFieldAccessor.__get__G s" : x333re c 4 t |t r| }nt |t rt | }nt |t
rt
| }nyt |t rt
|j }nOt |t r|
d }n$t |t st d t t | || d S )NrK zEValue must be either a bytes, memoryview or BigBitFieldData instance.)rv r tobytes buffer_typer r rU r r rT rO r r r rN )ra r| r~ r s rc rN zBigBitFieldAccessor.__set__K s eZ ( ( :MMOOEE
{
+
+
:%LLEE
y
)
) : u%%EE
/
/ : u}--EE
y
)
) :LL))EEE:.. : 9 : :
:
!4((005AAAAAre r_ )rf rg rh r~ rN r r s @rc r r F sU 4 4 4 4B B B B B B B B Bre r c ( e Zd ZeZ fdZd Z xZS )r c ~ | dt t t | j |i | d S )Nr )r rU r r r r s rc r zBigBitField.__init___ sA )Z000)k4 )4:6:::::re c ( |t | n|S r_ )rU r s rc r
zBigBitField.db_valuec s $)$5z% 5@re )rf rg rh r r< r r
r r s @rc r r \ sS (N; ; ; ; ;A A A A A A Are r c e Zd ZdZd Zd ZdS )rX r/ c X t |t rt | dk r|S t |t r(t | dk rt j | }t |t j r|j S t j | j S # |cY S xY w)N rD r )rv r9 r r r r/ r r s rc r
zUUIDField.db_valuej s eZ ( ( +SZZ2-=-=L
u
%
% +#e***:*:IE***E eTY ' ' 9 9U##' ' LLLs
B# #B)c j t |t j r|S |t j | nd S r_ )rv r r/ r s rc r0 zUUIDField.python_valuex s5 eTY ' ' L#(#4ty $>re Nrf rg rh rN r
r0 r` re rc rX rX g s7 J ? ? ? ? ?re rX c e Zd ZdZd Zd ZdS )r r0 c t |t r(t | dk r| | S t |t r(t | dk rt j | }t |t
j r| |j S |t d d S )NrD r )r zTvalue for binary UUID field must be UUID(), a hexadecimal string, or a bytes object.)rv r r r r9 r r/ r r s rc r
zBinaryUUIDField.db_value s eU # # )E
b(8(8$$U++ +
z
*
* )s5zzR/?/?I%(((E eTY ' ' I$$U[11 1
H I I
I
re c t |t j r|S t |t r| }n&|r$t |t
st | }|t j | nd S )Nr )rv r r/ r r r r s rc r0 z BinaryUUIDField.python_value s} eTY ' ' !L
z
*
* !MMOOEE
!:eU33 !%LLE).):tyu%%%%Dre Nr r` re rc r r ~ s? J I I IE E E E Ere r c fd}|S )Nc N | j j j | S r_ )rA r' r r- )ra r+ s rc decz_date_part.<locals>.dec s! z (55iFFFre r` r+ r s ` rc
_date_partr s& G G G G G Jre c |pd }|D ]=} |t j | | c S # t $ r Y :w xY w| S )Nc | S r_ r` xs rc rx z"format_date_time.<locals>.<lambda> s a re )r strptimer )r~ formats post_processfmts rc r r sp 0KKL < 1 : :5# F FGG G G G D Ls (6
AAc v t j | d S # t t f$ r | cY S w xY w)Nr )r r r r rb s rc r r sJ ))%1DEEE z " s " 88c $ e Zd ZdZd fd Z xZS )_BaseFormattedFieldNc Z ||| _ t t | j |i | d S r_ )r r r r )ra r r r r s rc r z _BaseFormattedField.__init__ s9 "DL1!4((14B6BBBBBre r_ )rf rg rh r r r r s @rc r r sL GC C C C C C C C C Cre r c e Zd ZdZg dZd Zd Zd Z e e d Z
e e d Z e e d Z e e d Z
e e d
Z e e d Zd S )
r) r% )r r r c ^ |r*t |t rt || j S |S r_ )rv r9 r r r s rc rA zDateTimeField.adapt s2 9Zz22 9#E4<88 8 re c J | j j j | S r_ rA r' r r2 r s rc r2 zDateTimeField.to_timestamp z (55d;;;re c L | j j j || S r_ rA r' r r/ ra rW s rc truncatezDateTimeField.truncate z (66tTBBBre r r r r r r N)rf rg rh rN r rA r2 r
r r r r r r r r r` re rc r) r) s J G
< < <C C C 8JJv&& ' 'D HZZ(( ) )E
(::e$$
%
%C 8JJv&& ' 'D
Xjj**
+
+F
Xjj**
+
+FFFre r) c e Zd ZdZg dZd Zd Zd Z e e d Z
e e d Z e e d Z d S )
r( r$ )r r r c |r.t |t rd }t || j | S |r.t |t j r| S |S )Nc * | S r_ )r r s rc rx z!DateField.adapt.<locals>.<lambda> s 16688 re )rv r9 r r r r ra r~ pps rc rA zDateField.adapt sf Zz22 ##B#E4<<< <
z%):;; ::<< re c J | j j j | S r_ r r s rc r2 zDateField.to_timestamp r
re c L | j j j || S r_ r
r
s rc r
zDateField.truncate r
re r r r N)
rf rg rh rN r rA r2 r
r r r r r r` re rc r( r( s J G < < <C C C 8JJv&& ' 'D HZZ(( ) )E
(::e$$
%
%CCCre r( c e Zd ZdZg dZd Z e ed Z e ed Z e ed Z
dS )rU r. )r r r r r c F |r\t |t rd }t || j | S t |t j r| S |@t |t j r&t j j |z S |S )Nc * | S r_ )r r s rc rx z!TimeField.adapt.<locals>.<lambda> s qvvxx re )rv r9 r r r r timedeltaminr
s rc rA zTimeField.adapt s $%,,
$'''t|R@@@E8#455
$ zz||# E83E!F!F %)E17799 9 re r r r N) rf rg rh rN r rA r r r r r r` re rc rU rU s J G 8JJv&& ' 'D
Xjj**
+
+F
Xjj**
+
+FFFre rU c fd}|S )Nc | j j j }| j dk r| t | j d z n| }| | | S Nr Fr. )rA r' r
resolutionrY r- r4 )ra rM r r+ s rc r z!_timestamp_date_part.<locals>.dec sc
Z
&?Q&& do?????,0
y"*;*;D*A*ABBBre r` r s ` rc _timestamp_date_partr
s( C C C C C
Jre c \ e Zd Zd ed D Z fdZd Zd Zd Zd Z d Z
d Z e e
d
Z e e
d Z e e
d Z e e
d
Z e e
d Z e e
d Z xZS )rV c g | ]}d |z S )r r` rV r s rc rY zTimestampField.<listcomp> s 1111Q111re rL c 0 | dd | _ | j sd| _ ni| j t dd v rd| j z | _ nB| j | j vr4t dd d | j D z d | j z | _ | d
d pd | _ | j rt nt j j
}| d | t t | j |i | d S )
Nr
r rj rL r z,TimestampField resolution must be one of: %sr c 3 4 K | ]}t | V d S r_ rM r
s rc rr z*TimestampField.__init__.<locals>.<genexpr> s( &N&N!s1vv&N&N&N&N&N&Nre i@B r Fr )r r
r valid_resolutionsr rU ticks_to_microsecondr r r r r r rV r )ra r r dfltr s rc r zTimestampField.__init__ s **\488 P DOO
_a
+
+ DO 3DOO
_D$:
:
: K !YY&N&Nt7M&N&N&N N N O P P
P$+t$>!::eU++4u <vvx'8'<)T***,nd##,d=f=====re c t j t j t j | d d S )N )r r gmtimemktime timetuple)ra r s rc local_to_utczTimestampField.local_to_utc$ s7
$+dk",,...I.I"J"J2A2"NOOre c t j | }t j | S r_ )calendartimegm utctimetupler r )ra r r s rc utc_to_localzTimestampField.utc_to_local+ s4
_R__ . .
/
/ ..r222re c | j r&t j | S t j | S r_ )r r&
r'
r(
r r"
r#
r s rc
get_timestampz TimestampField.get_timestamp3 sB 8 2?5#5#5#7#788 8;u 0 011 1re c |d S t |t j rndt |t j r&t j |j |j |j }n$t
t || j z S | | }| j dk r||j
dz z
}|| j z }t
t | S )Nr gư>) rv r r r r r r roundr
r+
microsecond)ra r~ r s rc r
zTimestampField.db_value: s = F eX . / / 7
x}
-
- 7 %ej%+uyIIEEuUT_ 45566 6&&u-- ?Q %+g5 6I (I5##$$$re c d |t |t t t f r| j dk r0t || j \ }}t || j z }nd}| j rt | }n t j
| }|r| | }|S )Nr r )r.
) rv r r longr
r r
r r r r r )ra r~ ticks microsecondss rc r0 zTimestampField.python_valueK s EC3E!F!F "" %eT_ = = u "54+D#D E E x
?(// )77>>
@
,
?? re c | j dk r| t | j d z n| }| j j j | S r
)r
rY rA r' r r4 )ra r s rc r4 z TimestampField.from_timestamp] sO ?Q&& do?????,0
z (77===re r r r r r r )rf rg rh r r
r r$
r)
r+
r
r0 r4 r r
r r r r r r r r s @rc rV rV sI 11a111> > > > >"P P P3 3 32 2 2% % %" $> > >
8((00 1 1D H))'22 3 3E
(''..
/
/C 8((00 1 1D
X**844
5
5F
X**844
5
5FFFFFre rV c e Zd Zd Zd ZdS )r> c d |-t j dt j | d S d S )N!Ir )structr socket inet_atonra r s rc r
zIPField.db_valuek s0 ?=v'7'<'<==a@ @ ?re c X |'t j t j d| S d S )Nr6
)r8
inet_ntoar7
packr:
s rc r0 zIPField.python_valueo s+ ?#FKc$:$:;; ; ?re N)rf rg rh r
r0 r` re rc r> r> j s5 A A A< < < < <re r> c e Zd ZdZeZdS )r r! N)rf rg rh rN re rA r` re rc r r t s J EEEre r c & e Zd Zd fd Zd Z xZS )r Nc ^ t t | j |i | | || _ d S d S r_ )r r r rA )ra rA r r r s rc r zBareField.__init__z s> 'i '8888 DJJJ re c d S r_ r` r8 s rc rR zBareField.ddl_datatype rR re r_ )rf rg rh r rR r r s @rc r r y sL
re r c e Zd ZeZeZ d fd Zed Z fdZ
d Z d Z d Z
d Zd fd
Zdd Zd
Z xZS )r6 NTc | dd t t | j |i | |t d |}| t d | }|
t d |
}|dk | _ || _ || _ || _ d | _ || _
|| _ || _ || _
|
| _ | | _ | | _ d S )Nrx TzP"rel_model" has been deprecated in favor of "model" for ForeignKeyField objects.zO"to_field" has been deprecated in favor of "field" for ForeignKeyField objects.zK"related_name" has been deprecated in favor of "backref" for Field objects.ra )r r r6 r r _is_self_referencer r declared_backrefbackref on_delete on_update
deferrabler object_id_namer constraint_name)ra rA rA rF
rG
rH
rI
_deferredr to_fieldrJ
r rK
related_namer r r s rc r zForeignKeyField.__init__ s
'4(((-ot$$-t>v>>> B
C
C
C E B
C
C
C E # :
;
;
;"G"'6/ ' ""$!
," . re c t | j t s | j j S t | j t r t
j S t j S r_ )rv r r rN r r r: r s rc rN zForeignKeyField.field_type sG $.)44 .>, ,
5
5 ."- -&&re c t | j t s| j S t t
| S r_ )rv r r rJ r r6 )ra r s rc rJ z ForeignKeyField.get_modifiers sG $.)44 2>//11 1_d++99;;;re c l | j p-d| j j j d| j d| j j j S )Nfk_rq _refs_)rK
rA r' r; r r r s rc get_constraint_namez#ForeignKeyField.get_constraint_name sG # - - J ' ' ' N + +(- -re c 6 | j | S r_ )r rA r s rc rA zForeignKeyField.adapt s ~##E***re c t || j rt || j j }| j | S r_ )rv r r r r r
r s rc r
zForeignKeyField.db_value s@ eT^ , , 8E4>#677E~&&u---re c d t || j r|S | j | S r_ )rv r r r0 r s rc r0 z ForeignKeyField.python_value s1 eT^ , , L~**5111re c | j s!| d r|n|dz | _ | j s(| j | _ | j |k r| xj dz
c_ n+| j |k r t d|j j d|d | j r|| _ t | j t r t | j | j | _ n | j | j j j | _ t t | ||| | j | _ t# | j r| | | _ n| j d c| _ | _ | j sd|j j z | _ |r\t) || j t+ | | j dvr2t) | j | j | | d S d S d S )N_idzForeignKeyField "z"."zA" specifies an object_id_name that conflicts with its field name.z%s_setz!+)r r rJ
r r' r rD
r rv r r9 r r r r6 r r; r rE
rF
r r% backref_accessor_classr s rc r zForeignKeyField.bind s N'+}}U';'; Mtt D " A"&"2D "d**##u,##
D
(
( *(- (8(8(8$$$ @ A A
A " # "DN dnj 1 1 > $T^T^ D DDNN
^
# !^ 1 =DN ot$$))%}EEE , T* + + N 0066DLL262G /DL$/| 7#ek&66DL ; E4.0@0F0F G G G|4'' 33D99; ; ; ; ; ; ;''re Fc g }| j s|rR| }| t d t t | g | t d t
| f t d | j t
| j f g | j r*|
t d| j z | j r*|
t d| j z | j r*|
t d| j z t | S )Nr! z FOREIGN KEY
REFERENCESz ON DELETE %sz ON UPDATE %sz
DEFERRABLE %s)rK
rT
r7 rQ rf rF r. r r rG
r rH
rI
ru )ra
explicit_namerp r s rc foreign_key_constraintz&ForeignKeyField.foreign_key_constraint sI := :++--D LLL!!066779
:
:
:
dW % % N dn . / / 1 2 2 2 > ? LL^dn <== > > > > ? LL^dn <== > > > ? A LL_t >?? @ @ @ re c | d rt d || j j j v r| j j j | S t d|z )N__z)Cannot look-up non-existant "__" methods.zNForeign-key has no attribute %s, nor is it a valid field on the related model.)r| r r r' r@ r s rc r zForeignKeyField.__getattr__ sp ??4 N !LMM M 4>'. . .>'.t4 4 ACG H I I Ire ) NNNNNNNNNTNNrm r )rf rg rh r r< r rZ
r r rN rJ rT
rA r
r0 r r^
r r r s @rc r6 r6 s 'N ,BF<@?CDH!/ !/ !/ !/ !/ !/F ' ' X'< < < < <
- - - + + +. . .
2 2 2
"; "; "; "; "; ";H ,I I I I I I Ire r6 c d e Zd Z e Z fdZej ZddZd Z e
d Z xZ S )r+ c N || _ | | _ t j | t
t | | d | d | d d S )Nr r r )r r r ) field_kwargsrl rel_model_namer+ _unresolvedr r r r )ra rd
r r s rc r zDeferredForeignKey.__init__ s " , 2 2 4 4&**4000
$''00
=11F##
=11 1 3 3 3 3 3re Nc 0 t | j fi | j S r_ )r+ rd
rc
)ra memos rc __deepcopy__z DeferredForeignKey.__deepcopy__ s !$"5KK9JKKKre c t |fddi| j }|j r'| j j | j | d S | j j | j | d S )NrL
T)r6 rc
r rA r' set_primary_keyr add_field)ra r rA s rc set_modelz DeferredForeignKey.set_model sp OOTOT=NOO 9 J , ,TY > > > > > J & &ty% 8 8 8 8 8re c t t j t j d }|D ]X}|j | j k r4| | t j | Yd S )Nr3 r )
r r+ re
r
attrgetterrd
rf rl rl
discard) model_cls
unresolveddrs rc resolvezDeferredForeignKey.resolve' s . : ( 3H = =? ? ?
; ;B I$6$<$<$>$>>> Y'''".66r::: ; ;re r_ )
rf rg rh rP re
r ru r rh
rl
ro rs
r r s @rc r+ r+ s #%%K3 3 3 3 3 HL L L L9 9 9 ; ; \; ; ; ; ;re r+ c e Zd Zd Zd Zd ZdS )r, c g | _ d S r_ )_refsr s rc r z DeferredThroughModel.__init__2 s
re c @ | j |||f d S r_ )rv
r r
s rc set_fieldz DeferredThroughModel.set_field5 s%
5%./////re c f | j D ](\ }}}||_ |j || )d S r_ )rv
through_modelr' rk
)ra rz
src_modelm2mfieldr s rc rl
z DeferredThroughModel.set_model8 sG )- 6 6 %Ix%2H " O % %dH 5 5 5 5 6 6re N)rf rg rh r rx
rl
r` re rc r, r, 1 sA 0 0 06 6 6 6 6re r, c " e Zd ZdxZxZxZZdZdS ) MetaFieldNF)rf rg rh r r rA r r r` re rc r~
r~
> s' +//K/'/EDKKKre r~
c , e Zd Z fdZddZd Z xZS )ManyToManyFieldAccessorc t t | ||| |j | _ |j | _ |j | _ | j j j | j }| j j j | j }|s t d| j d| j d |s t d| j d| j d |d | _ |d | _
d S )Nz Cannot find foreign-key to "z" on "z" model.r ) r r
r rA r rz
r'
model_refsr src_fkdest_fk)ra rA rA r src_fksdest_fksr s rc r z ManyToManyFieldAccessor.__init__D s
%t,,55eUDIII[
" 0$*5djA%+6t~F C * "jjj$*<*<*< > ? ?
? C * "nnnd.@.@.@ B C C
C aj { re NFc ||sM j j dk r=t | j j }t |t r fd|D S t | j j j }|' j j rt d j d|d t | j j
j j |k S j S )Nr c D g | ] }t |j j S r` )r r
r rV r ra s rc rY z3ManyToManyFieldAccessor.__get__.<locals>.<listcomp>Y s( OOOGC ): ; ;OOOre zCannot get many-to-many "" for unsaved instance "rz )r
rF
r rv r` r r rA _prevent_unsavedr ManyToManyQueryr rU rz
rA r5 )ra r| r} force_queryrF
src_ids ` rc r~ z ManyToManyFieldAccessor.__get__T s
P4;#6##=#=!(DK,?@@ gt,, POOOOwOOOO Xt{'<'ABBF~$*"=~ j59ZZZ"K L L L#HdDNCCT$,--T$*%%U4;&011
3
zre c t || j j j }|'| j j rt
d| j d|d | |d }| |d d S )NzCannot set many-to-many "r
rz T)r
)clear_existing) r r
r r rA r
r r~ r )ra r| r~ r
r; s rc rN z ManyToManyFieldAccessor.__set__f s 4;#8#=>> >dj 9> *15XXX G H H
H X4 88
% -----re rh )rf rg rh r r~ rN r r s @rc r
r
C s[ # # # # # $. . . . . . .re r
c ~ e Zd ZeZ d dZd Zd
fd Zd Ze d Z
e
j d Z
d
Z d Z
xZS )r@ NTFc |Ht |t s t | st d |s||t d || _ || _ || _ || _ || _ || _
|| _ d S )NzKUnexpected value for through_model. Expected Model or DeferredThroughModel.zFCannot specify on_delete or on_update when through_model is specified.) rv r, r& r r r rF
_through_model
_on_delete
_on_updater
_is_backref)ra rA rF
rz
rG
rH
prevent_unsavedr
s rc r zManyToManyField.__init__r s $ }.BCC
B ]++
B !A B B B
@I$9Y=R "? @ @ @ +## / &re c t | S r_ )r
r s rc _get_descriptorz ManyToManyField._get_descriptor s &t,,,re c t | j t r | j || | d S t t
| ||| | j skt | j || j | j
| j d }| j p|j
j dz | _ | j j
| j | d S d S )NT)rF
rz
rG
rH
r
rq )rv r
r, rx
r r@ r r
rA rz
r
r
rF
r' r r rk
)ra rA r r> many_to_many_fieldr s rc r zManyToManyField.bind s d)+? @ @ ) )%t < < < F
ot$$))%}EEE M!0
" 0 / /
"" "" "" <A5;+;c+ADL N * *4<9K L L L L L M Mre c j d t | j | j f| j | j ff D S )Nc g | ]\ }}|S r` r` )rV rq rA s rc rY z.ManyToManyField.get_models.<locals>.<listcomp> s( 6 6 6(!U 6 6 6re )r r
rA r r s rc
get_modelszManyToManyField.get_models sN 6 6f
tz *!
!4> 2.4 '5 '5 6 6 6 6re c P | j | | _ | j S r_ )r
_create_through_modelr s rc rz
z ManyToManyField.through_model s( &"&"<"<">">D ""re c || _ d S r_ )r
r s rc rz
z ManyToManyField.through_model s #re c J \ d fD G fdd } j j d}j j t fi |j j t fi |d|i}j j d}t |t f| S )Nc & g | ]}|j j S r` )r' r; rV rA s rc rY z9ManyToManyField._create_through_model.<locals>.<listcomp> s AAAU%+(AAAre c e Zd Zj j j Zj j j Zd e z Z j j j j fdffZ
dS )3ManyToManyField._create_through_model.<locals>.Metaz
%s_%s_throughTN) rf rg rh rA r' r r ra r; r r )r r ra tabless rc r r
sZ z'0HZ%,F(55==8J).#).1GGGre r )rG
rH
Through) r
r
r
r' r r6 rf r rA )ra r rN attrs
klass_namer r r
s ` @@@rc r
z%ManyToManyField._create_through_model s ??$$SAAsCjAAA $T_MM INOC : :6 : : INOC : :6 : : D
'*llCLLLA
J%000re c | j S r_ )rz
r s rc get_through_modelz!ManyToManyField.get_through_model s !!re )NNNNTFrm )rf rg rh r
r< r r
r r
r rz
r r
r
r r s @rc r@ r@ o s ,NJNCH' ' ' '$- - -M M M M M M$6 6 6
# # X#
$ $ $1 1 1*" " " " " " "re r@ c 8 e Zd ZdZd fd Zd Zd ZddZ xZS ) VirtualFieldNc ||n| j }|
| nd | _ t t | j |i | d S r_ ) field_classfield_instancer r
r )ra r
r r r2 r s rc r zVirtualField.__init__ sS * 6 D<L).):eeggg*lD!!*D;F;;;;;re c H | j | j | S |S r_ )r
r
r s rc r
zVirtualField.db_value s' *&//66 6 re c H | j | j | S |S r_ )r
r0 r s rc r0 zVirtualField.python_value s' *&33E:: : re Tc || _ |x| _ x| _ | _ t ||| || | d S r_ )rA r r r; r r< r= s rc r zVirtualField.bind sI
8<<<49t~tT 0 0d C CDDDDDre r_ rm ) rf rg rh r
r r
r0 r r r s @rc r
r
s| K< < < < < <
E E E E E E E Ere r
c \ e Zd ZdZd Zed Zd dZd Zd Z d Z
d Z d Z d
d Z
dS )r" Nc " || _ d | _ d S r_ ) field_names_safe_field_names)ra r
s rc r zCompositeKey.__init__ s &!% re c l j & j j S fd j D _ j S )Nc H g | ] }j j j | j S r` )rA r' r@ r; rV fra s rc rY z1CompositeKey.safe_field_names.<locals>.<listcomp> s? &A &A &A*+ '+j&6&=a&@&J &A &A &Are )r
rA r
r s `rc safe_field_namesz CompositeKey.safe_field_names s[ ! )z!''&A &A &A &A/3/?&A &A &AD "%%re c L t fd| j D S | S )Nc 0 g | ]}t | S r` r )rV r
r| s rc rY z(CompositeKey.__get__.<locals>.<listcomp> s# NNN1'(A..NNNre )ra r
r{ s ` rc r~ zCompositeKey.__get__ s4 NNNN8MNNNOO O re c & t |t t f st d t | t | j k rt
d t | D ]!\ }}t || j | | "d S )NzIA list or tuple must be used to set the value of a composite primary key.zVThe length of the value must equal the number of columns of the composite primary key.) rv r` ra r r r
r r r )ra r| r~ r field_values rc rN zCompositeKey.__set__ s %$ // 8 7 8 8
8 u::T -.. . . H I I
I )% 0 0 B B C Hd .s 3[ A A A A B Bre c z fdt j | D }t t j | S )Nc L g | ] \ }}j j j | |k !S r` rA r' r@ )rV rA r~ ra s rc rY z'CompositeKey.__eq__.<locals>.<listcomp> sE I I I'5%
(/6%? I I Ire )zipr
rt r r )ra r r s ` rc r zCompositeKey.__eq__ sQ I I I I+.t/?+G+GI I I hm[111re c | |k S r_ r` r s rc r zCompositeKey.__ne__ s re c B t | j j | j f S r_ )r rA rf r
r s rc r zCompositeKey.__hash__ s TZ($*:;<<<re c |j t k }| t fd j D d| S )Nc > g | ]}j j j | S r` r
)rV rA ra s rc rY z(CompositeKey.__sql__.<locals>.<listcomp>
s< !@ !@ !@%* "&!1!8!? !@ !@ !@re r )r rB r) ru r
)ra r9 r s ` rc r% zCompositeKey.__sql__ sm l*wwx !@ !@ !@ !@.2.>!@ !@ !@AEvO O P P Pre Tc j || _ |x| _ x| _ | _ t || j | d S r_ )rA r r r; r r= s rc r zCompositeKey.bind
s9
8<<<49t~ty$'''''re r_ rm )rf rg rh rN r r r
r~ rN r r r r% r r` re rc r" r" s H& & & & & X&
B B B2 2 2
= = =P P P( ( ( ( ( (re r" c < e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d S )
_SortedFieldList_keys_itemsc " g | _ g | _ d S r_ r
r s rc r z_SortedFieldList.__init__ s
re c | j | S r_ )r
)ra r s rc r z _SortedFieldList.__getitem__ s {1~ re c * t | j S r_ )rw r
r s rc r z_SortedFieldList.__iter__ r re c |j }t | j | }t | j | }|| j || v S r_ )r4 r r
r r
)ra r r r r s rc __contains__z _SortedFieldList.__contains__ sA N
A & & Q ' 't{1Q3'''re c @ | j |j S r_ )r
rx r4 r" s rc rx z_SortedFieldList.index& s z 000re c |j }t | j | }| j || | j || d S r_ )r4 r r
r r
)ra r r r s rc r z_SortedFieldList.insert) sP N
A & &
!Q 1d#####re c P | | }| j |= | j |= d S r_ )rx r
r
)ra r r s rc r z_SortedFieldList.remove/ s* jj K JsOOOre N) rf rg rh r r r r r
rx r r r` re rc r
r
s #I ! ! !( ( ( 1 1 1$ $ $ re r
c e Zd Zd#dZed Zej d Zd Zd$dZd Z d$d Z
d$d
Z d$d Z d$d Z
d$d
Zd%dZd%dZd$dZd$dZd$dZd$dZd Zd$dZd Zd Zd Zd Zd Zd Z d Z d Z d Z d$d Z d! Z!d&d"Z"dS )'rN Nc f || _ || _ | dt || _ d S )Nr )rA rJ r rD r )ra rA r r s rc r zSchemaManager.__init__9 s4
!""7L999 . re c h | j p| j j j }|t d| j z |S )Nz=database attribute does not appear to be set on the model: %s)rJ rA r' r r8 r s rc r zSchemaManager.database? sF
^
8tz / 8
:& (ACG:(N O O
O re c || _ d S r_ r r s rc r zSchemaManager.databaseG s
re c 0 | j j di | j S r )r rL r r s rc _create_contextz SchemaManager._create_contextK s ,t},DDt/CDDDre Tc \ | dd }| }| |rdnd |r| d | | j d g }g }| j j j rV fd j j D }| t t d t | f j
D ]m}| | | t |t r.|j s'| | n j r| j | | | | t ||z j et/ j } | D ]N}
t |
t0 st3 d | d |
Og } j r| d
j r| d | r+| d d
| z |S )N temporaryFCREATE TEMPORARY TABLE
CREATE TABLE r5 r c 4 g | ]}j | j S r` )r@ r )rV
field_namerH s rc rY z/SchemaManager._create_table.<locals>.<listcomp>Z s9 J J J ( +j18 J J Jre rG z table_settings must be stringsSTRICTz
WITHOUT ROWIDr r ) r r
r r) rA r'
composite_keyr r
r ru rQ r.
sorted_fieldsrU rv r6 r r^
r r7 _create_table_option_sqltable_settingsrc r9 r
strict_tables
without_rowidrU )
ra r/ r$ is_tempr9 r r
pk_columnsrA r
setting
extra_optsrH s
@rc
_create_tablezSchemaManager._create_tableN s ++k511""$$ M--oNNN * KK( ) ) )
##C((( z IJ J J J,0,<,HJ J JJ x]););)9*)E)E)G H H
I
I
I ' C CE NN599S>> * * *% 11
C%.
C""5#?#?#A#ABBB 1 t / 0 0 0488AABBB ;!677888 * )$*= > >N)
2
2!':66 G$%EFFF C ((1111
:z 0 0 : : : Az 0 0 A A A 7 KK * 5 55 6 6 6
re c g }t | j j j pi | }|s|S t | D ]\ }}t
|t s8t | r
|j j }n t t | }| t t | |fd |S )Nr r )rP rA r' r$ r r rv re r& r( rQ rW r ru )ra r$ r r r~ s rc r
z&SchemaManager._create_table_option_sqlx s TZ - 5 ;WEE L 11 @ @JC eT**
,E?? , !K -EE E
OOE LL3s88U"3#>>> ? ? ? ? re c T | j | j dd|i| d S Nr/ r` )r r r
ra r/ r$ s rc r" zSchemaManager.create_table s7
0d 0 F Fd Fg F FGGGGGre c J | | d rdnd }|r| d | t t | d | S )Nr
r
r
r5 r )r
r r r) rf rc ra r; r; r/ rH r9 s rc _create_table_asz SchemaManager._create_table_as s ##%% 88K00F116EG G * KK( ) ) )V\* 5 5677 U re c \ | j ||fd|i|}| j | d S )Nr/ )r
r r r
s rc create_table_asz SchemaManager.create_table_as s? #d#JIIDIDII
c"""""re c 6 | |rdnd | j }| d r| d }n*| d r| d }|S )NzDROP TABLE IF EXISTS z DROP TABLE cascade CASCADErestrictz RESTRICT)r
r r) rA r )ra r/ r$ r9 s rc _drop_tablezSchemaManager._drop_table s ##%%4J//]KKDJ ;;y ! ! +++j))CC
[[
$
$ +++k**C
re c T | j | j dd|i| d S r
)r r r
r
s rc r' zSchemaManager.drop_table s7
.d . D DD DG D DEEEEEre Fc z | j }|j s?| d | j S | d | j }|r| d }|r| d }|S )Nr& zTRUNCATE TABLE z RESTART IDENTITYr
)r rH r
r r) rA )ra restart_identityr
rM r9 s rc _truncate_tablez SchemaManager._truncate_table s
] >((** W^,,SS__
> ""$$,,->??CCDJOO 3++ 122C *++j))C
re c b | j | || d S r_ )r r r )ra r r
s rc rH z SchemaManager.truncate_table s/
d 2 23CW M MNNNNNre c \ fd j j D S )Nc < g | ]} | S r` )
_create_indexrV rx r/ ra s rc rY z1SchemaManager._create_indexes.<locals>.<listcomp> s? A A A ""5$// A A Are rA r' fields_to_indexra r/ s ``rc _create_indexesz SchemaManager._create_indexes sN A A A A A !Z - = = ? ?A A A Are c P t |t rk| j j s| d }n |j |k r| | }t | j t rt | }|
| S rh ) rv r9 r rE r/ r, rJ rR r r
r) )ra rx r/ s rc r zSchemaManager._create_index s eU # # -=2
)
5))$$
4(($..99
- &e,,##%%))%000re c l | | D ] }| j | d S N)r/ )r
r r ra r/ r; s rc create_indexesz SchemaManager.create_indexes sE ))t)44 ) )E M ! !% ( ( ( ( ) )re c \ fd j j D S )Nc f g | ]-}t |t | .S r` )rv r9 _drop_indexr s rc rY z/SchemaManager._drop_indexes.<locals>.<listcomp> sH - - - eU++- -- - - -re r r s ``rc
_drop_indexeszSchemaManager._drop_indexes sE - - - - - !Z - = = ? ?- - - -re c T d}|r| j j r|dz
}t |j t r,|j j r t
|j j |j }nt
|j }| |
| S )Nz DROP INDEX z
IF EXISTS ) r rF rv r) rS r rf r r
r r) )ra rx r/ r9 r: s rc r zSchemaManager._drop_index s ! &DM1 & %I elE * * -u|/C - 4ekBBJJ ,,J ""##Z "re c l | | D ] }| j | d S r
)r r r r s rc drop_indexeszSchemaManager.drop_indexes sE ''T'22 ) )E M ! !% ( ( ( ( ) )re c Z |j r | j j st d|j z d S )Nz@Sequences are either not supported, or are not defined for "%s".)rN r rG r r r" s rc _check_sequencesz SchemaManager._check_sequences sC ~ ?T]%< ? 138: > ? ?
? ? ?re c |j j j r$t |j j j |j S t |j S r_ )rA r' r rf rN r" s rc _sequence_for_fieldz!SchemaManager._sequence_for_field s< ; # *%++2ENCC C%.)) )re c | | | j |j sM| d | | S d S )NzCREATE SEQUENCE r r r rN r
r r) r r" s rc _create_sequencez SchemaManager._create_sequence sv e$$$},,U^<< ;$_&& W /00S11%8899
; ; ;re c l | | }| | j | d S d S r_ )r r r ra rA seq_ctxs rc create_sequencez SchemaManager.create_sequence s? ''.. M ! !' * * * * * re c | | | j |j rM| d | | S d S )NzDROP SEQUENCE r r" s rc _drop_sequencez SchemaManager._drop_sequence sv e$$$ = ( ( 8 8 ;$_&& W -..S11%8899
; ; ;re c l | | }| | j | d S d S r_ )r# r r r s rc
drop_sequencezSchemaManager.drop_sequence s? %%e,, M ! !' * * * * * re c | d |j d | d S )Nz ALTER TABLE z ADD T)r
r r) rA r^
r" s rc _create_foreign_keyz!SchemaManager._create_foreign_key sY "" ((U[!!!!U11$7788 :re c ` | j | | d S r_ )r r r' r" s rc create_foreign_keyz SchemaManager.create_foreign_key
s,
d 6 6u = =>>>>>re c | j j r0| j j j D ] }|j r| | d S d S r_ )r rG rA r' r
rN r! r" s rc create_sequencesz SchemaManager.create_sequences sY = " 0 )7
0
0> 0((/// 0 0
0
0re c v | | j |fi | | | d S r
)r+ r" r )ra r/
table_optionss rc
create_allzSchemaManager.create_all sL $00-000 &&&&&re c | j j r0| j j j D ] }|j r| | d S d S r_ )r rG rA r' r
rN r% r" s rc drop_sequencesz SchemaManager.drop_sequences sY = " . )7
.
.> .&&u--- . .
.
.re c R | j |fi | |r| d S d S r_ )r' r0 )ra r/ r0 r$ s rc drop_allzSchemaManager.drop_all! sF ((((( " ! ! ! ! ! " "re r_ rm rj rD )#rf rg rh r r r r r
r
r
r" r
r
r
r' r rH r
r r r r r r r r r! r# r% r' r) r+ r. r0 r2 r` re rc rN rN 8 sc / / / / X _ _ E E E( ( ( (T
H H H H # # # # F F F F O O O OA A A A
1
1
1
1) ) ) )- - - -
" " ") ) ) )? ? ?
* * * ; ; ;+ + +
; ; ;+ + +
: : :? ? ?0 0 0 ' ' ' '
. . . " " " " " "re rN c ( e Zd Z ddZd Zd dZd Zd Zd Zd
Z e
d Z e j d Z e j
d
Z e
d Zej d Ze
d Zd Zd Zd dZd Zd Zd Zd Zd Zd Zd ZdS ) MetadataNFTc | t d | }|| _ || _ i | _ i | _ i | _ t
| _ g | _ g | _ i | _
i | _ i | _ i | _
g | _ |j | _ | | _ || _ |s0| j r| | n| }|| _ d | _ |rt/ | ng | _ || _ || _ || _ d x| _ | _ || _ | | _ |
| _ || _! || _" || _# i | _$ i | _% tM j' t. | _( tM j' t. | _) i | _* |
pi | _+ |, D ]\ }}t[ | || t] |/ | _0 g | _1 d S )NzC"db_table" has been deprecated in favor of "table_name" for Models.)2r rA r r@ r combinedr
_sorted_field_listr
sorted_field_namesr _default_by_name
_default_dict_default_callables_default_callable_listrf rl r rs rE make_table_namer; r) r` r r r r r
rV only_save_dirty
depends_onr
r
r
r
refsbackrefsr defaultdictr
model_backrefs
manytomanyr$ r r rP keys_additional_keysr )ra rA r r; r r r r r> r? r$ db_tablers r
r
r
r
rE r r r~ s rc r zMetadata.__init__( s 6
7
7
7!J
"2"4"4 "$
" "$ &(#N((** ,"4 7 ! 06$--e444 # 3 3 5 5
% (/7tG}}}R & &377T 0 . $ , * *"
%1$77 ) 5d ; ; }" ,,.. & &JC D#u % % % % #FKKMM 2 2 re c x | j rt j dd| j S t | j j S )NrC rq )rE rD rj r rn rA rf r s rc r= zMetadata.make_table_namek s6 " 56)S$)44 4 tz 2333re c D |s|st d d | j d fg}t }t j | f }|r|j n|j }|r | }||v r| | |rQ|j D ]7\ } }
|
| |
df |
|
j 8|rQ|j D ]7\ } }
|
| |
df |
|
j 8||S )Nz)One of `refs` or `backrefs` must be True.FT)
r rA rP r dequer popleftr r@ r r r' rA ) ra r@ rA depth_firstr r queuer currfkrA s rc model_graphzMetadata.model_graphp sN JH J HII I
D)*uu!4'** )<u} .688Dt||X HHTNNN
.!% !2!2 . .IBLL"eU!3444LL----
.!% !4!4!6!6 . .IBLL"eT!2333LL---- . re c |j }|| j |< | j | | | j |j j |< |j j | j | d S r_ )r r@ r
r rA r' rA rC ra rA rels rc add_refzMetadata.add_ref sg o % ##E***$(J 5! ,33E:::::re c |j }| j |= | j | | |j j |= |j j | j | d S r_ )r r@ r
r r' rA rC rA rR s rc
remove_refzMetadata.remove_ref sa o Ie ##E*** I u % ,33E:::::re c $ || j |j < d S r_ rD r r" s rc add_manytomanyzMetadata.add_manytomany s &+
###re c | j |j = d S r_ rX r" s rc remove_manytomanyzMetadata.remove_manytomany s OEJ ' ' 're c | j <t | j d | j D | j | j | j | _ | j S )Nc g | ] }|j
S r` )r rV rA s rc rY z"Metadata.table.<locals>.<listcomp> s CCCu"CCCre )r r rJ )r) rS r; r
r rA r r s rc r( zMetadata.table sR ; CC0BCCC{z - ) ) )DK {re c t d )NzCannot set the "table".r r s rc r( zMetadata.table s 6777re c d | _ d S r_ )r) r s rc r( zMetadata.table r re c | j S r_ )r r s rc r zMetadata.schema s
|re c || _ | `d S r_ )r r( r s rc r zMetadata.schema s JJJre c l | j rt | j | j S t | j S r_ )r rf r; r s rc r zMetadata.entity s0 < +$,88 8$/** *re c d t | j | _ d | j D | _ d S )Nc g | ] }|j
S r` r )rV r
s rc rY z2Metadata._update_sorted_fields.<locals>.<listcomp> s "F"F"Fa16"F"F"Fre )r` r7 r
r8 r s rc _update_sorted_fieldsz Metadata._update_sorted_fields s4 !$"9 : :"F"F43E"F"F"F re c t |t r|j }| j |g }| j |g }||fS r_ )rv
ModelAliasrA r
r rC )ra rA forwardrefsrA s rc get_rel_for_modelzMetadata.get_rel_for_model sU eZ ( ( KEo))%44 &**5"55X&&re c || j v r| | n)|| j v r | | j | t |t
s | `| | j || || j |j < || j
|j < || j |j < || j |j < | j
| | |j ||j | j |< t% |j r6|j | j |< | j |j |j f n@|j | j |< |j | j |j < n | | j || t |t0 r| | d S t |t4 r |j r| | d S d S d S r_ ) r@ remove_fieldrD r[ rv r~
r( r rA r r r r6 r7 r rg r r r r; r< r r: r9 r6 rT r@ rY )ra r
rA r> s rc rk
zMetadata.add_field s $ $ j ) ) ) )
4?
*
* " "4?:#> ? ? ?%++ >
JJtz:} = = =&+DK
#.3DL* +(-DM%* %/4DM%+ , # * *5 1 1 1 & & ( ( (}(',}
e$ U]++ F5:]D+E2/66
8=
8G H H H H 16
D&u-8=
D)%*5 JJtz:} = = = e_ - - ' LL
/
/ 'EJ ' & & & & & ' ' ' 're c || j vrd S | `| j | }| j |j = | j |= | j |j = n# t $ r Y nw xY w| j | | |j
| j |= | j |d r@t | j D ]*\ }\ }}||k r | j | n+n;| j |d | j |j d t% |t& r| | d S d S r_ )r@ r( r r r r6 r r7 r rg r r r; r r< r: r9 r rv r6 rV )ra r
originalr r rq s rc rm zMetadata.remove_field s T[ ( ( F J;??:.. L- . M* %
h 233 D &&x000 ""$$$ '
h'&**8T::
?$-d.I$J$J LAyaz)) 377::: * "&&x666%))(->>> h 0 0 & OOH % % % % % & &s
A
AAc t |t | _ | || || _ |j pt
|j | _ d S r_ )rv r" r
rk
r rV re rN )ra r rA s rc rj
zMetadata.set_primary_key sV '| < < tU###
!
re c j r%t fd j j D S j dur j fndS )Nc * g | ]}j | S r` r@ )rV r
ra s rc rY z-Metadata.get_primary_keys.<locals>.<listcomp> s6 J J J ( +j1 J J Jre Fr` )r
ra r r
r s `rc r zMetadata.get_primary_keys sw P J J J J,0,<,HJ J J K K
K +/*:%*G*GD$&&R Ore c l | j }| j D ]\ }} | ||< |S r_ )r9 rL r< )ra ddr
r s rc get_default_dictzMetadata.get_default_dict sC
"
'
'
)
)#'#> ' ' J $WYYBzNN re c g }| j D ]N}|j r
|j s|j r6| t | j |f|j |j O| j D ]}t |t r| | -t |t t f r|\ }}g }|D ]t}t |t r!| | j | 8t |t r| | ct d|z | t | j || |S )N)r. r0 z;Expected either a field name or a subclass of Node. Got: %s)r. )r
r rx r. r rB rA r> r rv re r` ra r9 r6 r )ra r r
index_obj index_partsr. r@ rW s rc r zMetadata.fields_to_index s # ? ?A}
w
?!(
?z$*qd1801 > > > ? ? ? N NI)T**
Ny))))Ie}55
N&/# V ' M MD!$
33 M
dmD&9::::#D$// M
d++++ ( *EGK*L M M Mz$*fV L L LMMMre c || _ || j j _ | `t |t r |j d }| j D ]
} || d S r_ ) r rA r rJ r( rv rL r r )ra r hooks rc set_databasezMetadata.set_database; se
'/
$ J h & & 8<+?HN D DNNNN re c || _ | `d S r_ )r; r( )ra r; s rc set_table_namezMetadata.set_table_nameH s $ JJJre )NNNNNNFNNNNNFFNT)TTTrm )rf rg rh r r= rP rT rV rY r[ r r( r deleterr r rg rk rk
rm rj
r rv r r| r~ r` re rc r4 r4 ' s FJ<@AEDHEI$( A A A A F4 4 4
2; ; ;; ; ;, , ,( ( ( X \8 8 \8 ] ] X ] ] + + X+ G G G' ' '!' !' !' !'F& & &:" " "P P P 6 re r4 c ( e Zd Zg Z fdZd Z xZS )SubclassAwareMetadatac t t | j |g|R i | | j | d S r_ )r r r r# r ra rA r r r s rc r z SubclassAwareMetadata.__init__P sM 3#T**3EKDKKKFKKK 5!!!!!re c 0 | j D ]
} || d S r_ )r# )ra r5 rA s rc
map_modelsz SubclassAwareMetadata.map_modelsT s, [ E BuIIII re )rf rg rh r# r r r r s @rc r r M sL
F" " " " " re r c e Zd ZdS )r. Nr r` re rc r. r. Y r re r. c r e Zd Z eg d Z fdZd Zd Zd Zd Z d Z
d Z d Z d
Z
e
Zd Z xZS ) ModelBase) r r r r r$ r rs r
r> rE r
r
c |t k s|d j t k r$ t t j |||fi |S i }| dd }|r9|j D ] \ }}| d s|||< t |dd } d x}
} |D ]} t | d s| j }
| t |
j
} j |
j z }|
j D ]}||v r||vr|
j | ||< | d|
j | d|
j | j D ]B\ }}||v r
t' |t( r#|j j
st |j ||< C| dd pi }| d t. }| d
t0 } t t j |||fi | d x _ _ | fi | _ | fi | _ g } j D ]X\ }}t' |t8 r>|j
r| rt; d |z |j
r||}
} A| ||f Y| &| d ur | | | j fntA d
f\ } }
n&d } n#t' | tB rd}
d j _" | d ur j # |
| |D ] \ }} j $ || !t d rd|vrtK d fd d j z }d j& i}tO |tP f| }| _( ) tT + S )Nr r rq r r' r r schema_optionsmodel_metadata_classschema_manager_classz over-determined primary key %s.Fr' __composite_key__Tr r9 c D dj d| dS )Nr r8 r )rf r )ra r s rc rx z#ModelBase.__new__.<locals>.<lambda> s# dllnnnn3. re z%sDoesNotExistrg ),rG rf r r r r r[ r r| r r r' r r inheritablerF r r r rv r rA r r4 rN r r r r2 r r r r r" r
rj
rk
r rg r r. validate_modelr+ rs
)r r basesr
r meta_optionsrH r rX rI pk_name parent_pkr base_metaall_inheritablesoptsr Schemar@ r r~ rA exc_name exc_attrsexception_classr s ` rc r zModelBase.__new__b s : q!2j!@!@05C((0dE5 ; ;39; ;
; yy&& (
++--
(
(1||C(( (&'LO
T=$
/
/ "")
1 1A1g&&
I $Y%: ; ; !o 0J JO '
<
<''A\,A,A&/&8&;LO # #J 0B C C C # #Hi.> ? ? ?***,,
1
1A::x a // 18K 1 ' 0 0E!H
1 !1488>B 6AA !!"8-HH ,eIs##+CueNNvNN%)) s{D-- -- fS**E** ,,,.. 0 0JC%''
0$ 0 0$%F%MNNN& 0"'BBMM3,///
:%%"+"7 !*9> : : ) T 2 GG
L
)
) +)G&*CI #
U?? I % %gr 2 2 2! - -KD% I e , , , , 3 " " /z'>'> C &. &. &. &.
/
/
/ $cl2!3>2 x, )DD* ""3'''
re c d| j z S )Nz <Model: %s>)rf r s rc r9 zModelBase.__repr__ s t},,re c D t | S r_ )rw r r s rc r zModelBase.__iter__ s DKKMM"""re c , | | S r_ ) get_by_idra r s rc r zModelBase.__getitem__ s ~~c"""re c 2 | || d S r_ ) set_by_id)ra r r~ s rc r zModelBase.__setitem__ s sE"""""re c 0 | | d S r_ ) delete_by_idr s rc r zModelBase.__delitem__ s # re c T | | dS # | j $ r Y dS w xY wr )r r. r s rc r
zModelBase.__contains__ sG NN3 4 55 s
''c N | S r_ )r r' r s rc r zModelBase.__len__ s {{}}""$$$re c dS r@ r` r s rc __bool__zModelBase.__bool__ s ttre c @ | | j j S r_ )r) r' r( r8 s rc r% zModelBase.__sql__ s wwtz'(((re )rf rg rh rP r r r9 r r r r r
r r __nonzero__r% r r s @rc r r \ s # : : : ; ;K
Y Y Y Y Yv- - -# # ## # ## # # % % %###K) ) ) ) ) ) )re r c e Zd Zd Zd Zd ZdS )r< c > || _ || _ || _ || _ d S r_ )r# r r8 r9 )ra r# r r8 r9 s rc r z _BoundModelsContext.__init__ s%
" *re c g | _ | j D ]`}| j |j j | | j | j | j t | j a| j S N)rZ ) r r# r r' r r r8 r9 rP )ra rA s rc r z _BoundModelsContext.__enter__ sy [ 2 2E & &u{'; < < < JJt}dnd6H #DK 0 0
2
2
2
2{re c t | j | j D ]:\ }}| || j | j t
| j ;d S r )r
r# r r r8 r9 rP )ra r r r! rA rM s rc r z _BoundModelsContext.__exit__ sf T[$*=>> 2 2IE2 JJr4>4+= #DK 0 0
2
2
2
2 2 2re N)rf rg rh r r r r` re rc r< r< sA + + + 2 2 2 2 2re r< c v e Zd Zd Zd Zed Zed3d Zed Zed Z ed3d Z
ed3d Z ed3d
Z ed Z
ed3d Zed3d
Zed Zed Zed Zed3d Zed3d Zed Zed Zed Zed Zed Zed Zed Zed Z d Z e e Z e j d Z d Z!d Z"d Z#d4d!Z$d" Z%e d# Z&d5d%Z'd6d&Z(d' Z)d( Z*d) Z+d* Z,ed7d+ Z-ed8d, Z.ed- Z/ed9d. Z0ed8d/ Z1ed0 Z2ed1 Z3ed2 Z4dS ):rA c | dd ri | _ n | j | _ t | j | _ i | _ |D ]}t | ||| d S )N__no_default__)r r r' rv rP r r r )ra r r r s rc r zModel.__init__ s ::& - - : DMM J 7 7 9 9DM$-(( ( (A D!VAY ' ' ' ' ( (re c J | j j durt | j ndS )NFzn/a)r' r rW _pkr s rc r z
Model.__str__ s# $
6e C Cs48}}}Nre c d S r_ r` r s rc r zModel.validate_model s re Nc " t | | S r_ )ri )r r s rc r z Model.alias s #u%%%re c H | }|s | j j }t | || S )N)
is_default)r' r
ModelSelect)r r@ r s rc r z Model.select s0 Z
-Y,F3:>>>>re c i }|rt |t s|rt d|z |S |D ]u} t |t r|n| j j | }n=# t $ r0 t |t st d|d|d |}Y nw xY w|| ||< v|rJ|D ]G} || || j j | < # t $ r || |t | | < Y Dw xY w|S )Nz/Data cannot be mixed with keyword arguments: %szUnrecognized field name: "z" in rR ) rv r r r2 r' r6 r re r )r r r
normalizedr rA s rc _normalize_datazModel._normalize_data sx
. dD))
=$ &57;&< = = =
.
. $.sE$:$: :SS"%)"4S"9 E %c400 8 (j,/CC*7 8 8 8 EEE
%)I
5!! @
@
@@:@+Jsy 1# 677 @ @ @4:3KJwsC 0 0111@s# )A 7BB/C #C10C1c J t | | || S r_ ) ModelUpdater )r _Model__datar s rc r z Model.update+ " 3 3 3FF C CDDDre c J t | | || S r_ ) ModelInsertr r r r s rc r z Model.insert/ r re c & t | || S r r r rS r@ s rc insert_manyzModel.insert_many3 s 3tV<<<<re c D fd|D }t || S )Nc ^ g | ])}t |t rt | n|*S r` )rv r9 r )rV rA r s rc rY z%Model.insert_from.<locals>.<listcomp>9 sJ 3 3 3"' +5UJ*G*G 73&&& 3 3 3re r
r )r r; r@ r s ` rc insert_fromzModel.insert_from7 s@ 3 3 3 3+13 3 33ug>>>>re c D | j |fi | d S r r r s rc r z
Model.replace= s* sz&++F++77 BBBre c V | || d S )N)rS r@ r )r r r s rc replace_manyzModel.replace_manyA s( $v66 Y'' )re c $ t | || S r_ )ModelRaw)r r) rN s rc rawz Model.rawG s S&)))re c t | S r_ ) ModelDeleter s rc r z Model.deleteK s 3 re c B | di |}| d |S )NT) force_insertr` )save)r r; insts rc createz Model.createO s, s||U|| t $$$ re c |t || }n|g}t j j } j j r& j j j }| | j j j r( j j dur j
}nd } fd|D }g |D ]L}t |t r
|j 2
|j M|D ]} fd| D }
|
| } |rD| Bt# | | D ]1\ } }
t# || D ]\ }}t% |
|j | 2d S )NFc 4 g | ]}j j | S r` )r' r@ )rV r
r s rc rY z%Model.bulk_create.<locals>.<listcomp>g s# MMM:#)":.MMMre c 3 6 K | ]fd D V dS )c 0 g | ]}t | S r` r )rV r
rA s rc rY z/Model.bulk_create.<locals>.<genexpr>.<listcomp>p s# 777AgeQ''777re Nr` )rV rA r
s @rc rr z$Model.bulk_create.<locals>.<genexpr>p sL ) ) 8777777 ) ) ) ) ) )re rs )r r` r' r8 rV r r r r r r rv r6 r rJ
r r r
r )r
model_list
batch_sizebatchesr
r pk_fieldsr@ rA batchr rO r0 rA pk_fieldobj_idr
s ` @rc bulk_createzModel.bulk_createU s ! j*55GG!lG39788 9 # (i+0G w ' ' ' 9 . 9 - - 2244II IMMMMMMM ) )E% 11
) U 12222 UZ(((( > >E) ) ) )"') ) )E//%/77??AAC
>S_"%c5// > >JC.1)S.A.A > >*6 x}f====>
> >re c t j j t rt d fd|D }d |D }|t || }n|g}d} j j }|D ]}d |D } i }
t
|| D ]\ } } g }
|D ]k}t || }t |t s| | }|
| |j |f lt ||
}||
| < |
|
j j | z
}|S )NzGbulk_update() is not supported for models with a composite primary key.c b g | ]+}t |t rj j | n|,S r` )rv r9 r' r@ )rV r
r s rc rY z%Model.bulk_update.<locals>.<listcomp> sG # # # *4Az)B)BI#)"1%% # # #re c T g | ]%}t |t r|j n|j &S r` )rv r6 rJ
r r^ s rc rY z%Model.bulk_update.<locals>.<listcomp> sD 6 6 6%* *4E?)K)K !%%j6 6 6re r c g | ] }|j
S r` )r r
s rc rY z%Model.bulk_update.<locals>.<listcomp> s 444Uuy444re )rv r' r r" r r r
r re r r r r r r5 r r )r r r@ r r
r rz rI r id_listr rA r r rA r~ cases ` rc bulk_updatezModel.bulk_updatex s ci+\ : : 9 8 9 9
9# # # #!# # #6 6.46 6 6 ! j*55GG!lG
Y
" E44e444GF "65 1 1
%
% t " B BE #E4 0 0E%eT22 6 %u 5 5LL"++ei"8"8%!@AAAAB $u
#**V$$5.227;;<<799
AA re c " t | d S r )NoopModelSelectr s rc noopz
Model.noop s sB'''re c 8 | }|rbt | dk rEt |d t r*| | j j |d k }n
|j | }|r
|j di |}| S )Nr r r` ) r r rv r r5 r' r r6 r )r r; filterssqs rc r z Model.get s
ZZ\\ &5zzQ:eAh#<#<XXci 3uQx ?@@ RXu% &%%W%%Bvvxxre c @ | j |i |S # t $ r Y d S w xY wr_ )r r. )r r; r s rc get_or_nonezModel.get_or_none s@ 37E-W-- - DD s
c H | | j j |k S r_ )r r' r r rI s rc r zModel.get_by_id s wwsy,2333re c |'| | S | | | j j |k S r_ )r r r r5 r' r )r r r~ s rc r zModel.set_by_id sY ;::e$$,,.. .JJu%%U390C788
Dre c | | j j |k S r_ )r r5 r' r r r s rc r zModel.delete_by_id s4 zz||!!#)"72"=>>FFHHHre c f | di }| }| D ],\ }}| t | | |k }- | dfS # | j $ r |r| | | j j
5 | j di |dfcd d d cY S # 1 swxY w Y Y d S # t $ r3} | dfcY d }~cY S # | j $ r |w xY wd }~ww xY ww xY w)Nr FTr` )
r r r r5 r r r. r r' r r r r; )r r r r; rA r~ excs rc
get_or_createzModel.get_or_create s ::j"--
"LLNN > >LE5KKU 3 3u <==EE 99;;% %
,MM(+++Y'..00 6 6%3:////56 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6!
99;;---------' I
sl -B
D05C/C! C/ D0!C% %C/(C% )C//
D,:DD,D0
D$$D''D,,D0c @ | j |i |S r_ )r r6 )r dq_nodesr s rc r6 z Model.filter s" "szz||"H8888re c ` | j j dur t | | j j j S d S rh )r' r r r; r s rc get_idz Model.get_id s4
: ! . .4!7!ABB B / .re c F t | | j j j | d S r_ )r r' r r r s rc r z Model._pk s" dj,1599999re c , | j j | j k S r_ )r' r r r s rc _pk_exprzModel._pk_expr s z%11re c i }|D ]G}t |t r| j j | }|j |v r||j ||j < H|S r_ )rv r9 r' r6 r )ra
field_dictonlynew_datarA s rc
_prune_fieldszModel._prune_fields s] > >E%,,
3
+E2zZ'''1%*'=$re c | j j D ]d}|j }||v o%|| d u o| j | d u}|r/t | |t
| | | j | ||< ed S r_ )r' r@ r r r r r r )ra r foreign_key_field foreign_key
conditionss rc _populate_unsaved_relationsz!Model._populate_unsaved_relations s !% E E +0Kz) :;'4/: --T9
Ek74+E+EFFF*.- *D
;' E Ere Fc . | j }| j j dur| j j }| j }nd x}}|| || }nF| j j r:|s8| || j }|s| j dS |
| d}| j j r || |j
d ||s| j j r!|j D ]}| |d n| |j
d |st! d | j di | | }nw|V | j di | }|4| j j s|&|| _ | j |j
n | j di | | xj t/ | z c_ |S )NFr zno data to save!r` )r rL r' r r r r> dirty_fieldsr r r rV r r r
r
r r r5 r r r ro
rP ) ra r r r r pk_valuerS pk_part_namerI s rc r z
Model.save s9 ]''))
: ! . .z-HxHH"& &Hx ++J==JJ
Z
' ++J8IJJJ
!!### u ((444 : $ 0)9 NN8=$ / / / z'
4$,$8 7 7L NN<66667 x}d333
5 !3444 4;,,,,224==??CCKKMMDD
! **z**2244B~4:#<~#+#3 ##HM222 DK % %* % % - - / / / s:& re c * t | j S r_ )re r r s rc is_dirtyzModel.is_dirty0 r re c 4 fd j j D S )Nc 0 g | ]}|j j v |S r` )r r r
s rc rY z&Model.dirty_fields.<locals>.<listcomp>5 s' MMMaqv7L7L7L7L7Lre )r' r
r s `rc r
zModel.dirty_fields3 s" MMMM4:3MMMMre Tc # * K t | }t | d fg}i }t }|r| \ }}||v r | | |j j D ]\ } }
|
|u s| | | j | j j k } n| |z } |
|
j j | } | j
r|ra| |
g | | f | j
r|r| |
| |
| f |t! t# | D ]$}
| |
d D ] \ }}||fV %d S r )r rP r r r' rA r r r r r r r5 r r r r r! r )ra search_nullableexclude_null_children model_classr queriesr r r; rO r r= r r r qs rc dependencieszModel.dependencies7 s 4jj t**d#$uu < 99;;LE5}} HHUOOO!&!5!;!;!=!=
<
<
I ++u} $- 0A"B BDD ;D % , ,Y_-H I I "U4[[ w </ <&&y"55<<dBZHHHw <#8 < ++++ i%:;;;' <* +d++,, A Q++
A!e
re c |r| | D ]\ }}|j }|j r<|s: |j di |j d i | O| | t | | S )N)r r` )
r rA r r r r5 r r r r )ra r delete_nullabler; rO rA s rc delete_instancezModel.delete_instanceV s : ! . . EX . Y Y
:
: r7 :? : EL33BGT?3399%@@HHJJJJLLNN((//779999Dzz ""(( 99AACCCre c 8 t | j | j f S r_ )r r r r s rc r zModel.__hash__` s T^TX.///re c T |j | j k o| j d uo| j |j k S r_ )r r r s rc r z Model.__eq__c s3 Ot~ -
" HD
" H ! #re c | |k S r_ r` r s rc r z Model.__ne__i s 5= re c ^ |j j R|j j rF | t | |j j S # t
t f$ r Y nw xY w| t t | | j j j
| j j j S )Nr. ) r r/ r r) rY r r r r' r r r
r8 s rc r% z
Model.__sql__l s 9 *sy/C *
wwuTSY5H I I IJJJ z*
wwuWT4:+A+F G G'+z'='FH H H I I Is -A A A c . | j j |u}| j | |s|rh|t }| j || }|D ]9\ }}} ||vr/|j | | | :|S )N)r@ rA )r' r r| rP rP r )
r r r8 r9 rZ is_differentGrq rA
is_backrefs
rc r z
Model.bind s y)9 x((( (
( 55 %%9}%MMA()
(
($5*((K,,X666 LL'''re c ( t | f||| S r_ r; )r r r8 r9 s rc r zModel.bind_ctx s "C68Y
NNNre c n | j }| j j |j j |j S r_ )r' r r r r( rf r )r Ms rc r zModel.table_exists s+ I{#001A18LLLre c & d|v r$t d | d }|r'| j j j s| rd S | j j r | d| j j | j j |fi | d S )N
fail_silentlyzU"fail_silently" has been deprecated in favor of "safe" for the create_table() method.r
)
r r r r rE r r' r
r r. )r r/ r$ s rc r" zModel.create_table s g % % C
D
D
D;;//D ,> !! F 9 A {CI,? @ @ @ t//w/////re c |r'| j j j s| sd S | j j r | d| j j | j j ||fi | d S )Nr
)r r rF r r' r
r r2 )r r/ r0 r$ s rc r' zModel.drop_table s ,< ##%% F 9 A {CI,? @ @ @ T>==W=====re c * | j j di | d S r )r rH )r r$ s rc rH zModel.truncate_table s# " "--W-----re c t | |fi |S r_ )rB r r@ r s rc rx z Model.index s #v00000re c t | dk rIt |d t t f r'| j j |d d S | j j t | |fi | d S rR )r rv rQ r9 r' r r rB r. s rc add_indexzModel.add_index s~ v;;!
6!9sEl C C I $ $VAY / / / / / I $ $ZV%F%Fv%F%F G G G G Gre r_ )FNr rj )TTNrD rm )5rf rg rh r r classmethodr r r r r r r r r r r r r r r r r r r r r r r6 r r r r r r r r r r
r r r r r r% r r r r" r' rH rx r0 r` re rc rA rA s ( ( (O O O
[
& & & [& ? ? [? [4 E E E [E E E E [E = = = [= ? ? [?
C C C [C ) ) ) [)
* * [* [ [
> > > [ >D $ $ $ [$L ( ( [(
[
[ 4 4 [4 D D [D I I [I [ ( 9 9 [9C C C (6
CZ: : Z:2 2 2 E E E) ) ) )V! ! ! N N XN >D D D D0 0 0# # # ! ! !I I I( [ O O O [O M M [M 0 0 0 [ 0 > > > [> . . [. 1 1 [1 H H [H H Hre rA c > e Zd ZdZd
dZd Zd Zd Zd Zd Z d Z
dS ) ri z3Provide a separate reference to a model in a query.Nc . || j d< || j d< d S )NrA r )r[ )ra rA r s rc r zModelAlias.__init__ s !&
g !&
g re c | j f| j j z D ]M} |j | }t |t r| d | c S ># t $ r Y Jw xY wt | j | }t |t r0t
| | | j |< | j | S |S r_ ) rA rk r[ rv r r~ r r r2
FieldAliasr )ra r r r
model_attrs rc r zModelAlias.__getattr__ s
* !55 A
j& c?33 3 ;;tT222223
TZ..
j% ( ( '","3"3D*"E"EDM$ =& &s 7A
A! A!c t d )Nz'Cannot set attributes on model aliases.r r s rc r zModelAlias.__setattr__ s FGGGre c > fd j j j D S )Nc 0 g | ]}t | S r` r )rV rz ra s rc rY z0ModelAlias.get_field_aliases.<locals>.<listcomp> s# NNNQa NNNre )rA r' r8 r s `rc get_field_aliasesz ModelAlias.get_field_aliases s% NNNN$**:*MNNNNre c N |s| }t | | S r_ )r: r )ra selections rc r zModelAlias.select s+ 1 ..00I4+++re c | j di |S r rA )ra r s rc r zModelAlias.__call__ s tz##F###re c |j t k r| | j S | j r| j |j | < |j t k rb| | j j j d t |j | S | t |j | S r ) r rD r) rA r r rB r' r r rf r8 s rc r% zModelAlias.__sql__ s 9 $ $774:&& & : 1&*jC d # 9 $ $S)011 WV__S 1$ 78899
; 776#"3D"9::;; ;re r_ ) rf rg rh r r r r r: r r r% r` re rc ri ri s ==' ' ' ' &H H HO O O, , ,
$ $ $< < < < <re ri c N e Zd Zd Zed Zd Zd Zd Zd Z d Z
d Z d S )
r5 c : || _ |j | _ || _ d S r_ )rM rA rA )ra rM rA s rc r zFieldAlias.__init__ s \
re c R G d d| t | } ||| S )Nc e Zd ZdS )&FieldAlias.create.<locals>._FieldAliasNr r` re rc _FieldAliasrD s Dre rE )r )r rM rA rE s rc r zFieldAlias.create sF #tE{{ {65)))re c 6 t | j | j S r_ )r5 rM rA r s rc r\ zFieldAlias.clone s $+tz222re c 6 | j | S r_ )rA rA r s rc rA zFieldAlias.adapt s 4:#3#3E#:#: :re c 6 | j | S r_ )rA r0 r s rc r0 zFieldAlias.python_value s $**A*A%*H*H#Hre c 6 | j | S r_ )rA r
r s rc r
zFieldAlias.db_value s dj&9&9%&@&@ @re c F |dk r| j nt | j | S )NrA )rM r rA r s rc r zFieldAlias.__getattr__
s" "goot{{74:t3L3LLre c f | t | j | j j S r_ )r) r! rM rA r r8 s rc r% zFieldAlias.__sql__
s% wwvdk4:+ABBCCCre N) rf rg rh r r1 r r\ rA r0 r
r r% r` re rc r5 r5 s
* * [*
3 3 3 ;::HHH@@@M M MD D D D Dre r5 c t t g fdd }t | D ]
} | S )Nc , | v r| vr | | j j D ]\ }}|j s | | j j r| j j D ]
} | | d S d S d S r_ )r r' r@ r r r? r )rA r r
dependencydfsr# r: r s rc rO zsort_models.<locals>.dfs s F??uD 0 0 HHUOOO*/+*:*@*@*B*B
#
#& Y #+ #C NNN{%
$"'+"8 $ $JC
OOOO OOE " " " " " ? 0 0re c 2 | j j | j j fS r_ )r' r r; )r s rc rx z sort_models.<locals>.<lambda>" s qw|QW%78 re r )rP r )r# r) r rO r: r s ` @@@rc r! r! s
[[F 55DH # # # # # # # #
9 8E
F
&
&
& A Ore c Z e Zd Zej Z fdZej dd Z d Z
d Z xZ S )_ModelQueryHelperc t t | j |i | | j s| j j j | _ d S d S r_ )r rR r rJ rA r' r r s rc r z_ModelQueryHelper.__init__+ sM / &&/@@@@~ 7 !Z - 6DNNN 7 7re Nc H t j | _ || j n|| _ d S r_ )r r@ r rA r r s rc r@ z_ModelQueryHelper.objects0 s$ *5*=DJJ;re c | j p| j }|t j k r| | S |t j k rt
|| j | j S |t j k rt || j | j S |t j k rt || j | j S |t j
k r!t || j | j | j S t! d|z r )r r r rA _get_model_cursor_wrapperr> ModelDictCursorWrapperrA rn r= ModelTupleCursorWrapperr? ModelNamedTupleCursorWrapperr@ ModelObjectCursorWrapperr r r s rc r z%_ModelQueryHelper._get_cursor_wrapper5 s >:T%: sy 11&99 9
!
!)&$*doNN N
"
"*64:tOO O
(
(/
04A A
A
(
(+FDJ,0OT=NP P
P ;h FGG Gre c : t || j g | j S r_ )rZ rA r s rc rV z+_ModelQueryHelper._get_model_cursor_wrapperF s '
B
KKKre r_ )
rf rg rh r rA r r re rL r@ r rV r r s @rc rR rR ( s y7 7 7 7 7
YO O O YOH H H"L L L L L L Lre rR c $ e Zd Z fdZd Z xZS )r c j || _ d| _ t t | j d||d| d S )Nr` r )rA rn r r r )ra rA r) rN r r s rc r zModelRaw.__init__K sA
&h &H3vHHHHHHHre c | d S # t $ r? | \ }}| j | j d|d| w xY w)Nr . instance matching query does not exist:
SQL:
Params: )r rh r) rA r. r s rc r z ModelRaw.getP s E<<>>!$ $ E E E ((**KC*))+/:::sssFF+D E E
E Es
A A%)rf rg rh r r r r s @rc r r J sS I I I I I
E E E E E E Ere r c r e Zd Zd ZeZd ZeZd ZeZd Z e Z
d Z d Z d dZ
d d Zej d
ZdS ) BaseModelSelectc 0 t | j | d| S )NrF ModelCompoundSelectQueryrA r s rc rH zBaseModelSelect.union_all[ '
D+sKKKre c 0 t | j | d| S )NrG rd r s rc rK zBaseModelSelect.union_ s '
D'3GGGre c 0 t | j | d| S )NrH rd r s rc rK zBaseModelSelect.intersectc rf re c 0 t | j | d| S )NrI rd r s rc rL zBaseModelSelect.except_g s '
D(CHHHre c ` | j s| t | j S r_ )r r rw r s rc r zBaseModelSelect.__iter__k s+ # LLNNND()))re c " t | g|R i |S r_ )rI )ra
subqueriesr s rc rI zBaseModelSelect.prefetchp s 4z444V444re Nc | dd }d |_ | | d S # t $ r? | \ }}| j |j d|d| w xY w)Nr r r_ r` )r7 r r rh r) rA r. )ra r r\ r) rN s rc r zBaseModelSelect.gets s
a## $ F==**1- - F F F ))++KC*))+0;;;VV+E F F
F Fs
: A Bc \ | | S # | j j $ r Y d S w xY w)N)r )r rA r. r s rc r zBaseModelSelect.get_or_none~ sB 88X8.. .z& DD s ++c P g }|D ]t r | j j 1t t
r=j st d | fdj D | || _ d S )Nr c 0 g | ]}t | S r` r r s rc rY z,BaseModelSelect.group_by.<locals>.<listcomp> r re )
r& r7 r' r
rv rS r r r r^ r s @rc r zBaseModelSelect.group_by s ( (F
( :;;;;FE**
( 2$ &1 2 2 2 !B !B !B !B17 !B !B !B C C C C ''''!re r_ )rf rg rh rH r rK r rK r rL r r rI r r re rL r r` re rc rb rb Z s L L LGH H H
FL L LGI I IG* * *
5 5 5 F F F F
Y" " Y" " "re rb c $ e Zd Z fdZd Z xZS )re c V || _ t t | j |i | d S r_ )rA r re r r s rc r z!ModelCompoundSelectQuery.__init__ s3
6&--6GGGGGGre c 6 | j | S r_ )r rV r s rc rV z2ModelCompoundSelectQuery._get_model_cursor_wrapper s x11&999re )rf rg rh r rV r r s @rc re re sL H H H H H: : : : : : :re re c g }| D ]Ɗt r | j j 1t t
r(| nt t r.j r'| fdj D | |S )Nc 0 g | ]}t | S r` r )rV r fms rc rY z+_normalize_model_select.<locals>.<listcomp> s# CCC72s++CCCre )
r& r7 r' r
rv ri r: rS r r )fields_or_modelsr@ rv s @rc _normalize_model_selectrx s
F B<< MM"(0 1 1 1 1
J
'
' MM"..00 1 1 1 1
E
"
" r{ MMCCCCr{CCC D D D D MM" Mre c e Zd Zd fd Z fdZ fdZ fdZddZd Zd Z dd
Z
e j e
j dddfd Zdd Ze
j ddfd
Zd ZddZd Zd ZddZddZ xZS )r Fc |x| _ | _ i | _ || _ t | }t t | |g| d S r_ )rA _join_ctx_joins _is_defaultrx r r r )ra rA rw r r@ r s rc r zModelSelect.__init__ sV &++
T^ %()9::
k4 ))5'6:::::re c t t | }t |j |_ |S r_ )r r r\ r r| r s rc r\ zModelSelect.clone s4 k4((..00EL)) re c |s| j s3d| _ t | } t t | j | S | S rh )r} rx r r r )ra rw r@ r s rc r zModelSelect.select sJ <4#3 < $D ,-=>>F25d++2F; ; re c j d| _ t | } t t | j | S rh )r} rx r r r )ra r r@ r s rc r zModelSelect.select_extend s2 (115u[$''5v>>re Nc & || j n|| _ | S r_ )rA r{ r8 s rc switchzModelSelect.switch s '*{ re c t | r|dfS t |t r|j r |j dfS t |t r |j dfS t |t r |j dfS dS )NTFrh )r& rv rS r ri rA r )ra r s rc
_get_modelzModelSelect._get_model s C== $9
U
#
# $
$:u$ $
Z
(
( $9e# #
[
)
) $9e# #{re c t |t }|r |p|j }| }| | \ }}| | \ }} |r|r|| _ |}
|r| sst |t r^|j |u r|j j |j
} n:|j |u r|j j |j
} nt d|d|d|d d }n t |t r|} d }nd } |
||| | \ } }
||rdnd}| rdnd}|
rBt |t | | }t |t | j | }nAt |t | | }t |t | j | }||k }|s|
|
s| j
}nz|j j
}nm|r%| #|| j k r|
st# d|d| d nEt |t$ r0t& }
|p|j }|s t |t( r |p|j }|||
fS )
Nz"on" clause Column z does not belong to z or rR r r z Cannot assign join alias to "zF", as this attribute is the object_id_name for the foreign-key field "r )rv rR r r r r{ r! rM r' r r r r2 _generate_on_clauser r rJ
r r r rS rf )ra r r r r on_aliasr{
src_is_model
dest_model
dest_is_modelr rM
fk_fieldr% src_attr dest_attrr r s rc _normalize_joinzModelSelect._normalize_join s b%(( $29DB #'//#"6"6 <$(OOD$9$9!
M 3 - 3 - !DN$K !
]
2v8N8N
9## ( 6rw ?HHY$&& ) / 7 @HH(.*,""iii*E F F F B&&
#'#;#;:x$5 $5 Hj z%1D66}&3 FFF P!$)(D(DEEC!#wx/A8'L'LMMCC!#wx'B'BCCC!$0BI(N(NOOCSj
N'
'#=DD%+0DD
Nh 2H 333J3 j=ATT888"M N N N f
%
% - K&4;D
-JtU 3 3
-,t}D+&&re c
|j }dx
}||j v r|j | }n||j v r|j | }d
|s|dS t d|d|d .t t
rj n
fd|D }t | dk r
|d
fS |6|D ] }|j |j j k r|
fc S t d
|d|d d t |t r|j
|j } }t | }
t |t r%t |t
r|j n|} | |
v r| n9t | t r$t | t
r| j n| } | |
v r| dfS ) NFTrh z#Unable to find foreign key between z and z,. Please specify an explicit join condition.c 2 g | ]}|u s r |j u |S r` )r )rV r
r% r rM
s rc rY z3ModelSelect._generate_on_clause.<locals>.<listcomp>/ sC D D Dqv++$ &)*)@)@ )@)@)@re r r z"More than one foreign key between z*. Please specify which you are joining on.)r' r
rC r rv r5 rA r r r
r r rP r2 )ra r r rM
r rH r rO r r fk_setlhs_frhs_fr% r s ` @@rc r z ModelSelect._generate_on_clause s( y!&&
Y 4? " " -II
T(
(
( +D1I J
D~"{ * !cc444 ) * *
*
! )38Z(H(H $hnn#
D D D D D DI D D DI y>>Q Q<+ +
:
*
*7djo-- z>))) . * !cc444 ) * *
* b* % % %vrvC ^^F#u%%
%%/Z%@%@I cF?? $HC''
%%/Z%@%@I cF?? $H re c || j n|}|t j k s|t j k rd}n|t j k r^| |||| \ }}}|r?| j |g | j | ||||f n|t d | j
st d | j
}| j
t |||| d S )NTz)Cannot specify on clause with cross join.r )
r{ r? r2 r: r8 r r| r r r r r r )ra r r r r r r r s rc rU zModelSelect.joinY s # dnn $ $ T5F(F(FBB
$*
$
$$($8$8dB$M$M !Bk
N &&sB/// C ''t[)(LMMM
^ HII I 7 566 6""$$ tD$ 2 > >?????re c H | |t j ||| S r_ r )ra r r r r s rc r zModelSelect.left_outer_joinm s yytC>>>re c 4 | ||||| S r_ rT )ra r r r r r s rc join_fromzModelSelect.join_fromp s yyy"c4888re c t | j dk r(| j s!t || j | j | j S t
|| j | j | j | j S r )r r r| rZ rA rn ModelCursorWrapperr s rc rV z%ModelSelect._get_model_cursor_wrappers sj t 1 $ $T[ $+FDJ,0OTZI I
I!&$*do"&/4;@ @ @re c | j }| j |g D ]\ }}}}||k r| c S | | j |fd|i| | S )Nr )r{ r| r r rU ) ra lmrmr join_kwargsjoin_ctxr rq r s rc ensure_joinzModelSelect.ensure_joinz s >'+{r2'>'> #D![!rzz #t{{2#B==2===DDXNNNre c D g }g }t t f}t | D ]h\ }}| j }d|v rJ| dd d t v r'| dd \ }}t | }n |t d }n
t d }d|vrt || } n| d D ]}
| j
|d D ]J\ } } }
}
t ||
d } n# Y nxY w| |
k s t | t r| j
|
k r| } n?Kt ||
} |,t | | r | j }| | | || | j||fS )Nr`
r r r r` )r6 r r r rA rsplitr- r r r| r rv ri r r r )ra qdictr joinsfksr r~ rN r r6 piecer r rq s rc convert_dict_to_nodez ModelSelect.convert_dict_to_node s 0 // 0 0JC:Ds{{szz$ 2 21 5 C C **T1--R ^ % %3 %T3 / /
YYt__ 5 5E,0KOOD",E,E 5 5(dAq*1$t*D*DZZ$ 5==Zj-I-I=-1Z5-@-@#'D !E%,T5%9%9
,J1L1L,#-#7D !LL 4 4 4 LLJ.. / / / /e|s :D D c |r4|r2t t j d |D t di |z }nh|r4t t j d |D t z }n2|r t di |t z }n| S t
j |g }g }t }|r| }t |t s-d|j fd|j
ffD ]\ }} t | t r| | j \ }
} | D ]0} | |vr*| | | | 1t t j |
}
| j rt' |
}
t) |||
| | ||r|s|j }| }
|D ]i}t |t* r|j |j }}|}n*t |t0 r|j |j }}|j }|
||| }
j|
| S )Nc 6 g | ]}| S r` rc rV r s rc rY z&ModelSelect.filter.<locals>.<listcomp> -F-F-FAaggii-F-F-Fre c 6 g | ]}| S r` rc r s rc rY z&ModelSelect.filter.<locals>.<listcomp> r re r r r` ) rt r r r0 rN r\ r rJ rP rK rv r
r r r r; r r r rg r r6 rA r r rA r r5 )ra r r dq_noder dq_joins
seen_joinsrN sider r; r rU r rA r r field_objs rc r6 zModelSelect.filter s F hm-F-F-F-F-FGG||F||$GG
hm-F-F-F-F-FGG!||$GG
ll6llZ\\1GG::<<
wi ( (UU
$99;;D dJ//
!& 1E483D E
$
$ e eR((
$#'#<#<U[#I#ILE5 % 1 1 z11 $OOD 1 1 1 &NN4 0 0 0!'
u!=!=J ~ 9%,Z%8%8
D$
3333HHUOOOO% $( "6 " kG
9 9E% 11
( eoB ! E?33
( eoB !K %%b"i88EE{{7###re Tc 6 | j j j || |fi |S r_ )rA r r
)ra r r/ rH s rc r" zModelSelect.create_table s& 1tz!1$dKKdKKKre c | j rQ|rOt | j dk r7| j j j dur$| | j j j S | t | j S r )r} r rn rA r' r r) r3 r s rc r z ModelSelect.__sql_selection__ sq 9 9DO0D0Dq0H0H : 'u 4 4774:+788 8ww}T_55666re r r_ r r" rm )rf rg rh r r\ r r r r r r re rL r? r3 rU r r rV r r r6 r" r r r s @rc r r s ; ; ; ; ; ;
? ? ? ? ?
A' A' A'F? ? ? ? B
Y#':$Dt @ @ @ Y@&? ? ? ? .2ZDt 9 9 9 9@ @ @O O O O! ! ! F1$ 1$ 1$fL L L L7 7 7 7 7 7 7 7re r c e Zd Zd Zd ZdS )r c J | j j j | S r_ )rA r' r r@ r8 s rc r% zNoopModelSelect.__sql__ s z (88===re c t | S r_ )r r s rc r z#NoopModelSelect._get_cursor_wrapper s V$$$re N)rf rg rh r% r r` re rc r r s2 > > >% % % % %re r c . e Zd Z fdZ fdZd Z xZS )_ModelWriteQueryHelperc ^ || _ t t | j |g|R i | d S r_ )rA r r r r s rc r z _ModelWriteQueryHelper.__init__ s>
4$d++4ULTLLLVLLLLLre c g }|D ]F}t | r | |j j 1| | G t t | j | S r_ )r& r7 r' r
r r r r )ra r r r r s rc r z _ModelWriteQueryHelper.returning so # #D~~
# TZ 56666 T""""<u+T22<eDDre c F | j j j }|j |j |< d S r_ )rA r' r( rf r )ra r9 r( s rc r z'_ModelWriteQueryHelper._set_table_alias s$
&#(>% re )rf rg rh r r r r r s @rc r r sj M M M M ME E E E E2 2 2 2 2 2 2re r c e Zd ZdS )r Nr r` re rc r r Dre r c B e Zd Zej Z fdZ fdZd Zd Z xZ
S )r c t t | j |i | | j L| j j j =| j j j j r)| j j | _ d S d S d S d S r_ ) r r r rn rA r' r r r r s rc r zModelInsert.__init__ s )k4 )4:6::: ? "tz'7'@'Lz (9
F"&*"2"C"C"E"E # "'L'L
F
Fre c r |r| j t j | _ t t | j | S r_ )r r rA r r r )ra r r s rc r zModelInsert.returning
s7
' / YDN1u[$''19==re c $ | j j j S r_ )rA r' r r s rc r z ModelInsert.get_default_data s z ((re c ^ | j j j }| j j j r
|dd n|S r )rA r' r
rV )ra r@ s rc r z ModelInsert.get_default_columns s. !/ !Z - <Hvabbzz&Hre ) rf rg rh r r= r r r r r r r s @rc r r s yF F F F F > > > > >) ) )I I I I I I Ire r c e Zd ZdS )r Nr r` re rc r r r re r c 8 e Zd Z fdZd ZddZd Zd Z xZS )r
c || _ || _ |j j j | _ |j j j | _ t t | j
||fg|R i | d S r_ ) _instance _accessorr
r r _src_attrr
_dest_attrr r
r )ra r| accessorrS r r r s rc r zManyToManyQuery.__init__ sg !!! 27"*49-ot$$-cC6KDKKKFKKKKKre c Z t |d t r fd|D S |S )Nr c : g | ]}t |j S r` )r r r
s rc rY z,ManyToManyQuery._id_list.<locals>.<listcomp>) s% NNNcGC 11NNNre )rv rA )ra model_or_id_lists ` rc _id_listzManyToManyQuery._id_list' s= &q)5 1 1 ONNNN=MNNN N re Fc 6 |r| | j t | j | j t |t ri| t j j
}j j
j g| d S t | }|sd S fd| | D }j | d S )N)r@ r; c D g | ] }j j j j |i S r` )r
r r
)rV rel_idr r
s rc rY z'ManyToManyQuery.add.<locals>.<listcomp>= sB 4 4 4 $f %v/ 4 4 4re )r r r r r rv rE r rY r
r rz
r r
r rc r r )ra r~ r
r; insertsr r
s @@rc r zManyToManyQuery.add, s$ JJLLL> 88 e[ ) ) BMMf
*, ,E
" . . )9:
/
$WYYYYY ''E &&4 4 4 4 4 #mmE 2 24 4 4G
" . .w 7 7 ? ? A A A A Are c t | j | j }t |t rt |j | j }| | }| j j
| j j |z | j j
|k z S t | }|sd S | j j
| j j | | z | j j
|k z S r_ )r r r rv rE rA r r r rz
r r5 r
r
r rc r )ra r~ r
r r s rc r zManyToManyQuery.removeC s 88 e[ ) ) U[$/::F }}V,,HN0VXXU /8; .&8:; ; WYY
!''E
N0VXXU /4==3G3GG .&8:; ; WYY
re c t | j | j }| j j | j j |k S r_ ) r r r r rz
r r5 r
r )ra r
s rc r zManyToManyQuery.clearY sK 88,t~,677 re r ) rf rg rh r r r r r r r s @rc r
r
s L L L L L
B B B B. , re r
c fd}|S )Nc N | S # t t f$ r | cY S w xY wr_ )r r )r~ conv_funcs rc validatez#safe_python_value.<locals>.validateb sA 9U## #:& LLL s
$$r` )r r s ` rc safe_python_valuer a s#
Ore c . e Zd Z fdZd ZeZd Z xZS )BaseModelCursorWrapperc x t t | | || _ |pg | _ d S r_ )r r r rA r )ra r rA r r s rc r z BaseModelCursorWrapper.__init__k s8
$d++44V<<<
m re c | j j j }| j j j }| j j }t
| j j | _ g | _ d g| j z x| _ }d g| j z x| _
}t | D ]Q\ }}|d x}} | d }
|
dk r
||
dz d }|
d }| j | | j | } | } n!# t" $ r ||v r || x} } nY Y nw xY w| }
|
r
| | j |< t' | t( r)| j r
| j ||< | ||< |
s| j | j |< t' | t0 r| j r | j ||< 1t' | t4 r| j r| j | j ||< `| j rt' | j d t: r| j d }t' |t< r"|j d }| | }t' |t( rtC |j ||< ||v rB| j r|| j ||< t' | tD r| j# |k r || ||< Sd S )Nr rR rt r r )$rA r' r6 r( r r r r r
convertersr@ r r r5 r r rk rh ri rv r2 re r0 r rN rP r% r. r+ re rf r r r r! rM )ra r6 r( r r r@ r description_itemr orig_column dot_indexr r= ri rm rZ s rc r z*BaseModelCursorWrapper._initialize_columnsp s :#,
&k- 011
(,v
'::* $v
22 f%.{%;%; = 3 = 3 !C!#3A#6 6F[
S))IB A
/\\&))F L ' ' '
) ;s+ ((
X%%&.v&66Htt H $t
((**H
0$/ S!
$&&
3# 8&*&7JsO "s 2(, DL%D*--
3(2E
3"*"5
3D(++
3
3%1&*&8JsOO^ P
4>!3Dd(K(K P !N1 - 4 4 6 6E!%00 3 ${2 ( T 2 2!%// P*;E<N*O*O
38##< D&.v&6&CJsO dF++ 3 u0D0D"*6"2F3K{= 3 = 3s /
DD/.D/c t r_ r^ r s rc r z"BaseModelCursorWrapper.process_row r` re )rf rg rh r r r r r r s @rc r r j sa $ $ $ $ $
G3 G3 G3R %J" " " " " " "re r c e Zd Zd ZdS )rW c i }| j | j }}| j }t | j D ]=}|| }||v r|| || || ||< 2|| ||< >|S r_ )r r r@ r r )ra r0 r r r r@ r r s rc r z"ModelDictCursorWrapper.process_row s "lDOtz"" & &A1:Dv~~x!}( ,z!}SV 4 4t "1vt
re N)rf rg rh r r` re rc rW rW s#
re rW c e Zd ZeZd ZdS )rX c | j | j c}| fdt | j D S )Nc ^ g | ])}| | | n| *S r_ r` )rV r r r0 s rc rY z7ModelTupleCursorWrapper.process_row.<locals>.<listcomp> sM !( !( !( '1m&?]Z]3q6
"
"
"SV!( !( !(re )r r r r r )ra r0 r r s ` @rc r z#ModelTupleCursorWrapper.process_row sa "lDO !( !( !( !( !(4:&&!( !( !( ) ) )re N)rf rg rh ra r r r` re rc rX rX s( K) ) ) ) )re rX c e Zd Zd ZdS )rY c g }t j D ]"}| j | #t j d| _ fd _ d S )Nr c j | S r_ r )r0 ra s rc rx z9ModelNamedTupleCursorWrapper.initialize.<locals>.<lambda> s '7t'7'= re ) r r r r r r r r r )ra
attributesr s ` rc r z'ModelNamedTupleCursorWrapper.initialize s| """
tz"" / /A dl1o . . . .&1%DD====re N)rf rg rh r r` re rc rY rY s# > > > > >re rY c ( e Zd Z fdZ fdZ xZS )rZ c || _ t | | _ t t | ||| d S r_ )r r& r rZ r )ra r rA r r r s rc r z!ModelObjectCursorWrapper.__init__ sC & --
&--66vufMMMMMre c t t | | }| j r* | j dddi|}|j |S | j di |S )Nr r r` )r rZ r r& r r r )ra r0 r r r s rc r z$ModelObjectCursorWrapper.process_row sz -t44@@EE = ,"$"<<!<t<<C J J#4#++d++ +re r r s @rc rZ rZ sV N N N N N
, , , , , , , , ,re rZ c * e Zd Z fdZd Zd Z xZS )r c x t t | ||| || _ || _ d S r_ )r r r r r )ra r rA r r r r s rc r zModelCursorWrapper.__init__ s8
$''00GGG"
re c | t d | j D }| j | j }}| j | j i| _ i | _ g | _ t j
| j }t }|r| }t |t r5| |j | |j `|| j vrjt |t& }| j | D ]c\ }} }
} || j vrS|
| j |< | j || ||| f | | | | d||D ]I} | | j vr>t+ | r | | j | < %t | t, r| j | j | < J| j D ] \ } }
}}
}
| |v o||v p| |v | j | < g | _ t1 | D ]\ }}| j }| j | }|%t |t2 r|j }n|j }nt |t6 rJ|j | j vr4t; | d|j d|j d |j }nEt |t> r| }t |t@ r|j }| j | d S )Nc g | ] }||j S r_ r> r^ s rc rY z1ModelCursorWrapper.initialize.<locals>.<listcomp> s) 2 2 2E $ 0 "K 0 0 0re z specifies bind-to z, but z# is not among the selected sources.)!r rP r@ r r rA key_to_constructor src_is_dest src_to_destr rJ r rK rv r r r r r r r r& ri column_keysr r5 rM rW r r rk re r! )ra selected_srcr r r destsrN r r r r r r rq r r r= rA s rc r z ModelCursorWrapper.initialize sd """ 2 2T[ 2 2 2 3 3 +t|#':tz": !$.11 &==??D$%%
TX&&& TX&&&4:%% t,,G59Z5E
&
&1T; d 5553>D+C0 $++T4g-6-8 9 9 9IIcNNNLL%%%' &, = =C$111C== =36D+C00 Z00 =369D+C0 #'"2 N N CD!Q$'5L %Ndl6J 7M9< 9L
S ! ! "6** ) )IC*CK$E eZ00 & ,CC +CCD&))
&9D$;;;$&*kkmmmmTYYY &K L L L i dD)) ) ;;==D dF++ & +C # #C ( ( ( () ) )re c i }g }| j D ]/\ }} |d ||< | || 0|| j }t }t | j D ]\ }}| || } | j | }
|| } | | | | j
| r | j
| | } t | t r| | |
< t | |
| | j D ]\ } }
}}}|| } || }n# t $ r Y &w xY w| | ||vr| j | sM| |vr||vr| d rk|r|| |
< st | |
| |D ]0} t | t$ r| j 1|| j S )NT)r z
OUTER JOIN)r r r rA rP r r r r r r rv r r r r r r rA r r )ra r0 r@ object_listr r default_instanceset_keysr r| r r~ r r r r r joined_instances rc r z ModelCursorWrapper.process_row@ sV $ 7 = = ? ? - - C&;d;;;GCL ws| , , , ,"4:.55!$"233 1 1HC {{3(899H\#&FHE S!!!s#
4,,U33(D))
1#( &%0000 6:5E 9 9 1S$gy s|H
")$-
4<H$$T-=-A-A$-G-G$ x''D,@,@ %%l33 -A
9!0$8888 $ ( (H(E**
(%%'''tz""s ,D55
EE)rf rg rh r r r r r s @rc r r sZ
C) C) C)J8# 8# 8# 8# 8# 8# 8#re r c 0 e Zd Z d fd Zd Zd Z xZS )
PrefetchQueryNc |rT|r| d |D }d |D }n| d |D }d |D }t t || }|j }t t | | |||||| S )Nc g | ] }|j
S r` r> r^ s rc rY z)PrefetchQuery.__new__.<locals>.<listcomp> s !B!B!B%%+!B!B!Bre c & g | ]}|j j S r` )r r r^ s rc rY z)PrefetchQuery.__new__.<locals>.<listcomp> s $N$N$NeU_%9$N$N$Nre c g | ] }|j
S r` )r r^ s rc rY z)PrefetchQuery.__new__.<locals>.<listcomp> s !F!F!Fe%/!F!F!Fre c g | ] }|j
S r` rf r^ s rc rY z)PrefetchQuery.__new__.<locals>.<listcomp> s $D$D$DEUZ$D$D$Dre )r` r
rA r r r ) r r; r@ r%
rel_models
field_to_namerA foreign_key_attrsr s rc r zPrefetchQuery.__new__} s A
E %!B!B6!B!B!BJ$N$Nv$N$N$N!! %!F!Fv!F!F!FJ$D$DV$D$D$D! V->!?!? @ @M ]C((00
J
uN N Nre c | j rB| j D ]8}|j |j }||f}||v r t ||j || 9d S | j D ]{\ }}|j |j j }||f}| |g }|D ],}t ||| |j -t ||j
| |d S r_ ) r% r@ r r r r
r r r r rF
) ra r| id_maprA
identifierr attname
rel_instancesr s rc populate_instancez PrefetchQuery.populate_instance s ? @
?
? % .uz :
j)&==Hej&+>>>
?
? #'"4
@
@w % .u/C D
j) &
3 3 3
) ( (DD'8444K%%''''%- ????
@
@re c | j D ]l\ }}|j |j | }||f}| j r|||< ;| |g || | md S r_ )r
r r0 r r% r r )ra r| r
rA r
identityr s rc store_instancez PrefetchQuery.store_instance s " 0 - -NE7 33H4Eg4NOOH(#C
- &s !!#r***s ""8,,,, - -re )NNNNN)rf rg rh r r
r
r r s @rc r r { sj EI*.N N N N N N @ @ @"- - - - - - -re r _PrefetchQuery)r; r@ r% r
r
rA c t | g}t | D ];\ }}t |t r|\ }}nd }t |t st | st |t r| }|j t t |dz D ]}d x}} || }
|
j |
j x} t | t r| j } j j
| g } | r fd| D }fd| D }
n j j | } |s| r|u s| n |rd|z nd}t! d|| |r|fnd }|rF|t" j k rJt' t( j fdt- ||
D }| | }n|t" j k rg }t3 }t- ||
D ]K\ }}| t7 j |j |k | | L| j | t' t( j | }| t ||d | | rg }g }| D ]H}t7 |j! j" }t7 |j" }| ||f I|t" j k ra|D ]0\ }}| | | z 1| t' t( j | }n|t" j k rg }|D ]M\ }}| | t7 j |j }| ||k N| j | t' t( j | }| t || d
| =|S ) Nr c : g | ]}t |j S r` )r r )rV rO subquery_models rc rY z)prefetch_add_subquery.<locals>.<listcomp> s% GGGBw~rw77GGGre c D g | ] }t |j j S r` )r r r )rV rO last_objs rc rY z)prefetch_add_subquery.<locals>.<listcomp> s( KKKwx ):;;KKKre z using %sr( z-Error: unable to find foreign key for query: c F g | ] \ }}| | z S r` )r )rV rO rI
last_querys rc rY z)prefetch_add_subquery.<locals>.<listcomp> s@ -3 -3 -3 R :,,R000-3 -3 -3re )r FT)#r r rv ra r! r& ri r rA r r r; r' r
r rC r rJ rB rt r r+ r
r5 r? rP r r rw r r r rU r r ) r rl
prefetch_type
fixed_queriesr r target_modelr r rA fixed
last_modelrelsrC tgt_errr r
select_pksrO rI r@ rF
r r
select_fksr r
r
r
s @@@rc prefetch_add_subqueryr!
s "2&&'M ,, FP FP 8 h & & %- "Hll L(E** )x/A/A ) h
+ + ) ((H! %A,,'' F FA ! !C(!!$E J$)K /J*j11
. ' -
!'266z2FFD
OGGGG$GGGKKKKdKKK)/>BB:NN
x
|x'?'?'3'; 5AHkL00bG .2:(GG"E F F
F #/8 D % P
333 hl -3 -3 -3 -3$'SMM-3 -3 -3 4 4 $>>$// -"444 UU
!#smm ' 'FBKK
bn E E KLLL NN2&&&&#,,..33%J%z2 hlD11 4 3 3
xeT!J!J K K K K
PDF#
5
5 #NG4E4J K K "8W\::
y( 34444
333+1 J J'IxKK Z->->x-H-H HIIII#>>& t*D*DEE -"444
+1 5 5'Ix %%h/// $Z\83G H HFKK V 34444#,,..33%J%z2 hlD11 4 3 3
x4!N!N O O O re c |s| S | dt j }|rt d|z t | || }i }i }t | D ]}|j }|j r;|j D ]3} | | g ||
| 4| |i || }
t | | } |j
D ]M} |j r| | |
| r,|| D ]#}
|
| ||
j $Nt! |j
S )Nr
zUnrecognized arguments: %s)r rJ rB r r!
r rA r@ r
r r re r r; r
r
r` )r rl r r
r
depsrel_mappq query_modelr r
has_relationsr| rS s rc rI rI s JJ
0CDDM
@5>???)"j-HHM
DG}%% E Eh
9 . ]
.
. ""9b111 "))"---- R(((k" W[[ 5 566
E EHy
4!!(F333
E";/ E EC))(DODDDD E >>re r_ r` r r )rI (V bisectr r
contextlibr rL r functoolsr inspectr
r&
r r rq rM r loggingr rD r8
r7
rm r r r r collections.abcr ImportError pysqlite3r pysq3 pysqlite2rg sqlite_version_info psycopg2cffir
rq r r r r ri psycopg2.extrasr pg_register_uuidr# psycopgrl rk rm __version____all__r\ Handler getLoggerr
addHandlerr unicoderT rW rU bufferr rv callabler r` ra frozensetrP r execrr builtinsrs rt r r r9 r r0
r r r r r r register_adapterrt r r r r register_converterra r r r r r r r r r ru r{ rE r r ler ger lshiftr- r r? r rJ r rB rD rF rH rv rw rx compileri rk rG rJ rP r[ r& rc rg rn r r~ rL r& r r r r r r# rO r3 re rq ry r r r r r r3 r r r rS r rZ r rN r! r r r rR rW rg r r rY r r r r r` rd r
r rf rQ r r% r5 r[ rF r{ r r ru r3 r. r r r1 r0 rW rM r r r r r r! rC rE rN rA rP r r r
r r9 rB rF rT r8 r% r' r; r< r= rD rF rK rb
EXCEPTIONSr ru rv rx r{ r} localr r r r$ rO rR rG rC r r r r r r r r r r r r r% r2 r r: r rO r r r7 rH r4 r/ r* r} r r3 rT r r r r r rX r r r r r r) r( rU r
rV r> r r r6 r+ r, r~
r
r@ r
r" r
rN r4 r r. r r r< rA ri r5 r! rR r rb re rx r r r r r r r
r r rW rX rY rZ r r r!
rI r` re rc <module>rJ
s) % % % % % %
$''''''' $ $ $########$))))))) -------
NNN
*g.III GGG
######FO D OOO4444440000000 Hyyy AAAAAA D ,,,,,,, JJJ L L L \####### go
8 $ $ ++-- A!IJK )LI 3/KD ?@@@ OOO),,,,,,, ) ) )(((((((() 11IIJ KJ D 36K
WXw
'
'F (L g (9
%FF' ' '' ' ' # G W_c222 G X]C000 G X]C000
7""888KKK J J J ! !24DEEE""6<888"";0ABBB 4" IJJ
!!
# # -1133 !4 X !4 X $ $ $; ; ;) ) )H H H H Ht H H H 688 X
t
C 3 s s
s
t!" t#$ 8%& t'( 8)*
+, '-.
I/0 812
I34 456 S7> X
+
+ ;
+ ;
+
/
.
. 2 2
4
466
H 8
Z
I
B 6 & Z
! "
# $ &% &
I' . x
"
$ & & & h
2: 233 2: 344 "
$ ) ) ) ) ? ? ?
9 8G G GC C C9 9 9 &; &; &; &; &;F &; &; &;R E 0 $ # # # #f # # # )! )! )! )! )!6 )! )! )!X, , , , , "K "8 .:
;
; , , ,. h0 h0 h0 h0 h0f h0 h0 h0V: : :(
. 6 D F V f B B B B B4 B B B/8 /8 /8 /8 /8T /8 /8 /8d$ $ $ $ $f $ $ $N zE
3
3
3
3
3
3
3
38 8 8 8 8 8 8 82\* \* \* \* \*OY \* \* \*~ 9 , ) F< < < < </6 < < <~K K K K K K K K\P P P P PZ P P P,
"
"
"
"
"*
"
"
"' ' ' ' 'F ' ' ' V $0 $0 $0 $0 $0K $0 $0 $0N" " " " "[ " " "2 2 2 2 2k 2 2 2 $ $ $ $ $6 $ $ $ 2 2 2 2 2\; 2 2 25 5 5 5 5J 5 5 5*& & & & &K & & & & & &
2
2
2
2
2;
2
2
2 { D3 3 3 34 4 4 4) ) ) ) ) ) ) ) X6 6 6 6 6z 6 6 6G G G G GZ G G G"
*
> > > >C C C C Cz C C CL XdDk k k k kT k k k\ 6 6 6 6 6$ 6 6 6& & & & &$ & & &. . . . .: . . .( , z 0! ! !' ' ' / / / / / / / / :j ! !
'&& & & & &[ & & & 7% 7% 7% 7% 7% 7% 7% 7%t d% d% d% d% d% d% d% d%N$ $ $ $ $y $ $ $(L L L L LI L L L^ % ,> > > > > &+ > > >H@% @% @% @% @%* @% @% @%F{% {% {% {% {%Z {% {% {%|1 1 1 1 1% 1 1 1h/- /- /- /- /-[ /- /- /-d\A \A \A \A \A[ \A \A \A~ - - - - -[ - - - > > > > >D > > >B%P %P %P %P %P %P %P %PP 5 5 5 5 5i 5 5 5
2 1 1 1 1? 1 1 1 * * * * *O * * * $ $ $ $ $
$ $ $ ) ) ) ) )] ) ) ) + + + + +_ + + + ( ( ( ( (M ( ( ( , , , , ,
, , , + + + + +} + + + + + + + +} + + +I I I I Iv I I I. &"$$"*(( 0)% ' '
)(44 ' &13 3
('DF F ,[+46 6 &{%noFF v $ @ ? ? ? ?' ? ? ?8 8 8 8 8 8 8 8 } } } } }( } } }@ & & &S4 S4 S4 S4 S4X S4 S4 S4l a; a; a; a; a; a; a; a;H]# ]# ]# ]# ]#H ]# ]# ]#F5 5 5 5 5f 5 5 50@ @ @ @ @f @ @ @8-& -& -& -& -&6 -& -& -&`# # # # # # # #RI I I I IF I I IX
$& & & & &m & & &, , , , ,+ , , , V .
'
'
'
'
'F
'
'
' ' ' ' ' ' ' ' 'D f 2 2 2 2 2v 2 2 2&r r r r r J r r r j u 5 l 9 9 9 9 9 9 9 9 9 6 6 6 6 6I 6 6 6? ? ? ? ?i ? ? ? * 5 5 5 5 55 5 5 5> O O O O O5 O O O= = = = = = = = Y >&+ &+ &+ &+ &+|_ &+ &+ &+R\, \, \, \, \,f \, \, \,~B B B B B- B B B,A A A A A) A A A? ? ? ? ? ? ? ?.E E E E Ei E E E4
C C C C C% C C C, , , , ,' , , ,6& & & & &# & & &6, , , , ,# , , ,4 X6 X6 X6 X6 X6_ X6 X6 X6v< < < < <o < < < 5
HI HI HI HI HIe HI HI HIV ; ; ; ; ; ; ; ;F
6
6
6
6
66
6
6
6
). ). ). ). ).m ). ). ).XP" P" P" P" P"i P" P" P"fE E E E E9 E E E06( 6( 6( 6( 6(9 6( 6( 6(r v Jl" l" l" l" l"F l" l" l"^c c c c cv c c cL H $ # # # #9 # # #~) ~) ~) ~) ~) ~) ~) ~)B2 2 2 2 2& 2 2 2*IH IH IH IH IHNN9d + + IH IH IHX7< 7< 7< 7< 7< 7< 7< 7<tD D D D D D D D2 . L L L L L L L LD
E
E
E
E
E (
E
E
E 9" 9" 9" 9" 9"' 9" 9" 9"x: : : : :0C : : : r7 r7 r7 r7 r7/6 r7 r7 r7j % % % % %k % % %2 2 2 2 2 . 2 2 2& (& I I I I I(& I I I4 (& ? ? ? ? ? k ? ? ? D R" R" R" R" R" . R" R" R"j 3 ") ) ) ) ) 4 ) ) )> > > > >#: > > >, , , , , 5 , , ,"C# C# C# C# C#/ C# C# C#L+- +- +- +- +-*K*+; >M N N +- +- +-\J J JZ s &A- - A;:A;?B B# BB#B B# B B#"B#'C C
C
C$ $C,+C,0
D ;D D D D D D D D D1 1D98D9=E E
E E# #E>=E>(G/ / G=<G=