e, Z3e j& e j- $ d?1 G d@ dAe, Z4e j& e j- $ dB1 e j- $ d1 G dC dDe, Z5e j& e j- $ dE1 G dF dGe,ej0 Z6dH Z7dS )JzWsqlalchemy.orm.interfaces.LoaderStrategy
implementations, and related MapperOptions. )absolute_importN )
attributes)exc)
interfaces)loading)
properties)query)
unitofwork)util)_DEFER_FOR_STATE)_SET_DEFERRED_EXPIRED)LoaderStrategy)StrategizedProperty)_state_session)
InstanceState) _none_set)aliased )event)inspect)log)sql)visitorsFc 8 t t j | j g }
g } |o| j |r!| j r| t | j | j j
v r3| j j
| j \ | fd |r | t j |r)| j
r | j r| fd |j D ]} | | j | j u r| j | j sct) j | j | j f| |||
|o| j p| j t0 j u ||||| p| j | j d | }
| D ]} ||
| d S )N)defaultc 6 t j | |j fi S N)orm_util_validator_eventskey)descpropfnoptss P/opt/cloudlinux/venv/lib64/python3.11/site-packages/sqlalchemy/orm/strategies.pyz%_register_attribute..B s* x 9dh &* c 0 t j | S r )r backref_listeners)r" r# backrefuselists r& r' z%_register_attribute..P s :#?'7$ $ r( ) parent_tokenr, compare_function useobject extension trackparent typecallable callable_active_history
impl_classsend_modified_eventsdoc) listr to_listr0 r,
single_parentappendsingle_parent_validatorr! parent
validatorsr track_cascade_eventsback_populates_effective_sync_backrefself_and_descendants_propsget
class_manager_attr_has_implr register_attribute_implclass_ directionr ONETOMANYviewonlyr7 )r# mapperr/ r. r2 r3 proxy_propertyr4 r5 kw
attribute_ext listen_hooksmr" hookr+ r$ r% r, s @@@@r& _register_attributerS ) s2 dnbAAABBML(DLG 5T' 5 3444 x4;)));)$(3D
=J ;<<< % t3
"
( ! ! 18<< H
/00::
5 " !1#' % & >~)== )# -%)2]%G$-6GH% & ' D, %
!
!T4 9 ! !r( )
instrumentdeferredc 6 e Zd ZdZdZ fdZ ddZd Z xZS )UninstrumentedColumnLoaderzRepresent a non-instrumented MapperProperty.
The polymorphic_on argument of mapper() often results in this,
if the argument is against the with_polymorphic selectable.
columnsc | t t | || | j j | _ d S r )superrW __init__parent_propertyrY selfr= strategy_key __class__s r& r\ z#UninstrumentedColumnLoader.__init__ s5
($//88 NNN+3 r( Nc b | j D ]&}|r
|j | }| | 'd S r )rY r; ) r_ context query_entitypathloadoptadaptercolumn_collectionkwargscs r& setup_queryz&UninstrumentedColumnLoader.setup_query sJ ( (A
'OA& $ $Q ' ' ' ' ( (r( c d S r )r_ rc re rf rL resultrg
populatorss r& create_row_processorz/UninstrumentedColumnLoader.create_row_processor s
r( r ) __name__
__module__ __qualname____doc__ __slots__r\ rk rp
__classcell__ra s @r& rW rW sq I4 4 4 4 4
(
(
(
(
r( rW Tc 8 e Zd ZdZdZ fdZd Zd Zd Z xZ S ) ColumnLoaderz8Provide loading behavior for a :class:`.ColumnProperty`.)rY is_compositec t t | || | j j | _ t | j d | _ d S )Ncomposite_class)r[ ry r\ r] rY hasattrrz r^ s r& r\ zColumnLoader.__init__ sL
lD!!**6<@@@+3 #D$8:K L Lr( c | j D ]&} |r
|j | } | | '| j d }
|r
|j |
}
|
|| j < d S Nr )rY r; r] ) r_ rc rd re rf rg rh memoized_populatorsri rj fetchs r& rk zColumnLoader.setup_query ss ( (A
'OA& $ $Q ' ' ' ' Q +OE*E49D 0111r( c d| _ | j d j }| j j p,| j d j p|j t | j v }t | j |d|j | d S )NTr F)r/ r. r4 )
is_class_levelrY typer] r4 primary_keyversion_id_colsetrS compare_values)r_ rL coltyper4 s r& init_class_attributez!ColumnLoader.init_class_attribute s ",q/&
/
:|A*
:$DL(9(99 $ 3)
r( c | j D ]N}|r
|j | }| |d } | r%|d | j | f d S O|d | j df d S )NFquickexpireT)rY _getterr; r! )
r_ rc re rf rL rn rg ro colgetters
r& rp z!ColumnLoader.create_row_processor s
< : :C
+ oc*^^C//F
7#**DHf+=>>>
x ' '4(8 9 9 9 9 9r( )
rq rr rs rt ru r\ rk r rp rv rw s @r& ry ry sx CB)IM M M M M
: : :,
$
:
:
:
:
:
:
:r( ry )query_expressionc 0 e Zd Z fdZd Zd Zd Z xZS )ExpressionColumnLoaderc t t | || t j t fd| j j D | _ d S )Nc 3 D K | ]}| V d S r )compare).0rj nulls r& z2ExpressionColumnLoader.__init__.. sA ,
,
$% $ ,
,
,
,
,
,
r( ) r[ r r\ r r anyr] rY _have_default_expression)r_ r= r` r ra s @r& r\ z ExpressionColumnLoader.__init__ st
$d++44V\JJJxzz(+ ,
,
,
,
)-)=)E,
,
,
)
)
%%%r( c d } |rd|j v r|j d g} n| j r | j j } | d S | D ]&}
|r
|j |
}
| |
'| d } |r
|j | } | || j < d S )N
expressionr )
local_optsr r] rY r; ) r_ rc rd re rf rg rh r ri rY rj r s r& rk z"ExpressionColumnLoader.setup_query s 3|w'999 ),78GG
* 3*2G ? F ( (A
'OA& $ $Q ' ' ' '
+OE*E49D 0111r( c & |rd|j v r|j d g}|D ]N} |r
|j | } | | d }
|
r%|d | j |
f d S O|d | j df d S d S d S )Nr Fr r T)r rY r r; r! ) r_ rc re rf rL rn rg ro rY r r s r& rp z+ExpressionColumnLoader.create_row_processor s
>|w'999 ),78G
>
> /!/#.C U33 w'..&/ABBBEE 8$++TXt,<===== > >99r( c p d| _ t | j |d| j d j j d d S )NTFr )r/ r. accepts_scalar_loader)r rS r] rY r r r_ rL s r& r z+ExpressionColumnLoader.init_class_attribute" sI " !\!_ 1 @"'
r( )rq rr rs r\ rk rp r rv rw s @r& r r se
: : :<> > >$
r( r )rU rT )
do_nothingc B e Zd ZdZdZ fdZd Zd Z d dZd Z xZ
S )
DeferredColumnLoaderzAProvide loading behavior for a deferred :class:`.ColumnProperty`.)rY groupc t t | || t | j d rt d | j j | _ | j j | _ d S )Nr| z8Deferred loading for composite types not implemented yet)r[ r r\ r} r] NotImplementedErrorrY r r^ s r& r\ z DeferredColumnLoader.__init__6 so
"D))226<HHH 4'): ; ; %M
+3 )/
r( c | j s0| j j }|d | j |f d S |d | j df d S )Nnewr F)r r] _deferred_column_loaderr; r! ) r_ rc re rf rL rn rg ro set_deferred_for_local_states r& rp z)DeferredColumnLoader.create_row_processor? sl " ;$<
)
u $ $dh0L%M N N N N N x ' '5(9 : : : : :r( c | d| _ t | j |d| j d j j | j d d S )NTFr )r/ r. r3 expire_missing)r rS r] rY r r _load_for_stater s r& r z)DeferredColumnLoader.init_class_attributeO sO " !\!_ 1 @*
r( Nc |r:d|j v r1t | j | j j s7|r*| j r#|j d| j z d s |r7| j |v r. | j
d j |||||||fi | d S | j rt || j < d S t || j < d S )N undefer_pkszundefer_group_%sF))rU F)rT T)r r rY intersectionr= _should_undefer_in_wildcardr rD r! r]
_get_strategyrk r r r
)
r_ rc rd re rf rg rh r only_load_propsrN s
r& rk z DeferredColumnLoader.setup_query[ s2 I "W%777 %%22K; 8
8 J 8 &**&3U 8 8 %)H$?$?
D . .;
!#
I8M 4 5 5 58H 4 5 5 5r( c j s t j S |t j z s t j S j j } j r fd|j D }n j g}fd|D }t }|2t j dt j
d j d | | }t j |j | t j t j S )Nc g | ]H}t |t r1t |j t r|j j k A|j IS rm )
isinstancer strategyr r r! )r pr_ s r&
z8DeferredColumnLoader._load_for_state.. sb a!455 qz+?@@
Gtz)) *))r( c & g | ]
}|j v |S rm )
unmodified)r kstates r& r z8DeferredColumnLoader._load_for_state.. s& <<
r( c V fd}|d j |f d S )Nc j r5| j j | | d S d |j < d S r )r, r get_implr!
initializer dict_rowr_ s r& invoke_no_loadz5NoLoader.create_row_processor..invoke_no_load sJ |
'
&&tx00;;E5IIIII"&dhr( r r; r! ) r_ rc re rf rL rn rg ro r s ` r& rp z NoLoader.create_row_processor sD ' ' ' ' ' 5 $(N!;<<<<| j o6| j j d | j d| j j | _ | j rlt5 | j D ]:}|| j j v r*| j j | D ]}| j | | j |< ;| j d | d S d S )
Nr r r T)reverse_directionz%s lazy loading clause %sr use_proxies equivalentsz2%s will use query.get() to optimize instance loads)r[ r r\
strategy_optsr r r r r r] _join_conditioncreate_lazy_clauser r r r r r loggerinfor, _get_clauser rL _equivalent_columnsr r8 )r_ r= r` join_conditionr rj ra s r& r\ zLazyLoader.__init__ s
j$ (( >>> ! / 77 B ! / 7> I ' 4 4 E -=
- - / /
O !
- - - E E
! %
4dDOLLL % %
L
'*22 K ; 3
< D 122
N
N$+999 ![ )
r( c | j | j c}g d }t j |i d|i fd}t j |i d|i }|fS )Nc d| _ d S NF)unique) bindparams r& visit_bindparamzFLazyLoader._memoized_attr__simple_lazy_clause..visit_bindparamg s $I r( r c | j v r* | j | j d f d S | j $ | j d | j f d S d S r )_identifying_keyr; r! callablevalue)r bind_to_colparamss r& r zFLazyLoader._memoized_attr__simple_lazy_clause..visit_bindparaml s )[88
!
#I$>? #+
y}dIO DEEEEE ,+r( )r r r traversecloned_traverse)r_ criterionr r r s @@r& "_memoized_attr__simple_lazy_clausez-LazyLoader._memoized_attr__simple_lazy_clauseb s "&/43D ; % % % )R+)GHHH
F
F
F
F
F
F , rK 9
& r( c | j \ }}| t j |d |D S | j j }| }t
j | }|t j z r|t j z }i }|D ]O\ } }
} |
B|r(|t j z r|
|||
| } n| |||
| } | || < P||fS )Nc g | ]\ }}}| S rm rm )r r! identr s r& r z4LazyLoader._generate_lazy_clause.. s DDD$5CCDDDr( ) r sql_utiladapt_criterion_to_nullr] r= objr
instance_dictINIT_OKLOAD_AGAINST_COMMITTED#_get_committed_state_attr_by_column_get_state_attr_by_column) r_ r r r
param_keysrL or r r! r$ r s r& _generate_lazy_clausez LazyLoader._generate_lazy_clause~ s $ 8 : =3DDDDD
%, IIKK(++ Z' ' * z) )G!+ C w)J J " F F ueW EE # < < ueW E F3KK& r( c 8 t j d| d|d )N'z ' is not available due to lazy=')sa_excInvalidRequestError)r_ r r r s r& _invoke_raise_loadz LazyLoader._invoke_raise_load s* ((8<ddd C
r( c |j s&| j j s|j r|j s t
j S |j }d }|t
j z s| j r|t
j z s|r t
j
S | j r<|t
j z s-| j r|t
j
z r| ||d t | }|sM|t
j z r t
j
S t! j dt% j | d| j d | j r| ||| }t
j
|v r t
j
S t
j |v r t
j S t- j | rd S | | j ||| }||t
j u rd S |S |t
j z r|t
j
z s t
j
S | |||| S )Nr r z> is not bound to a Session; lazy load operation of attribute 'r )r lazy_loaded_from) r! r] load_on_pending
_load_pending
session_idr r r r NON_PERSISTENT_OKr r NO_RAISERELATED_OBJECT_OKr4 r r r r r _get_ident_for_use_get NEVER_SETr
issupersetr
_identity_lookupr PASSIVE_CLASS_MISMATCH_emit_lazyload)r_ r r pendingprimary_key_identityr instances r& r zLazyLoader._load_for_state s] y )(8 ) + )
# ) ( (i- # *++ 0DL 0*66 0;B 0 / /
= j 11 = L = Z 99 =
# #E7G < < < '' ,,
4!33// %e,,,,dhhh8
< 4#'#>#>$ $ +/CCC!33%)===!++#$899
t }}77 $ !& 8 H #z @@@ 4#Oj //
4 !==
4 "33"" U 0'
r( c j j }t j z r|j n|j j fd j j D S )Nc D g | ] } j | S )r r )r pkr get_attrr r_ r s r& r z5LazyLoader._get_ident_for_use_get.. sD
HUE4#8# j
! rd S n3t; j t> j"
! rd S j
r |d | fd
fd } || fd
| # }
j$ r|
S tK |
} | r*| dk r t; j& d j z |
d S d S )Nc 8 | j S r )r
r )r r_ s r& r' z+LazyLoader._emit_lazyload..) s t{)C)C r( c P | d S r )_adapt_all_clauses_with_invoke_all_eagersqs r& r' z+LazyLoader._emit_lazyload.., s a**,,DDUKK r( T)fullc N | j j j S r ) select_fromrL r] secondaryr_ r_ s r& r' z+LazyLoader._emit_lazyload..5 s" !--K!5!? r( c , | d S r ) autoflushr^ s r& r' z+LazyLoader._emit_lazyload..> s Q[[%7%7 r( r c . | S r _set_lazyload_fromr_ r s r& r' z+LazyLoader._emit_lazyload..P s a.B.B5.I.I r( c P | j t j j j S r )order_byr r9 r] rd s r& r' z+LazyLoader._emit_lazyload..X s# *!*\$"6"?@@ r( c | j | j j j S r )optionsLoadfor_existing_path
_current_pathr= lazyloadr! )r_ revstrategy_optionss r& r' z+LazyLoader._emit_lazyload..g sF aii(-?? OCJ 7 "(37++ r( c . | S r )filter)r_ lazy_clauses r& r' z+LazyLoader._emit_lazyload..z s +!6!6 r( c J | j | _ | S r )update_params)r_ r s r& set_default_paramsz5LazyLoader._emit_lazyload..set_default_params~ s# MM!) $ $ $ AIHr( c . | S r rh rj s r& r' z+LazyLoader._emit_lazyload.. s !*>*>u*E*E r( r zKMultiple rows returned with uselist=False for lazily-loaded attribute '%s' r )'r add_criteriar] bake_queriesspoilrc r! r NO_AUTOFLUSH load_options load_path_add_lazyload_optionsr r r4 with_post_criteria_load_on_pk_identityr
rL rl _reverse_propertyrI r r _use_getr r r r/ r has_intersectionr r values
_never_setallr, lenwarn)r_ rt r r rD r r_ rC effective_pathr{ rn lrw r rs s `` ` @@@r& rB zLazyLoader._emit_lazyload s 6
LLCCCCT J J K K
#0
GGG ) 5
NN
i- 9g
77 9
NN77 8 8 8 H #_T-A BN
# #E$6 G G G <
!
H''wGGG '
##$I$I$I$IJJ%%MM$+..0D
(
NN
'9 C
!555L 6"3<<< 6
# 8 8 H H V $X%7 II
t
"8#6
H
H 4 D # #E7N C C C 6666777
AgJJ
E E E E
F
F
2
3
3
SUU < MF A
q55IJ ./ ay tr( c ,
| j
| j sMt j |j t
|
}|d | j |f d S |j s|j r)
fd} |d | j | f d S d S )Nr c 4 | | d S r )_reset)r r r r! s r& reset_for_lazy_callablez@LazyLoader.create_row_processor..reset_for_lazy_callable s UC(((((r( ) r! r r "_instance_level_callable_processorrE LoadLazyAttributer; populate_existingalways_refresh) r_ rc re rf rL rn rg ro set_lazy_callabler r! s @r& rp z LazyLoader.create_row_processor s h" J @"$5c4$@$@#!G !G
u $ $dh0A%B C C C C C
&
J&*?
J
)
)
)
)
)
u $ $dh0G%H I I I I I
J
Jr( )rq rr rs rt ru r\ r r! r/ r4 r r= r dependenciesrW rB rp rv rw s @r& r r s
I / / / / /b
0! ! !8 ! ! !@
V
V
V
p
T-..% % /.% T899H H :9H T J J J J J J Jr( r c , e Zd ZdZd Zej fdZdS )r z-serializable loader object used by LazyLoaderc , || _ |j | _ d S r )r! r` )r_ r! initiating_strategys r& r\ zLoadLazyAttribute.__init__ s / <r( c | j }|j j }|j | }|j | j }| || S r )r! r rL rC r r` r )r_ r r r! rM r# r s r& r zLoadLazyAttribute.__call__ sF h -. %c*#D$56''w777r( Nr rm r( r& r r sE 77= = = '1&< 8 8 8 8 8 8r( r immediatec * e Zd ZdZd Z ddZd ZdS )ImmediateLoaderrm c ` | j d | d S N)r r r] r r r s r& r z$ImmediateLoader.init_class_attribute 2 ** !
v
&
&
&
&
&r( Nc d S r rm ) r_ rc r re rf rg rh parentmapperri s r& rk zImmediateLoader.setup_query s
r( c V fd}|d j |f d S )Nc d | j | | d S r )r r! rD r s r& load_immediatez.load_immediate s- NN48 $ $ ( ( 6 6 6 6 6r( delayedr ) r_ rc re rf rL rn rg ro r s ` r& rp z$ImmediateLoader.create_row_processor sD 7 7 7 7 7 9 $$dh%?@@@@@r( NN)rq rr rs ru r rk rp rm r( r& r r sX I' ' '
A A A A Ar( r subqueryc e Zd ZdZ fdZd Z ddZd Zd Zd Z d Z
d
Z d Z G d d
e
Zd Zd Zd Z xZS )SubqueryLoader)
join_depthc | t t | || | j j | _ d S r )r[ r r\ r] r r^ s r& r\ zSubqueryLoader.__init__ s4
nd##,,V\BBB .9r( c ` | j d | d S r r r s r& r z#SubqueryLoader.init_class_attribute r r( Nc h |j j sd S |j j r|j d || j }| |j dd } | | }
n| j }
|j dt j j
} | |z } | |j d sY| j r6|j j
r|j j
j nd|j z dz | j k rd S n | | j rd S | | \ } }
}|j dt$ f|j }| || |
||j }|j |
}dt$ f|d| i|_ | d }| || \ }}} |j | }| |||||
}| || ||
}| | }| |j d| d S ) Nr path_with_polymorphic)
subquery_pathNloaderr r
orig_queryF) r
_enable_eagerloads
_yield_per
_no_yield_perr] rD r r r PathRegistryrootcontainsr rq lengthcontains_mapperrL
_get_leftmostr _generate_from_original_query entity_zeror _attributes_set_enable_single_crit_prep_for_joins add_columns _apply_joins_setup_options_setup_outermost_orderbyr )r_ rc r re rf rg rh r ri with_poly_entityeffective_entity subq_pathleftmost_mapper
leftmost_attrleftmost_relationshipr
left_aliasr_ to_join
local_attr parent_aliass r& rk zSubqueryLoader.setup_query s }/ 4 F
]
% 4 M ' '
3 3 3D() 88 7
' / #{ &** #X%:%?
$ }}W /::
#=6
3:: k " ( ( F( **4;77
y ) )
! '++
> *GM
77 !
$ $%5 6 6
> *J #Y
% %e , ,,0,@,@ -
-
)\
AM: &
w
L2B
9j:J K K ) )! , ,
#Z33333r( c j t j d }| j | r | j d u r| j | j c}n |d c}|j }fd|D }||fS )Nr r c f g | ]-}t d j j | j .S r )getattrr _columntopropertyr! )r rj r r s r& r z0SubqueryLoader._get_leftmost..k sL
! #_%Fq%I%M
r( )re r _class_to_mapperr= isar]
local_columns)r_ r subq_mapper
leftmost_prop
leftmost_colsr r s ` @r& r z SubqueryLoader._get_leftmost\ s N / ! ==
KOOK ( ( G$ ! 44-1[$:N *O]]-8)A, *O]%3
#
}<. s0 # "8} 8 M 8 8 8r( FTc 3 $ K | ] }|j V d S r )table)r rj s r& r z?SubqueryLoader._generate_from_original_query.. s$ 66Q666666r( use_mapper_path)_clone correlate _from_obj_set_select_fromr8 r column_descriptions_adapt_col_list
_set_entitiesdistinct_target_key _distinctr? r _order_byrl _limit_offset with_labelsr r AliasedClass) r_ r r r r orig_entityr_ target_colsr tembed_qr s r& r z,SubqueryLoader._generate_from_original_queryt s
) )$ / / {
'1'E
" ''
66 $$$ 3 G $ & & AKK
( 66+66666
;''221=AA "&AKE
;% )2AK
8 1 AK
--//**,, * Wd
r( c
g }t | }t | D ]\\ }\ }}|dk r0||dz
d j }| | r|n|} n|} | | |j f ]t | dk r|
nEt |d d }
|
j r|
j
nt j |
j
d
j
j }
fd| D } ||
fS )Nr r r Tr c Z g | ]'}t j j | j (S rm )r r= r r! )r rj r r_ s r& r z2SubqueryLoader._prep_for_joins.. s@
L$+"?"B"F G G
r( )r8 pairs enumeraterL r r; r! r r r r r r r] r )r_ r r r r irL r# prev_mapper to_appendr
local_colsr r s ` @r& r z SubqueryLoader._prep_for_joins sJ Y__&&''!*5!1!1 2 2 A~1uu $AEl1o 4 +6??6+B+B NKK " NNItx0 1 1 1 1
w<**D$
#{ ( 4K )7
L00r( c t | }|dk r2t ||d d | g}nu|dk r`t ||d d | t ||d d | g}n|dk rd |dd D }g }|r| d } t | d | d }
|r"|
|d d }
n|
| }
| |
|t ||d d |d j g|z t ||d d | gz }|D ]}
| |
d }|S )Nr r r r c g | ]K}t |d j st j |d n |d j |d fLS )r r )r r r r r )r items r& r z/SubqueryLoader._apply_joins.. sg #47++<(H)$q'222 a G r( T)from_joinpoint)r r of_typepopr; r= join) r_ r_ r r r r ltjmiddleinnerr attrs r& r zSubqueryLoader._apply_joins s 'll !88
GAJqM22::;KLLGG AXX
GAJqM22::<HH gbk!n55==$ GG 1WW $AbDM F E
# zz!}} tAwQ00 6 <<q ! 55DD << 55D T"""
# WQZ]33;;E!HOLLM L'"+a.99AA(
2 2DtD11AAr( c t | | } |j |j }|j r |j |_ |S r )_with_current_path_conditional_options
_with_options_populate_existing)r_ r_ r r r s r& r z SubqueryLoader._setup_options sE
+ + "A "J$< = ( A#-#@A r( c | j j rM|j d }|j t j | j j } |j | }|S r )r] rl r _target_adaptercopy_and_processr r9 )r_ r_ eagerjoineager_order_bys r& r z'SubqueryLoader._setup_outermost_orderby" s] (
, AI & 6 G G T 1 :;; N
N+Ar( c . e Zd ZdZdZd Zd Zd Zd ZdS ) SubqueryLoader._SubqCollectionszGiven a :class:`_query.Query` used to emit the "subquery load",
provide a load interface that executes the query at the
first moment a value is needed.
Nc || _ d S r )subq)r_ r s r& r\ z(SubqueryLoader._SubqCollections.__init__9 s
DIIIr( c n | j | | j || S r )_data_loadrD )r_ r! r s r& rD z#SubqueryLoader._SubqCollections.get< s- z!
:>>#w// /r( c t j t | _ t j | j d D ]/\ }}| j | d |D 0d S )Nc | dd S )Nr rm xs r& r' z7SubqueryLoader._SubqCollections._load..C s qu r( c 3 & K | ] }|d V
dS )r Nrm r vvs r& r z8SubqueryLoader._SubqCollections._load..D s& $7$7rRU$7$7$7$7$7$7r( ) collections defaultdictr8 r itertoolsgroupbyr extend)r_ r vs r& r z%SubqueryLoader._SubqCollections._loadA sn $066DJ!)$)__EE
8
81
1
$$$7$7Q$7$7$77777
8
8r( c @ | j | d S d S r )r r )r_ r r r s r& r z&SubqueryLoader._SubqCollections.loaderF s# z!
"!r( ) rq rr rs rt r r\ rD r r rm r( r& _SubqCollectionsr 0 sa 0 0 0
8 8 8
r( r+ c F | j j | j j j st j d| z || j }| |j d }|d S |j
|j
u s
J d | j j } | |j d }
|
1| | }
|
|j d|
rfd| D } | j r| ||
| | d S | ||
| | d S )NJ'%s' does not support object population - eager loading cannot be applied.r zlSubquery session doesn't refer to that of our context. Are there broken context caching schemes being used?r$ c * g | ]}j | S rm rX )r rj rg s r& r z7SubqueryLoader.create_row_processor..k s AAA'/!,AAAr( )r= rE r! implsupports_populationr2 r3 r] rD r r r r+ r r, _create_collection_loader_create_scalar_loader) r_ rc re rf rL rn rg ro r r r$ s ` r& rp z#SubqueryLoader.create_row_processorJ so {(27K ,@BFG
D()xx*J77 < F|w...
" /.. )7
hhw 1=AA //55K HHW' D D D BAAAAjAAAJ < * *j*
& &j*
r( c fd fd}|d j f |d j |f |j r)|d j j f d S d S )Nc j t fdD d }| j | || d S )Nc g | ]
}| S rm rm r r r s r& r z_SubqueryLoader._create_collection_loader..load_collection_from_subq..{ 666Cs3x666r( rm )rD tupler r! set_committed_value)r r r
collectionr$ r r_ s ` r& load_collection_from_subqzKSubqueryLoader._create_collection_loader..load_collection_from_subqy sr ( 6666:66677 J
NN48 $ $ 8 8uj
r( c 8 j |vr | || d S d S r r )r r r r; r_ s r& &load_collection_from_subq_existing_rowzXSubqueryLoader._create_collection_loader..load_collection_from_subq_existing_row s3 xu$$))%<<<<< %$r( r existingeagerr; r! invoke_all_eagersr )r_ rc r$ r ro r= r; s ` `` @r& r1 z(SubqueryLoader._create_collection_loaderv s = = = = = = 5 $(,E!FGGG: %%
X= >
$ G w & &+2D'E F F F F F G Gr( c fd fd}|d j f |d j |f |j r)|d j j f d S d S )Nc j t fdD d }t | dk rt j dz |d }| j | || d S )Nc g | ]
}| S rm rm r6 s r& r zWSubqueryLoader._create_scalar_loader..load_scalar_from_subq.. r7 r( r r LMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' r )rD r8 r r r r r! r9 )r r r r: scalarr$ r r_ s ` r& load_scalar_from_subqzCSubqueryLoader._create_scalar_loader..load_scalar_from_subq s ( 6666:66677 J :"" GIMN
]F NN48 $ $ 8 8v N N N N Nr( c 8 j |vr | || d S d S r r )r r r rG r_ s r& "load_scalar_from_subq_existing_rowzPSubqueryLoader._create_scalar_loader..load_scalar_from_subq_existing_row s3 xu$$%%eUC88888 %$r( r r> r? r@ )r_ rc r$ r ro rI rG s ` `` @r& r2 z$SubqueryLoader._create_scalar_loader s O O O O O O O 9 9 9 9 9 9 5 $(,A!BCCC: %%
X9 :
$ G w & &+2D'E F F F F F G Gr( r )rq rr rs ru r\ r rk r r r r r r objectr+ rp r1 r2 rv rw s @r& r r s. I: : : : :' ' ' a4 a4 a4 a4F= = =0? ? ?B-1 -1 -1^2 2 2h 6 4* * *XG G G.G G G G G G Gr( r joinedc z e Zd ZdZdZ fdZd Z ddZd Zd Z d
Z
d Z d Z dd
Z
d Zd Zd Zd Z xZS ) JoinedLoaderzcProvide loading behavior for a :class:`.RelationshipProperty`
using joined eager loading.
)r _aliased_class_poolc t t | || | j j | _ g | _ d S r )r[ rM r\ r] r rN r^ s r& r\ zJoinedLoader.__init__ s>
lD!!**6<@@@ .9#% r( c ` | j d | d S r r r s r& r z!JoinedLoader.init_class_attribute r r( NFc * |j j sdS |j j r!| j r|j d || j }d}
|r| || nd} | dur | ||||| \ } }}
nu| |j d s9| j
r|j dz | j
k rdS n | | j
rdS | |||||||| \ } }}
}| |j dd }|t! | j }
nd}
|| j }t' j || j
||| |
|
| j
| |*dt+ |j v rt/ j d dS dS ) z@Add a left outer join to the statement that's being constructed.Nzjoined collectionFr r r )with_polymorphicr chained_from_outerjoinzDetected unaliased columns when generating joined load. Make sure to use aliased=True or flat=True when using joined loading with with_polymorphic().)r
r r r, r r] _init_user_defined_eager_proc$_setup_query_on_user_defined_adapterr r r r r rL _generate_row_adapterrD r with_polymorphic_mappersr r _setup_entity_queryr secondary_columnsr2 r3 )r_ rc rd re rf rg rh r rS ri rR user_defined_adapterclausesadd_to_collectionr s r& rk zJoinedLoader.setup_query s? }/ = F
]
% =$, = M ' '(; < < <D()
D . .w @ @ @ u , ,
99 tW6J
!! ==!3X>>
? {Q 88 9))$+66 F ** ! &
!& 88 7
' & &
$ DK # K - #9
'DC %5
5
-
-
,E
( ' -
-
r( c d|j vrdS |j j }| |j dd }|dur|S |j d }|dd \ }}|Pt |t r|j | }t j
||j j }n||
|j d r<| |j d }t j ||j j }n%|j j |j d }| |j d| |S )Neager_from_aliasF user_defined_eager_row_processor)r r )r re r= rD r r strr aliasr%
ColumnAdapterrL r r r
ORMAdapterr
_polymorphic_adaptersr ) r_ rf rc re rg rb root_mapperr# r s r& rT z*JoinedLoader._init_user_defined_eager_proc sq W%7 7 75|" (( BE
% N "#56 I T %%%
1 ))%00 ,4;#B GG }}W /1HII
#'88&(?$ $ #-$ $ ?
"-=AAK
BG
r( c | |j | }|r4|r2| | }| |j d| n |r |}| |j d| |j }|||fS )Nr_ )_get_entity_clausesr
wrapr r primary_columns)r_ rc r re rg rZ r\ s r& rU z1JoinedLoader._setup_query_on_user_defined_adapterM s ,,W]GDD
+
#7#<#s,Ca,G GG s #c #d.// / / , !- %***555 $
H
H ( * * $ + +H 5 5 5',,r( c
2 | |j dd } | r| }
n| | }
t |
d| ft
j |
| j j ddd } | j J | j
j rd|_ |%|j
d| j
j n | j
j } | sd}|j | j ||||| | |f |j }
| |j d| | ||
|fS )Nr joinedloader_ormadapterTF)r adapt_requiredallow_label_resolveanonymize_labels innerjoineager_row_processor)rD r rr r _memor rd rL r
aliased_classr] r, multi_row_eager_loadersr rx create_eager_joinsr; _create_eager_joinrY r )r_ rc r re rf rg rh r rS r rq r[ rx r\ s r& rV z"JoinedLoader._generate_row_adapter sl 88 7
?'HH55g>>H(##))
& - 7 % ! *
$000 ' 3.2G + "
" ";0D0N O O O%/ * &* ""))' &
$ 5 #%:GDDD!24JJJr( c ||j } n|} |j o |j j }
d } ||j vrn|
sl|j ret
j |j |j } t | dk rt j d | r |j | d }
| d |
}} | ||j }} |j | | }|rt |dd rit |j | | j r| n| j }t |j | j | j }nBt t- j | j |j d | j | j }n| j }|j J | p| p|dk p |j j }|rSt- j ||j || p'|j j p|ot7 |t8 j | j | j }n| |||| }||j | < |j |_ |sit
j | j j! D ]J}| j" j# $ | r)|r
|j% | }|j& ' | K| j j( rF|xj) |j* + tY j- | j j( z
c_) d S d S ) Nr zCan't identify which query entity in which to joined eager load from. Please use an exact match when specifying the join path.r r{ Tr unnestedisouter
_left_memo _right_memo).rL r| r
_should_nest_selectable eager_joins from_clauser% #find_left_clause_that_matches_givenrn r r2 r3
setdefaultr r r{ _entity_for_mapperr r= r r! r] r r r represents_outer_join_ORMJoinr r Join_splice_nested_inner_joinstop_on
_find_columns primaryjoinpersist_selectablerj contains_columnrY rj r; rl r r r r r9 )r_ rc rd re rg r r[ rx rS r should_nest_selectablequery_entity_keyindexesclausedefault_towraptowrapefmonclauseattach_on_outsider r s r& r~ z JoinedLoader._create_eager_join s &-KK&K
+
6
5
3 3 3*
4#
4 B#\%< G 7||a 00
F ,WQZ8
4;1:v. # ' -
$// n
,w66
g 344GG"t{33%KK #3:tx9MNN" ) W%7 H( +H$000 ' &
> }
>J&
> '= )% %
M +AM*Kz&#(/K/K ; K II 66fgx I 1: ,- ) 3 8 -$0
8
8 13CCCHH 8 3 %oc 2+223777 ( ; " ")::l4/899+; +;
; " " " " ; ;r( c : |du r t |t j sJ nt |t j j r | ||j ||| S t |t j s6|d |u r*t j ||j |d||d j S d S | ||j
|||j }|8d}| ||j |||j
}||dus
J d d S nd}|rR|j s |j s| | }n[t j |j ||j |j |j
}n-t j ||j
|j |j |j }|j |_ |S ) NFr` r r z9assertion failed attempting to produce joined eager loadsT)r r )r r )r r r r rn FromGroupingr elementr{ rL rightr leftr r _splice_into_centerr r ) r_ re join_objr[ r splicing target_join right_splicer s r& r z&JoinedLoader._splice_nested_inner_joinX s u h(9:: : :: :
#."=
>
> 11h&8
Hh&788 Bx8## ( ) ! ' $R
t44 (.'8X5I
L 88hmWh8K K " E)))N *))t
# L #
K,?
$ 8 8 E E $ - M % $ , ' 2 !)! ( $ 0 I %0$? !r( c $ |r| || nd}|dur5|}|j r |r| |j }n.|j r|j }n | |j d }|dS | j || r|S dS )NFry )rT rg ri rD r rL _result_has_identity_key)r_ rc rn rg re rf rZ decorators r& _create_eager_adapterz"JoinedLoader._create_eager_adapter s
D . .w @ @ @ u , ,,I
,9
, %NN7? ; ;
, #O !35JKKI u ; / / B B 5r( c | j j | j j j st j d| z || j }| ||||| } | durj| j }
t j
| j |||| j | } | j
s| ||
| | d S | ||
| | d S | j d ||||||| d S )Nr- Fr )r= rE r! r/ r0 r2 r3 r] r r _instance_processorrL r r, r2 r1 r rp ) r_ rc re rf rL rn rg ro our_path
eager_adapterr! _instances r& rp z!JoinedLoader.create_row_processor sO {(27K ,@BFG
,- 22 VWh
% %(C 3 % I <
**7CJOOOOO..S)Z
. .%
""w r( c fd}fd}fd}|d | j |f |d | j |f j r$|d | j |f d S d S )Nc t j | | }t j |d }|j | f< | }|| | d S d S Nappend_without_eventr init_state_collectionr UniqueAppenderr; ) r r r r: result_listinstr rc r! s r& #load_collection_from_joined_new_rowzSJoinedLoader._create_collection_loader..load_collection_from_joined_new_row sw #9%LLJ - 2 K 0;G s| , 9S>>D ""4((((( r( c | fj v rj | f }n7t j | | }t j |d }|j | f< | }|| | d S d S r r ) r r r r r: r r rc r! s r& (load_collection_from_joined_existing_rowzXJoinedLoader._create_collection_loader..load_collection_from_joined_existing_row s s|w 111 % 0% > ( =5#
# 1 6 4?"E3<0 9S>>D ""4((((( r( c | d S r rm r r r r s r& load_collection_from_joined_execzPJoinedLoader._create_collection_loader..load_collection_from_joined_exec IcNNNNNr( r r> r? r; r! rA )r_ rc r! r ro r r r s ``` r& r1 z&JoinedLoader._create_collection_loader s ) ) ) ) ) ) ) ) ) ) ) ) ) )& 5
X: ;
: %%
X? @
$ w & &;<
r( c fd} fd}fd}|d j |f |d j |f |j r$|d j |f d S d S )Nc $ | |< d S r rm )r r r r r! s r& load_scalar_from_joined_new_rowzKJoinedLoader._create_scalar_loader..load_scalar_from_joined_new_row s #3 E#JJJr( c z | }|v r%|| urt j dz d S d S ||< d S )NrE )r r )r r r r> r r! r_ s r& $load_scalar_from_joined_existing_rowzPJoinedLoader._create_scalar_loader..load_scalar_from_joined_existing_row so !y~~H e||5:--IK .- &c
r( c | d S r rm r s r& load_scalar_from_joined_execzHJoinedLoader._create_scalar_loader..load_scalar_from_joined_exec& r r( r r> r? r )r_ rc r! r ro r r r s ` `` r& r2 z"JoinedLoader._create_scalar_loader
s ( ( ( ( ( (
& & & & & & && 5 $(,K!LMMM: %%
X; <
$ w & &78
r( )NNF)F)rq rr rs rt ru r\ r rk rT rU rr rV r~ r r rp r1 r2 rv rw s @r& rM rM s1
4I& & & & &
' ' ' $^ ^ ^ ^@- - -^@ @ @4!- !- !-F=K =K =K~M; M; M;` ;@D D D DL 8% % %N* * *X# # # # # # #r( rM selectinc e Zd ZdZ ej dg d ZdZ fdZd Z d Z
d Z d Z e
j d
d Zd Z e
j d
d
Zd Zd Z xZS )SelectInLoader)r omit_join
_parent_alias _query_info_fallback_query_infor queryinfo)load_only_childload_with_joinin_exprpk_colszero_idxchild_lookup_colsi c t t | || | j j | _ | j j t j u }| j j | j j | _ ne| j d }|r
|j
| _ n<| j j d
|j d| j j | _ | j rQ|r4| | _ | | _ d S | | _ d S | | _ d S )Nr r Tr )r[ r r\ r] r rI r r r r r r= r
r r r _init_for_omit_join_m2or _init_for_joinr _init_for_omit_join)r_ r= r` is_m2o
lazyloaderra s r& r\ zSelectInLoader.__init__M s=
nd##,,V\BBB .9%/:3GG ) 5 ! 1 ;DNN -;;% J
!+!3!%!8!;!C!C - $ $ ? "D " " > 5
>#'#?#?#A#A ,0,?,?,A,A)))#'#;#;#=#= # 2 2 4 4D r( c d t j j j fdt D fd j j D x}}t | dk rt j
| }d}n
|d }d} dd|||d S )Nc 3 r K | ]1}j j |d D ]}|| fV 2dS )rm N)r= r rD )r r equivpk_to_fkr_ s r& r z5SelectInLoader._init_for_omit_join..n sl
8<.t s)
!xHSMr( r Fr T) rL r] r local_remote_pairsry r8 r= r r r tuple_
query_info)r_ r fk_colsr r r s ` @r& r z"SelectInLoader._init_for_omit_joinj s 0 C
(^^
%)[%<
' w<. s! III2z226IIIr( )rL r r r r r] r r )r_ r r r lookup_colsr s @r& r z&SelectInLoader._init_for_omit_join_m2o s +) w<. s4
,/G " "3 ' '
r( r Fr T)
r r= rH r r r r r r r )r_ r r r r s @r& r z SelectInLoader._init_for_join s $T[%7 8 8$,--
37;3J
w<. s] & &
44 " * ; 5 & & & & & &r( c @ g | ]\ }}|j d ||j |f S )r )r! rL )r r overwrites r& r z1SelectInLoader._load_for_path.. s= $E9 1 uej)< r( c : g | ]} | S rm r r r insps r& r z1SelectInLoader._load_for_path.. ' GGG4..s33GGGr( c : g | ]} | S rm r r s r& r z1SelectInLoader._load_for_path.. r r( c P | t j dgR S )NrJ )r
Bundle)r r r s r& r' z/SelectInLoader._load_for_path.. s- GMM T,G,,,.> r( c . | S r )rb )r_ r s r& r' z/SelectInLoader._load_for_path..+ s Q]]3C%D%D r( c | t j j S r )rb r r r] r! r )r_ r par_ s r& r' z/SelectInLoader._load_for_path..2 sI !--++00B 4 899AA( r( c | | t j dd S N primary_keysT) expandingrv in_r r r_ r s r& r' z/SelectInLoader._load_for_path..; 3 !((KK
n M M MNN r( c | | t j dd S r
r
r s r& r' z/SelectInLoader._load_for_path..A r r( c * | S r )r r^ s r& r' z/SelectInLoader._load_for_path..M s Q%8%8%:%: r( c : g | ]} | S rm r )r elemr s r& r z1SelectInLoader._load_for_path..S s4 & & &6:++D11& & &r( c | j S r )rl )r_ r s r& r' z/SelectInLoader._load_for_path..V s ^)D r( c | j d } | j |j t j j j S r )r rl r r r r9 r] )r_ r r_ s r& r z?SelectInLoader._load_for_path.._setup_outermost_orderbyY sJ !" AI%1:"2CC L)=)F G G r( ) r! r r r$ r% r8 r= rL r8 r r r r r; r r r r r r r r} r r
r r r] r rl _load_via_child_load_via_parent)r_ rV rc re states load_onlyr r
our_states none_statesr
related_identr_ r r r r r rL r r r r s ` ` @@@@@@@@r& r z SelectInLoader._load_for_path s2
22 F%
% ! G$066J K[F$*
G
G y "Z
% & & & & & & ) :& & & ! !
/=@@!%!:JE },, }-44
I6 &&z9'EFFFF ) (. J
$ $( H +,,D$
HGGGGwGGG --g66GGGGwGGG LL
(
NNDDDD E E E E
#B
NN
%
NN
NN
]
$d4+?&@
( <
NN:: ; ; ; ( 9 ,
9!%!5!>( & & & &>L& & &N D D D DEEEE 7888 % F KQ
! !*j!W E E E E Er( c H | j }t | }|r|d| j }|| j d }d ||j fd|D D } |D ]g}
| |
d } ||
D ]F\ } }
}|s
| j |
v r| | j | |
|s| n| g Gh||D ]A\ } }
}|s
| j |
v r| | j | |
d Bd S )Nr c i | ]\ }}|| S rm rm )r r r) s r&
z2SelectInLoader._load_via_child..u s. Aq 1 r( c 2 g | ]}j r|d n|S r r )r r! r s r& r z2SelectInLoader._load_via_child..x s6 " " "CF*"5>A3" " "r( r ) r, sorted
_chunksizer r rD r! r r9 )r_ r r r r_ rc r, our_keyschunkdatar! related_objr r r s ` r& r z SelectInLoader._load_via_childm s , *%% Q 01E 1 12H Ago . . 5 5" " " "JO" " " 6 D
#hhsD 1 1 /9# +E5)$ !U):): NN48,,@@ +2E
' : (3 M M #E5)
U!2!2
NN48 $ $ 8 8t L L L L
M Mr( c | j }|rdnd }|rl|d| j }|| j d }fd|D }t j t } t j ||j | d D ]*\ }
} | |
d | D +|D ]\ } }
}}|s
| j
|v r| | | }|sb|r`t | dk rt j d| z |
| j
|
||d |
| j
|
|| |jd S d S ) Nrm r c < g | ]\ }}}}j r|d n|S r r" )r r! r r r r s r& r z3SelectInLoader._load_via_parent.. sA 5C
I %-6A3 r( r# c | d S r rm r s r& r' z1SelectInLoader._load_via_parent.. s
!A$ r( c 3 & K | ] }|d V
dS )r Nrm r" s r& r z2SelectInLoader._load_via_parent.. s& 1 1r!u 1 1 1 1 1 1r( r rE )r, r% r$ r% r8 r& r' r r r( r! rD r r r r r9 )r_ r r r_ rc r,
_empty_resultr' r r( r r) r! r r r r: s ` r& r z SelectInLoader._load_via_parent s , %/4
& q4? 23E#DO$5$56J 9> L
*400D!)'/""))|)DD
2
21 Q 1 1q 1 1 111115:
1UJ TX%;%; !XXc= 9 9
: :** .04 5
NN48,,@@ z:a= NN48,,@@ z: I & & & & & r( )rq rr rs ru r$
namedtupler r% r\ r r r r r r rW rp r r r rv rw s @r& r r 3 s= I ('
J J5 5 5 5 5:O O O,
N N N ' ' '
T-..% % /.%1
1
1
f T-..PF PF /.PFd(M (M (MT* * * * * * *r( r c fdfd}fd}t j | d|ddd t j | d|ddd d S )Nc |t|j j k rd| t j | }|r;||ur7t j dt
j | d| j ddd |S )Nz Instance z+ is already associated with an instance of z via its z0 attribute, and is only allowed a single parent.bbf1)code) r! hasparentr instance_stater2 r3 r instance_strrH )r r oldvalue initiatorr4 r# s r& _do_checkz*single_parent_validator.._do_check s $(!:!:!++J,Ee,L,LMMI
XU 2 2 00 ,U3333U\\\444I r( c | |d | S r rm )r r r8 r9 s r& r; z'single_parent_validator..append s ytY777r( c | ||| S r rm )r r r7 r8 r9 s r& set_z%single_parent_validator..set_ s yx;;;r( r; T)rawretvalr4 r )r listen)r" r# r; r< r9 s ` @r& r< r< s 8 8 8 8 8< < < < <
L hDd
LudT$OOOOOOr( )NNNNFN)8rt
__future__r r$ r& r r r r r r r
r r r baser
r r r r r r r r r r r2 r r r r% r rS ColumnProperty strategy_forrW class_loggerry r r rJ r r RelationshipPropertyr r
MemoizedSlotsr r r r rM r r< rm r( r& rH s 2 2 & & & & & & " " " " " " ' ' ' ' ' ' & & & & & & + + + + + + # # # # # # " " " " " " S! S! S! S!l ''55'II
JI
F ''4%'HH?: ?: ?: ?: ?:> ?: ?: IH ?:D '''>>B
B
B
B
B
\ B
B
?> B
J ''$'GG ''4'88A' A' A' A' A'> A' A' 98 HG A'H 8 8 8 8 8& 8 8 8
4
4
4
4
4
4
4
4 --->> n ?> --8-<< --4-88= = = = =) = = 98 =< =< --4-88 --8-<< --7-;; -->-BB -->-BBuJ uJ uJ uJ uJ+T-? uJ uJ CB CB <; =< 98 uJp
8
8
8
8
8
8
8
8 --;-??A A A A A0 A A @?A< --:->>yG yG yG yG yG/ yG yG ?> yGx
--8-<< --5-99D
D
D
D
D
- D
D
:9 =< D
N --:->>L L L L L/1C L L ?> L^ P P P P Pr(