fume-manage-python.git

U  
¸ý°dÄâã@sÈdZddlmZddlmZddlmZddlmZddlmZddlmZddlm    Z    dd    lm
Z
dd
lmZddlmZddlm Z dd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZ ddlmZddl!m"Z"ddl#m$Z$ddl#m%Z%dd l#m&Z&dd!l'm(Z(ddl'mZ)dd"l*m+Z+dd#l*m,Z,dd$l*m-Z-dd%lm.Z.er>dd&l/m0Z0dd'lm1Z1dd(l2m3Z3dd)l4m5Z5dd*l6m7Z7dd+l8m9Z9dd,l:m;Z;dd-l<m=Z=dd.l>m?Z?dd/l#m@Z@dd0l'mAZAe d1ed2ZBe d3eCd2ZDe E¡ZFeeGeeeGeffZHd4d5d6d7d8d9ZIe Jd:¡dzd<d=ZKejLd>d?d@e Jd:¡d{dAdBdCdDdEdFdGZMdHdIdJdKdLdMdNdOZNdPdPdPdPdQej.ej.dQdQdR    dHdSdTdUdVdWdXdCdYdZdCdCd[d\d]ZOdPdPdPdPdPdQej.ej.dQdQd^
dHdSd_dUdVdWdXd`dCdYdZdCdCda dbdcZPd|dddeZQd}dfdgZRdhdiZSd~djdkZTdldmZUdndoZVdpdqZWdrdsZXdtduZYGdvdwdwZZdxdyZ[dPS)zßprivate module containing functions used to convert database
rows into object instances and associated state.
 
the functions here are called primarily by Query, Mapper,
as well as some of the attribute loading strategies.
 
é)Úannotations)ÚAny)ÚDict)ÚIterable)ÚList)ÚMapping)ÚOptional)ÚSequence)ÚTuple)Ú TYPE_CHECKING)ÚTypeVar)ÚUnioné)Ú
attributes)Úexc)Ú path_registry)Ú_DEFER_FOR_STATE)Ú_RAISE_FOR_STATE)Ú_SET_DEFERRED_EXPIRED)ÚPassiveFlag)Ú FromStatement)ÚORMCompileState)ÚQueryContext)Ú    _none_set)Ú    state_stré)Úutil)Úresult_tuple)ÚChunkedIteratorResult)ÚFrozenResult)ÚSimpleResultMetaData)Úselect)ÚForUpdateArg)ÚLABEL_STYLE_TABLENAME_PLUS_COL)ÚSelectState)Ú
EMPTY_DICT)Ú_IdentityKeyType)ÚLoaderCallableStatus)Ú    ORMOption)ÚMapper)ÚQuery)ÚSession)Ú InstanceState)ÚCursorResult)Ú_ExecuteOptions)ÚResult)ÚSelectÚ_T)ÚboundÚ_OzCursorResult[Any]rzResult[Any])ÚcursorÚcontextÚreturncsÈt_jrdjj_n
di_j}|j}jjoVt|j    dkoV|j    dj
zFttfddjj    D\}}j rjsjrt d¡Wn0tk
rÎt ¡ ¡W5QRXYnXdd    d
djjrfddjj    D}nfd djj    D}t|||d}fdd}j dd¡rht|dfdd}t||jjd}    |    j t|d¡|    _jj r°dd}
d|
f|    _!j rÄ|      j ¡|    S)a¤Return a :class:`.Result` given an ORM query context.
 
    :param cursor: a :class:`.CursorResult`, generated by a statement
     which came from :class:`.ORMCompileState`
 
    :param context: a :class:`.QueryContext` object
 
    :return: a :class:`.Result` object representing ORM results
 
    .. versionchanged:: 1.4 The instances() function now uses
       :class:`.Result` objects and has an all new interface.
 
    FTrrcsg|]}| ¡qS©)Z row_processor)Ú.0Úquery_entity)r5r4r7úMd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/orm/loading.pyÚ
<listcomp>qsÿzinstances.<locals>.<listcomp>zØCan't use yield_per with eager loaders that require uniquing or row buffering, e.g. joinedload() against collections or subqueryload().  Consider the selectinload() strategy for better flexibility in loading objects.cSst d¡dS)Nz@Can't use the ORM yield_per feature in conjunction with unique()©Úsa_excÚInvalidRequestError)Úentryr7r7r:Ú
_no_uniquesÿzinstances.<locals>._no_uniquecsfdd}|S)Ncst d¡dS)NzkCan't apply uniqueness to row tuple containing value of type %r; this datatype produces non-hashable valuesr<©Úobj©Údatatyper7r:Úgos
þÿz,instances.<locals>._not_hashable.<locals>.gor7)rDrEr7rCr:Ú _not_hashablesz instances.<locals>._not_hashablecs0g|](}jrn|js$|js$|jr(tndqS©N)Ú    yield_perÚuse_id_for_hashÚ_non_hashable_valueZ_null_column_typeÚid©r8Úent)r@r5r7r:r;s
øÿþýücs<g|]4}jrn$|js*|jr*|jjn|jr4tndqSrG)rHrIrJÚcolumnÚtyperKrL)r@rFr5r7r:r;¤súÿÿÿÿ)Z_unique_filtersc3sÖ|}i_|r  |¡}|s(qÒn ¡}rHdfdd|D}nfdd|D}rÄ|rptj ¡}jrªtj ¡}j ¡|D]\}}| |¡qqp|rÄj ¡j |¡|V|sqÒqdS)Nrcsg|]}|qSr7r7)r8Úrow©Úprocr7r:r;Ãsz-instances.<locals>.chunks.<locals>.<listcomp>cs"g|]tfddDqS)csg|]}|qSr7r7)r8rR©rPr7r:r;Æsz8instances.<locals>.chunks.<locals>.<listcomp>.<listcomp>)Útuple)r8)ÚprocessrSr:r;Ås)    ÚpartialsZ    fetchmanyZ _raw_all_rowsÚlistÚpost_load_pathsÚitemsÚclearÚinvokeÚupdate)ÚsizerHÚfetchÚrowsZtop_level_post_loadsZ
post_loadsÚpathÚ    post_load)r5r4Úis_top_levelrUÚ single_entityrQr:Úchunks³s:
 
ÿ    ÿ
 
zinstances.<locals>.chunksZprebuffer_rowsNcstSrG)Úiter)r])Ú_prebufferedr7r:rdës)Zsource_supports_scalarsÚrawZdynamic_yield_per)ÚfilteredZis_single_entitycSst d¡dS)Nz~The unique() method must be invoked on this Result, as it contains results that include joined eager loads against collectionsr<rAr7r7r:Úrequire_uniquesÿz!instances.<locals>.require_unique)"Ú
_new_runidÚrunidZtop_level_contextrXÚ compile_stateZ_has_mapper_entitiesÚload_optionsZ_only_return_tuplesÚlenÚ    _entitiesZsupports_single_entityrWÚziprHZloaders_require_bufferingZloaders_require_uniquingr=r>Ú    ExceptionrZsafe_reraiseÚcloseZ_legacy_uniquingr Úexecution_optionsÚgetrr5Z_is_server_sideÚ_attributesÚunionÚdictZmulti_row_eager_loadersZ_unique_filter_state)r4r5rlrhÚlabelsÚextraZunique_filtersZrow_metadatardÚresultrir7)r@rFrfr5r4rbrUrcr:Ú    instancesNs
ÿ
ýþÿÿ
    ÿþÿ
 
 
 
ö øÿ2û
ÿ
 
r{zsqlalchemy.orm.contextTc    sìtjj|r| ¡jj|dd}|j}z´d|_fddt|jD}dd|jD}t    |dd|jD}g}    | 
¡D]T}
|D]<}|
|dk    r|jt  |
|¡t |
|¡|iid|
|<q|     ||
¡q|| |    ¡W¢S||_XdS)    azMerge a :class:`_engine.FrozenResult` back into a :class:`_orm.Session`,
    returning a new :class:`_engine.Result` object with :term:`persistent`
    objects.
 
    See the section :ref:`do_orm_execute_re_executing` for an example.
 
    .. seealso::
 
        :ref:`do_orm_execute_re_executing`
 
        :meth:`_engine.Result.freeze`
 
        :class:`_engine.FrozenResult`
 
    F©Úlegacycs g|]\}}t|jr|qSr7©Ú
isinstanceÚ _MapperEntity©r8ÚiÚe©Úquerycontextr7r:r;-sþz'merge_frozen_result.<locals>.<listcomp>cSsg|]
}|jqSr7©Z_label_namerLr7r7r:r;2scSsg|]
}|jqSr7©Z_extra_entitiesrLr7r7r:r;5sN©ÚloadÚ
_recursiveZ_resolve_conflict_map)rÚ    preloadedÚorm_contextÚ
_autoflushÚORMSelectCompileStateÚ_create_entities_collectionÚ    autoflushÚ    enumeraterorZrewrite_rowsÚ_mergerÚinstance_stateÚ instance_dictÚappendÚ with_new_rows)ÚsessionÚ    statementÚ frozen_resultrÚctxrÚmapped_entitiesÚkeysÚkeyed_tuplerzÚnewrowrr7rr:Úmerge_frozen_results@ÿ
þÿûrz:func:`_orm.merge_result`zyThe function as well as the method on :class:`_orm.Query` is superseded by the :func:`_orm.merge_frozen_result` function.)Úalternativez
Query[Any]z>Union[FrozenResult, Iterable[Sequence[Any]], Iterable[object]]Úboolz"Union[FrozenResult, Iterable[Any]])ÚqueryÚiteratorrr6c    svtjj|jr ¡t|tr4|}t|j}nd}j    j
|dd}j}zd_|ojt|j dk}|r¢t|j djrfdd|D}nt|}n¤fd    dt|j D}g}d
d|j D}    t|    dd|j D}
|D]\}t|}|D]<} || dk    røjt || ¡t || ¡iid|| <qø| |
|¡qè|rZ| |¡W¢St|W¢SW5|_XdS) z Merge a result into the given :class:`.Query` object's Session.
 
    See :meth:`_orm.Query.merge_result` for top-level documentation on this
    function.
 
    NTr|Frrc    s,g|]$}jt |¡t |¡iidqS)r)rrrr)r8Úinstance)rrr7r:r;wsùûz merge_result.<locals>.<listcomp>cs g|]\}}t|jr|qSr7r~rrr7r:r;sþcSsg|]
}|jqSr7rrLr7r7r:r;scSsg|]
}|jqSr7rrLr7r7r:r;sr)rrrrrrrreÚdatarrrrnrorrWrrrrrrrr)r¢r£rrrrrcrzrrrrPrrr7)rrrr:Úmerge_resultKs^
ÿø
 
þÿûr¦r+z
Mapper[_O]z_IdentityKeyType[_O]rz)Union[LoaderCallableStatus, Optional[_O]])rÚmapperÚkeyÚpassiver6cCs|j |¡}|dk    rt |¡}|jr6|j |¡s6tjS|jr|tj    @sLtj
S|tj@sZ|Sz| ||¡Wn$t jk
r| |g¡YdSX|SdSdS)zqLook up the given key in the given session's identity map,
    check the object for expired state if found.
 
    N)Úidentity_maprtrrÚinheritsr§ÚisaZPASSIVE_CLASS_MISMATCHZexpiredZSQL_OKZPASSIVE_NO_RESULTZRELATED_OBJECT_OKZ _load_expiredÚorm_excÚObjectDeletedErrorZ_remove_newly_deleted)rr§r¨r©r¤Ústater7r7r:Úget_from_identity¥s"
 
 
 
r°NF)    rmÚ refresh_stateÚwith_for_updateÚonly_load_propsÚno_autoflushÚbind_argumentsrsÚrequire_pk_colsÚis_user_refreshzUnion[Select, FromStatement]zOptional[_IdentityKeyType]zOptional[Sequence[ORMOption]]zOptional[InstanceState[Any]]zOptional[ForUpdateArg]zOptional[Iterable[str]]zMapping[str, Any]r.)rrr¨rmr±r²r³r´rµrsr¶r·c    CsD|dk    r|d}|d} nd}} t|||||||| |||    |
|d S)z.Load the given identity key from the database.Nrr©
rmr±r²r³Úidentity_tokenr´rµrsr¶r·)Úload_on_pk_identity)rrr¨rmr±r²r³r´rµrsr¶r·Úidentr¹r7r7r:Ú load_on_identÌs&
ór¼r¸zOptional[Tuple[Any, ...]]z Optional[Any]) rrÚprimary_key_identityrmr±r²r³r¹r´rµrsr¶r·c
    sL|} |  ¡}|jrt|dkr$tj}|jtjkr8tj    }n|j}|dk    rÒ| j
d}|j\}d|kr¢fddt|j |D}t ||¡}t|t|kr¢t d¡t |ddi¡f|_fdd    t||j D}nd}|dk    rêd}||_n| jdk    rd}| j|_nd
}|r|rs$t d¡jj}fdd| |¡D}|rdt d |djd¡jj}|D]"}||jrp| |¡}qqpr¾jr¾|dj j!i7}|j"j}t#||||||d\}}||_d|_$|rö|dd
i7}tj% &|
d|i¡}
|j'|||
|    d (¡ )¡}z
| *¡WSt+j,k
rFYdSXdS)z6Load the given primary key identity from the database.NZplugin_subjectcs"h|]\}}|dkr|jqSrG©r¨)r8ÚcolÚvalue©Ú_get_paramsr7r:Ú    <setcomp>sþz&load_on_pk_identity.<locals>.<setcomp>zofully NULL primary key identity cannot load any object.  This condition may raise an error in a future release.Z
_orm_adaptTcsi|]\}}|j|qSr7r¾)r8Zid_valÚprimary_keyrÁr7r:Ú
<dictcomp>1sÿz'load_on_pk_identity.<locals>.<dictcomp>Fz9refresh_state is required when require_pk_cols is presentcs h|]}j|j ¡r|qSr7)ÚattrsÚhistoryÚhas_changes)r8r¨)r±r7r:rÃJsþz7Please flush pending primary key changes on attributes z for mapper z! before proceeding with a refreshÚ _current_path)Ú version_checkr³r±r¹r·rZ_sa_orm_load_options)Úparamsrsrµ)-Z_cloneZ_is_lambda_elementÚAssertionErrorrZdefault_load_optionsÚ_compile_optionsr$Zdefault_select_compile_optionsrÚdefault_compile_optionsZ_propagate_attrsÚ_get_clauserprÄÚsql_utilZadapt_criterion_to_nullrnrÚwarnZ_deep_annotateZ_where_criteriaZ_for_update_argr=Ú ArgumentErrorr§Z_primary_key_propkeysÚ
differencer>Ú_propsZ_is_relationshiprvrmÚ    load_pathÚparentÚoptionsÚ_set_get_optionsZ    _order_byr%Z
merge_withÚexecuteÚuniqueÚscalarsZonerZ NoResultFound)rrr½rmr±r²r³r¹r´rµrsr¶r·r¢ÚqÚcompile_optionsr§rÏZnonesrËrÊZrefresh_state_prokeysrÈÚmpÚpZnew_compile_optionsrzr7)rÂr±r:rºós°
ÿÿ
 
 
 
þÿÿ
ÿþ
ÿ
þ ÿ"
 
ù
 
ÿüÿ
rºc
Cs|i}i}    |r||    d<|r ||    d<|r4||    d<d|d<|rDt||d<|rP||    d<|r\||    d<|    rh||    7}|rt||7}||fS)    NZ_version_checkZ_populate_existingZ_refresh_stateTZ_for_refresh_stateZ_only_load_propsZ_identity_tokenZ_is_user_refresh)Ú    frozenset)
Zcompile_optZload_optÚpopulate_existingrÊr³r±r¹r·rÝrmr7r7r:rØ¬s(rØc    Ks´|r| |¡}
n|j}
i}| |jd|¡|oBt|dkoB|dj}|
D]6} |r\| j|kr\qH| j||||f||||d|    qH|dk    r°||jk    r°|r¢|j    |}n|}| 
|¡dS)NÚmemoized_setupsréÿÿÿÿ)r³Úcolumn_collectionZmemoized_populatorsÚcheck_for_adapt)Z_iterate_polymorphic_propertiesZ_polymorphic_propertiesÚsetrrnÚis_aliased_classr¨ÚsetupÚpolymorphic_onÚcolumnsr)rlr§r9r`ÚadapterräZwith_polymorphicr³Úpolymorphic_discriminatorÚkwZpoly_propertiesÚquick_populatorsrårÀÚpdr7r7r:Ú_setup_entity_queryÏs@ ÿüø    ÷ ÿþrðcCst dt|f¡dS)NamLoading context for %s 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.)rrÑr)r¯r7r7r:Ú_warn_for_runid_changed    s
úÿrñc
s>
jj}
d
f}| |
j|d¡}|dkrÂ
j} dk    rT|  
fddD¡} | jdt¡}g}ggggggd}dkrª
j}rfdd|D}| |¡nd||d    }| D]ò}||kr¦||}|t    krô|d
 
|j|jf¡n°|t kr|d 
|jdf¡n|tkr6|d
 
|j|jf¡nnd}r`j|}|dk    r`| |d¡}|sr| |d¡}|r|d  
|j|f¡n| ||
||¡q¾| 
|¡q¾| |
j||¡|d}dd| ¡D|dD]}| ||
|¡qäjjjjr jj|n|jjjp8
j t
jjjt
jjj tjjj!rtjjj!    tj"tj#jj$j%j&j'rÐ
j(}|dk    rÌrÀj|}| |¡ndsn|    dk    rnd|jf}|jkrj|j)dkrj|j*d}nd}
 +||    ¡}|rn||    k    rndksHt,t-|||    |}t. /|j0|||¡t. 1¡rjdkrª
 2¡nd|d
j3rºt4j5nt4j    
 fdd}
j6r:|    s:s:fdd}t7||
||||    }|S)z]Produce a mapper level row processor callable
    which processes rows into mapped instances.ÚgettersNc3s|]}j|VqdSrG)rÔ)r8Úk©r§r7r:Ú    <genexpr>?sz&_instance_processor.<locals>.<genexpr>râ)ÚnewÚquickÚdeferredÚexpireÚexistingÚeagercsg|]}j|qSr7)rê)r8Úc)rër7r:r;Vsz'_instance_processor.<locals>.<listcomp>)Úcached_populatorsÚtodoÚprimary_key_getterrörùFr÷rýcSsi|]\}}|t|qSr7)rW)r8r¨rÀr7r7r:rÅ¦sz'_instance_processor.<locals>.<dictcomp>rþÚloader))Zselectinload_polymorphicTÚentitiesrÿc
s¨r,}| ¡}|}|jk}d}d}n¶|f} |¡}|dk    r|}|}|jk}|}d}rârâ|sât    |||nT|drdSd}d}d}    j ¡}|}|}||_|_|_     ||¡}|kròd}|sü|r
|rs|s|_
|_t||||||     |rö|j}    |rrn|j j |¡|j|    krnt|rÂj||j|    krÂt|n,rÂ|j j |
¡|jkrÂt||sÐ|jrörê
rê| |
¡n| |¡r¤ |d¡n|j}
|jk}|r0|
s0 drt|||||
 }|rr~|j}    |j j ||¡|j|    kr~t|| ||¡r¤jr¤ |d¡|S)NTFrrû)rBrkrtÚ_validate_version_idÚ class_managerZnew_instancer¨r¹Ú
session_idZ_add_unpresentrmrÕÚ_populate_fullÚmanagerÚdispatchrrñrÚrefreshÚmodifiedZ_commitZ_commit_allÚ    add_stateÚunloadedrVÚ_populate_partialZinvoke_all_eagers)rPr¯r¤Údict_ÚisnewZcurrentloadÚloaded_instanceÚidentitykeyZeffective_populate_existingZexisting_runidrÚto_load)r5Úidentity_classr¹rrÚis_not_primary_keyÚload_evtrÕÚloaded_as_persistentr§r³Úpersistent_evtráÚ
populatorsrarÿÚpropagated_loader_optionsÚrefresh_evtÚrefresh_identity_keyr±rkrÚsession_identity_maprÊÚversion_id_getterr7r:Ú    _instancesØ
ý
 
ÿ    
 
ÿÿ÷
ÿ
øz&_instance_processor.<locals>._instancecs&|f}|ds|SdSdS)Nrr7)rPr)rr¹rrÿr7r:Úensure_no_pk¨sýz)_instance_processor.<locals>.ensure_no_pk)8Z_identity_classrlrtrZ    _prop_setÚintersectionr%rÄZ _tuple_getterrrr¨Z_deferred_column_loaderrrZ_raise_column_loaderrêÚ_getterZcreate_row_processorrærYrÚcurrent_pathr`rrªráZalways_refreshr¡rrrrrrrZhash_keyrkr¹rÊÚversion_id_colZstrategyZ
local_optsZ_should_selectin_loadrÌÚ_load_subclass_via_inÚPostLoadÚcallable_for_pathr§Úfor_contextÚ_identity_key_from_stateÚallow_partial_pksrÚ
issupersetÚpolymorphic_mapÚ_decorate_polymorphic_switch)r9r§r5rzr`rër³r±rìÚ_polymorphic_fromrlZ
getter_keyròÚpropsrîrþrýZpk_colsÚpropr¿ÚgetterZadapted_colr"r¨Úoption_entitiesZselectin_load_viaZ    callable_rrr7)rër5rr¹rrrrrÕrr§r³rrárrarÿrrrr±rkrrrÊrr:Ú_instance_processors:
ÿÿú    ý
 
ÿ
 
 
ÿ
 
ù ÿÿý
 
 
 
þûú    
ÿ<"÷r1csj|j|j}|jdk    }tjjdk|js0|rD ||¡\nj\fdd}|S)Nrcs¢sfdd|D}|sdS|j}f|jf}j|}|jj|_|jd|ji7_|jrp|jdd}|j     
|tfdd|Dd¡ ¡  ¡ ¡dS)Ncs$g|]\}}|j ¡r||fqSr7)r§Z+_would_selectin_load_only_from_given_mapper)r8ÚsÚvrôr7r:r;Ýsþz:_load_subclass_via_in.<locals>.do_load.<locals>.<listcomp>rÉT)rács,g|]$\}}r|jddn|jdqS)rrr¾)r8r¯Z
load_attrs)Úzero_idxr7r:r;ôsÿ)Zprimary_keys)r¢Z _with_optionsr×rlrÎrÍrÖrársrrÙrwrÚrÛÚall)r5r`ÚstatesÚ    load_onlyZeffective_entityZ
orig_queryr×Zq2©Zdisable_optZ
enable_optr§r0rÜr4r7r:Údo_loadÖs*
þ
 
 
þÿþz&_load_subclass_via_in.<locals>.do_load)r§r«rnZbase_mapperrÄrçZ_subclass_load_via_inZ_subclass_load_via_in_mapper)r5r`ÚentityZpolymorphic_fromr0Zpolymorphic_from_mapperZnot_against_basemostr9r7r8r:r#Âs
 
ÿ%r#c     Cs|r |j|_|dD]\}    }
|
|||    <q|r^|dD]$\}    }| |    d¡|r6|j |    ¡q6n"|dD]\}    }|rf|j |    ¡qf|dD]\}    }||||qnt||jkrö||_|dD]\}    }
|    |kr¸|
|||    <q¸|dD]\}    }||||qÞn|dD]\}    }||||qþdS)Nr÷rùrörú)rkÚpopÚexpired_attributesÚaddrÕ) r5rPr¯r rrÕrrárr¨r/Úset_callableÚ    populatorr7r7r:rþs.
rc Cs|s`|r.|dD]\}}    ||kr|    |||<q|j|}
|dD]\}}||
kr@||||q@n|}
|
|j|<|dD]\}}    ||
krv|    |||<qv|dD],\}}||
kr| |d¡|r|j |¡q|dD]\}}||
krÒ||||qÒ|dD]\}}||krø||||qø|
S)Nr÷rúrùrörû)rVr;r<r=) r5rPr¯r rrÕrrr¨r/rr?r>r7r7r:r7s4
 
rc    CsD| |||j¡||kr@t dt|| |||j¡||f¡dS)NzWInstance '%s' has version id '%s' which does not match database-loaded version id '%s'.)Z_get_state_attr_by_columnr"rZStaleDataErrorr)r§r¯r rPr/r7r7r:r]s&ÿþÿûþÿrc    sr|dk    r|njdkr Sr.j    
fdd}    t |    ¡
 ¡fdd}
|
S)Nc    sdzj|}Wn tk
r.td|Yn2X|kr<dS| ¡sJdSt|dSdS)Nz*No such polymorphic_identity %r is definedF)r,)r*ÚKeyErrorrÌr¬r1)Ú discriminatorZ
sub_mapper)rër5r§r`r9rzr7r:Úconfigure_subclass_mappers&ÿ
 
ùz?_decorate_polymorphic_switch.<locals>.configure_subclass_mappercs|}|dk    rf|}|r$||S|dkr\|}|rVt d|j|f¡qddSq|Sn$|}|rt d|f¡ndSdS)NFzRow with identity key %s can't be loaded into an object; the polymorphic discriminator column '%s' refers to %s, which is not a sub-mapper of the requested %szjRow with identity key %s can't be loaded into an object; the polymorphic discriminator column '%s' is NULL)r=r>r*)rPrArr)rr/Úinstance_fnr§Úpolymorphic_instancesrér7r:Úpolymorphic_instances6üüÿ 
þÿz:_decorate_polymorphic_switch.<locals>.polymorphic_instance)rérêrZPopulateDictr )rCr5r9r§rzr`rìrërrBrEr7)rër5rr/rCr§r`rDrér9rzr:r+os
 
 
&r+c@sPeZdZdZdZddZddZddZed    d
Z    eddZ
ed dZdS)r$z4Track loaders and states for "post load" operations.)Úloadersr6Ú    load_keyscCsi|_t ¡|_d|_dSrG)rFrÚOrderedDictr6rG)Úselfr7r7r:Ú__init__Ís
zPostLoad.__init__cCs||j|<dSrG)r6)rIr¯Ú    overwriter7r7r:r
ÒszPostLoad.add_statec    st|js
dStj |¡}|j ¡D]D\}}}}}fdd|j ¡D}|r |||||jf||q |j ¡dS)Ncs&g|]\}}|jj ¡r||fqSr7)rr§r¬)r8r¯rK©Úlimit_to_mapperr7r:r;åsþz#PostLoad.invoke.<locals>.<listcomp>)    r6rZPathRegistryZcoercerFÚvaluesrYrGrZ)    rIr5r`Zeffective_contextÚtokenrÚargrír6r7rLr:r[Ùs4ù
þÿÿÿzPostLoad.invokecCs$|j |j¡}|dk    r |r ||_|SrG)rXrtr`rG)Úclsr5r`r³Úplr7r7r:r&ðszPostLoad.for_contextcCs|j|jko||j|jjkSrG)r`rXrF)rIr5r`r¨r7r7r:Úpath_exists÷sþzPostLoad.path_existsc    OsF|j|jkr|j|j}nt}|j|j<||||||f|j|<dSrG)r`rXr$rF)    rQr5r`rMrOZloader_callablerPrírRr7r7r:r%þsúzPostLoad.callable_for_pathN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú    __slots__rJr
r[Úclassmethodr&rSr%r7r7r7r:r$Ès
 
r$cs8|j}|st dt|¡t|tj@}|r>| j     ¡¡}j
r|js| ||¡}|dk    r|t |}t||d|||dSt|j}|r|j}    n<fddjD}
|j |
¡rÄt dt|¡ |¡}    t |    ¡rÞjrèt |    ¡rüt dt|¡dSt|t t¡|    |||d}|r4|dkr4t |¡dS)    z4initiate a column-based attribute refresh operation.zQInstance %s is not bound to a Session; attribute refresh operation cannot proceedN)r³r±r´csg|]}j|jqSr7)Z_columntopropertyr¨)r8r¿rôr7r:r;Dsz*load_scalar_attributes.<locals>.<listcomp>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).)r±r³r´)rrZDetachedInstanceErrorrr¡rZNO_AUTOFLUSHrrÆrr«ZconcreteZ_optimized_get_statementrr¼r¨rÄr<r=r>r'rÚissubsetr(r)rZwarn_limitedr!Zset_label_styler#r®)r§r¯Zattribute_namesr©rr´rZstmtZhas_keyZidentity_keyZpk_attrsrzr7rôr:Úload_scalar_attributesspÿÿ
ú
 
 
ÿþÿ
ÿÿþüúr[)T)T)NNNNNN)NNN)NNNN)\rWÚ
__future__rÚtypingrrrrrrr    r
rrr ÚrrrrÚbaserrrrr5rrrrrrr=ZenginerZ engine.resultrrr Zsqlr!rÐZsql.selectabler"r#r$r%Ú_typingr&r'Z
interfacesr(r§r)r¢r*rr+r¯r,Z engine.cursorr-Zengine.interfacesr.r/r0r1Úobjectr3ÚcounterrjÚstrZ_PopulatorDictr{Zpreload_modulerZbecame_legacy_20r¦r°r¼rºrØrðrñr1r#rrrr+r$r[r7r7r7r:Ú<module>
sâB;þýT,ó(,ò*=ø
*÷
:ö
0<9&YH