관리-도구
편집 파일: loading.cpython-38.pyc
U -?�f�� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z dd lm Z dd lm Z dd lm Z dd lm Z dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddl m Z ddl m Z ddlmZ dd lm Z dd l!m"Z" dd l#m$Z$ dd l#m%Z% dd l#m&Z& dd!l'm(Z( dd l'm Z) dd"l*m+Z+ dd#l*m,Z, dd$l*m-Z- dd%l m.Z. e �r>dd&l/m0Z0 dd'lm1Z1 dd(l2m3Z3 dd)l4m5Z5 dd*l6m7Z7 dd+l8m9Z9 dd,l:m;Z; dd-l<m=Z= dd.l>m?Z? dd/l#m@Z@ dd0l'mAZA e d1ed2�ZBe d3eCd2�ZDe �E� ZFeeGee eGef f ZHd4d5d6d7�d8d9�ZIe �Jd:�dzd<d=��ZKe jLd>d?d@�e �Jd:�d{dAdBdCdDdE�dFdG���ZMdHdIdJdKdLdM�dNdO�ZNdPdPdPdPdQe j.e j.dQdQdR� dHdSdTdUdVdWdXdCdYdZdCdCd[� d\d]�ZOdPdPdPdPdPdQe j.e j.dQdQd^� dHdSd_dUdVdWdXd`dCdYdZdCdCda� dbdc�ZPd|ddde�ZQd}dfdg�ZRdhdi� ZSd~djdk�ZTdldm� ZUdndo� ZVdpdq� ZWdrds� ZXdtdu� ZYG dvdw� dw�ZZdxdy� Z[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]r z Result[Any])�cursor�context�returnc s� t � �_�jr d��jj�_n d�i �_�j}|j}�jj oVt|j �dkoV|j d j �zFt t ��fdd��jj D �� �\�}}�j r��js��jr�t�d��W n0 tk r� t�� � ��� W 5 Q R X Y nX dd � � ddd �d d ��� ��fd d��jj D �}t|||d�}�����fdd�}�j�dd��rLt |d����fdd�}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. FTr r c s g | ]}|� � ���qS � )Z row_processor)�.0� query_entity)r5 r4 r7 �F/opt/hc_python/lib64/python3.8/site-packages/sqlalchemy/orm/loading.py� <listcomp>q s �z instances.<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.c S s t �d��d S )Nz@Can't use the ORM yield_per feature in conjunction with unique()��sa_exc�InvalidRequestError)�entryr7 r7 r: � _no_unique� s �z instances.<locals>._no_unique��legacy� uncertainc s6 |s��fdd�}|S �s t S d� � fdd�}|S d S )Nc s@ �r z t | �W S Y nX t�d� �d�r0dnd� d���d S )Nz=Can't apply uniqueness to row tuple containing value of type z; z the values returned appear to bezthis datatype producesz non-hashable values)�hashr= r> ��obj)�datatyperC r7 r: �go� s ���z,instances.<locals>._not_hashable.<locals>.goFc s( � s z t | �W S Y nX d� t| �S )NT)rD �idrE )�_use_idr7 r: rH � s )rI )rG rB rC rH r7 )rJ rG rC r: � _not_hashable� s z instances.<locals>._not_hashablec sN g | ]F}�j r� n6|js<|js$|jr<�|jj�jj|jd �n |jrFtnd�qS )rA N) � yield_perZuse_id_for_hashZ_non_hashable_valueZ_null_column_type�column�type� load_optionsZ_legacy_uniquingrI �r8 Zent)r@ rK r5 r7 r: r; � s �� ���� )Z_unique_filtersc 3 s� | }i �_ |r ��|�}|s(q�n��� }�rH�d � � fdd�|D �}n�fdd�|D �}�r�|rpt�j�� �}�jr�t�j�� �}�j�� |D ]\}}|��|� q�qp|rĈj�� �j�|� |V |s q�q d S )Nr c s g | ] }� |��qS r7 r7 )r8 �row��procr7 r: r; � s z-instances.<locals>.chunks.<locals>.<listcomp>c s" g | ]� t � fd d��D ���qS )c s g | ] }|� ��qS r7 r7 )r8 rS �rQ r7 r: r; � s z8instances.<locals>.chunks.<locals>.<listcomp>.<listcomp>)�tuple)r8 )�processrT r: r; � s ) �partialsZ fetchmanyZ _raw_all_rows�list�post_load_paths�items�clear�invoke�update)�sizerL �fetch�rowsZtop_level_post_loadsZ post_loads�path� post_load)r5 r4 � is_top_levelrV � single_entityrR r: �chunks� s: � � zinstances.<locals>.chunksZprebuffer_rowsNc s t � �S �N)�iter)r^ )� _prebufferedr7 r: re s )Zsource_supports_scalars�rawZdynamic_yield_per)�filteredZis_single_entityc S s t �d��d S )Nz~The unique() method must be invoked on this Result, as it contains results that include joined eager loads against collectionsr< rE r7 r7 r: �require_unique s �z!instances.<locals>.require_unique)!� _new_runid�runidZtop_level_contextrY � compile_stateZ_has_mapper_entitiesrO Z_only_return_tuples�len� _entitiesZsupports_single_entityrX �ziprL Zloaders_require_bufferingZloaders_require_uniquingr= r> � Exceptionr Z safe_reraise�closer �execution_options�getr r5 Z_is_server_side� _attributes�union�dictZmulti_row_eager_loadersZ_unique_filter_state) r4 r5 rn rj �labels�extraZunique_filtersZ row_metadatare �resultrk r7 )r@ rK rh r5 r4 rc rV rd r: � instancesN s| � � ��� ��� +� �2 � � r| zsqlalchemy.orm.contextTc s� t jj� |r| �� � jj|dd�}| j}z�d| _� fdd�t|j�D �}dd� |jD �}t |dd� |jD ��}g } |� � D ]T} |D ]<} | | dk r�| j t � | | �t �| | �|i i d�| | < q�| �|| �� q||�| �W �S || _X dS ) az Merge 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�rB c s g | ]\}}t |� j�r|�qS r7 �� isinstance� _MapperEntity�r8 �i�e�� querycontextr7 r: r; I s �z'merge_frozen_result.<locals>.<listcomp>c S s g | ] }|j �qS r7 �Z _label_namerP r7 r7 r: r; N s c S s g | ] }|j �qS r7 �Z_extra_entitiesrP r7 r7 r: r; Q s N��loadZ _recursiveZ_resolve_conflict_map)r � preloaded� orm_context� _autoflush�ORMSelectCompileState�_create_entities_collection� autoflush� enumeraterp r Z rewrite_rows�_merger �instance_state� instance_dict�append� with_new_rows) �session� statement� frozen_resultr� �ctxr� �mapped_entities�keys� keyed_tupler{ �newrowr� r7 r� r: �merge_frozen_result+ s@ � � � � r� z: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�iteratorr� r6 c sv t jj�| j�� r��� t|t�r4|}t|j�}nd}�j j | dd�}�j }�zd�_ | ojt |j �dk}|r�t|j d �j�r�� �fdd�|D �}nt|�}n��fd d�t|j �D �}g }d d� |j D �} t| d d� |j D ��} |D ]\} t| �} |D ]<} | | dk r��jt�| | �t�| | �� i i d �| | < q�|�| | �� q�|�rZ|�|�W �S t|�W �S W 5 |�_ X dS ) 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} Fr r c s, g | ]$}�j t�|�t�|�� i i d ��qS )r� )r� r r� r� )r8 �instance)r� r� r7 r: r; � s ��z merge_result.<locals>.<listcomp>c s g | ]\}}t |� j�r|�qS r7 r~ r� r� r7 r: r; � s �c S s g | ] }|j �qS r7 r� rP r7 r7 r: r; � s c S s g | ] }|j �qS r7 r� rP r7 r7 r: r; � s r� )r r� r� r� r� r r rg �datar� r� r� ro rp r� rX r� r r� r r� r� r� r� )r� r� r� r� r� r� rd r{ r� r� r� rQ r� r� r7 )r� r� r� r: � merge_resultg s^ � � � � � r� r+ z Mapper[_O]z_IdentityKeyType[_O]r z)Union[LoaderCallableStatus, Optional[_O]])r� �mapper�key�passiver6 c C s� | j �|�}|dk r�t�|�}|jr6|j�|�s6tjS |jr�|tj @ sLtj S |tj @ sZ|S z|� ||� W n$ t jk r� | �|g� Y dS X |S dS dS )zqLook up the given key in the given session's identity map, check the object for expired state if found. N)� identity_mapru r r� �inheritsr� �isaZPASSIVE_CLASS_MISMATCHZexpiredZSQL_OKZPASSIVE_NO_RESULTZRELATED_OBJECT_OKZ _load_expired�orm_exc�ObjectDeletedErrorZ_remove_newly_deleted)r� r� r� r� r� �stater7 r7 r: �get_from_identity� s" r� NF) rO � refresh_state�with_for_update�only_load_props� no_autoflush�bind_argumentsrt �require_pk_cols�is_user_refreshz Union[Select, FromStatement]zOptional[_IdentityKeyType]z Optional[Sequence[ORMOption]]z Optional[InstanceState[Any]]zOptional[ForUpdateArg]zOptional[Iterable[str]]zMapping[str, Any]r. ) r� r� r� rO r� r� r� r� r� rt r� r� c C sD |dk r|d } |d } nd } } t | || ||||| ||| | | d� S )z.Load the given identity key from the database.Nr r � rO r� r� r� �identity_tokenr� r� rt r� r� )�load_on_pk_identity)r� r� r� rO r� r� r� r� r� rt r� r� �identr� r7 r7 r: � load_on_ident� s& �r� r� zOptional[Tuple[Any, ...]]z Optional[Any]) r� r� �primary_key_identityrO r� r� r� r� r� r� rt r� r� c sL |} | � � }|jrt�|dkr$tj}|jtjkr8tj }n|j}|dk r�| j d }|j \}� d|kr�� fdd�t |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�|�r���s$t�d ���jj}�fd d�|�|�D �}|�rdt�d |� d�j� d����jj }|D ]"}|| j �rp|� |�} �q��qp��r��j �r�|d�j j!i7 }|j"�j � }t#||||�|| d�\}}||_d|_$|�r�|dd i7 }tj%�&| d|i�} | j'||| | d��(� �)� }z |�*� W S t+j,k �rF Y dS X dS )z6Load the given primary key identity from the database.NZplugin_subjectc s" h | ]\}}|d kr� | j �qS rf �r� )r8 �col�value�� _get_paramsr7 r: � <setcomp>8 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_adaptTc s i | ]\}}� | j |�qS r7 r� )r8 Zid_val� primary_keyr� r7 r: � <dictcomp>K s � z'load_on_pk_identity.<locals>.<dictcomp>Fz9refresh_state is required when require_pk_cols is presentc s h | ]}� j | j�� r|�qS r7 )�attrs�history� has_changes)r8 r� )r� r7 r: r� d s �z7Please flush pending primary key changes on attributes z for mapper z! before proceeding with a refresh� _current_path)� version_checkr� r� r� r� r� Z_sa_orm_load_options)�paramsrt r� )-Z_cloneZ_is_lambda_element�AssertionErrorr Zdefault_load_options�_compile_optionsr$ Z default_select_compile_optionsr �default_compile_optionsZ_propagate_attrs� _get_clauserq r� �sql_utilZadapt_criterion_to_nullro r �warnZ_deep_annotateZ_where_criteriaZ_for_update_argr= � ArgumentErrorr� Z_primary_key_propkeys� differencer> �_propsZ_is_relationshiprw rO � load_path�parent�options�_set_get_optionsZ _order_byr% Z merge_with�execute�unique�scalars�oner� Z NoResultFound)r� r� r� rO r� r� r� r� r� r� rt r� r� r� �q�compile_optionsr� r� Znonesr� r� Zrefresh_state_prokeysr� �mp�pZnew_compile_optionsr{ r7 )r� r� r: r� s� �� � �� �� � � �" � �� � r� c C s| 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) Z compile_optZload_opt�populate_existingr� r� r� r� r� r� rO r7 r7 r: r� � s( r� c K s� |r|� |�} n|j} i } |�| jd| � |oBt|�dkoB|d j} | D ]6} |r\| j|kr\qH| j| |||f||| | d�| �� qH|d k r�||jk r�|r�|j | }n|}|� |� d S )N�memoized_setupsr ���)r� �column_collectionZmemoized_populators�check_for_adapt) Z _iterate_polymorphic_propertiesZ_polymorphic_properties�setr ro �is_aliased_classr� �setup�polymorphic_on�columnsr� )rn r� r9 ra �adapterr� Zwith_polymorphicr� �polymorphic_discriminator�kwZpoly_properties�quick_populatorsr� r� �pdr7 r7 r: �_setup_entity_query� s@ ��� � �� r� c C s t �dt| �f � d S )Nam Loading 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.)r r� r )r� r7 r7 r: �_warn_for_runid_changed s ��r� c s� � j ��j} d� f} |�| j| d�} | dk�r j} � dk rT| �� fdd�� D ��} |��jdt�}g }g g g g g g d�}�dkr�� j}� r�� fdd�|D �}|�|��nd�||�d �} | D ]�}||k�r�|| }|t kr�|d � |j |j f� n�|t k�r|d � |j d f� n�|tk�r6|d � |j |jf� nnd}� �r`� j| }|dk �r`|�|d �}|�sr|�|d �}|�r�|d � |j |f� n|��| |� |� |� q�|� |� q�|�| j| | � | d }dd� |�� D ��| d D ] }|��| |� |� �� �q�j��jjj�r �jj| n|��jj��j�p8� j� t � j j j ��t � j j j ��t �jj j!�� � �rt�jj j!� tj"�tj#��jj$��j%��j&��j'���rЈ j(}|dk �r̈ �r�� j| }|�|��nd���s�| dk �r�d|jf}|�jk�r�j| j)dk�r�j| j*d }nd}� �+|| �}|�r�|| k �rʈ dk�sHt,�|j-�r~g }|}|�r�|| k �r�|� |� |j.}�qXn|g}|D ]@} t/�0��| ��r��q�t1�|| | |�} t/�2��| j3| | | � �q�t/�4��� ����r��j ��dk�r� �5���n d�| d �� j6�rt7j8�nt7j���������� � � � � ������������fdd�} � j9�r�| �s���s�����fdd�} t:| �| � |||� | � } | S )z]Produce a mapper level row processor callable which processes rows into mapped instances.�gettersNc 3 s | ]}� j | V qd S rf )r� )r8 �k�r� r7 r: � <genexpr>U s z&_instance_processor.<locals>.<genexpr>r� )�new�quick�deferred�expire�existing�eagerc s g | ]}� j | �qS r7 )r� )r8 �c)r� r7 r: r; l s z'_instance_processor.<locals>.<listcomp>)�cached_populators�todo�primary_key_getterr� r� Fr� r� c S s i | ]\}}|t |��qS r7 )rX )r8 r� r� r7 r7 r: r� � s z'_instance_processor.<locals>.<dictcomp>r� �loader))Zselectinload_polymorphicT�entitiesr� c s� �r,�}|� � }�|�}|j�k}d}d}n���| ��f}��|�}|d k r��|�}�|�}|j�k}| }d}�r�r�|s�t� ||| �� nT�|d �r�d S d}d}d}� j�� }�|�}�|�}||_�|_�|_�� ||� � }�|kr�d}|s�|�r |�r��s|�s�|_ �|_ t � | |||�||� � |�r�|j} |�r���rn|j j�|� � |j| k�rnt|� � �r� j|� |j| k�r�t|� n,��r�|j j�|� � � |j�k�r�t|� |�s�|j�r���r� �r�|�|� � n |�|�� ��r���|d� n�|j} |� jk}|�r0| �s0� d �r�t� | |||�| � �} |�r���r~|j} |j j�|� | � |j| k�r~t|� |�|| � ��r�� j�r���|d� |S )NTFr r� )rF rm ru �_validate_version_id� class_managerZ new_instancer� r� � session_idZ_add_unpresentrO r� �_populate_full�manager�dispatchr� r� r� �refresh�modifiedZ_commitZ _commit_all� add_state�unloadedrW �_populate_partialZinvoke_all_eagers) rQ r� r� �dict_�isnewZ currentload�loaded_instance� identitykeyZeffective_populate_existingZexisting_runidr �to_load)r5 �identity_classr� r� r� �is_not_primary_key�load_evtr� �loaded_as_persistentr� r� �persistent_evtr� � populatorsrb r� �propagated_loader_options� refresh_evt�refresh_identity_keyr� rm r �session_identity_mapr� �version_id_getterr7 r: � _instance+ s� � � ��� � � z&_instance_processor.<locals>._instancec s& � �| ��f}�|d �s |S d S d S )Nr r7 )rQ r )r r� r r� r7 r: � ensure_no_pk� s � z)_instance_processor.<locals>.ensure_no_pk);Z_identity_classrn ru r Z _prop_set� intersectionr% r� Z _tuple_getterr r� r� Z_deferred_column_loaderr r Z_raise_column_loaderr� �_getterZcreate_row_processorr� rZ r � current_pathra r� r� r� Zalways_refreshr� r r r� r r r� r� Zhash_keyrm r� r� �version_id_colZstrategyZ local_optsZ_should_selectin_loadr� Z is_mapperr� �PostLoad� path_exists�_load_subclass_via_in�callable_for_pathr� � for_context�_identity_key_from_state�allow_partial_pksr � issuperset�polymorphic_map� _decorate_polymorphic_switch) r9 r� r5 r{ ra r� r� r� r� �_polymorphic_fromrn Z getter_keyr� �propsr� r� r� Zpk_cols�propr� �getterZ adapted_colr" r� �option_entitiesZselectin_load_viaZ _load_supersZ_endmost_mapperZ_selectinload_entityZ callable_r r r7 )r� r5 r r� r� r� r r r� r r� r� r r� r rb r� r r r r� rm r r r� r r: �_instance_processor+ s\ � �� � � � � ��� ��� ��� �< ! � r2 c sj |j �|j }|jd k }t�jj�dk�|js0|rD��||�\��� n �j\��� � �����fdd�}|S )Nr c s� �s �fdd�|D �}|s d S | j }|jr@��|�}� �|�}n�}� }|f|j |f }�j|� } | jj| _| jd|ji7 _| jr�| j dd�} | j � | t �fdd�|D �d��� � �� �� d S )Nc s$ g | ] \}}|j �� �r||f�qS r7 )r� Z+_would_selectin_load_only_from_given_mapper)r8 �s�vr� r7 r: r; s �z:_load_subclass_via_in.<locals>.do_load.<locals>.<listcomp>r� T)r� c s, g | ]$\}}� r |j d d n|j d �qS )r r r� )r8 r� Z load_attrs)�zero_idxr7 r: r; # s �)Z primary_keys)r� r� Z _prepend_pathZ _with_optionsr� rn r� r� r� rt r� r� rx r� r� �all) r5 ra �states� load_onlyZeffective_entityZ orig_queryZenable_opt_lclZdisable_opt_lclr� �q2�Z disable_optZ enable_optr� r1 r� r5 r7 r: �do_load� s6 � � ���z&_load_subclass_via_in.<locals>.do_load)r� r� ro Z base_mapperr� r� Z_subclass_load_via_inZ _subclass_load_via_in_mapper)r5 ra �entityZpolymorphic_fromr1 Zpolymorphic_from_mapperZnot_against_basemostr; r7 r: r: r% � s � .r% c C s |r�| j |_ |d D ]\} } | |�|| < q|r^|d D ]$\} } |�| d � | r6|j�| � q6n"|d D ]\} } | rf|j�| � qf|d D ]\} } | |||� q�nt||jkr�||_|d D ] \} } | |kr�| |�|| < q�|d D ]\} } | |||� q�n |d D ]\} } | |||� q�d S )Nr� r� r� r� )rm �pop�expired_attributes�addr� ) r5 rQ r� r r r� r r� r r� r0 � set_callable� populatorr7 r7 r: r - s. r c C s |s`|r.|d D ] \}} ||kr| |�||< q| j | } |d D ] \}} || kr@| |||� q@n�|} | | j |< |d D ] \}} || krv| |�||< qv|d D ],\}} || kr�|�|d � | r�|j�|� q�|d D ] \}} || kr�| |||� q�|d D ] \}} ||kr�| |||� q�| S )Nr� r� r� r� r� )rW r= r> r? ) r5 rQ r� r r r� r r r� r0 r rA r@ r7 r7 r: r f s4 r c C sD | � ||| j�||�kr@t�dt|�| � ||| j�||�f ��d S )NzWInstance '%s' has version id '%s' which does not match database-loaded version id '%s'.)Z_get_state_attr_by_columnr" r� ZStaleDataErrorr )r� r� r rQ r0 r7 r7 r: r � s& �� ����r c sr |d k r|�n�j ��d kr �S � r.� j� �� ���� � fdd�} t�| ��� ����������fdd�} | S )Nc sd z�j | }W n tk r. td| ��Y n2X |�kr<d S |���sJdS t�|���� �d�S d S )Nz*No such polymorphic_identity %r is definedF)r- )r+ �KeyErrorr� r� r2 )� discriminatorZ sub_mapper)r� r5 r� ra r9 r{ r7 r: �configure_subclass_mapper� s& � �z?_decorate_polymorphic_switch.<locals>.configure_subclass_mapperc s� �| �}|d k rf�| }|r$|| �S |dkr\� | �}|rVt �d|��j| �f ��qdd S q��| �S n$� | �}|r�t �d|�f ��nd S d S )NFz�Row 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+ )rQ rC r r )r r0 � instance_fnr� �polymorphic_instancesr� r7 r: �polymorphic_instance� s6 ��� ��z:_decorate_polymorphic_switch.<locals>.polymorphic_instance)r� r� r Z PopulateDictr ) rE r5 r9 r� r{ ra r� r� r rD rG r7 ) r� r5 r r0 rE r� ra rF r� r9 r{ r: r, � s &r, c @ sP e Zd ZdZdZdd� Zdd� Zdd� Zed d � �Z ed d � �Z ed d� �Z dS )r# z4Track loaders and states for "post load" operations.)�loadersr7 � load_keysc C s i | _ t�� | _d | _d S rf )rH r � OrderedDictr7 rI )�selfr7 r7 r: �__init__� s zPostLoad.__init__c C s || j |< d S rf )r7 )rK r� � overwriter7 r7 r: r � s zPostLoad.add_statec st | j s d S tj�|�}| j�� D ]D\}}� }}}� fdd�| j �� D �}|r ||||| jf|�|� q | j �� d S )Nc s& g | ] \}}|j j�� �r||f�qS r7 )r r� r� )r8 r� rM ��limit_to_mapperr7 r: r; s �z#PostLoad.invoke.<locals>.<listcomp>) r7 r Z PathRegistryZcoercerH �valuesrZ rI r[ ) rK r5 ra Zeffective_context�tokenr �argr� r7 r7 rN r: r\ s4 � � ���zPostLoad.invokec C s$ |j �|j�}|d k r |r ||_|S rf )rY ru ra rI )�clsr5 ra r� �plr7 r7 r: r' s zPostLoad.for_contextc C s |j |jko ||j|j jkS rf )ra rY rH )rK r5 ra r� r7 r7 r: r$ $ s �zPostLoad.path_existsc O sF |j |jkr|j|j }nt� }|j|j < ||||||f|j|< d S rf )ra rY r# rH ) rS r5 ra rO rQ Zloader_callablerR r� rT r7 r7 r: r& + s �zPostLoad.callable_for_pathN) �__name__� __module__� __qualname__�__doc__� __slots__rL r r\ � classmethodr' r$ r& r7 r7 r7 r: r# � s r# c s8 |j }|s t�dt|� ��t|tj@ �}|r>|�� j� � �}� j r|� j s|� � ||�}|dk r|t � |�}t||d|||d�S t|j�}|r�|j} n<� fdd�� jD �} |j�| �r�t�dt|� ��� �|�} t�| �rވ jr�t�| �r�t�dt|�� dS t|t� �� t �| |||d�} |�r4| dk�r4t� |��dS ) z4initiate a column-based attribute refresh operation.zQInstance %s is not bound to a Session; attribute refresh operation cannot proceedN)r� r� r� c s g | ]}� j | j�qS r7 )Z_columntopropertyr� )r8 r� r� r7 r: r; p s z*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� ) r� r� ZDetachedInstanceErrorr r� r Z NO_AUTOFLUSHr r� r� r� ZconcreteZ_optimized_get_statementr r� r� r� r> r= r> r( r �issubsetr) r* r Z warn_limitedr! Zset_label_styler# r� ) r� r� Zattribute_namesr� r� r� r� �stmtZhas_keyZ identity_keyZpk_attrsr{ r7 r� r: �load_scalar_attributes= sp �� � � �� ���� � r] )T)T)NNNNNN)NNN)NNNN)\rX � __future__r �typingr r r r r r r r r r r � r r r� r �baser r r r r5 r r r r r r r= Zenginer Z engine.resultr r r �sqlr! r� Zsql.selectabler" r# r$ r% Z_typingr& r' Z interfacesr( r� r) r� r* r� r+ r� r, Z engine.cursorr- Zengine.interfacesr. r/ r0 r1 �objectr3 �counterrl �strZ_PopulatorDictr| Zpreload_moduler� Zbecame_legacy_20r� r� r� r� r� r� r� r2 r% r r r r, r# r] r7 r7 r7 r: �<module> s� ^ ;� �T+�(,�* < � ) � 7 � @E9%YH