U
|
¸ý°dQÌ ã @ s d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlmZ ddlm Z dd l
|
m Z dd
|
l
|
m Z dd l
|
mZ dd l
|
mZ dd l
|
mZ ddl
|
mZ ddl
|
mZ ddl
|
mZ ddl
|
mZ ddl
|
mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddl m Z ddl m!Z! dd l m"Z" dd l m#Z# dd lm$Z$ dd lm%Z% dd l&m'Z' dd!l(m)Z) dd"l*m+Z+ dd#lm,Z, dd$lm-Z- d%d&l
|
m.Z. d%d
|
l
|
m Z/ d%d'l
|
m0Z0 d%d(l
|
m1Z1 d%d)l
|
m2Z2 d%dl
|
mZ d%dl2mZ3 d%d*l2m4Z4 d%d+l5m6Z6 d%d,l5m7Z7 e r6dd-lm8Z8 d%d.l9m:Z: dbd0d1Z;ej<j=d/d/d2G d3d4 d4e$Z>e1j?ej<j=d5d/d2G d6d7 d7e$Z@e1j?ej<j=d5d8G d9d: d:e@ZAe1j?ej<j=d5d5d;ej<j=d5d5d5d<ej<j=d5d=G d>d? d?e$ZBG d@dA dAZCG dBdC dCe$ZDe1j?ej8j=d5d=G dDdE dEe$ZEe1j?ej8j=dFdGej8j=ddGG dHdI dIeDZFe1j?ej8j=d5dGej8j=dJdGej8j=dKdGej8j=dLdGej8j=dMdGG dNdO dOeDejGe1jHZIG dPdQ dQZJG dRdS dSeDZKej8j=dTdGG dUdV dVeKZLe1j?ej8j=dWdGG dXdY dYeKZMe1j?ej8j=dZdGej8j=d/dGG d[d\ d\eDZNe1j?ej8j=d]dGG d^d_ d_eKejGZOd`da ZPdS )czWsqlalchemy.orm.interfaces.LoaderStrategy
|
implementations, and related MapperOptions.é )Ú annotationsN)ÚAny)ÚDict)ÚTuple)Ú TYPE_CHECKINGé )Ú
|
attributes)Úexc)Ú
|
interfaces)Úloading)Ú path_registry)Ú
|
properties)Úquery)Ú relationships)Ú
|
unitofwork)Úutil)Ú_DEFER_FOR_STATE)Ú_RAISE_FOR_STATE)Ú_SET_DEFERRED_EXPIRED)Ú ATTR_WAS_SET)ÚLoaderCallableStatus)Ú PASSIVE_OFF)Ú PassiveFlag)Ú_column_descriptions)ÚORMCompileState)ÚORMSelectCompileState)Ú QueryContext)ÚLoaderStrategy)ÚStrategizedProperty)Ú_state_session)Ú InstanceState)ÚLoad)Ú _none_set)Ú AliasedClassé )Úevent)Úinspect)Úlog)Úsql)Úvisitors)Ú LABEL_STYLE_TABLENAME_PLUS_COL)ÚSelect)ÚRelationshipProperty)Ú ColumnElementFc s" g }
|
|o | j |r"| jr"|
|
t¡ | j| jjkrV| jj| j \|
|
fdd¡ |rf|
|
tj¡ |r| j r| j
|
r|
|
fdd¡ |j D ]} | | j | j¡kr| j | j¡stj| j| jf| |||oâ| jpâ| jtjk||||| pö| j | jd | } |
|
D ]} | | | q
|
qd S )Nc s t j| |j fS ©N)Úorm_utilZ_validator_eventsÚkey©ÚdescÚprop)ÚfnÚopts© úPd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/strategies.pyÚ<lambda>Y s ÿÿz%_register_attribute.<locals>.<lambda>c s t | ¡S r. )r Zbackref_listenersr1 )ÚbackrefÚuselistr6 r7 r8 g s ÿ) Z parent_tokenr: Úcompare_functionÚ useobjectZ trackparentÚ typecallableÚ callable_Úactive_historyÚ
|
impl_classZsend_modified_eventsÚdoc)r: Z single_parentÚappendÚsingle_parent_validatorr0 ÚparentZ
|
validatorsr Ztrack_cascade_eventsZback_populatesZ_effective_sync_backrefZself_and_descendantsÚ_propsÚgetÚ class_managerZ_attr_has_implr Zregister_attribute_implÚclass_Ú directionr
|
Z ONETOMANYZviewonlyrA )r3 Úmapperr< r; r= r> Zproxy_propertyr? r@ ÚkwZ listen_hooksÚmr2 Úhookr6 )r9 r4 r5 r: r7 Ú_register_attributeB sZ
|
|
|
ÿ
|
ÿ
|
ÿ þþ
|
ïîrN )Ú
|
instrumentÚdeferredc s6 e Zd ZdZdZ fddZd
|
ddZdd Z ZS ) ÚUninstrumentedColumnLoaderz¶Represent a non-instrumented MapperProperty.
|
|
The polymorphic_on argument of mapper() often results in this,
|
if the argument is against the with_polymorphic selectable.
|
|
©Úcolumnsc s t ||¡ | jj| _d S r. )ÚsuperÚ__init__Úparent_propertyrS ©ÚselfrD Ú strategy_key©Ú __class__r6 r7 rU s z#UninstrumentedColumnLoader.__init__Nc K s* | j D ] }|r|j | }| ||¡ qd S r. )rS Ú _append_dedupe_col_collection) rX Ú compile_stateÚ query_entityÚpathÚloadoptÚadapterÚcolumn_collectionÚkwargsÚcr6 r6 r7 Ú setup_query¤ s
|
|
|
z&UninstrumentedColumnLoader.setup_queryc C s d S r. r6 © rX Úcontextr^ r_ r` rJ Úresultra Ú
|
populatorsr6 r6 r7 Úcreate_row_processor³ s z/UninstrumentedColumnLoader.create_row_processor)N) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú __slots__rU re rj Ú __classcell__r6 r6 rZ r7 rQ s ù
|
rQ Tc s> e Zd ZdZdZ fddZd ddZdd Zd
|
d Z Z S ) Ú ColumnLoaderz8Provide loading behavior for a :class:`.ColumnProperty`.)rS Ú is_compositec s* t ||¡ | jj| _t| jd| _d S )NÚcomposite_class)rT rU rV rS Úhasattrrr rW rZ r6 r7 rU È s
|
zColumnLoader.__init__Fc K sv | j D ]<}
|
|r6|r,| |
|
¡}
|
|
|
d kr6 d S n
|
|j |
|
}
|
| |
|
|¡ q| j d } |rh|j | } | d krhd S | || j< d S ©Nr )rS Zadapt_check_presentr\ rV ) rX r] r^ r_ r` ra rb Úmemoized_populatorsZcheck_for_adaptrc rd Úfetchr6 r6 r7 re Í s
|
|
|
|
|
zColumnLoader.setup_queryc C s` d| _ | jd j}| jjpD| jd jpD|jd k oD|j |jd ¡| jk}t | j|d|j
|
|d d S )NTr F)r< r; r? ) Úis_class_levelrS ÚtyperV r? Ú primary_keyZversion_id_colÚ_columntopropertyrF rN Úcompare_values)rX rJ Zcoltyper? r6 r6 r7 Úinit_class_attributeî s"
|
ÿ
|
ÿû
|
ûz!ColumnLoader.init_class_attributec C sZ | j D ]:} |r|j | } | | d¡}
|
|
|
r|d | j|
|
f¡ qVq|d | jdf¡ d S )NFÚquickÚexpireT)rS Ú_getterrB r0 ) rX rg r^ r_ r` rJ rh ra ri ÚcolÚgetterr6 r6 r7 rj s
|
|
z!ColumnLoader.create_row_processor)F)
|
rk rl rm rn ro rU re r} rj rp r6 r6 rZ r7 rq Á s ÷
|
!rq )Zquery_expressionc s4 e Zd Z fddZdd Zdd Zdd Z ZS ) ÚExpressionColumnLoaderc s< t ||¡ t ¡ d ¡ t fdd| jjD | _d S )Nc 3 s | ]}| ¡ V qd S r. )Úcompare©Ú.0rd ©Únullr6 r7 Ú <genexpr>' s z2ExpressionColumnLoader.__init__.<locals>.<genexpr>) rT rU r( r ÚlabelÚanyrV rS Ú_have_default_expressionrW rZ r r7 rU s
|
ÿz ExpressionColumnLoader.__init__c K s d } |r d|j kr |j d g} n| jr.| jj} | d kr:d S | D ] }
|
|rP|j|
|
}
|
| |
|
|¡ q>| d } |r|j| } | d krd S | || j< d S )NÚ
|
expressionr )Ú
|
local_optsr rV rS r\ ) rX r] r^ r_ r` ra rb rv rc rS rd rw r6 r6 r7 re + s"
|
|
z"ExpressionColumnLoader.setup_queryc C sr |rnd|j krn|j d g} | D ]:}
|
|r0|j|
|
}
|
| |
|
d¡} | r |d | j| f¡ qnq |d | jdf¡ d S )Nr Fr~ r T)r rS r rB r0 ) rX rg r^ r_ r` rJ rh ra ri rS r r r6 r6 r7 rj O s
|
z+ExpressionColumnLoader.create_row_processorc C s( d| _ t| j|d| jd jjdd d S )NTFr )r< r; Zaccepts_scalar_loader)rx rN rV rS ry r| ©rX rJ r6 r6 r7 r} i s ûz+ExpressionColumnLoader.init_class_attribute)rk rl rm rU re rj r} rp r6 r6 rZ r7 r s $r )rP rO )rP rO Ú raiseload)Z
|
do_nothingc sN e Zd ZdZdZ fddZdd Zdd Zdd
|
d Zd d Z dd Z
|
Z S )ÚDeferredColumnLoaderzAProvide loading behavior for a deferred :class:`.ColumnProperty`.)rS Úgroupr c sJ t ||¡ t| jdr"td| j dd¡| _| jj| _| jj | _ d S )Nrs z8Deferred loading for composite types not implemented yetr F)
|
rT rU rt rV ÚNotImplementedErrorÚ strategy_optsrF r rS r rW rZ r6 r7 rU s ÿ
|
z DeferredColumnLoader.__init__c
|
|
C s |j rB|jjjrB| j|jjjkrB| j d¡ ||||||||¡ nH| jsv| j rX| jj
|
} n| jj } |d | j| f¡ n|d | jdf¡ d S )N©)rP F©rO TÚnewr F) Ú refresh_stater Ú_compile_optionsÚ_only_load_propsr0 rV Ú _get_strategyrj rx r Z_raise_column_loaderZ_deferred_column_loaderrB )
|
rX rg r^ r_ r` rJ rh ra ri Z set_deferred_for_local_stater6 r6 r7 rj s4 ÿþýÿö ÿÿz)DeferredColumnLoader.create_row_processorc C s, d| _ t| j|d| jd jj| jdd d S )NTFr )r< r; r> Zload_on_unexpire)rx rN rV rS ry r| Ú_load_for_stater r6 r6 r7 r} ¾ s úz)DeferredColumnLoader.init_class_attributeNc
|
K sª |j jr| jjsT|r(t| j | jj¡sT|rF| j rF|j
|
d| j d¡sT|rx| j |krx| j d¡j|||||||f| n.| jrt|| j< n | jst|| j< n
|
t|| j< d S )Nzundefer_group_%sFr )Úcompile_optionsZ_render_for_subqueryrV Z_renders_in_subqueriesÚsetrS Ú intersectionrD Z_should_undefer_in_wildcardr r rF r0 r re rx r r r r )
|
rX r] r^ r_ r` ra rb rv Zonly_load_propsrK r6 r6 r7 re Ê sR þýú
|
ÿù ô ó ÿòîîÿ÷
|
ö z DeferredColumnLoader.setup_queryc s´ j s tjS |tj@ s tjS jj} jr@ fdd|j D }n j g}fdd|D }t
|
}|d krt dt ¡ j f ¡ jr |d¡ t jt|t¡ tjS )Nc s4 g | ],}t |trt |jtr|j jkr|jqS r6 )Ú
|
isinstancer Ústrategyr r r0 )r Úp©rX r6 r7 Ú
|
<listcomp> s
|
|
üz8DeferredColumnLoader._load_for_state.<locals>.<listcomp>c s g | ]}| j kr|qS r6 )Z
|
unmodified)r Úk)Ústater6 r7 r¤ s
|
zfParent instance %s is not bound to a Session; deferred load operation of attribute '%s' cannot proceedÚraise)r0 r Ú
|
ATTR_EMPTYr ÚSQL_OKÚPASSIVE_NO_RESULTÚmanagerrJ r Ziterate_propertiesr Úorm_excÚDetachedInstanceErrorr/ Ú state_strr Ú_invoke_raise_loadr Zload_scalar_attributesr r r )rX r¦ ÚpassiveÚ localparentZtoloadr Úsessionr6 )rX r¦ r7 r þ s6
|
|
þþÿ ÿz$DeferredColumnLoader._load_for_statec C s t d| f ¡d S )Nz+'%s' is not available due to raiseload=True©Úsa_excÚInvalidRequestError©rX r¦ r° Úlazyr6 r6 r7 r¯ & s ÿz'DeferredColumnLoader._invoke_raise_load)N) rk rl rm rn ro rU rj r} re r r¯ rp r6 r6 rZ r7 r u s
|
4 ÷
|
4(r c @ s0 e Zd ZdZd dddddZejfdd Zd
|
S ) ÚLoadDeferredColumnsz7serializable loader object used by DeferredColumnLoaderFÚstrÚbool©r0 r c C s || _ || _d S r. r» )rX r0 r r6 r6 r7 rU / s z LoadDeferredColumns.__init__c C s> | j }|jj}|j| }| jr$d}nd}| |¡}| ||¡S )N)©rP Tr )r T)r¼ r )r0 r« rJ rE r r r )rX r¦ r° r0 r± r3 rY r¡ r6 r6 r7 Ú__call__3 s
|
|
z LoadDeferredColumns.__call__N)F)rk rl rm rn rU r r r½ r6 r6 r6 r7 r¸ , s r¸ c s, e Zd ZdZdZ fddZdd Z ZS )ÚAbstractRelationshipLoaderz0LoaderStratgies which deal with related objects.)rJ Útargetr: Úentityc s: t ||¡ | jj| _| jj| _| jj| _| jj| _d S r. )rT rU rV rJ rÀ r¿ r: rW rZ r6 r7 rU I s
|
|
|
|
z#AbstractRelationshipLoader.__init__c
|
C s | j d¡ ||||||||¡S )N))r· Ú immediate)rV r rj rf r6 r6 r7 Ú#_immediateload_create_row_processorP s ÿöz>AbstractRelationshipLoader._immediateload_create_row_processor)rk rl rm rn ro rU r rp r6 r6 rZ r7 r¾ D s r¾ c @ s e Zd ZdZdS )ÚDoNothingLoaderzßRelationship loader that makes no change to the object's state.
|
|
Compared to NoLoader, this loader does not initialize the
|
collection/attribute to empty/none; the usual default LazyLoader will
|
take effect.
|
|
N)rk rl rm rn r6 r6 r6 r7 rà i s rà Znoload)r· c @ s$ e Zd ZdZdZdd Zdd ZdS )ÚNoLoaderzQProvide loading behavior for a :class:`.Relationship`
|
with "lazy=None".
|
|
r6 c C s d| _ t| j|d| jjd d S )NT)r< r= )rx rN rV Úcollection_classr r6 r6 r7 r} s üz NoLoader.init_class_attributec
|
s$ fdd} |d j| f¡ d S )Nc s& j rt | | j¡ n
|
d | j< d S r. )r: r Úinit_state_collectionr0 ©r¦ Údict_Úrowr£ r6 r7 Úinvoke_no_load s z5NoLoader.create_row_processor.<locals>.invoke_no_loadr )rB r0 )
|
rX rg r^ r_ r` rJ rh ra ri rÊ r6 r£ r7 rj s z NoLoader.create_row_processorN)rk rl rm rn ro r} rj r6 r6 r6 r7 rÄ u s
|
rÄ Úselectr§ Ú raise_on_sqlZ baked_selectc s® e Zd ZU dZdZded< ded< ded< ded< d ed
|
< d d d fd d Zdd Zdd Zdd Z dd Z
|
dddde j fddZ dd Ze d ¡d d Zd d! Z ZS )"Ú
|
LazyLoaderztProvide loading behavior for a :class:`.Relationship`
|
with "lazy=True", that is loads when first accessed.
|
|
) Ú
|
_lazywhereÚ_rev_lazywhereZ_lazyload_reverse_optionÚ _order_byÚuse_getÚis_aliased_classÚ _bind_to_colÚ_equated_columnsÚ_rev_bind_to_colÚ_rev_equated_columnsÚ_simple_lazy_clauseÚ _raise_alwaysÚ _raise_on_sqlzColumnElement[bool]rÎ z Dict[str, ColumnElement[Any]]rÓ rÏ rÕ zRelationshipProperty[Any]rV zTuple[Any, ...])rD rY c s8 t ||¡ | jd dk| _| jd dk| _t| jj| _| jj }|
|
¡ \| _ | _ | _ |j
|
dd\| _| _| _| jjrdd t | jj¡D | _nd | _| j d| | j ¡ | j oÚ| j oÚ| jjd j| j dd
|
| jjd | _ | j r4t | j D ]4}|| jjkrð| jj| D ]}| j | | j |< q qð| j d | ¡ d S ) Nr· r§ rÌ T)Zreverse_directionc S s g | ]}t |d di¡qS )Ú
|
_orm_adaptT)Úsql_utilÚ_deep_annotate©r Úelemr6 r6 r7 r¤ Ú s ÿz'LazyLoader.__init__.<locals>.<listcomp>z%s lazy loading clause %sr F©Z use_proxiesZ compare_keysÚ equivalentsz4%s will use Session.get() to optimize instance loads) rT rU r rØ rÙ r& rÀ rÒ rV Ú_join_conditionZcreate_lazy_clauserÎ rÓ rÔ rÏ rÕ rÖ Úorder_byr Úto_listrÐ ÚloggerÚinfor: Ú _get_clauser rJ Ú_equivalent_columnsrÑ Úlist)rX rD rY Zjoin_conditionr rd rZ r6 r7 rU Ã sP ü
|
ü þ
|
|
ÿ üý ÿzLazyLoader.__init__c C sv d| _ | jj}| jjr d}d}n4| jjtjk s4| jsL|rBd}d}qTd}d}nd }}t| j|d| j | jj
|
||d d S )NTF)r< r> r= r? Ú_deferred_history) rx rV Ú _legacy_inactive_history_styler? rI r
|
Ú MANYTOONErÑ rN r rÅ )rX rJ rê r? ré r6 r6 r7 r} ÿ s2 ÿ ÿþùz LazyLoader.init_class_attributec sd t | jddi¡}|| j } g dd }t |i d|i¡ fdd}t |i d|i¡}|fS )NrÚ Tc S s
|
d| _ d S )NF)Úunique©Ú bindparamr6 r6 r7 Úvisit_bindparam+ s zFLazyLoader._memoized_attr__simple_lazy_clause.<locals>.visit_bindparamrî c sF | j kr$ | j | j d f¡ n | jd krB | jd | jf¡ d S r. )Z_identifying_keyrB r0 ÚcallableÚvaluerí ©Z bind_to_colÚparamsr6 r7 rï 0 s
|
ýÿ
|
)rÛ rÜ rÎ rÓ r) ZtraverseZcloned_traverse)rX Z lazywhereÚ criterionrï r6 rò r7 Ú"_memoized_attr__simple_lazy_clause! s ÿ ÿz-LazyLoader._memoized_attr__simple_lazy_clausec C s² | j \}}|d kr(t |dd |D ¡S | jj}| ¡ }t |¡}|tj @ rV|tj N }i }|D ]J\} }
|
} |
|
d k r |r|tj
|
@ r| |||
|
|¡} n| |||
|
|¡} | || < q^||fS )Nc S s g | ]\}}}|qS r6 r6 )r r0 Úidentrñ r6 r6 r7 r¤ G s z4LazyLoader._generate_lazy_clause.<locals>.<listcomp>) r× rÛ Zadapt_criterion_to_nullrV rD Úobjr Ú instance_dictr ZINIT_OKÚLOAD_AGAINST_COMMITTEDÚ#_get_committed_state_attr_by_columnÚ_get_state_attr_by_column) rX r¦ r° rô Z
|
param_keysrJ ÚorÈ ró r0 rö rñ r6 r6 r7 Ú_generate_lazy_clauseB s:
|
ÿ
|
|
|
ÿ ÿ
|
z LazyLoader._generate_lazy_clausec C s t d| |f ¡d S )Nz&'%s' is not available due to lazy='%s'r³ r¶ r6 r6 r7 r¯ b s
|
ÿz LazyLoader._invoke_raise_loadNr6 c C s |j s | jjs|jr|js tjS |j }d } | jo>| p>|j }
|
|t j
|
@ sN|
|
r\|t j @ sb|rbtj S | jr|t j@ s|
|
r|t j@ r| ||d¡ t|} | sÄ|t j@ rªtj S t dt |¡| j f ¡|
|
rz| | ||¡} tj | krètj S tj| krøtjS t | ¡rd S | j |jkr(|t j @ s(tj S | j | j | ||d} | d k r\| tj krVd S | S n |t j
|
@ rt|t j@ sztj S | !| || ||||||¡ S )Nr§ zbParent instance %s is not bound to a Session; lazy load operation of attribute '%s' cannot proceed)r° Zlazy_loaded_from)"r0 rV Zload_on_pendingZ _load_pendingZ
|
session_idr r¨ rÑ Ú_extra_criteriar r© r ZNON_PERSISTENT_OKrª rØ ÚNO_RAISEZRELATED_OBJECT_OKr¯ r r¬ r r/ r® Ú_get_ident_for_use_getZ NEVER_SETr" Ú
|
issupersetÚdictÚDEFERRED_HISTORY_LOADr Z_identity_lookuprÀ ZPASSIVE_CLASS_MISMATCHÚ_emit_lazyload) rX r¦ r° r` Úextra_criteriaÚ extra_optionsÚalternate_effective_pathÚexecution_optionsÚpendingÚprimary_key_identityrÑ r² Úinstancer6 r6 r7 r g s
|
þýûÿÿþü õ ô
|
þÿ ÿ
|
|
|
ÿþü
|
ÿþ÷zLazyLoader._load_for_statec sD j j}tj@ r|jn|jj fddjjD S )Nc s" g | ]} j | d qS )©r° ©rÔ ©r Úpk©rÈ Zget_attrr° rX r¦ r6 r7 r¤ â s ÿz5LazyLoader._get_ident_for_use_get.<locals>.<listcomp>)r« rJ r rù rú rû r rz )rX r² r¦ r° Úinstance_mapperr6 r r7 r Ø s
|
þz!LazyLoader._get_ident_for_use_getz sqlalchemy.orm.strategy_optionsc
|
sº t jj j ¡ }
|
tj|
|
g|
|
jtt j
|
d} t j } | d|d7 } j jd k r\| j j j¡} |j } | sr|tj@ rt ddi¡| _ j}|js|rè|jrè|d kr®|j j }n
|
| j }|j}|rà|jràd}|t j|¡f7 }|| _ n$|d kr|jj j }n
|
| j }|r | j |7 _ | j d|i7 _ |rn j rZ|t j!@ sZ "||d¡ t#j$|| || | dS j%r~ j%| _& fdd }| j'| j ff7 _' (||¡\}}| rÌt j) *| d
|
| i¡} nd
|
| i} j|j+krô|t j,@ sôt-j.S | rt /tj0| 1¡ ¡r,d S nt /tj2| 1¡ ¡r,d S j rN|t j!@ sN "||d¡ |f| _3|j4| || d }| 5¡ 6¡ 7¡ } j8r|S t9|}|r²|d krªt :d j ¡ |d S d S d S )N)Ú _raw_columnsÚ_propagate_attrsÚ _label_styler F)Z_invoke_all_eagersÚ_lazy_loaded_fromZ autoflushÚ _current_pathrÌ )Ú load_optionsr c sR j jD ]D}|jtjkr|jrt|jtsj
|
| j j |j ¡ |¡ | ¡ qd S r. )rV Z_reverse_propertyrI r
|
rë Z_use_getr r¡ rÍ r! Z _construct_for_existing_pathr r rD ZlazyloadZprocess_compile_state)Úcompile_contextÚrev©rX Ústrategy_optionsr6 r7 Ú_lazyload_reverse< s
|
ÿþ
|
ýÿÿüüz4LazyLoader._emit_lazyload.<locals>._lazyload_reverseZ_sa_orm_load_options)r r zKMultiple rows returned with uselist=False for lazily-loaded attribute '%s' r );r Z preloadedZorm_strategy_optionsrÀ Ú__clause_element__r+ Ú_create_raw_selectr r* r Údefault_compile_optionsr Zdefault_load_optionsrV Z secondaryÚ select_fromrJ r0 r Z NO_AUTOFLUSHÚ immutabledictÚ_execution_optionsrÑ r rþ Z load_pathr/ ÚLoaderCriteriaOptionÚ _with_optionsÚ_path_registryr rÙ r rÿ r¯ r Zload_on_pk_identityrÐ Ú_order_by_clausesZ_with_context_optionsrý Ú
|
EMPTY_DICTZ
|
merge_withr r r r Zhas_intersectionr" ÚvaluesZ
|
_never_setZ_where_criteriaÚexecuterì ZscalarsÚallr: ÚlenÚwarn)rX r² r¦ r
|
r° r` r r r r Z clauseelementZstmtr r rÑ Úeffective_pathr5 r Z lazy_clauseró rh Úlr6 r r7 r ç sÂ
|
üþ ÿ
|
|
ÿ
|
|
ûÿ ÿþ ÿ
|
ÿþ ÿ
|
þÿzLazyLoader._emit_lazyloadc
|
sÀ | j |jjr@|jjjr@| j |jjjkr@| ||||||||¡S | jrP|r|jrt
|
|j t | ||jrp| |¡nd ¡} |d | j | f¡ n,|js|jr¼ fdd}
|
|d | j |
|
f¡ d S )Nr c s | | ¡ d S r. )Z_resetrÇ ©r0 r6 r7 Úreset_for_lazy_callable¿ s z@LazyLoader.create_row_processor.<locals>.reset_for_lazy_callable)r0 r Z_is_user_refreshr r r r rx rþ r Z"_instance_level_callable_processorrG ÚLoadLazyAttributeÚ_generate_extra_criteriarB Úpopulate_existingZalways_refresh) rX rg r^ r_ r` rJ rh ra ri Zset_lazy_callabler0 r6 r/ r7 rj sF ÿþýø
|
ÿÿ úô z LazyLoader.create_row_processor)rk rl rm rn ro Ú__annotations__rU r} rõ rý r¯ r r' r r Zpreload_moduler rj rp r6 r6 rZ r7 rÍ s.
|
<"! ø
|
q
|
rÍ c @ s. e Zd ZdZdd Zdd ZejfddZdS ) r1 a¦ semi-serializable loader object used by LazyLoader
|
|
Historically, this object would be carried along with instances that
|
needed to run lazyloaders, so it had to be serializable to support
|
cached instances.
|
|
this is no longer a general requirement, and the case where this object
|
is used is exactly the case where we can't really serialize easily,
|
which is when extra criteria in the loader option is present.
|
|
We can't reliably serialize that as it refers to mapped entities and
|
AliasedClass objects that are local to the current process, which would
|
need to be matched up on deserialize e.g. the sqlalchemy.ext.serializer
|
approach.
|
|
c C s || _ |j| _|| _|| _d S r. ©r0 rY r` r )rX r0 Zinitiating_strategyr` r r6 r6 r7 rU ß s zLoadLazyAttribute.__init__c C s( | j d k rt d¡ | j| j| jddS )NzvCan't reliably serialize a lazyload() option that contains additional criteria; please use eager loading for this caser6 r5 )r r r, r0 rY r` r£ r6 r6 r7 Ú __getstate__å s
|
ÿüz LoadLazyAttribute.__getstate__c C s: | j }|jj}|j| }|j| j }|j||| j| jdS )N)r` r ) r0 r« rJ rE Z _strategiesrY r r` r )rX r¦ r° r0 r r3 r¡ r6 r6 r7 r½ ó s
|
üzLoadLazyAttribute.__call__N) rk rl rm rn rU r6 r r r½ r6 r6 r6 r7 r1 Í s r1 c @ s e Zd ZdZdZdddZdS )Ú
|
PostLoaderz;A relationship loader that emits a second SELECT statement.r6 Nc C sN |j jptjj| }| ¡ }t d|i¡}|rF|j dd ¡}|dk} nd }d} |d k rÂ| j
|
j srt d| j
|
d¡|j dt| |¡}| s¢|dk r¢|d||fS | sÂ| dt| |d i¡}tj ||| j
|
¡rà|d||fS || j
|
}
|
|| j
|
} |
|
|jd
|
¡sB|r(| jd |krB|d||fS n| | j¡rB|d||fS |d ||fS ) NZsa_top_level_orm_contextÚrecursion_depthéÿÿÿÿFz'recursion_depth option on relationship z0 not valid for non-self-referential relationshipZ_recursion_depth_r r Úloaderr$ T)r] Ú current_pathr/ Ú PathRegistryÚrootZ_get_top_level_contextr r! r rF rV Z_is_self_referentialr´ rµ r ÚidÚunionr ÚPostLoadZ path_existsÚcontainsr ÚlengthÚcontains_mapperrJ ) rX rg r_ r` Ú
|
join_depthr- Ztop_level_contextr r8 Zunlimited_recursionÚ path_w_propZeffective_path_w_propr6 r6 r7 Ú_setup_for_recursion sp þÿ
|
ÿ ÿ ü ÿÿ ÿ
|
|
üüz PostLoader._setup_for_recursion)N)rk rl rm rn ro rF r6 r6 r6 r7 r7 s r7 rÁ c @ s( e Zd ZdZdd Zdd Zdd ZdS ) ÚImmediateLoaderr6 c C s | j d¡ |¡ d S ©N©)r· rË ©rV r r} r r6 r6 r7 r} R s
|
ÿþz$ImmediateLoader.init_class_attributec C sZ | |||¡\} }
|
} } |
|
s(tjtjB } n tjtjB } tj || | j | j
|
| j || | | ¡ d S r. ) rF r ZPASSIVE_NO_FETCH_RELATEDr rÿ r r r@ Úcallable_for_pathrD rV Ú_load_for_path)rX rg r^ r_ r` rJ rh ra ri r- Ú
|
run_loaderr r8 Úflagsr6 r6 r7 rj W s( û ÷z$ImmediateLoader.create_row_processorc C s |r.t |jj} || ¡ f| _| ¡ }
|
| f} n d } |}
|
d} | j} | j d¡} |D ]J\}}|j }|sj| |krP| j
|
||| |
|
|d}|t k rP| | ¡ |||¡ qPd S )Nr6 rI )r r r )r! r_ rÀ Z_recurserg Ú_truncate_recursiver0 rV r r r r Úget_implÚset_committed_value)rX rg r_ ÚstatesÚ load_onlyr` rN r8 r Znew_optr r r0 Ú
|
lazyloaderr¦ Ú overwriterÈ rñ r6 r6 r7 rL ~ s8 þ û
|
ÿz ImmediateLoader._load_for_pathN)rk rl rm ro r} rj rL r6 r6 r6 r7 rG N s 'rG Úsubqueryc s e Zd ZdZ fddZdd Zdd Zdd Zd
|
d Zd d Z dd Z
|
dd Z G dd dZ dd Z dd Zdd Zdd Z ZS ) ÚSubqueryLoader©rD c s t ||¡ | jj| _d S r. )rT rU rV rD rW rZ r6 r7 rU ¯ s zSubqueryLoader.__init__c C s | j d¡ |¡ d S rH rJ r r6 r6 r7 r} ³ s
|
ÿþz#SubqueryLoader.init_class_attributec sÀ |}|j }t |d ¡}| j |¡rB| j|d krB| j| j }n||d }|r|j| jj| t |t }|rt
|
j || d
¡7 n||j } fdd| D }
|
|
|
|fS )Nr r c s& g | ] }t jd j j| jqS ©r )Úgetattrr_ rÀ r{ r0 r
©Úleftmost_mapperZ new_subq_pathr6 r7 r¤ ß s
|
ü
|
|
þz0SubqueryLoader._get_leftmost.<locals>.<listcomp>)r_ r/ Z_class_to_mapperrD ÚisarV Ú _entitiesÚ entity_zeror% r+ r r< ZcoerceÚ local_columns) rX Úorig_query_entity_indexÚ subq_pathZcurrent_compile_stateÚis_rootZgiven_subq_pathZ subq_mapperZ leftmost_propÚ
|
additionalZ leftmost_colsÚ leftmost_attrr6 r[ r7 Ú _get_leftmost¸ s4
|
ÿ þÿþ ÿ ûz SubqueryLoader._get_leftmostc C s. | ¡ d ¡}tj tj¡}|j |j¡ |}|js^d|_|j j
|
|fdd t ||dD | dd |D | ¡ ¡} | |_|j}
|
|
|
dkrd|_n6|
|
d krÊdd | D D ] } t| | j¡sªd|_ qÊqª|jsÖd |_|jdkr |jr t | |j¡} | r | | | ¡ | t¡ ¡ } t j || dd
|
}|S ) NFc S s h | ]}|d dk r|d qS )rÀ Nr6 )r Úentr6 r6 r7 Ú <setcomp> s üz?SubqueryLoader._generate_from_original_query.<locals>.<setcomp>)r] c S s g | ]}t j t jj|¡qS r6 )r( Z coercionsÚexpectZrolesZColumnsClauseRole)r rü r6 r6 r7 r¤ " s ÿz@SubqueryLoader._generate_from_original_query.<locals>.<listcomp>Tc S s h | ]
|
}|j qS r6 )Útabler
r6 r6 r7 rh 1 s r6 ©Úuse_mapper_path) Z_cloneZ correlater ÚQueryÚ__new__Ú__dict__ÚupdateZ _from_objZ_enable_assertionsr Znon_generativer Z_adapt_col_listZ_get_current_adapterr Údistinct_target_keyZ _distinctr r rz Z_has_row_limiting_clauser& rÛ Z expand_column_list_from_order_byZ _set_entitiesZset_label_styler* rV r/ r# )rX Úorig_compile_stateÚ
|
orig_queryr\ re Úleftmost_relationshipZ orig_entityÚqZq2Z target_colsrq ÚtZto_addZembed_qÚ
|
left_aliasr6 r6 r7 Ú _generate_from_original_queryé s^ ÿ ÿþþþû ÿ ÿz,SubqueryLoader._generate_from_original_queryc sÎ g }t | ¡ }t|D ]N\}\}}|dkrR||d d j}| |¡rL|n|} n|} | | |jf¡ qt|dk rz| n.t|d d }
|
|
|
j r|
|
j
|
nt j |
|
j
|
dd j j} fdd| D } || fS ) Nr r r$ r9 Trk c s g | ]}t jj| jqS r6 )rZ rD r{ r0 r
©Ú parent_aliasrX r6 r7 r¤ v s ÿz2SubqueryLoader._prep_for_joins.<locals>.<listcomp>)rè ÚpairsÚ enumeraterJ r] rB r0 r+ r& rÒ rÀ r/ r# rV r` ) rX rw rb Úto_joinr{ ÚirJ r3 Z prev_mapperZ to_appendrå Ú
|
local_colsÚ
|
local_attrr6 ry r7 Ú_prep_for_joinsM s, ÿ þz SubqueryLoader._prep_for_joinsc C s0 t |}|dkr,t||d d |¡g}nê|dkrft||d d |¡t||d d |¡g}n°|dkrdd |dd
D }g }|rØ| d¡} t| d | d }
|
|rÂ|
|
|d d ¡}
|
n
|
|
|
|¡}
|
| |
|
¡ qt||d d |d j¡g| t||d d |¡g }|D ]}
|
| |
|
¡}q|S )Nr r r$ r9 c S s: g | ]2}t |d js$t |d ¡n|d j|d fqS )r r )r& rÒ r/ r# rÀ )r Úitemr6 r6 r7 r¤ s ü ÿüz/SubqueryLoader._apply_joins.<locals>.<listcomp>)r+ rZ Úof_typeÚpoprB rD Újoin) rX ru r} rw rz Úeffective_entityZltjZmiddleÚinnerr Úattrr6 r6 r7 Ú _apply_joins| sD ÿÿþ
|
|
ù
|
|
ÿÿÿþÿ
|
zSubqueryLoader._apply_joinsc C sB |j }|r*|jr*|t | j| |¡¡f7 }| |¡}|j| }|S r. )r$ rþ r/ r# rÀ r2 Z_with_current_pathÚoptions) rX rg ru rb Úrewritten_pathrs r r` Ú new_optionsr6 r6 r7 Ú_setup_options± s
|
þÿ
|
|
z SubqueryLoader._setup_optionsc s& j jr" fdd}| | j ¡}|S )Nc s | j tt jj¡7 _ d S r. ©Úeager_order_byÚtupler rã rV râ ©r r£ r6 r7 Ú_setup_outermost_orderbyØ s ÿzISubqueryLoader._setup_outermost_orderby.<locals>._setup_outermost_orderby)rV râ Ú_add_context_option)rX ru r r6 r£ r7 r Õ s ÿz'SubqueryLoader._setup_outermost_orderbyc @ s4 e Zd ZdZdZdd Zdd Zdd Zd d
|
Zd S ) z SubqueryLoader._SubqCollectionsz±Given 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.
|
|
©r² r r ró ÚsubqÚ_datac C s4 |j | _ |j| _|j| _|jp i | _|| _d | _d S r. r )rX rg r r6 r6 r7 rU ó s z(SubqueryLoader._SubqCollections.__init__c C s | j d kr| ¡ | j ||¡S r. )r Ú_loadrF )rX r0 Údefaultr6 r6 r7 rF ý s
|
z#SubqueryLoader._SubqCollections.getc C s t t¡| _| j}|jd ks t| | j¡}| jj r<|
|
¡ }t| | j ¡}t |dd ¡D ]"\}}| j| dd |D ¡ q\d S )Nc S s | dd
S )Nr r6 ©Úxr6 r6 r7 r8 ó z7SubqueryLoader._SubqCollections._load.<locals>.<lambda>c s s | ]}|d V qdS )r Nr6 ©r Úvvr6 r6 r7 r s z8SubqueryLoader._SubqCollections._load.<locals>.<genexpr>)Ú collectionsÚ defaultdictrè r r r² ÚAssertionErrorZ with_sessionr Z_populate_existingr3 ró Ú itertoolsÚgroupbyÚextend)rX ru Úrowsr¥ Úvr6 r6 r7 r s z%SubqueryLoader._SubqCollections._loadc C s | j d kr| ¡ d S r. )r r )rX r¦ rÈ rÉ r6 r6 r7 r: s
|
z&SubqueryLoader._SubqCollections.loaderN) rk rl rm rn ro rU rF r r: r6 r6 r6 r7 Ú_SubqCollectionsã s
|
r¦ c C s |j }|jjr|jjrd S |j |¡}d|_|| j }| |j dd ¡} | d k rT| }
|
n| j
|
}
|
|j j dt jjt jjf¡\} } | t jjk} | | } | | } |j j dtf|j ¡}t |d¡}|jrâ|jjd krÜt d| |f ¡ |j}|j|dd}| || || ¡\}}}} | ||||||¡}t |
|
¡}|j dtf|d| | fi¡|_ | d¡}| || ¡\}}}|j | }| !|||||
|
¡}| "||| | ||
|
|¡}| #|¡}|S ) NTÚpath_with_polymorphic)Zsubquery_pathsNrs ÚormzÙsubqueryloader for "%s" must invoke lambda callable at %r in order to produce a new query, decreasing the efficiency of caching for this statement. Consider using selectinload() for more effective full-lambda cachingF)Úlegacy)$r] r Ú_enable_eagerloadsZ_for_refresh_stater^ ÚindexZloaders_require_bufferingrV rF r rÀ r r" r/ r< r= rW r Z _get_plugin_class_for_pluginZ_is_lambda_elementr r r r, Z _resolvedZ_create_entities_collectionrf rx rm r? Z_set_enable_single_critr Z add_columnsr r r )rX rg r^ r_ rÀ r` ra r] ra Úwith_poly_entityr rb r rc rs Zcompile_state_clsrr r\ re rt rw ru r} r rz r6 r6 r7 Ú_setup_query_from_rowproc s¾ ÿþ
|
ÿþ ÿ ÿ ûÿ ÿ üû
|
ú
|
þÿ
|
ÿ
|
|
ÿù
|
z(SubqueryLoader._setup_query_from_rowprocc
|
sj |j r | |||||| |¡S | |||| j¡\} }
|
} } |
|
s@d S t|jtsPd S | jj| j j
|
j spt d| ¡t|dkrt |j| j¡s¨d S nt |d | j¡s¨d S | ||||d | ¡} | d krÌd S | jd ksÚt|| j }| jj} | |jd¡} | d kr | || ¡} | |jd| ¡ r8 fdd| D } | jrT| ||| | |¡ n| ||| | |¡ d S )NúJ'%s' does not support object population - eager loading cannot be applied.r r9 r c s g | ]} j | qS r6 rR r
©ra r6 r7 r¤ í s z7SubqueryLoader.create_row_processor.<locals>.<listcomp>) r r rF rD r r] r rD rG r0 ÚimplÚsupports_populationr´ rµ r+ r/ Ú _entity_isar_ r r² r rV r` rF r r¦ r r: Ú_create_collection_loaderÚ_create_scalar_loader)rX rg r^ r_ r` rJ rh ra ri Ú_rM r r r r6 r¯ r7 rj s ø ÿ ÿÿ ú
|
|
ÿ ÿz#SubqueryLoader.create_row_processorc sp | |¡ fddfdd}|d jf¡ |d j|f¡ |jrl|d j jf¡ d S )Nc s* |d¡}| j¡ | ||¡ d S )Nr6 )rF rP r0 rQ )r¦ rÈ rÉ Ú
|
collection©r rX Ú tuple_getterr6 r7 Úload_collection_from_subqý s ÿzKSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subqc s j |kr | || d S r. r/ rÇ )r¹ rX r6 r7 Ú&load_collection_from_subq_existing_row s
|
zXSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subq_existing_rowr ÚexistingÚeager©Z _tuple_getterrB r0 Úinvoke_all_eagersr: )rX rg rh r r ri rº r6 )r r¹ rX r¸ r7 r³ ø s
|
ÿz(SubqueryLoader._create_collection_loaderc sp | |¡ fddfdd}|d jf¡ |d j|f¡ |jrl|d j jf¡ d S )Nc sL |d¡}t|dkr*t d ¡ |d }| j¡ | ||¡ d S )Nr. r úLMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' r )rF r+ r r, rP r0 rQ )r¦ rÈ rÉ r¶ Zscalarr· r6 r7 Úload_scalar_from_subq s ÿÿzCSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subqc s j |kr | || d S r. r/ rÇ )rÀ rX r6 r7 Ú"load_scalar_from_subq_existing_row s
|
zPSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subq_existing_rowr r» r¼ r½ )rX rg rh r r ri rÁ r6 )r rÀ rX r¸ r7 r´ s
|
ÿz$SubqueryLoader._create_scalar_loader)rk rl rm ro rU r} rf rx r r r r r¦ r rj r³ r´ rp r6 r6 rZ r7 rW ª s 1d/5$4 ZrW Zjoinedc s e Zd ZdZdZ fddZdd Zd d d
|
Zd d Zd d Z dd Z
|
dd Z dd Z d ddZ dd Zdd Zdd Zd d Z ZS )!Ú JoinedLoaderz[Provide loading behavior for a :class:`.Relationship`
|
using joined eager loading.
|
|
)rD Ú_aliased_class_poolc s" t ||¡ | jj| _g | _d S r. )rT rU rV rD rà rW rZ r6 r7 rU 6 s
|
zJoinedLoader.__init__c C s | j d¡ |¡ d S rH rJ r r6 r6 r7 r} ; s
|
ÿþz!JoinedLoader.init_class_attributeNFc K s: |j js dS | jrd|_|| j }d}
|
|r:| |||j¡nd} | dk r`| ||||| ¡\} }} n`| |jd¡s| j r|j
|
d | j krdS n| | j ¡rdS | ||||||||¡\} }} }d|_| |jdd¡}|dk rät|j}
|
nd}
|
|| j }tj|| j ||| | |
|
| j |d |dk r6dt|jkr6t d¡dS ) z@Add a left outer join to the statement that's being constructed.NTFr: r$ r§ )Úwith_polymorphicÚ parentmapperÚ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: Úmulti_row_eager_loadersrV Ú _init_user_defined_eager_procr Ú$_setup_query_on_user_defined_adapterrA rD rB rC rJ Ú_generate_row_adapterZeager_adding_joinsrF r& Zwith_polymorphic_mappersrÀ r Z_setup_entity_queryr Úsecondary_columnsr´ rµ )rX r] r^ r_ r` ra rb rÅ rÆ rc rÄ Úuser_defined_adapterÚclausesÚadd_to_collectionr¬ r6 r6 r7 re @ s
|
ý ÿûûüý øû ÿÿ
|
÷ ÿÿzJoinedLoader.setup_queryc
|
C sâ d|j krdS |jj}| |jdd¡}|dk r2|S |j d }|dd
\}}|d k rt|trj|j |¡}t j
|
t j j |j ||j jdd}nF| |jd¡rÀ| |jd¡} t j
|
t j j| |j jd}n|j |j d ¡}| |d|¡ |S )NZeager_from_aliasFÚ user_defined_eager_row_processoréþÿÿÿ)Ú
|
selectablerà Zlimit_on_entityr§ )rà )r r_ rD rF r r r¹ r¿ Úaliasr/ Ú
|
ORMAdapterÚ_TraceAdaptRoleZ JOINEDLOAD_USER_DEFINED_ALIASrJ rç rA Z JOINEDLOAD_PATH_WITH_POLYMORPHICZ_polymorphic_adaptersr )
|
rX r` r] Ztarget_attributesr_ ra rÒ Z root_mapperr3 r¬ r6 r6 r7 rÈ ³ sZ
|
ÿ
|
|
û ÿ ÿý ÿýz*JoinedLoader._init_user_defined_eager_procc C sV | |¡}|r.|r.| |¡}| |jd|¡ n|rF|}| |jd|¡ |j}|||fS )NrÏ )Z_get_entity_clausesÚwrapr r Úprimary_columns)rX rg rÀ r_ ra rÌ rÎ r6 r6 r7 rÉ í s"
|
|
ýýz1JoinedLoader._setup_query_on_user_defined_adapterc C s° t | jjrt | jj}nd }d| f}||jkr@d |j|< }n|j| d |j|< }|t| jkr¦tj| j |d k r|j
|
ddnd ddd}t |jj | j |¡ | j| S )NZjoinedloader_acr r T)Úflat)rÒ r× rl ) r& rÀ rÒ rÑ r r+ rà r/ r# rJ Z_anonymous_fromclauserd rB )rX rg Zalt_selectabler0 ÚidxÚto_adaptr6 r6 r7 Ú_gen_pooled_aliased_class s&
|
ÿú z&JoinedLoader._gen_pooled_aliased_classc C sÔ | |jdd ¡} | r| }
|
n
|
| |¡}
|
t|
|
} | jd| ftjtjj| | j j
|
dddd} | j s^t |d k rx|j d| jj¡n| jj} | sd}|j | j||||| | ||rª|jndf ¡ |j}| |jd| ¡ | |||fS ) Nr§ Zjoinedloader_ormadapterTF)rà Zadapt_requiredZallow_label_resolveZanonymize_labelsÚ innerjoinr6 Úeager_row_processor)rF r rÚ r& Z_memor/ rÓ rÔ ZJOINEDLOAD_MEMOIZED_ADAPTERrJ rç rÒ r r rV rÛ Zcreate_eager_joinsrB Ú_create_eager_joinrþ rË r )rX r] rÀ r_ r` ra rb rÅ rÆ r¬ rÙ Z to_adapt_insprÍ rÛ rÎ r6 r6 r7 rÊ ) sR ÿ
|
ø
|
ÿý ÷ÿz"JoinedLoader._generate_row_adapterc
|
sX |d kr|j }
|
n|}
|
|jo |j} d } ||jkr~| s~|jr~t |j|j¡} t| dkr^t
|
d¡| r~|j| d }| d | } }| d kr||j } }|j | |¡}|rt |ddrä|j |
|
j¡rÈ|
|
n j¡}t |j j j}n t tj j|jdd j j}n j}|jst| p8| p8|dkp8|jj}| }|j d j fd
|
¡}|rr|t fd d |D 7 }|r¸tj ||j || p¦|jjp¦|o¦t |t j j j |d }n !|||||¡}||j| < |j|_"|s&t # jj$¡D ]4}|
|
j%j& '|¡rð|r|j(| }| )||j*¡ qð jj+rT| j,t |j- .t/ 0 jj+¡¡7 _,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Ò FTrk ZunnestedÚadditional_entity_criteriar6 c 3 s | ]}|j r| j¡V qd S r. )Zpropagate_to_loadersZ_resolve_where_criteriarJ )r Zaer£ r6 r7 r Ò s þz2JoinedLoader._create_eager_join.<locals>.<genexpr>©ÚisouterÚ
|
_left_memoÚ _right_memorþ )1rJ rÇ Z_should_nest_selectableZ eager_joinsZ from_clausesrÛ Z#find_left_clause_that_matches_givenrÑ r+ r´ rµ Ú
|
setdefaultrZ Ú aliased_inspZ_entity_for_mapperr] rD rÀ r0 rV r/ r# rÒ r r_ Zrepresents_outer_joinZglobal_attributesrF r Ú_ORMJoinr r( ZJoinÚ_splice_nested_inner_joinZstop_onZ _find_columnsZ primaryjoinZpersist_selectablerd Zcontains_columnrS r\ rÖ râ r Ú_target_adapterZcopy_and_processr rã )rX r] r^ r_ ra rÅ rÍ rÛ rÆ r r± Zshould_nest_selectableZquery_entity_keyZindexesZclauseZdefault_towrapZtowrapZefmÚonclauseZattach_on_outsideZextra_join_criteriarÞ Ú eagerjoinr r6 r£ r7 rÝ i sÔ þÿþý ÿ ÿþ ÿ
|
ÿý ÿû ÿþü ÿþ
|
ÿ÷ ÿ
|
ÿ
|
ÿ
|
ÿÿz JoinedLoader._create_eager_joinc
|
C s> |dkrt |tjs|tnbt |tjjr>| ||j||||¡S t |tjs||d |¡rxtj||j
|
|d||d j |dS d S | ||j ||||j ¡}|d krÖd}| ||j||||j¡}|d krÚ|dk sÐtdd S nd}|r|jsø|jsø| |¡} n tj|j||j|j|jd} n tj||j |j|j|j d} |j| _| S ) NFrÐ r9 rß z9assertion failed attempting to produce joined eager loadsT)rà rá )rà râ )r r/ rå r r( rÑ Z FromGroupingræ Úelementr] rä rJ Úrightrâ Úleftrá rà Z_splice_into_centerrè rç )
|
rX r_ Zjoin_objrÍ rè r ZsplicingZ target_joinZ right_spliceré r6 r6 r7 ræ
|
s ú ù
|
úúÿþ ûûz&JoinedLoader._splice_nested_inner_joinc C s |j }|r| |||j¡nd}|dk rP|}|jrB|rB| |j¡}qj|jrj|j}n| |jd¡}|d krjdS | j ||¡r||S dS d S )NFrÜ )r] rÈ r Zcompound_eager_adapterrÕ rF rJ Z_result_has_identity_key) rX rg rh ra r_ r` r] rÌ Ú decoratorr6 r6 r7 Ú_create_eager_adapterc
|
s4 ý ÿû
|
ÿ ÿz"JoinedLoader._create_eager_adapterc
|
C sÀ | j j| j jjs t d| ¡| jr,d|_|| j } |
|
|||| |¡}
|
|
|
dk r| j} t || j ||| | j |
|
¡} | js| || | |¡ q¼| || | |¡ n | j d¡ ||||||||¡ d S )Nr® TFrI )rD rG r0 r° r± r´ rµ r: Zloaders_require_uniquingrV rî r Z_instance_processorrJ rÀ r´ r³ r rj ) rX rg r^ r_ r` rJ rh ra ri Zour_pathZ eager_adapterr0 Ú _instancer6 r6 r7 rj
|
s\ ÿÿ
|
ÿú ÿÿöz!JoinedLoader.create_row_processorc sr fdd} fdd} fdd}|d | j|f¡ |d | j|f¡ jrn|d | j|f¡ d S )
|
Nc sF t | |¡}t |d¡}|j | f< |}|d k rB| |¡ d S ©NZappend_without_event©r rÆ r ZUniqueAppenderrB )r¦ rÈ rÉ r¶ Ú result_listÚinst©rï rg r0 r6 r7 Ú#load_collection_from_joined_new_rowÂ
|
s ÿzSJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_new_rowc sd | fj kr j | f }n(t | |¡}t |d¡}|j | f< |}|d k r`| |¡ d S rð rñ )r¦ rÈ rÉ rò r¶ ró rô r6 r7 Ú(load_collection_from_joined_existing_rowÏ
|
s ÿ ÿzXJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_existing_rowc s | d S r. r6 rÇ ©rï r6 r7 Ú load_collection_from_joined_execâ
|
s zPJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_execr r» r¼ ©rB r0 r¾ )rX rg r0 rï ri rõ rö rø r6 rô r7 r³ Á
|
s ÿÿÿz&JoinedLoader._create_collection_loaderc sp fdd} fdd} fdd}|d j|f¡ |d j|f¡ |jrl|d j|f¡ d S )
|
Nc s ||< d S r. r6 rÇ )rï r0 r6 r7 Ú load_scalar_from_joined_new_rowñ
|
s zKJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_new_rowc s8 |}|kr,|| k r4t d ¡ n||< d S )Nr¿ )r r, )r¦ rÈ rÉ r» ©rï r0 rX r6 r7 Ú$load_scalar_from_joined_existing_rowö
|
s þÿ zPJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_existing_rowc s | d S r. r6 rÇ r÷ r6 r7 Ú load_scalar_from_joined_exec s zHJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_execr r» r¼ rù )rX rg r0 rï ri rú rü rý r6 rû r7 r´ ð
|
s ÿÿz"JoinedLoader._create_scalar_loader)NNF)F)rk rl rm rn ro rU r} re rÈ rÉ rÚ rÊ rÝ ræ rî rj r³ r´ rp r6 r6 rZ r7 r + s( ÷
|
s:"@ " ÿ
|
Z$:/r Zselectinc s| e Zd ZdZe dddddddg¡Zd Z fd
|
d Zd d Z dd Z
|
dd Z dd Z dd Z dd Zdd Zdd Z ZS ) ÚSelectInLoader)rD Ú omit_joinÚ _parent_aliasÚ _query_infoÚ_fallback_query_infoZ queryinfoÚload_only_childÚload_with_joinÚin_exprÚpk_colsÚzero_idxÚchild_lookup_colsiô c s´ t ||¡ | jj| _| jjtjk}| jjd k r>| jj| _n<| j d¡}|rX|j | _n"| j
|
j d j |j dd| j
|
jd| _| jr¦|r| ¡ | _| ¡ | _q°| ¡ | _n
|
| ¡ | _d S )NrI r TFrß )rT rU rV rD rI r
|
rë rÿ r rÑ rD ræ r rÏ rç Ú_init_for_omit_join_m2or Ú_init_for_joinr Ú_init_for_omit_join)rX rD rY Zis_m2orT rZ r6 r7 rU / s,
|
ÿ
|
ü
|
zSelectInLoader.__init__c s t jjj fddt D ¡ fddjjD }}t|dkrbt j
|
| }d}n |d }d} dd|||d ¡S ) Nc 3 s0 | ](}j j |d ¡D ]}| | fV qqdS )r6 N)rD rç rF )r r¥ Úequiv©Úpk_to_fkrX r6 r7 r Q s þz5SelectInLoader._init_for_omit_join.<locals>.<genexpr>c s g | ]}| kr | qS r6 r6 ©r r )r r6 r7 r¤ W s z6SelectInLoader._init_for_omit_join.<locals>.<listcomp>r Fr T) r rV rá Zlocal_remote_pairsrp rè rD rz r+ r( Útuple_Ú
|
query_info)rX r Zfk_colsr r r6 r r7 r M s ÿþ
|
ÿ
|
|
z"SelectInLoader._init_for_omit_joinc sb | j j}t|dkr$tj| }d}n |d }d}| j d¡ fdd|D }| dd||||¡S )Nr Fr TrI c s g | ]} j | qS r6 r r ©rT r6 r7 r¤ m s z:SelectInLoader._init_for_omit_join_m2o.<locals>.<listcomp>)rJ rz r+ r( r rV r r )rX r r r Z lookup_colsr6 r r7 r c s
|
ÿz&SelectInLoader._init_for_omit_join_m2oc sj t | jj| _t| j fdd| jjD }t|dkrJtj| }d}n |d }d}| dd|||d ¡S )Nc s g | ]} |¡qS r6 ©Ú_adapt_elementr ©Zpa_inspr6 r7 r¤ v s z1SelectInLoader._init_for_join.<locals>.<listcomp>r Fr T)
|
r# rD rH r r& rz r+ r( r r )rX r r r r6 r r7 r
|
s s
|
|
ÿ
|
z SelectInLoader._init_for_joinc C s | j d¡ |¡ d S rH rJ r r6 r6 r7 r} s
|
ÿþz#SelectInLoader.init_class_attributec C sö |j r | ||||||||¡S | j|||| jd\} }
|
} } |
|
sBd S | jj| j jjsbt
|
d| ¡t |dkrt |j| j¡sd S nt |d | j¡sd S | } || j }| |jdd ¡}|d k rÊt|}n| j}tj || | j| j| j||| | ¡ d S )NrX r® r r9 r§ )r r rF rD rD rG r0 r° r± r´ rµ r+ r/ r² r_ rV rF r r& rÀ r r@ rK rL )rX rg r^ r_ r` rJ rh ra ri r- rM r r8 Z selectin_pathrE r¬ r r6 r6 r7 rj sp ø ÿûÿÿ
|
ÿ
|
÷z#SelectInLoader.create_row_processorc s´ |rj |krd S j} | jr¤t t¡}
|
g } j|D ]l\} jtfdd| j D } t
|
j | krtj } q¤d | kr|
|
| | f¡ q6| | f¡ q6| js¸dd |D }
|
| j}| j}| jsìjrìfdd|D } |¡}tjd| }| ¡ } ¡ }tj||gttjddd }| js<| ¡}n$| j ¡ t j j j ¡¡}| !| "t# $d
|
¡¡¡} j%j&}|j }| j'kr|j(}n&|j(} j'j(} fd dt)||D }|rè|j*rè|t +| , ¡¡f7 }|d k rú| -¡ }|j.| }| /d |i¡} j0r&|j1d d}j j2r| jsfj j2}jrZfdd|D }|j2| }nfdd}| 3|j ¡}| jr 4|
|
| | | |¡ n 5|
|
| | |¡ d S )Nc 3 s" | ]} j |tjd V qdS )r N)rû r ZPASSIVE_NO_FETCH)r Zlk)rJ r¦ Ú
|
state_dictr6 r7 r ë s úüz0SelectInLoader._load_for_path.<locals>.<genexpr>c S s$ g | ] \}}|j d ||j|fqS )r )r0 r )r r¦ rU r6 r6 r7 r¤ s ÿz1SelectInLoader._load_for_path.<locals>.<listcomp>c s g | ]} |¡qS r6 r r ©r r6 r7 r¤ s r r¨ )Zcompile_state_pluginZplugin_subject)r r r r Ú primary_keysc s g | ]\}}| |¡qS r6 )Z'_adapt_cached_option_to_uncached_option)r Zorig_optZ uncached_opt)rg r6 r7 r¤ j s
|
ý ÿr T)r3 c s g | ]} |¡qS r6 r rÝ r r6 r7 r¤ s ÿc s | j tt jj¡7 _ d S r. r r r£ r6 r7 r s ÿz?SelectInLoader._load_for_path.<locals>._setup_outermost_orderby)r )6r0 r r r r rè rD r r r r rª r rB r r r rÒ r r/ ZBundler r+ r r* r r r r r
rZ rV r ÚfilterZin_r( rî r] Zselect_statementr r$ Úziprþ r# r2 rO r Z_update_compile_optionsr3 r râ r Ú_load_via_childÚ_load_via_parent)rX rg r_ rR rS r r` r8 r r Ú
|
our_statesÚ none_statesrU Z related_identr r Z
|
bundle_entZ
|
bundle_sqlZ
|
entity_sqlru rs r- r Zcached_optionsZuncached_optionsr r r6 )rg r rJ rX r¦ r r7 rL Ó sÒ
|
ù
|
ÿþ
|
ÿ
|
þü
|
ÿÿ
|
|
ÿü þÿ
|
|
|
|
þ ÿú ÿz SelectInLoader._load_for_pathc sö | j }t|}|r¼|d| j
} || jd
}dd |jj|d fdd| D i|d ¡ D }
|
| D ]T} |
|
| d ¡} || D ]:\} }}|s| j|krq|| | j¡ | ||s®| n| g¡ q|qdq|D ]0\} }}|sÚ| j|krÚqÀ| | j¡ | |d ¡ qÀd S )Nr c S s i | ]\}}||qS r6 r6 )r r¥ r¥ r6 r6 r7 Ú
|
<dictcomp>¶ s ÿ z2SelectInLoader._load_via_child.<locals>.<dictcomp>r c s g | ]} j r|d n|qS rY ©r )r r0 ©r r6 r7 r¤ » s ÿz2SelectInLoader._load_via_child.<locals>.<listcomp>©ró r )
|
r: ÚsortedÚ
|
_chunksizer² r) rì rF r0 rP rQ )rX r r r ru rg r r: Zour_keysÚchunkÚdatar0 Z related_objr¦ rÈ rU r6 r! r7 r ¦ s<
|
þÿøþ ý
|
z SelectInLoader._load_via_childc s$ | j }|rdnd }|r |d| j
}|| jd
} fdd|D } t t¡}
|
t |jj|d| i|d ¡ dd ¡D ] \} } |
|
|
|
d d
|
| D ¡ qv|D ]\} }}}|s¸| j |kr¸q|
|
| |¡}|s|rt |d krêt d | ¡ | | j ¡ |||d ¡ q| | j ¡ |||¡ qqd S ) Nr6 r c s& g | ] \}}}} j r |d n|qS rY r )r r0 r¦ r rU r! r6 r7 r¤ ç s
|
ÿz3SelectInLoader._load_via_parent.<locals>.<listcomp>r r" c S s | d S ru r6 r r6 r6 r7 r8 ó r z1SelectInLoader._load_via_parent.<locals>.<lambda>c s s | ]}|d V qdS )r Nr6 r r6 r6 r7 r õ s z2SelectInLoader._load_via_parent.<locals>.<genexpr>r r¿ )r: r$ r r rè r¡ r¢ r² r) rì r£ r0 rF r+ r r, rP rQ )rX r r ru rg r r: Z _empty_resultr% r r& r¥ r¥ r0 r¦ r rU r¶ r6 r! r7 r Ý sN
|
þ
|
ýú þÿ ÿ ÿz SelectInLoader._load_via_parent)rk rl rm ro r Ú
|
namedtupler r$ rU r r r
|
r} rj rL r r rp r6 r6 rZ r7 rþ s, úþ M T7rþ c sT fdd fdd} fdd}t j| d|dddd t j| d
|
|dddd d S ) Nc sT |d k rP|j j krP| t |¡¡}|rP||k rPtjdt |¡| j f dd|S )NzsInstance %s is already associated with an instance of %s via its %s attribute, and is only allowed a single parent.Zbbf1)Úcode) r0 Ú hasparentr Zinstance_stater´ rµ r/ Z instance_strrH )r¦ rñ ÚoldvalueÚ initiatorr) )r3 r6 r7 Ú _do_check s ýûz*single_parent_validator.<locals>._do_checkc s | |d |S r. r6 )r¦ rñ r+ ©r, r6 r7 rB s z'single_parent_validator.<locals>.appendc s | |||S r. r6 )r¦ rñ r* r+ r- r6 r7 Úset_! s z%single_parent_validator.<locals>.set_rB T)ÚrawÚretvalr? r )r% Úlisten)r2 r3 rB r. r6 )r, r3 r7 rC s ÿrC )NNNNFN)Qrn Ú
|
__future__r r r¡ Útypingr r r r Ú r r r¬ r
|
r r r r r r r r/ Úbaser r r r r r r rg r r r r r r r² r r¦ r r r! r" r# r% r´ r& r' r( rÛ r) Zsql.selectabler* r+ r, Z sql.elementsr- rN ZColumnPropertyZ strategy_forrQ Z class_loggerrq r r r¸ r¾ rà rÄ Z MemoizedSlotsZ
|
IdentifiedrÍ r1 r7 rG rW r rþ rC r6 r6 r6 r7 Ú<module>
|
sú ÷
|
S+Z V ÿ 2%
|
&
|
ÿ -4M [ m {
|
