z/instances..filter_fn..2 sL !T !$ 3=BtHHH )tuplezip _entities)rowquerys r filter_fnz instances..filter_fn1 s= %( #%>%> r c > g | ]}| S )
row_processor)r query_entitycontextcursorr s r
z instances..: s; $ !..ugvFF r resultTr c & g | ]
} | S r" r" )r r procs r r' z instances..P s! 333cS 333r c @ g | ] fd D S )c & g | ]
} | S r" r" )r r* r s r r' z(instances...S s! ? ? ?tc ? ? ?r r" )r r keyed_tupleprocesss @r r' z instances..R sI K ? ? ? ?w ? ? ?@@ r N)
_new_runidrunidpost_load_paths_has_mapper_entitiesis_single_entityr listr r r lightweight_named_tuplepartials
_yield_per fetchmanyfetchallitemsinvoke unique_list Exception safe_reraiseclose)r r& r% filtered
single_entityr labelsfetchrowspath post_loadr r- r* r. s ``` @@@r instancesrG " s LLGM G)H*M II
- (-
& I 6xHHK !G
* (()9:: E ))
qz3333U333 $
$+#:#@#@#B#B
0
0i $////
9'i88
#
; <
LLNNN sD A.E 3BE E F ,F F F F F F F zsqlalchemy.orm.queryTc
|j
r
j } d
_ t |j dk }|r@t |j d j r
fd|D }nt | }nԈ fdt |j D }g }d |j D }t j
d| } |D ]}
t |
} |D ]W} | | M
t j
| | t j | | i i | | < X| | | t! | |
_ S # |
_ w xY w)
z@Merge a result into this :class:`_query.Query` object's Session.Fr r c g | ]@} t j | t j | i i AS )load
_recursive_resolve_conflict_map)_merger instance_state
instance_dict)r instancerK sessions r r' z merge_result..v sc ! NN"1(;;"0:: !#%.0 # r c D g | ] \ }}t |j | S r" )
isinstance
_MapperEntity)r iequerylibs r r' z merge_result.. s@ Aq a!788 r c g | ] }|j
S r" ) _label_name)r r s r r' z merge_result.. s ???CO???r r( NrJ )rR
_autoflush autoflushlenr rT rU r4 enumerater r5 rN r rO rP appenditer)rX r iteratorrK r\ rA r( mapped_entitieskeysr- r newrowrV rR s ` ` @r merge_resultre g s mG !I)& !EO,,1
" 3%/!,h.DEE
( %- h %eo 6 6 O
F??u???D 6xFFK
3
3 c( A ay,$+NN & 5fQi @ @ & 4VAY ? ?!%')24 %3 % %q
kk& 1 12222F|| %I%%%%s EE4 4 E=c | j | }|t j | }|j r&|j | s t j S |j rp|t j z s t j
S |t j z s|S | || n,# t j $ r | |g Y dS w xY w|S dS )zqLook up the given key in the given session's identity map,
check the object for expired state if found.
N) identity_mapgetr rO inheritsmapperisaPASSIVE_CLASS_MISMATCHexpiredSQL_OKPASSIVE_NO_RESULTRELATED_OBJECT_OK
_load_expiredorm_excObjectDeletedError_remove_newly_deleted)rR rj keypassiverQ states r get_from_identityrx s
#'',,H)(33 ? 55<#3#3F#;#; 5 4 4 = Z ..
!33 z ;;
##E73333-
--ug666tt
ts B) )%CCc Z ||d }|d }ndx}}t | ||||| S )z.Load the given identity key from the database.Nr r
)
refresh_statewith_for_updateonly_load_propsidentity_token)load_on_pk_identity)r ru rz r{ r| identr} s r
load_on_identr sP
A Q!%%
#''%
r c X |)| }| n| }|| }|j \ } d|v rwt fdt |j | D } t j || }t | t | k rt j d | |dd }||_
t fdt ||j D }
|
|_ |
d} ||_ n| j d} | j |_ nd} | t% | | ||| d|_ | S # t* j $ r Y dS w xY w)z6Load the given primary key identity from the database.Nc 4 g | ]\ }}|| j S r ru )r colvalue _get_paramss r r' z'load_on_pk_identity.. s6 "U } $( %}}r zofully NULL primary key identity cannot load any object. This condition may raise an error in a future release.TFc 4 g | ]\ }}| j |fS r" r )r id_val primary_keyr s r r' z'load_on_pk_identity.. s:
'FK [)-v6
r )populate_existing
version_checkr| rz r} )_clone_get_condition _mapper_zero _get_clausesetr r sql_utiladapt_criterion_to_nullr] r warn
_adapt_clause
_criteriondict_params_for_update_arg _get_optionsbool _order_byonerr
NoResultFound)
r primary_key_identityrz r{ r| r} qrj r nonesparamsr r s
@r r~ r~ s LLNN LLNN'##%%%+%7"k ' ' ' &) *,@' ' E #:;NNK5zzS!5 6 666
ook4?? "
+.(&*<, ,
"
+ *
! 1
NN }--#'#% AKuuww tts F F)(F)c 8 |r| | }
n|j }
i } | | j d| |
D ]#} |r
| j |vr | j | |||f||| d| $|2||j ur+|r|j | }
n|}
| |
d S d S d S )Nmemoized_setups)r| column_collectionmemoized_populators) _iterate_polymorphic_properties_polymorphic_propertiesr r ru setuppolymorphic_oncolumnsr_ )r% rj r$ rE adapterr with_polymorphicr| polymorphic_discriminatorkwpoly_propertiesquick_populatorsr pds r _setup_entity_queryr # s 9 @@
!8HHW
!24DEEE
uy ? ?
, / 0
"- %V-B B B + !:;BB*B $$$$$ .- B Br c P t j dt | d d S )NzLoading context for aW has changed within a load/refresh handler, suggesting a row refresh operation took place. If this event handler is expected to be emitting row refresh operations within an existing load or refresh operation, set restore_load_context=True when establishing the listener to ensure the context remains unchanged when the event handler completes.)r r r )rw s r _warn_for_runid_changedr U s: II !*% 0 0 0 0
3 r c !"#$%& j rfd D j t j t j } !| fdD } | j dt }
| D ]} | |
v r|
| } | t u r( d | j | j
f @| t u r# d | j df ld}
r%j | }|| |d }
|
s| | d }
|
r# d | j |
f | | | | | | j j j j rj j |z n|j j %j p j t5 j j j t5 j j j !t5 j j j rj j j t j t j! j j" $j# &j$ #j% s|d |j f}|j v rCj | j& d
k r- ' j | j( d | }n ' d| }|r=||ur9J tS || }tT + |j, ||| tT - r j "" . "nd" j/ r
t j0 n t j !"#$%&fd } j1 r|sste | ||| }|S )
z]Produce a mapper level row processor callable
which processes rows into mapped instances.c * g | ]}j | S r" )r )r cr s r r' z'_instance_processor..x s 777!7?1%777r Nc 3 2 K | ]}j | V d S r )_props)r krj s r r z&_instance_processor.. s* "M"M6=#3"M"M"M"M"M"Mr r newexpireFquickloader))selectinload_polymorphicTentitiesc r1 }| } | }|j k }d}d}n
t fdD f}" | }|> | } | }|j k }| }d}#r|st || ns |d rd S d}d}d}j } | } | }||_ |_ !|_ "
|| |sr0|r ss |_ |_ t |||| |r|j }|rjr:|j j | |j |k rt# | r+ j | |j |k rt# | n= r;|j j | |j k rt# | s|j r1 rr| | n| |" r |d n|j } | j v}|r
| sd rrt5 |||| }
|rZ rB|j }|j j | |
|j |k rt# | | ||
r j r |d |S )NTFc g | ]
}| S r" r" )r columnr s r r' z:_instance_processor.._instance.. s 999vs6{999r r eager) objr0 r rh _validate_version_id
class_manager new_instanceru r}
session_id_add_unpresent load_options load_path_populate_fullmanagerdispatchrK r rR refreshmodified_commit _commit_all add_stateunloadedr6 _populate_partialinvoke_all_eagers)$r rw rQ dict_isnew currentloadloaded_instance identitykeyexisting_runidr to_loadr r% identity_classr} rP rO is_not_primary_keyload_evtr loaded_as_persistentrj r| persistent_evtpk_colsr
populatorsrF propagate_options refresh_evtrefresh_identity_keyrz r0 r session_identity_mapr s$ ` r _instancez&_instance_processor.._instance s! 4 H!E yy{{H!M(++EK5(E K #OO
9999999:: K ,// <>%
h//&x00 ' '5$ $. $33E;GGG
Y 2+ Y 2
,+
,3D
,%6""+ !
G "'" 7 ;
.33E7CCC ;.88 3E : : :% ;,,W_eDDD ;.88 3E : : : 7M*22 w {e++/666$ G G$ G G
e_==== ))%1EFFF
1##E4000 ~H!11E
2H
2
7(;
2
, 2" ;).
.66ugwOOO ;.88 3E : : :MM%111
2W 6
2##E5111r )3r _identity_class collections defaultdictr4 _prop_set intersectionrh r r r r_ ru _deferred_column_loaderr
r _gettercreate_row_processorr r
_current_pathrE rR rg r always_refreshr r r rK r r rO rP hash_keyr r0 r} strategy_should_selectin_load
local_opts_load_subclass_via_inPostLoadcallable_for_pathrj for_context_identity_key_from_stateallow_partial_pks
issupersetpolymorphic_map _decorate_polymorphic_switch)'rj r% r( rE r r| rz r _polymorphic_frompropsr propr getter adapted_colru selectin_load_via callable_r r r} rP rO r r r r r r r r rF r r r r0 r r r s' `` ``` @@@@@@@@@@@@@@@@@@@@r _instance_processorr a sZ ( G 87777w777+N (..J E""""M"M"M"M_"M"M"MMMxx -y , , # # #"4(C&&&5!((Xt ;< --- 8$++TXu,=>>>> D")/#"6K".!' U!C!C 8 #^^C 7 7F w'..&/ABBBB
-- vvw
% %vvw
1 = & +
#d**
#?7 1JV5JF(1677Hv+4<==K'/2GHHN M & 7 L .N ,M )J)M ME +N . :# '$ $ $);C)@)I N
*
*
!' < <"3'2:>!! !
!' < <'! ! !2:K!K!K #***-gt=NOOI & &!(!!
$$Wi III
$ , 0 ' $*#B#B $ $ $
4 & 1 & 3W W W W W W W W W W W W W W W W W W W W W W W W W W W W Wr
&7
1 %
r c |j }t |j j dk |j r| | \ n |j \ fd}|S )Nr c ( | j } f|j z fz |j | }|j r| d || j
fd|D d S )N)
cache_pathc * | S r )r )r s r z8_load_subclass_via_in..do_load.. s a&9&9&;&; r c Z g | ]'\ }}r|j d d n |j d (S )r r r )r rw
load_attrszero_idxs r r' z:_load_subclass_via_in..do_load.. sF %E: $,= ! Q1 r ) primary_keys) r _with_lazyload_options
_with_optionsparent_populate_existing add_criteriarR r all) r% rE states load_onlyeffective_entity
orig_queryq2 disable_opt
enable_optr r s r do_loadz&_load_subclass_via_in..do_load s ]
%
%
MJ 4 4 ~ E K &
( = OO ; ; < < <
7?"" )/ #
#%%%%%r )rj r] base_mapperr is_aliased_class_subclass_load_via_in _subclass_load_via_in_mapper) r% rE entityrj r r r r r s @@@@r r r s
]F6%122a7H
I%+%A%A&%I%I":{{%+%H":{ & Nr c x |r| j |_ |d D ]\ } }
|
| || < |rA|d D ]7\ } } | | d | r|j | 8n*|d D ]!\ } } | r|j | "|d D ]\ } } | ||| |d D ]\ } } | ||| d S ||j k rD||_ |d D ]\ } }
| |vr |
| || < |d D ]\ } } | ||| d S |d D ]\ } } | ||| d S )Nr r r delayedexisting)r0 popexpired_attributesaddr )
r% r rw r r r r r r ru r set_callable populators
r r r s
)) m %g. % %KC E#JJ 6%/%9
6
6!\ #t$$$ 6,00555
6
&0%9
6
6!\ 6,00555 ( / ) )NC IeUC ( ( ( ( ( 3 ) )NC IeUC ( ( ( ( ) ) eo % % $ &g. ) )KC% #VC[[c
) 4 ) )NC IeUC ( ( ( ( ) ) ) 4 ) )NC IeUC ( ( ( ( ) )r c |s-| j | }|d D ]\ } }
| |v r
|
||| n|}|| j |< |d D ]\ } } | |v r | | || < |d D ];\ } } | |v r2| | d | r|j | <|d D ]\ } }
| |v r
|
||| |d D ]\ } }
| |v r
|
||| |d D ]\ } }
| |vr
|
||| |S )Nr( r r r r' r )r6 r) r* r+ )
r% r rw r r r r r r ru r- r r, s
r r r s -"5) ( 4 - -NCg~~ %,,, - ") %g. ) )KCg~~ #VC[[c
!+H!5 6 6 C g~~ #t$$$ 6,00555 ( / - -NCg~~ %,,, ( 3 - -NCg~~ %,,,$W- ) )Y h IeUC ( ( ( Nr c
| j }|d S |r
|j | }| ||| j || k rKt j dt | d| ||| j d|| d d S )Nz
Instance 'z' has version id 'z3' which does not match database-loaded version id 'z'.)version_id_colr _get_state_attr_by_columnrr StaleDataErrorr )rj rw r r r r0 s r r r ! s *N 9 8 ((v7LMM ~ $$ % 005&"7 N###
r c
||
nj
S r
j
fd}t j |
fd}|S )Nc j | }|u rd S t | S # t $ r t d| z w xY w)N)r z*No such polymorphic_identity %r is defined)r r KeyErrorAssertionError)
discriminator
sub_mapperr r% rj rE r( s r configure_subclass_mapperz?_decorate_polymorphic_switch..configure_subclass_mapperO s /
>J V##t&"(
<}L
s
+ Ac X | }|| }|r || S | S r r" )r r7 r instance_fnpolymorphic_instancesr s r polymorphic_instancez:_decorate_polymorphic_switch..polymorphic_instancee sC N+
$-m. sK $E9='++O<< " r ) r r PathRegistrycoercer@ valuesr: rA clear) rD r% rE tokenr argr r rJ s @r r; zPostLoad.invoke s { F )00667;|7J7J7L7L J J 3E?FC (, (9(9(;(; F
JwfdnIsIIIbIII r c Z |j |j }| |r||_ |S r )r1 rh rE rA )clsr% rE r| pls r r zPostLoad.for_context s/
$
(
(
3
3
>o>*BL r c P |j |j v o||j |j j v S r )rE r1 r@ )rD r% rE ru s r path_existszPostLoad.path_exists s1
I0 0
Bw.ty9AA
r c |j |j v r|j |j }n t x}|j |j < |||||f|j |< d S r )rE r1 r r@ ) rR r% rE rJ rO loader_callablerP r rS s r r zPostLoad.callable_for_path sZ 9/ / /(3BB6>jj @B(3 "O_c2 N
5r N) __name__
__module__ __qualname____doc__ __slots__rE r r; classmethodr rU r r" r r r r p s >>0I
' ' ' [
[
O O [O O Or r c & |j }|s$t j dt | z t |j }d}|r,| j } j r j
s || }|qt |
t j d | d|| }|du r|r|j }nf fd j D }|j | r$t+ j dt | z | }t1 j | r j rt1 j | r$t9 j dt | dS t |
||| }|r|t j | dS dS )
z4initiate a column-based attribute refresh operation.zQInstance %s is not bound to a Session; attribute refresh operation cannot proceedFN*)r| rz c 4 g | ]}j | j S r" )_columntopropertyru )r r rj s r r' z*load_scalar_attributes.. s1 69(-1 r z_Instance %s cannot be refreshed - it's not persistent and does not contain a full primary key.zwInstance %s to be refreshed doesn't contain a full primary key - can't be refreshed (and shouldn't be expired, either).)rz r| ) rR rr DetachedInstanceErrorr r ru r attrsrc ri concrete_optimized_get_statementr r optionsr Loadundeferfrom_statementr r* sa_excInvalidRequestErrorr r issubsetr r r warn_limitedrs ) rj rw attribute_namesrR has_keyr( statement identity_keypk_attrss ` r load_scalar_attributesrs sn mG
+
9>sCCDD ** / #
F B 9LL =C=O H '44X>>
024=e4D4DE
"::5AAL
| , , 5;5M
!,
/
/
6 %
F MM& ! ! +
06>(///0 0>>r )T)NNN)NNNN)&r[
__future__r r r r rr r r baser r
r r r rj sqlr counterr/ rG dependenciesre rx r r~ r r r r r r r r objectr rs r" r r r{ s ' & & & & & " " " " " " ' ' ' ' ' ' " " " " " "
T\^^
B B BJ )**2& 2& 2& +*2&j B KO 0
N N N Np "/% /% /% /%d $ "A A A AH
@4) 4) 4)t D
61 1 1 h5O 5O 5O 5O 5Ov 5O 5O 5OpP0 P0 P0 P0 P0r