관리-도구
편집 파일: strategies.cpython-37.pyc
B ��4]zJ � @ sv d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZ dd lmZ ddlmZ ddl mZ ddl mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z dd lmZ dd l mZ ddl m!Z! dKd d �Z"e j#j$ddd �G d d � d e��Z%e j&e j#j$d!dd �G d"d#� d#e���Z'e j&e j#j$d!d$�G d%d&� d&e'���Z(e j&e j#j$d!d!d'�e j#j$d!d(�G d)d*� d*e����Z)G d+d,� d,e*�Z+G d-d.� d.e�Z,e j&e j-j$d!d(�G d/d0� d0e���Z.e j&e j-j$d1d2�e j-j$dd2�G d3d4� d4e,����Z/e j&e j-j$d!d2�e j-j$d5d2�e j-j$d6d2�e j-j$d7d2�e j-j$d8d2�G d9d:� d:e,ej0�������Z1G d;d<� d<e*�Z2e j-j$d=d2�G d>d?� d?e,��Z3e j&e j-j$d@d2�G dAdB� dBe,���Z4e j&e j-j$dCd2�e j-j$dd2�G dDdE� dEe,����Z5e j&e j-j$dFd2�G dGdH� dHe,ej0���Z6dIdJ� Z7dS )LzWsqlalchemy.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 s< t tj| jg d��} g } |o | j�|r6| jr6| �t� | j| j j krj| j j | j \��| ���fdd�� |rz| �t j � |r�| j � � r�| �� �fdd�� x�|jD ]�} | | j�| j�kr�| j�| j�s�tj| j| jf| �||| |o�| jp�| jtjk||||| �p | j | jd� | ��} x| D ]}|| | � �q W q�W d S )N)�defaultc s t j| |j� f��S )N)�orm_utilZ_validator_events�key)�desc�prop)�fn�opts� �L/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/orm/strategies.py�<lambda>B s z%_register_attribute.<locals>.<lambda>c s t �| � ��S )N)r Zbackref_listeners)r r )�backref�uselistr! r" r# P s ) Z parent_tokenr% �compare_function� useobject� extensionZ trackparent� typecallable� callable_�active_history� impl_classZsend_modified_events�doc)�listr �to_listr( r% Z single_parent�append�single_parent_validatorr �parentZ validatorsr Ztrack_cascade_eventsZback_populatesZself_and_descendants�_props�get� class_managerZ_attr_has_implr Zregister_attribute_impl�class_� directionr Z ONETOMANYZviewonlyr- )r �mapperr' r& r) r* Zproxy_propertyr+ r, �kwZ attribute_extZ listen_hooks�mr �hookr! )r$ r r r% r" �_register_attribute) sP r< )� instrument�deferredc s6 e Zd ZdZdZ� fdd�Zd dd�Zdd � 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 t| ��||� | jj| _d S )N)�superr? �__init__�parent_propertyr@ )�selfr2 � strategy_key)� __class__r! r" rB � s z#UninstrumentedColumnLoader.__init__Nc K s, x&| j D ] }|r|j | }|�|� qW d S )N)r@ r0 ) rD �context� query_entity�path�loadopt�adapter�column_collection�kwargs�cr! r! r" � setup_query� s z&UninstrumentedColumnLoader.setup_queryc C s d S )Nr! )rD rG rI rJ r8 �resultrK � populatorsr! r! r" �create_row_processor� s z/UninstrumentedColumnLoader.create_row_processor)N) �__name__� __module__� __qualname__�__doc__� __slots__rB rO rR � __classcell__r! r! )rF r" r? s r? Tc s< e Zd ZdZdZ� fdd�Zdd� Zdd� Zd d � Z� Z S ) � ColumnLoaderz8Provide loading behavior for a :class:`.ColumnProperty`.)r@ � is_compositec s. t t| ��||� | jj| _t| jd�| _d S )N�composite_class)rA rY rB rC r@ �hasattrrZ )rD r2 rE )rF r! r" rB � s zColumnLoader.__init__c K sN x&| j D ] } |r|j | } |�| � qW | j d } |r@|j | } | || j< d S )Nr )r@ r0 rC ) rD rG rH rI rJ rK rL �memoized_populatorsrM rN �fetchr! r! r" rO � s zColumnLoader.setup_queryc C sP d| _ | jd j}| jjp4| jd jp4|jt| j�k}t| j|d|j |d� d S )NTr F)r' r& r+ ) �is_class_levelr@ �typerC r+ � primary_keyZversion_id_col�setr< �compare_values)rD r8 Zcoltyper+ r! r! r" �init_class_attribute� s z!ColumnLoader.init_class_attributec C s\ xV| j D ]8}|r|j | }|�|d�} | r|d �| j| f� P qW |d �| jdf� d S )NF�quick�expireT)r@ �_getterr0 r ) rD rG rI rJ r8 rP rK rQ �col�getterr! r! r" rR � s z!ColumnLoader.create_row_processor) rS rT rU rV rW rB rO rd rR rX r! r! )rF r" rY � s rY )Zquery_expressionc s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �ExpressionColumnLoaderc s t t| ��||� d S )N)rA rj rB )rD r2 rE )rF r! r" rB � s z ExpressionColumnLoader.__init__c K sd |r`d|j kr`|j d g} x$| D ] } |r2|j| } |�| � q W | d } |rV|j| } | || j< d S )N� expressionr )� local_optsr@ r0 rC ) rD rG rH rI rJ rK rL r] rM r@ rN r^ r! r! r" rO � s z"ExpressionColumnLoader.setup_queryc C st |rpd|j krp|j d g}xT|D ]8} |r2|j| } |�| d�} | r |d �| j| f� P q W |d �| jdf� d S )Nrk Fre rf T)rl r@ rg r0 r ) rD rG rI rJ r8 rP rK rQ r@ rh ri r! r! r" rR s z+ExpressionColumnLoader.create_row_processorc C s( d| _ t| j|d| jd jjdd� d S )NTFr )r' r& Zaccepts_scalar_loader)r_ r< rC r@ r` rc )rD r8 r! r! r" rd s z+ExpressionColumnLoader.init_class_attribute)rS rT rU rB rO rR rd rX r! r! )rF r" rj � s rj )r> r= )Z do_nothingc sF e Zd ZdZdZ� fdd�Zdd� Zdd� Zdd d �Zd d � Z � Z S )�DeferredColumnLoaderzAProvide loading behavior for a deferred :class:`.ColumnProperty`.)r@ �groupc s> t t| ��||� t| jd�r&td��| jj| _| jj| _d S )Nr[ z8Deferred loading for composite types not implemented yet)rA rm rB r\ rC �NotImplementedErrorr@ rn )rD r2 rE )rF r! r" rB , s z DeferredColumnLoader.__init__c C s< | j s$| jj}|d �| j|f� n|d �| jdf� d S )N�newrf F)r_ rC Z_deferred_column_loaderr0 r ) rD rG rI rJ r8 rP rK rQ Z set_deferred_for_local_stater! r! r" rR 5 s z)DeferredColumnLoader.create_row_processorc C s, d| _ t| j|d| jd jj| jdd� d S )NTFr )r' r& r* Zexpire_missing)r_ r< rC r@ r` rc �_load_for_state)rD r8 r! r! r" rd E s z)DeferredColumnLoader.init_class_attributeNc K s� |r"d|j kr"t| j��| jj�sN|r@| jr@|j �d| j d�sN|rr| j|krr| j � d�j |||||||f| � n | j r�t || j < n t|| j < d S )NZ undefer_pkszundefer_group_%sF))r> F)r= T)rl rb r@ � intersectionr2 Z_should_undefer_in_wildcardrn r4 r rC � _get_strategyrO r_ r r ) rD rG rH rI rJ rK rL r] �only_load_propsr9 r! r! r" rO Q s, z DeferredColumnLoader.setup_queryc s� �j s tjS |tj@ s tjS �jj}� jr@� fdd�|jD �}n� j g}�fdd�|D �}t ��}|d kr�t � dt � ��� j f ��|�|�}tj|�j |�d�d kr�t ����tjS )Nc s4 g | ],}t |t�rt |jt�r|j� jkr|j�qS r! )� isinstancer �strategyrm rn r )�.0�p)rD r! r" � <listcomp>� s z8DeferredColumnLoader._load_for_state.<locals>.<listcomp>c s g | ]}|� j kr|�qS r! )Z unmodified)rw �k)�stater! r" ry � s zfParent instance %s is not bound to a Session; deferred load operation of attribute '%s' cannot proceed)rt Z refresh_state)r r � ATTR_EMPTY�SQL_OK�PASSIVE_NO_RESULT�managerr8 rn Ziterate_propertiesr �orm_exc�DetachedInstanceErrorr � state_strr r Z load_on_identZObjectDeletedErrorZ ATTR_WAS_SET)rD r{ �passive� localparentZtoloadrn �sessionr r! )rD r{ r" rq � s* z$DeferredColumnLoader._load_for_state)N) rS rT rU rV rW rB rR rd rO rq rX r! r! )rF r" rm $ s &rm c @ s& e Zd ZdZdd� Zejfdd�ZdS )�LoadDeferredColumnsz7serializable loader object used by DeferredColumnLoaderc C s || _ d S )N)r )rD r r! r! r" rB � s z LoadDeferredColumns.__init__c C s. | j }|jj}|j| }|jt }|�||�S )N)r r r8 r3 � _strategiesrm rq )rD r{ r� r r� r rv r! r! r" �__call__� s z LoadDeferredColumns.__call__N)rS rT rU rV rB r � PASSIVE_OFFr� r! r! r! r" r� � s r� c s$ e Zd ZdZdZ� fdd�Z� ZS )�AbstractRelationshipLoaderz0LoaderStratgies which deal with related objects.)r8 �targetr% �entityc s> t t| ��||� | jj| _| jj| _| jj| _| jj| _d S )N)rA r� rB rC r8 r� r� r% )rD r2 rE )rF r! r" rB � s z#AbstractRelationshipLoader.__init__)rS rT rU rV rW rB rX r! r! )rF r" r� � 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)rS rT rU rV r! r! r! r" r� � s r� Znoload)�lazyc @ s$ e Zd ZdZdZdd� Zdd� ZdS )�NoLoaderzYProvide loading behavior for a :class:`.RelationshipProperty` with "lazy=None". r! c C s d| _ t| j|d| jjd� d S )NT)r' r) )r_ r< rC �collection_class)rD r8 r! r! r" rd � s z NoLoader.init_class_attributec s$ � fdd�}|d � � j|f� d S )Nc s, � j r | j�� j��| |� n d |� j< d S )N)r% r �get_implr � initialize)r{ �dict_�row)rD r! r" �invoke_no_load� s z5NoLoader.create_row_processor.<locals>.invoke_no_loadrp )r0 r ) rD rG rI rJ r8 rP rK rQ r� r! )rD r" rR � s z NoLoader.create_row_processorN)rS rT rU rV rW rd rR r! r! r! r" r� � s r� �select�raise� raise_on_sqlZ baked_selectc s� e Zd ZdZdZ� fdd�Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z e � d�dd� �Ze � d�dd� �Zdd� Z� ZS )� LazyLoaderz|Provide loading behavior for a :class:`.RelationshipProperty` with "lazy=True", that is loads when first accessed. ) � _lazywhere�_rev_lazywhere�use_get�is_aliased_class� _bind_to_col�_equated_columns�_rev_bind_to_col�_rev_equated_columns�_simple_lazy_clause� _raise_always� _raise_on_sql�_bakeryc s t t| ��||� | jd dk| _| jd dk| _t| j�j| _| j j }|� � \| _ | _ | _|j dd�\| _| _| _| j�d| | j � | j o�| j o�| jjd j| j d| jjd�| _| j�rxDt| j�D ]6}|| jjkr�x$| jj| D ]}| j| | j|< q�W q�W | j�d | � d S ) Nr� r� r� T)Zreverse_directionz%s lazy loading clause %sr )� use_proxies� equivalentsz2%s will use query.get() to optimize instance loads)rA r� rB Z strategy_optsr� r� r r� r� rC �_join_conditionZcreate_lazy_clauser� r� r� r� r� r� �logger�infor% � _get_clause�comparer8 �_equivalent_columnsr� r. )rD r2 rE Zjoin_conditionrh rN )rF r! r" rB s* zLazyLoader.__init__c C sD d| _ | jjp"| jjtjk p"| j }t| j|d| j| jj |d� d S )NT)r' r* r) r+ ) r_ rC r+ r7 r � MANYTOONEr� r< rq r� )rD r8 r+ r! r! r" rd 9 s z LazyLoader.init_class_attributec sT | j | j }� g �dd� }t�|i d|i� � �fdd�}t�|i d|i�}|�fS )Nc S s d| _ d S )NF)�unique)� bindparamr! r! r" �visit_bindparamV 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 )N)Z_identifying_keyr0 r �callable�value)r� )� bind_to_col�paramsr! r" r� [ s )r� r� r ZtraverseZcloned_traverse)rD � criterionr� r! )r� r� r" �"_memoized_attr__simple_lazy_clauseQ s z-LazyLoader._memoized_attr__simple_lazy_clausec C s� | j \}}|d kr(t�|dd� |D ��S | jj}|�� }t�|�}|tj@ rV|tjN }i }xR|D ]J\} } } | d k r�|r�|tj @ r�|� ||| |�} n|� ||| |�} | || < q`W ||fS )Nc S s g | ]\}}}|�qS r! r! )rw r �identr� r! r! r" ry r s z4LazyLoader._generate_lazy_clause.<locals>.<listcomp>) r� �sql_utilZadapt_criterion_to_nullrC r2 �objr � instance_dictZINIT_OK�LOAD_AGAINST_COMMITTED�#_get_committed_state_attr_by_column�_get_state_attr_by_column) rD r{ r� r� Z param_keysr8 �or� r� r r� r� r! r! r" �_generate_lazy_clausem s& z LazyLoader._generate_lazy_clausec C s t �d| |f ��d S )Nz&'%s' is not available due to lazy='%s')�sa_exc�InvalidRequestError)rD r{ r� r� r! r! r" �_invoke_raise_load� s z LazyLoader._invoke_raise_loadc C s< |j s | jjs|jr|js tjS |j }d }|tj@ s<| jrJ|tj @ sP|rPtj S | j rn|tj @ sn| � ||d� t|�}|s�|tj @ r�tj S t�dt�|�| j f ��| j�r,| �|||�}tj |kr�tj S tj|kr�tjS t�|�r�d S |�� j| j|||d�}|d k �r|S |tj@ �r&|tj@ �s,tj S | �||||�S )Nr� zbParent instance %s is not bound to a Session; lazy load operation of attribute '%s' cannot proceed)r� Zlazy_loaded_from) r rC Zload_on_pendingZ _load_pendingZ session_idr r| r} r� ZNON_PERSISTENT_OKr~ r� ZNO_RAISEr� r r� r� r r� �_get_ident_for_use_getZ NEVER_SETr � issupersetr Z_identity_lookupr� ZRELATED_OBJECT_OK�_emit_lazyload)rD r{ r� �pending�primary_key_identityr� �instancer! r! r" rq � sP zLazyLoader._load_for_statec sD �j j}�tj@ r|j�n|j��j� � ����fdd��jjD �S )Nc s" g | ]}��� �j | �d ��qS ))r� )r� )rw �pk)r� �get_attrr� rD r{ r! r" ry � s z5LazyLoader._get_ident_for_use_get.<locals>.<listcomp>)r r8 r r� r� r� �dictra )rD r� r{ r� �instance_mapperr! )r� r� r� rD r{ r" r� � s z!LazyLoader._get_ident_for_use_getzsqlalchemy.ext.bakedc C s |j dd�S )N�2 )�size)�bakery)rD �bakedr! r! r" �_memoized_attr__bakery� s z!LazyLoader._memoized_attr__bakeryz sqlalchemy.orm.strategy_optionsc s" �� �fdd���}|�dd� �j� �jjs:|jdd� �jjd k rX|��fdd�� �j }|sn|tj@ r||�dd� � �j r��j �j }|� �j |� �j r܈j r����|d� ||���fd d���|��j�|�S �jjr�|��fd d�� xJ�jjD ]>��jtjk�r �j�r t�jt��s |���fd d�� �q W �� �|�\� �|�rrt � t j ��!� ��r�d S nt � t j"��!� ��r�d S �j �r����|d� |�� fd d�� �fd d�} ||���fdd���| ��#� } �j$�r�| S t%| �} | �r| dk�rt �&d�j � | d S d S d S )Nc s | � � j�S )N)r r� )r� )rD r! r" r# � z+LazyLoader._emit_lazyload.<locals>.<lambda>c S s | � � �d�S )NF)Z_adapt_all_clausesZ_with_invoke_all_eagers)�qr! r! r" r# r� T)�fullc s | � � j� jj�S )N)� select_fromr8 rC � secondary)r� )rD r! r" r# s c S s | � d�S )NF)Z autoflush)r� r! r! r" r# r� r� c s | � � �S )N)�_set_lazyload_from)r� )r{ r! r" r# - r� c s | j t�� jj �� S )N)�order_byr r/ rC )r� )rD r! r" r# 5 s c s" | � �j�| j� j ��� j��S )N)�options�LoadZfor_existing_path� _current_pathr2 Zlazyloadr )r� )�rev�strategy_optionsr! r" r# D s c s | � � �S )N)�filter)r� )� lazy_clauser! r" r# W r� c s � � | j� � | _| S )N)�update�_params)r� )r� r! r" �set_default_params[ s z5LazyLoader._emit_lazyload.<locals>.set_default_paramsc s | � � �S )N)r� )r� )r{ r! r" r# b r� r zKMultiple rows returned with uselist=False for lazily-loaded attribute '%s' r )'r� � add_criteriarC Z bake_queriesZspoilr� r r Z NO_AUTOFLUSHZ load_optionsZ load_path�_add_lazyload_optionsr� r� r� Zwith_post_criteriaZ_load_on_pk_identityr r8 r� Z_reverse_propertyr7 r r� Z_use_getru rv r� r� r Zhas_intersectionr r �valuesZ _never_set�allr% �len�warn) rD r� r� r{ r� r� r� r� Zeffective_pathr� rP �lr! )r� r� r� rD r{ r� r" r� � sj zLazyLoader._emit_lazyloadc sh | j � | js8t�|jt� | �� �}|d �| j |f� n,|jsD|jrd� fdd�} |d �| j | f� d S )Nrp c s | � |� � d S )N)Z_reset)r{ r� r� )r r! r" �reset_for_lazy_callable� s z@LazyLoader.create_row_processor.<locals>.reset_for_lazy_callable) r r_ r Z"_instance_level_callable_processorr5 �LoadLazyAttributer0 �populate_existingZalways_refresh) rD rG rI rJ r8 rP rK rQ Zset_lazy_callabler� r! )r r" rR v s z LazyLoader.create_row_processor)rS rT rU rV rW rB rd r� r� r� rq r� r � dependenciesr� r� rR rX r! r! )rF r" r� � s * F r� c @ s& e Zd ZdZdd� Zejfdd�ZdS )r� z-serializable loader object used by LazyLoaderc C s || _ |j| _d S )N)r rE )rD r Zinitiating_strategyr! r! r" rB � s zLoadLazyAttribute.__init__c C s0 | j }|jj}|j| }|j| j }|�||�S )N)r r r8 r3 r� rE rq )rD r{ r� r r� r rv r! r! r" r� � s zLoadLazyAttribute.__call__N)rS rT rU rV rB r r� r� r! r! r! r" r� � s r� Z immediatec @ s* e Zd ZdZdd� Zd dd�Zdd� ZdS ) �ImmediateLoaderr! c C s | j �d��|� d S )N))r� r� )rC rs rd )rD r8 r! r! r" rd � s z$ImmediateLoader.init_class_attributeNc K s d S )Nr! ) rD rG r� rI rJ rK rL � parentmapperrM r! r! r" rO � s zImmediateLoader.setup_queryc s$ � fdd�}|d � � j|f� d S )Nc s | � � j��| |� d S )N)r� r r4 )r{ r� r� )rD r! r" �load_immediate� s z<ImmediateLoader.create_row_processor.<locals>.load_immediateZdelayed)r0 r ) rD rG rI rJ r8 rP rK rQ r� r! )rD r" rR � s z$ImmediateLoader.create_row_processor)NN)rS rT rU rW rd rO rR r! r! r! r" r� � s r� �subqueryc s� e Zd ZdZ� fdd�Zdd� Zd dd�Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z G dd� de �Zdd� Zdd� Zdd � Z� ZS ) �SubqueryLoader)� join_depthc s t t| ��||� | jj| _d S )N)rA r� rB rC r� )rD r2 rE )rF r! r" rB � s zSubqueryLoader.__init__c C s | j �d��|� d S )N))r� r� )rC rs rd )rD r8 r! r! r" rd � s z#SubqueryLoader.init_class_attributeNc K s� |j js d S |j jr |j �d� || j }|�|jdd �} | d k rJ| j} n| j} |j�dtj j �} | | } |� |jd�s�| j r�|j j r�|j j jnd|j d | j kr�d S n| �| j�r�d S | �| �\} } }|j�dtf|j �}| �|| | ||j�}|j� | �}dtf|d| i|_|�d�}| �|| �\}}}|j|� }|j|� }| �||||| �}| � || || �}| � |�}|� |jd|� d S ) Nr� �path_with_polymorphic)Z subquery_pathN�loaderr r � orig_queryF) r �_enable_eagerloads� _yield_per� _no_yield_perrC r4 r r� r � PathRegistry�root�containsr� r� �length�contains_mapperr8 � _get_leftmostr� � _generate_from_original_query� entity_zeror� � _attributesZ_set_enable_single_crit�_prep_for_joinsr� Z add_columns� _apply_joins�_setup_options�_setup_outermost_orderbyrb )rD rG r� rI rJ rK rL r� rM �with_poly_info�effective_entity� subq_path�leftmost_mapper� leftmost_attr�leftmost_relationshipr� � left_aliasr� �to_join� local_attr� parent_aliasr! r! r" rO � sX zSubqueryLoader.setup_queryc sp �j �t��d �}| j�|�r>| j�d kr>| j| j � }n|�d � }|j}� �fdd�|D �}� ||fS )Nr r c s$ g | ] }t �d j� j| j��qS )r )�getattrr� �_columntopropertyr )rw rN )r r r! r" ry I s z0SubqueryLoader._get_leftmost.<locals>.<listcomp>)rI r Z_class_to_mapperr2 �isarC � local_columns)rD r Z subq_mapperZ leftmost_propZ leftmost_colsr r! )r r r" r 9 s z SubqueryLoader._get_leftmostc C s� |� � �d �}|js4|�ttdd� |jD ���d� |�|�}|�|� |j }|dkr^d|_ n<|d kr�x2tdd� |D ��D ] } t|�� | j �szd|_ P qzW |j dkr�|j|_ |jd kr�|jd kr�d |_ |�� �� } tj|| dd�} | S )Nc S s g | ]}|d dk r|d �qS )r� Nr! )rw �entr! r! r" ry f s z@SubqueryLoader._generate_from_original_query.<locals>.<listcomp>FTc s s | ] }|j V qd S )N)�table)rw rN r! r! r" � <genexpr>} s z?SubqueryLoader._generate_from_original_query.<locals>.<genexpr>)�use_mapper_path)Z_cloneZ correlate� _from_objZ_set_select_fromr. rb Zcolumn_descriptionsZ_adapt_col_listZ _set_entities�distinct_target_keyZ _distinctr� ra Z _order_byr� Z_limit�_offsetZ with_labelsr� r � AliasedClass) rD r� r r r Z orig_entityr� Z target_colsr �tZembed_qr r! r! r" r Q s4 z,SubqueryLoader._generate_from_original_queryc s� g }t |�� �}xZt|�D ]N\}\}}|dkrT||d d j}|�|�rN|n|} n|} |�| |jf� qW t|�dk r~|� n.t|d d �} | j r�| j � nt j | j dd�� �j j} � �fdd�| D �} || � fS ) Nr r r ���T)r c s g | ]}t � �jj| j��qS r! )r r2 r r )rw rN )r rD r! r" ry � s z2SubqueryLoader._prep_for_joins.<locals>.<listcomp>)r. �pairs� enumerater8 r r0 r r� r r� r� r r rC r ) rD r r r r �ir8 r Z prev_mapperZ to_appendr� � local_colsr r! )r rD r" r � s& z SubqueryLoader._prep_for_joinsc C s< t |�}|dkr,t||d d ��|�g}n�|dkrft||d d ��|�t||d d ��|�g}n�|dk�rdd� |dd� D �}g }xP|r�|�d�} t| d | d �} |r�| �|d d �} n | �|�} |�| � q�W t||d d ��|d j�g| t||d d ��|�g }x |D ]} |j| dd�}�q W |S ) Nr r r r c S s: g | ]2}t |d �js$t�|d �n|d j|d f�qS )r r )r r� r r r� )rw �itemr! r! r" ry � s z/SubqueryLoader._apply_joins.<locals>.<listcomp>T)Zfrom_joinpoint)r� r �of_type�popr0 r2 �join) rD r� r r r r Zltj�middle�innerr$ �attrr! r! r" r � s0 " zSubqueryLoader._apply_joinsc C s( |� |�}|j|j� }|jr$|j|_|S )N)Z_with_current_pathZ_conditional_options� _with_options�_populate_existing)rD r� r r� r r! r! r" r � s z SubqueryLoader._setup_optionsc C s6 | j jr2|jd }|j�t�| j j��}|j|� }|S )Nr )rC r� r �_target_adapter�copy_and_processr r/ )rD r� � eagerjoin�eager_order_byr! r! r" r � s z'SubqueryLoader._setup_outermost_orderbyc @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d � ZdS ) z SubqueryLoader._SubqCollectionsz�Given a :class:`.Query` used to emit the "subquery load", provide a load interface that executes the query at the first moment a value is needed. Nc C s || _ d S )N)�subq)rD r1 r! r! r" rB s z(SubqueryLoader._SubqCollections.__init__c C s | j d kr| �� | j �||�S )N)�_data�_loadr4 )rD r r r! r! r" r4 s z#SubqueryLoader._SubqCollections.getc C s& t dd� t�| jdd� �D ��| _d S )Nc s s$ | ] \}}|d d� |D �fV qdS )c S s g | ] }|d �qS )r r! )rw �vvr! r! r" ry s zCSubqueryLoader._SubqCollections._load.<locals>.<genexpr>.<listcomp>Nr! )rw rz �vr! r! r" r s z8SubqueryLoader._SubqCollections._load.<locals>.<genexpr>c S s | dd � S )Nr r! )�xr! r! r" r# ! r� z7SubqueryLoader._SubqCollections._load.<locals>.<lambda>)r� � itertools�groupbyr1 r2 )rD r! r! r" r3 s z%SubqueryLoader._SubqCollections._loadc C s | j d kr| �� d S )N)r2 r3 )rD r{ r� r� r! r! r" r� $ s z&SubqueryLoader._SubqCollections.loader) rS rT rU rV r2 rB r4 r3 r� r! r! r! r" �_SubqCollections s r9 c s� | j j| j jjs t�d| ��|| j }|�|j d�}|d krDd S |j |j ksXt d��| jj } |�|j d�} | d kr�| � |�} |�|j d| � � r�� fdd�| D �} | jr�| �|| | |� n| �|| | |� d S )NzJ'%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?� collectionsc s g | ]}� j | �qS r! )r@ )rw rN )rK r! r" ry I s z7SubqueryLoader.create_row_processor.<locals>.<listcomp>)r2 r5 r �impl�supports_populationr� r� rC r4 r r� �AssertionErrorr r9 rb r% �_create_collection_loader�_create_scalar_loader) rD rG rI rJ r8 rP rK rQ r1 r# r: r! )rK r" rR ( s, z#SubqueryLoader.create_row_processorc sf � ��fdd����fdd�}|d � �j�f� |d � �j|f� |jrb|d � �j� jf� d S )Nc s8 �� t� fdd��D ��d�}| ��j��| ||� d S )Nc s g | ] }� | �qS r! r! )rw rh )r� r! r" ry Y s z_SubqueryLoader._create_collection_loader.<locals>.load_collection_from_subq.<locals>.<listcomp>r! )r4 �tupler� r �set_committed_value)r{ r� r� � collection)r: r# rD )r� r" �load_collection_from_subqW s zKSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subqc s �j |kr� | ||� d S )N)r )r{ r� r� )rC rD r! r" �&load_collection_from_subq_existing_row_ s zXSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subq_existing_rowrp �existing�eager)r0 r �invoke_all_eagersr� )rD rG r: r# rQ rD r! )r: rC r# rD r" r> T s z(SubqueryLoader._create_collection_loaderc sf � ��fdd����fdd�}|d � �j�f� |d � �j|f� |jrb|d � �j� jf� d S )Nc sZ �� t� fdd��D ��d�}t|�dkr8t�d� � |d }| ��j��| ||� d S )Nc s g | ] }� | �qS r! r! )rw rh )r� r! r" ry p s zWSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subq.<locals>.<listcomp>)Nr zLMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' r )r4 r@ r� r r� r� r rA )r{ r� r� rB Zscalar)r: r# rD )r� r" �load_scalar_from_subqn s zCSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subqc s �j |kr� | ||� d S )N)r )r{ r� r� )rH rD r! r" �"load_scalar_from_subq_existing_row{ s zPSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subq_existing_rowrp rE rF )r0 r rG r� )rD rG r: r# rQ rI r! )r: rH r# rD r" r? k s z$SubqueryLoader._create_scalar_loader)NN)rS rT rU rW rB rd rO r r r r r r �objectr9 rR r> r? rX r! r! )rF r" r� � s [A/4 ,r� Zjoinedc s� e Zd ZdZdZ� fdd�Zdd� Zd d d �Zd d � Zd d� Z dd� Z dd� Z dd� Z d dd�Z dd� Zdd� Zdd � Zd d � Z� ZS )!� JoinedLoaderzcProvide loading behavior for a :class:`.RelationshipProperty` using joined eager loading. )r� �_aliased_class_poolc s& t t| ��||� | jj| _g | _d S )N)rA rK rB rC r� rL )rD r2 rE )rF r! r" rB � s zJoinedLoader.__init__c C s | j �d��|� d S )N))r� r� )rC rs rd )rD r8 r! r! r" rd � s z!JoinedLoader.init_class_attributeNFc K s: |j js dS |j jr&| jr&|j �d� || j }d} |rD| �||�nd} | dk rj| �||||| �\} }} nZ|�|j d�s�| j r�|j d | j kr�dS n|� | j �r�dS | �||||||||�\} }} }|�|j dd�}|dk r�|j} nd} || j }tj|| j ||| | | | j |d� |dk �r6dt|j�k�r6t�d��dS ) z@Add a left outer join to the statement that's being constructed.Nzjoined collectionFr� r r� )�with_polymorphicr� �chained_from_outerjoinz�Detected 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� rC � _init_user_defined_eager_proc�$_setup_query_on_user_defined_adapterr� r r� r� r� r8 �_generate_row_adapterr4 Zwith_polymorphic_mappersr� r Z_setup_entity_queryrb �secondary_columnsr� r� )rD rG rH rI rJ rK rL r� rN rM rM �user_defined_adapter�clauses�add_to_collectionr r! r! r" rO � s\ zJoinedLoader.setup_queryc C s� d|j krdS |jj}|�|jdd�}|dk r2|S |j d }|dd � \}}|d k r~t|t�rj|j�|�}t j ||j j d�}nD|� |jd�r�|�|jd�}tj|j|j j d�}n|jj�|j d �}|�|jd|� |S )NZeager_from_aliasF� user_defined_eager_row_processor���)r� r� )rl rI r2 r4 r ru �strr� �aliasr� Z ColumnAdapterr8 r� r� r � ORMAdapterr� r Z_polymorphic_adaptersrb ) rD rJ rG rI rK rY Z root_mapperr r r! r! r" rO � s2 z*JoinedLoader._init_user_defined_eager_procc C sZ |� |j|�}|r2|r2|�|�}|�|jd|� n|rJ|}|�|jd|� |j}|||fS )NrV )Z_get_entity_clausesr �wraprb r �primary_columns)rD rG r� rI rK rS rU r! r! r" rP * s z1JoinedLoader._setup_query_on_user_defined_adapterc C s� t | j�jrt | j�j}nd }d| f}||jkr@d |j|< }n|j| d |j|< }|t| j�kr�tj| j |d k r�|j dd�nd ddd�}t |�jj | j� |� | j| S )NZjoinedloader_acr r T)�flat)rY r] r ) r r� r� � selectabler r� rL r r r8 rY rN r0 )rD rG Zalt_selectabler �idx�to_adaptr! r! r" �_gen_pooled_aliased_classD s" z&JoinedLoader._gen_pooled_aliased_classc C s� |� |jdd �} | r | j} n | �|�} t| �jd| ftj| | jj dddd�} | j d k sZt �| j j rhd|_|d k r�|j� d| j j�n| j j} | s�d}|j�| j|||||| | |f � |j} |�|jd| � | || |fS )Nr� Zjoinedloader_ormadapterTF)r� Zadapt_requiredZallow_label_resolveZanonymize_labels� innerjoin�eager_row_processor)r4 r r� ra r Z_memor rZ r8 r� � aliased_classr= rC r% �multi_row_eager_loadersrl rb Zcreate_eager_joinsr0 �_create_eager_joinrR rb )rD rG r� rI rJ rK rL r� rN r r` rT rb rU r! r! r" rQ g sB z"JoinedLoader._generate_row_adapterc C s$ |d kr|j } n|} |jo |jj} d } ||jkr�| s�|jr�t�|j|j�} t | �dkr`t � d��| r�|j| d } | d | } }| d kr�||j } }|j� | |�}|�r t |dd �r�t|j��| �| j�r�| n| j�}t |j| j| j�}n t tj| j|jdd�| j| j�}n| j}|jd k �s"t�| �pB| �pB|dk�pB|jj}|�r�tj||j|| �px|jj�px|�oxt |t j �| j| j d�}n| � ||||�}||j| < |j|_ |�s�xDt�!| jj"�D ]2}| j#j$�%|��r�|�r�|j&| }|j'�(|� �q�W | jj)�r | j*|j+�,t-�.| jj)��7 _*d S ) Nr z�Can't identify which query entity in which to joined eager load from. Please use an exact match when specifying the join path.r rd T)r Zunnested)�isouter� _left_memo� _right_memo)/r8 re r Z_should_nest_selectableZ eager_joinsZ from_clauser� Z#find_left_clause_that_matches_givenr^ r� r� r� � setdefaultr r rd Z_entity_for_mapperr r2 r� r rC r r r= r Zrepresents_outer_join�_ORMJoinru r ZJoin�_splice_nested_inner_joinZstop_onZ _find_columnsZ primaryjoinZpersist_selectablerN Zcontains_columnr@ r\ r0 r� r0 r- r. r r/ )rD rG rH rI rK r� rT rb rN r� Zshould_nest_selectableZquery_entity_key�indexesZclauseZdefault_towrapZtowrapZefm�onclauseZattach_on_outsider/ rh r! r! r" rf � s� z JoinedLoader._create_eager_joinc C s4 |dkrt |tj�svt�n\t |tjj�r<| �||j|||�S t |tj�sv|d |krrtj||j |d||d j d�S d S | �||j |||j �}|d kr�d}| �||j |||j�}|d kr�|dk s�td��d S nd}|�r |js�|js�|�|�}n tj|j ||j|j|jd�}n tj||j |j|j|j d�}|j|_|S ) NFrW r )rg rh ri z9assertion failed attempting to produce joined eager loadsT)rg rh )rg ri )ru r rk r= r r^ Z FromGroupingrl �elementrd r8 �rightri �leftrh rg Z_splice_into_centerrn r- ) rD rI Zjoin_objrT rn ZsplicingZ target_joinZ right_splicer/ r! r! r" rl 6 sV z&JoinedLoader._splice_nested_inner_joinc C sz |r| � ||�nd}|dk rF|}|jr8|r8|�|j�}q`|jr`|j}n|�|jd�}|d kr`dS | j�||�rr|S dS d S )NFrc )rO rK r[ r4 r r8 Z_result_has_identity_key)rD rG rP rK rI rJ rS � decoratorr! r! r" �_create_eager_adapter| s z"JoinedLoader._create_eager_adapterc C s� | j j| j jjs t�d| ��|| j }| �|||||�} | dk r�| j} t � | j |||| j | �} | j s|| �|| | |� q�| �|| | |� n | j�d��|||||||� d S )NzJ'%s' does not support object population - eager loading cannot be applied.F))r� r� )r2 r5 r r; r< r� r� rC rs r Z_instance_processorr8 r� r% r? r> rs rR ) rD rG rI rJ r8 rP rK rQ Zour_pathZ eager_adapterr � _instancer! r! r" rR � 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 )N�append_without_event)r �init_state_collectionr �UniqueAppenderr0 )r{ r� r� rB � result_list�inst)rt rG r r! r" �#load_collection_from_joined_new_row� s zSJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_new_rowc sd | �f�j kr �j | �f }n(t �| |��}t�|d�}|�j | �f< � |�}|d k r`|�|� d S )Nru )r rv r rw r0 )r{ r� r� rx rB ry )rt rG r r! r" �(load_collection_from_joined_existing_row� s zXJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_existing_rowc s � |� d S )Nr! )r{ r� r� )rt r! r" � load_collection_from_joined_exec� s zPJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_execrp rE rF )r0 r rG )rD rG r rt rQ rz r{ r| r! )rt rG r r" 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 )Nr! )r{ r� r� )rt r r! r" � 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 )NzLMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' )r r� )r{ r� r� rE )rt r rD r! r" �$load_scalar_from_joined_existing_row� s zPJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_existing_rowc s � |� d S )Nr! )r{ r� r� )rt r! r" � load_scalar_from_joined_exec s zHJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_execrp rE rF )r0 r rG )rD rG r rt rQ r} r~ r r! )rt r rD r" r? � s z"JoinedLoader._create_scalar_loader)NNF)F)rS rT rU rV rW rB rd rO rO rP ra rQ rf rl rs rR r> r? rX r! r! )rF r" rK � s$ U0#@ E ',rK Zselectinc s� e Zd ZdZe�dddddddg�Zd Z� fd d �Zd d � Z dd� Z dd� Z dd� Z e �d�dd� �Zdd� Ze �d�dd� �Zdd � Zd d � Z� ZS ) �SelectInLoader)r� � omit_join� _parent_alias� _query_info�_fallback_query_infor� Z queryinfo�load_only_child�load_with_join�in_expr�pk_cols�zero_idx�child_lookup_colsi� c s� t t| ��||� | jj| _| jjtjk}| jjd k rB| jj| _n:| j� d�}|r\|j | _n | j j d j |jd| j jd�| _| jr�|r�| �� | _| �� | _q�| �� | _n | �� | _d S )N))r� r� r T)r� r� )rA r� rB rC r� r7 r r� r� rs r� r2 r� r� r� r� �_init_for_omit_join_m2or� �_init_for_joinr� �_init_for_omit_join)rD r2 rE Zis_m2o� lazyloader)rF r! r" rB + s& zSelectInLoader.__init__c s� t �jjj�� � �� �fdd�t� �D �� � fdd��jjD � }}t|�dkrbt j |� }d}n |d }d}�� dd|||d �S ) Nc 3 s0 | ](}�j j�|d �D ]}|� | fV qqdS )r! N)r2 r� r4 )rw rz Zequiv)�pk_to_fkrD r! r" r L s z5SelectInLoader._init_for_omit_join.<locals>.<genexpr>c s g | ]}|� kr� | �qS r! r! )rw rh )r� r! r" ry R s z6SelectInLoader._init_for_omit_join.<locals>.<listcomp>r Fr T) r� rC r� Zlocal_remote_pairsr� r. r2 ra r� r �tuple_� query_info)rD r� Zfk_colsr� r� r! )r� rD r" r� G 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 T))r� r� c s g | ]}� j | �qS r! )r� )rw r� )r� r! r" ry g s z:SelectInLoader._init_for_omit_join_m2o.<locals>.<listcomp>)r8 ra r� r r� rC rs r� )rD r� r� r� Z lookup_colsr! )r� r" r� ] 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 r! )�_adapt_element)rw rh )�pa_inspr! r" ry q s z1SelectInLoader._init_for_join.<locals>.<listcomp>r Fr T) r r2 r6 r� r ra r� r r� r� )rD r� r� r� r! )r� r" r� m s z SelectInLoader._init_for_joinc C s | j �d��|� d S )N))r� r� )rC rs rd )rD r8 r! r! r" rd { s z#SelectInLoader.init_class_attributezsqlalchemy.ext.bakedc C s |j dd�S )Nr� )r� )r� )rD r� r! r! r" r� � s z%SelectInLoader._memoized_attr__bakeryc C s� | j j| j jjs t�d| ��|jjp.t j j | }t � |d | j �sJd S t j�||| j�r`d S || j } || j } | �|jdd �} | d k r�| j} n| j} | �|jd�s�| jr�| jd | jkr�d S n| �| j�r�d S t j�||| j | j| j| � d S )NzJ'%s' does not support object population - eager loading cannot be applied.r r� r� r )r2 r5 r r; r< r� r� r r� r r� r� Z _entity_isar ZPostLoadZ path_existsrC r4 r r� r� r� r� r� r8 Zcallable_for_path�_load_for_path) rD rG rI rJ r8 rP rK rQ Z selectin_pathZ path_w_propZselectin_path_w_propr r r! r! r" rR � s< z#SelectInLoader.create_row_processorc s, |r�j |krd S �j}|jr�t�t�}�j�x`|D ]X\�} �j� t��� fdd�|j D ��} t j | krp�j }P d | kr4|| � �� | f� q4W |js�dd� |D �}|j�|j�|js�t����jr�fdd��D ��������fdd��D ������fdd���} |j�s$| ��fd d�� n �j�| ����fd d�� |j�r\| ��fd d�� n| ���fd d�� |j} | �| j|�j � | j�r�| �d d� � �jj �r�|j�s�jj � �j�rԇfdd�� D �� | �� fdd�� n�fdd�} | �| � |j�r�� ||| |� n�� ||| |� d S )Nc 3 s" | ]}� j ��|tjd �V qdS ))r� N)r� r ZPASSIVE_NO_FETCH)rw Zlk)r8 r{ � state_dictr! r" r � s z0SelectInLoader._load_for_path.<locals>.<genexpr>c S s$ g | ] \}}|j d ||j|f�qS )r )r r� )rw r{ � overwriter! r! r" ry � s z1SelectInLoader._load_for_path.<locals>.<listcomp>c s g | ]}� � |��qS r! )r� )rw rh )�inspr! r" ry � s c s g | ]}� � |��qS r! )r� )rw rh )r� r! r" ry � s c s | � t jd��� � �S )Nr� )r� )r ZBundle)r� )r r� r! r" r# � s z/SelectInLoader._load_for_path.<locals>.<lambda>c s | � � �S )N)r� )r� )r r! r" r# � r� c s | � ���t��jj��� ��S )N)r� r' r rC r r% )r� )r �parD r! r" r# s c s | � � �tjddd���S )N� primary_keysT)� expanding)r� �in_r r� )r� )r� r! r" r# s c s | � � �tjddd���j�� S )Nr� T)r� )r� r� r r� r� )r� )r� r� r! r" r# s c S s | � � S )N)r� )r� r! r! r" r# r� c s g | ]}� � |��qS r! )r� )rw �elem)r� r! r" ry & s c s | j � � S )N)r� )r� )r0 r! r" r# ( r� c s& | j d }| j|j�t�� jj��� S )Nr )r r� r- r. r r/ rC )r� r/ )rD r! r" r + s z?SelectInLoader._load_for_path.<locals>._setup_outermost_orderby) r r� r� r: � defaultdictr. r2 r� r@ r� r r~ r� r0 r� r� r� r r� r� r� r� r� r r� r+ rC r, r� �_load_via_child�_load_via_parent)rD r� rG rI ZstatesZ load_onlyr r� � our_statesr� Z related_identr� r� r r! ) r0 r r� r� r8 r� r� rD r{ r� r" r� � sr z SelectInLoader._load_for_pathc s� | j }t|�}x�|r�|d| j� }|| jd � }dd� ||j�j� fdd�|D �d�D �}x\|D ]T} || } xF|| D ]:\} } } | s�| j| kr�qv| �| j��| | |s�| n| g� qvW q`W qW d S )Nr c S s i | ]\}}||�qS r! r! )rw rz r5 r! r! r" � <dictcomp>F s z2SelectInLoader._load_via_child.<locals>.<dictcomp>c s g | ]}� j r|d n|�qS )r )r� )rw r )r� r! r" ry J s z2SelectInLoader._load_via_child.<locals>.<listcomp>)r� )r% �sorted� _chunksizer� r� r r� rA )rD r� r� r� rG r% Zour_keys�chunk�datar Z related_objr{ r� r� r! )r� r" r� = s" z SelectInLoader._load_via_childc s� | j }|rdnd }x�|r�|d| j� }|| jd � }� fdd�|D �}dd� t�||j�j|d�dd � �D �} x�|D ]|\} } } } | s�| j| kr�qt| �| |�}|s�|r�t|�d kr�t � d | � | � | j�� | | |d � qt| � | j�� | | |� qtW qW d S ) Nr! r c s& g | ] \}}}}� j r |d n|�qS )r )r� )rw r r{ r� r� )r� r! r" ry d s z3SelectInLoader._load_via_parent.<locals>.<listcomp>c S s i | ]\}}d d� |D �|�qS )c S s g | ] }|d �qS )r r! )rw r4 r! r! r" ry i s z>SelectInLoader._load_via_parent.<locals>.<dictcomp>.<listcomp>r! )rw rz r5 r! r! r" r� h s z3SelectInLoader._load_via_parent.<locals>.<dictcomp>)r� c S s | d S )Nr r! )r6 r! r! r" r# l r� z1SelectInLoader._load_via_parent.<locals>.<lambda>r zLMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' ) r% r� r7 r8 r� r� r r4 r� r r� r� rA )rD r� r� r� rG r% Z _empty_resultr� r� r� r r{ r� r� rB r! )r� r" r� [ s0 z SelectInLoader._load_via_parent)rS rT rU rW r: � namedtupler� r� rB r� r� r� rd r r� r� rR r� r� r� rX r! r! )rF r" r� s* 1 r� c sT �fdd�� � fdd�}� fdd�}t j| d|dddd � t j| d |dddd � d S ) Nc sP |d k rL|j � j krL|�t�|��}|rL||k rLt�dt�|�| j� f ��|S )NzsInstance %s is already associated with an instance of %s via its %s attribute, and is only allowed a single parent.) r � hasparentr Zinstance_stater� r� r Z instance_strr6 )r{ r� �oldvalue� initiatorr� )r r! r" � _do_check� s z*single_parent_validator.<locals>._do_checkc s � | |d |�S )Nr! )r{ r� r� )r� r! r" r0 � s z'single_parent_validator.<locals>.appendc s � | |||�S )Nr! )r{ r� r� r� )r� r! r" �set_� s z%single_parent_validator.<locals>.set_r0 T)�raw�retvalr+ rb )r �listen)r r r0 r� r! )r� r r" r1 � s r1 )NNNNFN)8rV � __future__r r: r7 � r r r� r r r r r r r �baser r r r r� r r{ r r r r r� r r r r� r r< ZColumnPropertyZ strategy_forr? Z class_loggerrY rj rm rJ r� r� ZRelationshipPropertyr� r� Z MemoizedSlotsr� r� r� r� rK r� r1 r! r! r! r" �<module> s� M# B ; " @ v