?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/orm/__pycache__/strategies.cpython-39.pyc
???????
a ��Jh�� � @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlmZ ddlm Z ddlm Z dd lm Z d d l m Z d d l mZ d d l mZ d dl mZ d dl mZ d dl mZ d dl mZ d dl mZ d dl mZ d dl mZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlm Z d dlm Z d d l!m"Z" d d l!m#Z# d d l!m$Z$ d d l!m%Z% d d lm&Z& d d!lm'Z' d d"l(m)Z) d d#l*m+Z+ d d$l,m-Z- d d%lm.Z. d d&lm/Z/ d'd(l m0Z0 d'd l mZ1 d'd)l m2Z2 d'd*l m3Z3 d'd+l m4Z4 d'dl mZ d'dl4mZ5 d'd,l4m6Z6 d'd-l7m8Z8 d'd.l7m9Z9 d'd/l:m;Z; e �rfd d0l<m=Z= d d1lm>Z> d'd2l?m@Z@ dfd4d5�ZAejBjCd3d3d6�G d7d8� d8e&��ZDe3jEejBjCd9d3d6�G d:d;� d;e&���ZFe3jEejBjCd9d<�G d=d>� d>eF���ZGe3jEejBjCd9d9d?�ejBjCd9d9d9d@�ejBjCd9dA�G dBdC� dCe&�����ZHG dDdE� dE�ZIG dFdG� dGe&�ZJe3jEej>jCd9dA�G dHdI� dIe&���ZKe3jEej>jCdJdK�ej>jCddK�G dLdM� dMeJ����ZLe3jEej>jCd9dK�ej>jCdNdK�ej>jCdOdK�ej>jCdPdK�ej>jCdQdK�G dRdS� dSeJejMe3jN�������ZOG dTdU� dU�ZPG dVdW� dWeJ�ZQej>jCdXdK�G dYdZ� dZeQ��ZRe3jEej>jCd[dK�G d\d]� d]eQ���ZSe3jEej>jCd^dK�ej>jCd3dK�G d_d`� d`eJ����ZTe3jEej>jCdadK�G dbdc� dceQejM���ZUddde� ZVdS )gzWsqlalchemy.orm.interfaces.LoaderStrategy implementations, and related MapperOptions.� )� annotationsN)�Any)�Dict)�Optional)�Tuple)� TYPE_CHECKING)�Union� )� 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_only_set)� AliasedClass� )�event)�inspect)�log)�sql)�visitors)� LABEL_STYLE_TABLENAME_PLUS_COL)�Select)�Literal)�Mapper)�RelationshipProperty)� ColumnElementFc s" g } |o | j �|r"| jr"| �t� | j| jjv rV| jj| j \��| ���fdd�� |rf| �tj� |r�| j � � r�| j r�| �� �fdd�� |j D ]�} | | j � | j�u r�| j�| j�s�tj| j| jf| �|||o�| jp�| jtju ||||| p�| j | jd� | ��} | D ]} | | | � �q q�d S )Nc s t j| |j� fi ���S �N)�orm_utilZ_validator_events�key��desc�prop)�fn�opts� �N/home/agenciai/.local/lib/python3.9/site-packages/sqlalchemy/orm/strategies.py�<lambda>\ s ��z%_register_attribute.<locals>.<lambda>c s t �| � ��S r2 )r Zbackref_listenersr5 )�backref�uselistr: r; r< j s �) Z parent_tokenr> �compare_function� useobjectZ trackparent� typecallable� callable_�active_history� impl_classZsend_modified_events�doc)r> Z single_parent�append�single_parent_validatorr4 �parentZ validatorsr Ztrack_cascade_eventsZback_populatesZ_effective_sync_backrefZself_and_descendants�_props�get� class_managerZ_attr_has_implr Zregister_attribute_impl�class_� directionr Z ONETOMANYZviewonlyrE )r7 �mapperr@ r? rA rB Zproxy_propertyrC rD �kwZ listen_hooks�mr6 �hookr: )r= r8 r9 r> r; �_register_attributeF sZ � � � �� ��rR )� 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 � �||� | jj| _d S r2 )�super�__init__�parent_propertyrW ��selfrH � strategy_key�� __class__r: r; rY � s z#UninstrumentedColumnLoader.__init__Nc K s* | j D ] }|r|j | }|�||� qd S r2 )rW � _append_dedupe_col_collection) r\ � compile_state� query_entity�path�loadopt�adapter�column_collection�kwargs�cr: r: r; � setup_query� s z&UninstrumentedColumnLoader.setup_queryc C s d S r2 r: � r\ �contextrb rc rd rN �resultre � populatorsr: r: r; �create_row_processor� s z/UninstrumentedColumnLoader.create_row_processor)N) �__name__� __module__� __qualname__�__doc__� __slots__rY ri rn � __classcell__r: r: r^ r; rU � s � rU Tc s> e Zd ZdZdZ� fdd�Zd dd�Zdd � Zd d � Z� Z S ) � ColumnLoaderz8Provide loading behavior for a :class:`.ColumnProperty`.)rW � is_compositec s* t � �||� | jj| _t| jd�| _d S )N�composite_class)rX rY rZ rW �hasattrrv r[ r^ r: r; rY � s zColumnLoader.__init__Fc K sv | j D ]<} |r6|r,|�| �} | d u r6 d S n |j | } |�| |� q| j d } |rh|j | } | d u rhd S | || j< d S �Nr )rW Zadapt_check_presentr` rZ ) r\ ra rb rc rd re rf �memoized_populatorsZcheck_for_adaptrg rh �fetchr: r: r; ri � s zColumnLoader.setup_queryc C s` d| _ | jd j}| jjpD| jd jpD|jd uoD|j�|jd �| ju }t | j|d|j |d� d S )NTr F)r@ r? rC ) �is_class_levelrW �typerZ rC � primary_keyZversion_id_col�_columntopropertyrJ rR �compare_values)r\ rN ZcoltyperC r: r: r; �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 �NFZquick�expireT)rW �_getterrF r4 ) r\ rk rb rc rd rN rl re rm �col�getterr: r: r; rn s z!ColumnLoader.create_row_processor)F) ro rp rq rr rs rY ri r� rn rt r: r: r^ r; ru � s � !ru )Zquery_expressionc s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �ExpressionColumnLoaderc s< t � �||� t�� �d �� t� fdd�| jjD ��| _d S )Nc 3 s | ]}|� � � V qd S r2 )�compare��.0rh ��nullr: r; � <genexpr>) s z2ExpressionColumnLoader.__init__.<locals>.<genexpr>) rX rY r* r� �label�anyrZ rW �_have_default_expressionr[ r^ r� r; rY " s �z ExpressionColumnLoader.__init__c K s� d } |r|j r|j } n| jr$| jj} | d u r0d S | D ] } |rF|j| } |�| |� q4| d } |rv|j| } | d u rvd S | || j< d S ry )�_extra_criteriar� rZ rW r` ) r\ ra rb rc rd re rf rz rg rW rh r{ r: r: r; ri - s" z"ExpressionColumnLoader.setup_queryc C sh |rd|j rd|j } | D ]:} |r&|j| } |�| d�} | r|d �| j| f� qdq|d �| jdf� d S r� )r� rW r� rF r4 ) r\ rk rb rc rd rN rl re rm rW r� r� r: r: r; rn R s z+ExpressionColumnLoader.create_row_processorc C s( d| _ t| j|d| jd jjdd� d S )NTFr )r@ r? Zaccepts_scalar_loader)r| rR rZ rW r} r� �r\ rN r: r: r; r� l s �z+ExpressionColumnLoader.init_class_attribute)ro rp rq rY ri rn r� rt r: r: r^ r; r� s %r� )rT rS )rT rS � raiseload)Z do_nothingc sN e Zd ZdZdZ� fdd�Zdd� Zdd� Zdd d �Zd d � Z dd� Z � Z S )�DeferredColumnLoaderzAProvide loading behavior for a deferred :class:`.ColumnProperty`.)rW �groupr� c sJ t � �||� t| jd�r"td��| j�dd�| _| jj| _| jj | _ d S )Nrw z8Deferred loading for composite types not implemented yetr� F) rX rY rx rZ �NotImplementedError� strategy_optsrJ r� rW r� r[ r^ r: r; rY � s � z DeferredColumnLoader.__init__c C s� |j rB|jjjrB| j|jjjv rB| j�d��||||||||� nH| jsv| j rX| jj } n| jj } |d � | j| f� n|d � | jdf� d S )N�)rT F�rS T�newr� F) � refresh_stater �_compile_options�_only_load_propsr4 rZ � _get_strategyrn r| r� Z_raise_column_loaderZ_deferred_column_loaderrF ) r\ rk rb rc rd rN rl re rm Z set_deferred_for_local_stater: r: r; rn � s4 ����� ��z)DeferredColumnLoader.create_row_processorc C s, d| _ t| j|d| jd jj| jdd� d S )NTFr )r@ r? rB Zload_on_unexpire)r| rR rZ rW r} r� �_load_for_stater� r: r: r; 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|r|| j |v r|| j� d�j|||||||fi | �� n.| jr�t|| j< n | js�t|| j< n t|| j< d S )Nzundefer_group_%sFr� )�compile_optionsZ_render_for_subqueryrZ Z_renders_in_subqueries�setrW � intersectionrH Z_should_undefer_in_wildcardr� � local_optsrJ r4 r� ri r| r r� r r ) r\ ra rb rc rd re rf rz Zonly_load_propsrO r: r: r; ri � sP ��� �� � � ������ � z DeferredColumnLoader.setup_queryc s� �j s tjS |tj@ s tjS �jj}� jr@� fdd�|j D �}n� j g}�fdd�|D �}t ��}|d u r�t � dt ���� j f ��� jr�� ��|d� t��j�t|�t� tjS )Nc s4 g | ],}t |t�rt |jt�r|j� jkr|j�qS r: )� isinstancer �strategyr� r� r4 )r� �p�r\ r: r; � <listcomp> s �z8DeferredColumnLoader._load_for_state.<locals>.<listcomp>c s g | ]}|� j v r|�qS r: )Z unmodified)r� �k)�stater: r; r� � zfParent instance %s is not bound to a Session; deferred load operation of attribute '%s' cannot proceed�raise)r4 r � ATTR_EMPTYr �SQL_OK�PASSIVE_NO_RESULT�managerrN r� Ziterate_propertiesr! �orm_exc�DetachedInstanceErrorr3 � state_strr� �_invoke_raise_loadr Zload_scalar_attributesr� r r )r\ r� �passive� localparentZtoloadr� �sessionr: )r\ r� r; r� � s0 ����z$DeferredColumnLoader._load_for_statec C s t �d| f ��d S )Nz+'%s' is not available due to raiseload=True��sa_exc�InvalidRequestError�r\ r� r� �lazyr: r: r; r� ' s �z'DeferredColumnLoader._invoke_raise_load)N) ro rp rq rr rs rY rn r� ri r� r� rt r: r: r^ r; r� x s 3 � 3(r� c @ s0 e Zd ZdZd ddd�dd�Zejfdd �Zd S ) �LoadDeferredColumnsz7serializable loader object used by DeferredColumnLoaderF�str�bool�r4 r� c C s || _ || _d S r2 r� )r\ r4 r� r: r: r; rY 0 s z LoadDeferredColumns.__init__c C s> | j }|jj}|j| }| jr$d}nd}|�|�}|�||�S )N)�rT Tr� )r� T)r� r� )r4 r� rN rI r� r� r� )r\ r� r� r4 r� r7 r] r� r: r: r; �__call__4 s z LoadDeferredColumns.__call__N)F)ro rp rq rr rY r r r� r: r: r: r; r� - s r� c s, e Zd ZdZdZ� fdd�Zdd� Z� ZS )�AbstractRelationshipLoaderz0LoaderStratgies which deal with related objects.)rN �targetr> �entityc s: t � �||� | jj| _| jj| _| jj| _| jj| _d S r2 )rX rY rZ rN r� r� r> r[ r^ r: r; rY J s z#AbstractRelationshipLoader.__init__c C s | j �d��||||||||�S )N))r� � immediate)rZ r� rn rj r: r: r; �#_immediateload_create_row_processorQ s ��z>AbstractRelationshipLoader._immediateload_create_row_processor)ro rp rq rr rs rY r� rt r: r: r^ r; r� E 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)ro rp rq rr r: r: r: r; r� j s r� Znoload)r� c @ s$ e Zd ZdZdZdd� Zdd� ZdS )�NoLoaderzQProvide loading behavior for a :class:`.Relationship` with "lazy=None". r: c C s d| _ t| j|d| jjd� d S )NT)r@ rA )r| rR rZ �collection_classr� r: r: r; r� � s �z NoLoader.init_class_attributec s$ � fdd�} |d � � j| f� d S )Nc s& � j rt�| |� j� n d |� j< d S r2 )r> r �init_state_collectionr4 �r� �dict_�rowr� r: r; �invoke_no_load� s z5NoLoader.create_row_processor.<locals>.invoke_no_loadr� )rF r4 ) r\ rk rb rc rd rN rl re rm r� r: r� r; rn � s z NoLoader.create_row_processorN)ro rp rq rr rs r� rn r: r: r: r; r� v 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 fdd�Z 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]rZ zTuple[Any, ...])rH r] c s8 t � �||� | jd dk| _| jd dk| _t| j�j| _| jj }|� � \| _ | _ | _ |j dd�\| _| _| _| jjr�dd� t�| jj�D �| _nd | _| j�d| | j � | j o�| j o�| jjd j| j dd | jjd �| _ | j �r4t | j �D ]4}|| jjv r�| 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� �elemr: r: r; 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) rX rY r� r� r� r( r� r� rZ �_join_conditionZcreate_lazy_clauser� r� r� r� r� r� �order_byr �to_listr� �logger�infor> � _get_clauser� rN �_equivalent_columnsr� �list)r\ rH r] Zjoin_conditionr� rh r^ r: r; rY � sN � � � � �� �zLazyLoader.__init__c C sv d| _ | jj}| jjr d}d}n4| jjtjus4| jsL|rBd}d}qTd}d}nd }}t| j|d| j | jj ||d� d S )NTF)r@ rB rA rC �_deferred_history) r| rZ � _legacy_inactive_history_stylerC rM r � MANYTOONEr� rR r� r� )r\ rN r� rC r� r: r: r; 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�� bindparamr: r: r; �visit_bindparam+ s zFLazyLoader._memoized_attr__simple_lazy_clause.<locals>.visit_bindparamr� c sF | j � v r$��| j� | j d f� n | jd u rB��| jd | jf� d S r2 )Z_identifying_keyrF r4 �callable�valuer� �Z bind_to_col�paramsr: r; r� 0 s �� )r� r� r� r� r+ �traverseZcloned_traverse)r\ Z lazywhere� criterionr� r: r� r; �"_memoized_attr__simple_lazy_clause" s � �z-LazyLoader._memoized_attr__simple_lazy_clausec C s� | j \}}|d u r(t�|dd� |D ��S | jj}|�� }t�|�}|tj @ rV|tj N }i }|D ]J\} } } | d ur�|r�|tj @ r�|� ||| |�} n|� ||| |�} | || < q^||fS )Nc S s g | ]\}}}|�qS r: r: )r� r4 �identr� r: r: r; r� G r� z4LazyLoader._generate_lazy_clause.<locals>.<listcomp>) r� r� Zadapt_criterion_to_nullrZ rH �objr � instance_dictr ZINIT_OK�LOAD_AGAINST_COMMITTED�#_get_committed_state_attr_by_column�_get_state_attr_by_column) r\ r� r� r� Z param_keysrN �or� r� r4 r� r� r: r: r; �_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� r: r: r; r� b s �z LazyLoader._invoke_raise_loadNr: 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 ��| �r�| �| ||�} tj | v r�tj S tj| v r�tjS | jj�st� | ��r$d S nt� | ��r$d S | j |j v �rD|t j @ �sDtj S | j!| j"| ||d�} | d u�rx| tj#u �rrd S | S n |t j @ �r�|t j@ �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)%r4 rZ Zload_on_pendingZ _load_pendingZ session_idr r� r� r� r r� r ZNON_PERSISTENT_OKr� r� �NO_RAISEZRELATED_OBJECT_OKr� r! r� r� r3 r� �_get_ident_for_use_getZ NEVER_SETrN Zallow_partial_pksr$ r� � issuperset�dict�DEFERRED_HISTORY_LOADr Z_identity_lookupr� ZPASSIVE_CLASS_MISMATCH�_emit_lazyload) r\ r� r� rd �extra_criteria� extra_options�alternate_effective_path�execution_options�pending�primary_key_identityr� r� �instancer: r: r; r� g s� ������� � � ��� ��� ���zLazyLoader._load_for_statec sD �j j}�tj@ r|j�n|j��j� � ����fdd��jjD �S )Nc s" g | ]}��� �j | �d ��qS )�r� �r� �r� �pk�r� Zget_attrr� r\ r� r: r; r� � s �z5LazyLoader._get_ident_for_use_get.<locals>.<listcomp>)r� rN r r� r r r r~ )r\ r� r� r� �instance_mapperr: r r; 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|d�7 } � j jd ur\| �� j� j j�} |j } | sr|tj@ r�t �ddi�| _� j}|js�|r�|jr�|d u r�|j� j }n |� j }|j}|r�|jr�d}|t�� j|�f7 }|| _ n$|d u �r|jj � j }n |� j }|�r | j |7 _ | j d|i7 _ |�rn� j �rZ|t j!@ �sZ� �"||d� t#j$|| || | d�S � j%�r~� j%| _&� �fdd �}| j'|� j ff7 _'� �(||�\}}| �r�t j)�*| d | i�} nd | i} � j|j+v �r�|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� }� j8�r�|S t9|�}|�r�|d k�r�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}|jtju r|jrt|jt�s�j � | j j |j ��|��| � qd S r2 )rZ Z_reverse_propertyrM r r� Z_use_getr� r� r� r# Z _construct_for_existing_pathr� r rH ZlazyloadZprocess_compile_state)�compile_context�rev�r\ �strategy_optionsr: r; �_lazyload_reverseB 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_optionsrZ Z secondary� select_fromrN r4 r Z NO_AUTOFLUSH� immutabledict�_execution_optionsr� r r� Z load_pathr3 �LoaderCriteriaOption� _with_options�_path_registryr� r� r r r� r Zload_on_pk_identityr� �_order_by_clausesZ_with_context_optionsr � EMPTY_DICT� merge_withr r r r Zhas_intersectionZ _none_set�valuesZ _never_setZ_where_criteria�executer� Zscalars�allr> �len�warn)r\ r� r� r r� rd r r r r Z clauseelement�stmtr r r� �effective_pathr9 r! Z lazy_clauser� rl �lr: r r; r � s� �� � � ����� ��� ��zLazyLoader._emit_lazyloadc s� | j � |jjr@|jjjr@| j |jjjv r@| �||||||||�S | jrP|r�|jr�t � |j t � | ||jrp|� |�nd �� �} |d �| j | f� n,|js�|jr�� fdd�} |d �| j | f� d S )Nr� c s | � |� � d S r2 )Z_resetr� �r4 r: r; �reset_for_lazy_callable� s z@LazyLoader.create_row_processor.<locals>.reset_for_lazy_callable)r4 r Z_is_user_refreshr r� r� r� r| r� r" Z"_instance_level_callable_processorrK �LoadLazyAttribute�_generate_extra_criteriarF �populate_existingZalways_refresh) r\ rk rb rc rd rN rl re rm Zset_lazy_callabler7 r: r6 r; rn � sF ���� �� � � z LazyLoader.create_row_processor)ro rp rq rr rs �__annotations__rY r� r� r r� r r, r� r Zpreload_moduler rn rt r: r: r^ r; r� � s. <" � w r� c @ s. e Zd ZdZdd� Zdd� Zejfdd�ZdS ) r8 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 r2 �r4 r] rd r )r\ r4 Zinitiating_strategyrd r r: r: r; rY � s zLoadLazyAttribute.__init__c C s( | j d urt�d� | j| j| jdd�S )NzvCan't reliably serialize a lazyload() option that contains additional criteria; please use eager loading for this caser: r< )r r r2 r4 r] rd r� r: r: r; � __getstate__� s ��z LoadLazyAttribute.__getstate__c C s: | j }|jj}|j| }|j| j }|j||| j| jd�S )N)rd r ) r4 r� rN rI Z _strategiesr] r� rd r )r\ r� r� r4 r r7 r� r: r: r; r� � s �zLoadLazyAttribute.__call__N) ro rp rq rr rY r= r r r� r: r: r: r; r8 � s r8 c @ s e Zd ZdZdZddd�ZdS )� PostLoaderz;A relationship loader that emits a second SELECT statement.r: Nc C sN |j jptjj| }|�� }t�d|i�}|rF|j� dd �}|dk} nd }d} |d ur�| 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 |k�rB|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)ra � current_pathr3 � PathRegistry�rootZ_get_top_level_contextr r& r� rJ rZ Z_is_self_referentialr� r� r �id�unionr �PostLoadZ path_exists�containsr �length�contains_mapperrN ) r\ rk rc rd � join_depthr4 Ztop_level_contextr r? Zunlimited_recursion� path_w_propZeffective_path_w_propr: r: r; �_setup_for_recursion sl �� ��� ���� ��z PostLoader._setup_for_recursion)N)ro rp rq rr rs rM r: r: r: r; r> s r> r� c s8 e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Z� ZS ) �ImmediateLoader�rK c s t � �||� | jj| _d S r2 �rX rY rZ rK r[ r^ r: r; rY W s zImmediateLoader.__init__c C s | j �d��|� d S �N�)r� r� �rZ r� r� r� r: r: r; r� [ s ��z$ImmediateLoader.init_class_attributec C sl |j jjsd S | �|||| j�\} } } } | s:tjtjB } n tj tjB } t j � || | j | j| j|| | | � d S r2 )ra r� �_enable_eagerloadsrM rK r ZPASSIVE_NO_FETCH_RELATEDr r r r rG �callable_for_pathrH rZ �_load_for_path)r\ rk rb rc rd rN rl re rm r4 � run_loaderr r? �flagsr: r: r; rn ` s, � �z$ImmediateLoader.create_row_processorc C s� |r.t |jj�} ||�� f| _|�� } | f} n|} d} | j} | j�d�} |D ]P\}}|j }|sf| |vrL| j ||| | |d�}|t t j fvrL|�| ��|||� qLd S )Nr: rR )r r r )r# rc r� Z_recurserk �_truncate_recursiver4 rZ r� r r� r r r� �get_impl�set_committed_value)r\ rk rc �states� load_onlyrd rX r? r Znew_optr r r4 � lazyloaderr� � overwriter� r� r: r: r; rV � s8 � �� �z ImmediateLoader._load_for_path) ro rp rq rs rY r� rn rV rt r: r: r^ r; rN S s *rN �subqueryc s� e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z G dd� d�Z dd� Z dd� Zdd� Zdd� Z� ZS ) �SubqueryLoaderrO c s t � �||� | jj| _d S r2 rP r[ r^ r: r; rY � s zSubqueryLoader.__init__c C s | j �d��|� d S rQ rS r� r: r: r; r� � s ��z#SubqueryLoader.init_class_attributec s� |}|j }t�|d �}| j�|�rB| j|d u rB| j| j � }n||d � }|r�|j| jj| �t |�t �� }|r��t j � || d � �7 �n|�|j } � �fdd�| D �} � | |�fS )Nr r c s& g | ] }t �jd j� j| j��qS �r )�getattrrc r� r r4 r� ��leftmost_mapperZ new_subq_pathr: r; r� � s � �z0SubqueryLoader._get_leftmost.<locals>.<listcomp>)rc r3 Z_class_to_mapperrH �isarZ � _entities� entity_zeror* r1 r rC Zcoerce� local_columns) r\ �orig_query_entity_index� subq_pathZcurrent_compile_state�is_rootZgiven_subq_pathZ subq_mapperZ leftmost_prop� additionalZ leftmost_cols� leftmost_attrr: rd r; � _get_leftmost� s4 � ��� � �z SubqueryLoader._get_leftmostc C s0 |� � �d �}tj�tj�}|j�|j� |}|js`d|_|j j |gdd� t ||d�D ��R � |� dd� |D �|� � �} | |_|j} | du r�d|_n6| d u r�dd� | D �D ] } t| ��| j�s�d|_ q�q�|js�d |_|jdu �r|j�rt�| |j�} | �r|�| | � |�t��� } t j || dd �}|S ) NFc S s h | ]}|d dur|d �qS )r� Nr: )r� �entr: r: r; � <setcomp> s �z?SubqueryLoader._generate_from_original_query.<locals>.<setcomp>)ra c S s g | ]}t j�t jj|��qS r: )r* Z coercions�expectZrolesZColumnsClauseRole)r� r r: r: r; r� / s �z@SubqueryLoader._generate_from_original_query.<locals>.<listcomp>Tc S s h | ] }|j �qS r: )�tabler� r: r: r; rq > r� r: ��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 r~ Z_has_row_limiting_clauser+ r� Z expand_column_list_from_order_byZ _set_entitiesZset_label_styler, r` r3 r% )r\ �orig_compile_state� orig_queryre rn �leftmost_relationshipZ orig_entity�qZq2Z target_colsrz �tZto_addZembed_q� left_aliasr: r: r; � _generate_from_original_query� sV ��������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& r@ Trt c s g | ]}t � �jj| j��qS r: )rc rH r r4 r� �� parent_aliasr\ r: r; r� � s �z2SubqueryLoader._prep_for_joins.<locals>.<listcomp>)r� �pairs� enumeraterN rf rF r4 r1 r( r� r� r3 r% rZ ri ) r\ r� rk �to_joinr� �irN r7 Z prev_mapperZ to_appendr� � local_cols� local_attrr: r� r; �_prep_for_joinsZ s* � �z SubqueryLoader._prep_for_joinsc C s0 t |�}|dkr,t||d d ��|�g}n�|dkrft||d d ��|�t||d d ��|�g}n�|dk�rdd� |dd� D �}g }|r�|�d�} t| d | d �} |r�| �|d d �} n | �|�} |�| � q�t||d d ��|d j�g| t||d d ��|�g }|D ]} |�| �}�q|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� r3 r% r� )r� �itemr: r: r; r� � s � ��z/SubqueryLoader._apply_joins.<locals>.<listcomp>)r1 rc �of_type�poprF rH �join) r\ r~ r� r� r� �effective_entityZltjZmiddle�innerr� �attrr: r: r; � _apply_joins� sD ��� � ����� zSubqueryLoader._apply_joinsc C sB |j }|r*|jr*|t�| j|�|��f7 }|�|�}|j|� }|S r2 )r) r� r3 r( r� r9 Z_with_current_path�options) r\ rk r~ rk �rewritten_pathr| r� rd � new_optionsr: r: r; �_setup_options� s �� z SubqueryLoader._setup_optionsc s& � j jr"� fdd�}|�|� j �}|S )Nc s | j tt�� jj��7 _ d S r2 ��eager_order_by�tupler r� rZ r� �r r� r: r; �_setup_outermost_orderby� s �zISubqueryLoader._setup_outermost_orderby.<locals>._setup_outermost_orderby)rZ r� �_add_context_option)r\ r~ r� r: r� r; 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 r2 r� )r\ rk r� r: r: r; rY � s z(SubqueryLoader._SubqCollections.__init__c C s | j d u r| �� | j �||�S r2 )r� �_loadrJ )r\ r4 �defaultr: r: r; rJ s z#SubqueryLoader._SubqCollections.getc C s� t �t�| _| j}|jd u s J �|�| j�}| jjr<|� � }t|� | j ��}t � |dd� �D ]"\}}| j| � dd� |D �� q\d S )Nc S s | dd � S )Nr r: ��xr: r: r; r< r� z7SubqueryLoader._SubqCollections._load.<locals>.<lambda>c s s | ]}|d V qdS )r Nr: �r� �vvr: r: r; r� r� z8SubqueryLoader._SubqCollections._load.<locals>.<genexpr>)� collections� defaultdictr� r� r� r� Z with_sessionr Z_populate_existingr: r� � itertools�groupby�extend)r\ r~ �rowsr� �vr: r: r; r� s z%SubqueryLoader._SubqCollections._loadc C s | j d u r| �� d S r2 )r� r� )r\ r� r� r� r: r: r; rA s z&SubqueryLoader._SubqCollections.loaderN) ro rp rq rr rs rY rJ r� rA r: r: r: r; �_SubqCollections� s r� c C s� |j }|jjr|jjrd S |j�|�}d|_|| j }|�|j dd �} | d urT| } n| j } |j j �dt jjt jjf�\} } | t jju } | | } | | } |j j �dtf|j �}t�|d�}|jr�|jjd u r�t�d| |f � |j}|j|dd�}| �|| || �\}}}} | �||||||�}t � | �}|j j � |j dtf|d| | fi�|_ |� d�}| � || �\}}}|j!|� }| �"||||| �}| �#||| | || |�}| �$|�}|S ) NT�path_with_polymorphic)Zsubquery_pathsNr| �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)%ra r� rT Z_for_refresh_staterg �indexZloaders_require_bufferingrZ rJ r r� r r' r3 rC rD ra r Z _get_plugin_class_for_pluginZ_is_lambda_elementr r r r2 Z _resolvedZ_create_entities_collectionro r� rv r- r Z_set_enable_single_critr� Z add_columnsr� r� r� )r\ rk rb rc r� rd re ra rj �with_poly_entityr� rk r� rl r| Zcompile_state_clsr{ re rn r} r� r~ r� r� r� r: r: r; �_setup_query_from_rowproc# s� �� �� �� ��� �� � �� � �� z(SubqueryLoader._setup_query_from_rowprocc s� |r&|j jd ur&|j jjr&t�dd� |jrD| �||||||� |�S | �|||| j�\} } } } | sfd S t |j t �svd S | j j | j jjs�t�d| ��t|�dkr�t�|j| j �s�d S nt�|d | j �s�d S | �||||d |� �} | d u r�d S | jd u �sJ �|| j }| jj} |�|jd�} | d u �rH| � || �} |� |jd| � � �r`� fdd�| D �} | j �r|| � ||| | |� n| � ||| | |� d S ) Nz�The subqueryload loader option is not compatible with DML statements such as INSERT, UPDATE. Only SELECT may be used.This warning will become an exception in a future release.�2.0�J'%s' does not support object population - eager loading cannot be applied.r r@ r� c s g | ]}� j | �qS r: rV r� �re r: r; r� r� z7SubqueryLoader.create_row_processor.<locals>.<listcomp>)!ra � statement�is_dmlr �warn_deprecatedr� r� rM rK r� r rH rK r4 �impl�supports_populationr� r� r1 r3 � _entity_isarh r� r� rZ ri rJ r r� r� r> �_create_collection_loader�_create_scalar_loader)r\ rk rb rc rd rN rl re rm �_rW r� r� r� r: r� r; rn � s� � ���� � �� � � �z#SubqueryLoader.create_row_processorc sp |� |��� ��fdd����fdd�}|d ��j�f� |d ��j|f� |jrl|d ��j� jf� d S )Nc s* � � �|�d�}| ��j��| ||� d S )Nr: )rJ rZ r4 r[ )r� r� r� � collection�r� r\ � tuple_getterr: r; �load_collection_from_subq s �zKSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subqc s �j |vr� | ||� d S r2 r6 r� )r� r\ r: r; �&load_collection_from_subq_existing_row s zXSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subq_existing_rowr� �existing�eager�Z _tuple_getterrF r4 �invoke_all_eagersrA )r\ rk rl r� r� rm r� r: )r� r� r\ r� r; r� s �z(SubqueryLoader._create_collection_loaderc sp |� |��� ��fdd����fdd�}|d ��j�f� |d ��j|f� |jrl|d ��j� jf� d S )Nc sL � � �|�d�}t|�dkr*t�d� � |d }| ��j��| ||� d S )Nr2 r �LMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' r )rJ r1 r r2 rZ r4 r[ )r� r� r� r� Zscalarr� r: r; �load_scalar_from_subq, s ��zCSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subqc s �j |vr� | ||� d S r2 r6 r� )r� r\ r: r; �"load_scalar_from_subq_existing_row7 s zPSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subq_existing_rowr� r� r� r� )r\ rk rl r� r� rm r� r: )r� r� r\ r� r; r� ' s �z$SubqueryLoader._create_scalar_loader)ro rp rq rs rY r� ro r� r� r� r� r� r� r� rn r� r� rt r: r: r^ r; ra � s 1d/6"4 era Zjoinedc s� e Zd ZdZdZ� fdd�Zdd� Zd d d �Zd d � Zd d� Z dd� Z dd� Z d!ddd�dd�Z dd� Z dd� Zd d � Zd d � Z� ZS )"� JoinedLoaderz[Provide loading behavior for a :class:`.Relationship` using joined eager loading. rK c s t � �||� | jj| _d S r2 rP r[ r^ r: r; rY N s zJoinedLoader.__init__c C s | j �d��|� d S rQ rS r� r: r: r; r� R s ��z!JoinedLoader.init_class_attributeNFc K st |j js dS |r0|jdur0|jjr0t�dd� n | jr<d|_|| j }|rZ| � |||j �nd} | dur�| � ||||| �\} }} n`|� |j d�s�| j r�|jd | j kr�dS n|�| j�r�dS | �||||||||�\} }} }d|_|�|j dd�} | du�rt| �j}nd}|| j }tj|| j||| | || j|d � tj�|j�}|�rp| du�r^t � d ��nd d � |jD �|_dS ) z@Add a left outer join to the statement that's being constructed.Nz�The joinedload loader option is not compatible with DML statements such as INSERT, UPDATE. Only SELECT may be used.This warning will become an exception in a future release.r� TFrA r& r� )�with_polymorphic� parentmapper�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().c S s g | ]}|d ur|�qS r2 r: r� r: r: r; r� � s z,JoinedLoader.setup_query.<locals>.<listcomp>) r� rT r� r� r r� r> �multi_row_eager_loadersrZ � _init_user_defined_eager_procr �$_setup_query_on_user_defined_adapterrH rK rI rJ rN �_generate_row_adapterZeager_adding_joinsrJ r( Zwith_polymorphic_mappersr� r Z_setup_entity_queryZNONE_SETr� �secondary_columnsr� r� )r\ ra rb rc rd re rf r� r� rg �user_defined_adapter�clauses�add_to_collectionr� r� Z has_nonesr: r: r; ri W s� ���� ������ ��� � � ��zJoinedLoader.setup_queryc C s� d|j vrdS |jj}|�|jdd�}|dur2|S |j d }|dd � \}}|d ur�t|t�rj|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� rc rH rJ r r� r� r� �aliasr3 � ORMAdapter�_TraceAdaptRoleZ JOINEDLOAD_USER_DEFINED_ALIASrN r� rH Z JOINEDLOAD_PATH_WITH_POLYMORPHICZ_polymorphic_adaptersr� ) r\ rd ra Ztarget_attributesrc re r� Z root_mapperr7 r� r: r: r; r� � sP � ������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)r\ rk r� rc re r� r� r: r: r; r� s" ��z1JoinedLoader._setup_query_on_user_defined_adapterc C s |� |jdd �} | r| } nDt| j�} | jr2| j} nd } tj| j| d urR| j dd�nd ddd�} t| �} | j d| ftj tj j | | jjdddd�}|js�J �|d ur�|j� d| jj�n| jj}|s�d}|j�| j||||||||r�|jnd f � |j}|�|jd |� ||||fS ) Nr� T)�flat)r� r� ru Zjoinedloader_ormadapterF)r� Zadapt_requiredZallow_label_resolveZanonymize_labels� innerjoinr: �eager_row_processor)rJ r r( r� r� r� r3 r% rN Z_anonymous_fromclauseZ_memor� r� ZJOINEDLOAD_MEMOIZED_ADAPTERr� r� rZ r� Zcreate_eager_joinsrF �_create_eager_joinr� r� r� )r\ ra r� rc rd re rf r� r� r� Zto_adaptZinspZalt_selectableZ to_adapt_inspr� r� r� r: r: r; r� ) sd � �� � �� ��z"JoinedLoader._generate_row_adapterc sb |d u r|j } n|} |jo |j} d } ||jvr~| s~|jr~t�|j|j�} t| �dkr^t � d��| r~|j| d }| d | } }| d u r�||j } }|j� | |�}|�rt |dd�r�|j �| �� j�r�| n� j�}t |j� j� j�}n t tj� j|jdd�� j� j�}n� j}|j�sJ �| �p8| �p8|dk�p8|jj}| }|j�d � j fd �}|�rr|t� fd d �|D ��7 }|�r�tj ||j || �p�|jj�p�|�o�t |t j �� j|� j |d �}n� � ||d ||||�}||j| < |j|_!|�s0t�"� jj#�D ]4}| j$j%�&|��r�|�r |j'| }|�(||j)� �q�� jj*�r^| j+t|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 r� FTrt Zunnested�additional_entity_criteriar: c 3 s | ]}|j r|�� j�V qd S r2 )Zpropagate_to_loadersZ_resolve_where_criteriarN )r� Zaer� r: r; r� � s �z2JoinedLoader._create_eager_join.<locals>.<genexpr>��isouter� _left_memo� _right_memor� r� )0rN r� Z_should_nest_selectableZ eager_joinsZ from_clausesr� Z#find_left_clause_that_matches_givenr� r1 r� r� � setdefaultrc � aliased_inspZ_entity_for_mapperrf rH r� r4 rZ r3 r% r� rh Zrepresents_outer_joinZglobal_attributesrJ r� �_ORMJoinr� r* ZJoin�_splice_nested_inner_joinZstop_onZ _find_columnsZ primaryjoinZpersist_selectablerh Zcontains_columnrW r` r� r� r� �_target_adapterZcopy_and_processr r� )r\ ra rb rc re r� r� r� r� r r� Zshould_nest_selectableZquery_entity_keyZindexesZclauseZdefault_towrapZtowrapZefm�onclauseZattach_on_outsideZextra_join_criteriar� � eagerjoinr� r: r� r; r� x s� ����� ��� �� �� ��� �� �� � � � ��z JoinedLoader._create_eager_joinz#Union[Mapper, None, Literal[False]]z$Optional[path_registry.PathRegistry]�� entity_inside_join_structure�detected_existing_pathc C s� ||d u sJ �|du r(t |tj�s(J �t |tjj�rN| �|||j||||�S t |tj��rB|j} | j|||j |||| d ur�| d j nd d�} | d ur�|j s�| j s�|� | �} n tj|j | |j|j |jd�} | j| _| S | j|||j ||||j| d�} | d u�r&tj| |j |j|j |jd�} | j| _| S |du �r>d�s>J d��d S |�|��sRd S |�r�t|�d k�r�|d |u �sxJ �|d d� |jd d� k�r�d S tj||j|d|||d j |d �S ) Nr� Fr@ )r� )r� r� r� )r� r� z9assertion failed attempting to produce joined eager loadsr& ���r r� )r� r3 r� r* r� Z FromGroupingr� �elementr� �rightrN r� Z_splice_into_center�leftr� r� r� rf r1 rc r� ) r\ rc Z entity_we_want_to_splice_ontoZjoin_objr� r� r r� r� Zjoin_right_pathZ target_joinr� r: r: r; r� s� � � � �� � �� $ �z&JoinedLoader._splice_nested_inner_joinc C s� |j }|r| �|||j�nd}|durP|}|jrB|rB|�|j�}qj|jrj|j}n|�|jd�}|d u rjdS | j�||�r||S dS d S )NFr� )ra r� r Zcompound_eager_adapterr� rJ rN Z_result_has_identity_key) r\ rk rl re rc rd ra r� � decoratorr: r: r; �_create_eager_adapter� s. ��� ��z"JoinedLoader._create_eager_adapterc C s� |j jjsd S | jj| j jjs.t� d| ��| j r:d|_ || j } | � |||| |�} | dur�| j} t�|| j||| | j | �} | j s�| �|| | |� q�| �|| | |� n | j �d��||||||||� d S )Nr� TFrR )ra r� rT rH rK r4 r� r� r� r� r> Zloaders_require_uniquingrZ r� r Z_instance_processorrN r� r� r� r� rn ) r\ rk rb rc rd rN rl re rm Zour_pathZ eager_adapterr4 � _instancer: r: r; rn � sR �� �� ���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 urB|�|� d S �NZappend_without_event�r r� r ZUniqueAppenderrF )r� r� r� r� � result_list�inst�r� rk r4 r: r; �#load_collection_from_joined_new_row' s �zSJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_new_rowc sd | �f�j v r �j | �f }n(t �| |��}t�|d�}|�j | �f< � |�}|d ur`|�|� d S r� r� )r� r� r� r� r� r� r� r: r; �(load_collection_from_joined_existing_row4 s ��zXJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_existing_rowc s � |� d S r2 r: r� �r� r: r; � load_collection_from_joined_execG s zPJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_execr� r� r� �rF r4 r� )r\ rk r4 r� rm r� r r r: 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 r2 r: r� )r� r4 r: r; � load_scalar_from_joined_new_rowV s zKJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_new_rowc s8 � |�}�|v r,||� ur4t �d� � n||�< d S )Nr� )r r2 )r� r� r� r� �r� r4 r\ r: r; �$load_scalar_from_joined_existing_row[ s �� zPJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_existing_rowc s � |� d S r2 r: r� r r: r; � load_scalar_from_joined_execn s zHJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_execr� r� r� r )r\ rk r4 r� rm r r r r: r r; r� U s ��z"JoinedLoader._create_scalar_loader)NNF)FN)ro rp rq rr rs rY r� ri r� r� r� r� r� r� rn r� r� rt r: r: r^ r; r� C s, � 9O * � .$>/r� Zselectinc st e Zd ZdZe�dg d��ZdZ� fdd�Zdd� Z d d � Z d d � Z d d� Z dd� Z dd� Zdd� Zdd� Z� ZS )�SelectInLoader)rK � 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| _| jjtju }| jjd ur>| jj| _n<| j�d�}|rX|j | _n"| j j d j |j dd| j jd�| _| jr�|r�| �� | _| �� | _q�| �� | _n | �� | _d S )NrR r TFr� )rX rY rZ rK rM r r� r r� r� rH r� r� r� r� �_init_for_omit_join_m2or �_init_for_joinr �_init_for_omit_join)r\ rH r] Zis_m2or^ r^ r: r; rY � 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)rH r� rJ )r� r� �equiv��pk_to_fkr\ r: r; r� � s �z5SelectInLoader._init_for_omit_join.<locals>.<genexpr>c s g | ]}|� v r� | �qS r: r: �r� r� )r r: r; r� � s z6SelectInLoader._init_for_omit_join.<locals>.<listcomp>r Fr T) r rZ r� Zlocal_remote_pairsry r� rH r~ r1 r* �tuple_� query_info)r\ r Zfk_colsr r r: r r; r � 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 TrR c s g | ]}� j | �qS r: r r �r^ r: r; r� � r� z:SelectInLoader._init_for_omit_join_m2o.<locals>.<listcomp>)rN r~ r1 r* r rZ r� r )r\ 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_elementr �Zpa_inspr: r; r� � s z1SelectInLoader._init_for_join.<locals>.<listcomp>r Fr T) r% rH rL r r( r~ r1 r* r r )r\ r r r r: r r; r � s � z SelectInLoader._init_for_joinc C s | j �d��|� d S rQ rS r� r: r: r; r� � s ��z#SelectInLoader.init_class_attributec C s |j r | �||||||||�S | j|||| jd�\} } } } | sBd S |jjjsPd S | jj| j j j spt � d| ��t|�dkr�t�|j| j�s�d S nt�|d | j�s�d S | } || j }|�|jdd �}|d ur�t|�}n| j}tj�|| | j| j| j||| | � d S )NrO r� r r@ r� )r� r� rM rK ra r� rT rH rK r4 r� r� r� r� r1 r3 r� rh rZ rJ r r( r� r rG rU rV )r\ rk rb rc rd rN rl re rm r4 rW r r? Z selectin_pathrL r� r� r: r: r; rn � sj � �� �� � �z#SelectInLoader.create_row_processorc s� |r�j |vrd S �j} | jr�t�t�} g } �j�|D ]l\�} �j�t���fdd�| j D ��} t j | v rt�j } q�d | vr�| | � ��| f� q6| � ��| f� q6| js�dd� |D �} | j}| j}| js�jr�fdd�|D �}��|�}tjdg|�R � }|�� }��� }tj||gttjd�d�d �}| j�s@|���}n$|��j �� t �j �j j �� ���}|�!|�"t#�$d ���}� j%j&}|�j }|� j'u �r�|j(}n&|j(}� j'j(}� fd d�t)||�D �}|�r�|j*�r�|t�+�|�,� ��f7 }|d u�r�|�-� }|j.|� }|�/d |i�}� j0�r*|j1d d�}�j j2�r�| j�sj�j j2}�j�r^�fdd�|D �}|j2|� }n�fdd�}|�3|�j �}| j�r���4| | | |� |� n��5| | |� |� d S )Nc 3 s" | ]}� j ��|tjd �V qdS )r N)r r ZPASSIVE_NO_FETCH)r� Zlk)rN r� � state_dictr: r; r� S s ��z0SelectInLoader._load_for_path.<locals>.<genexpr>c S s$ g | ] \}}|j d ||j|f�qS )r )r4 r )r� r� r_ r: r: r; r� p s �z1SelectInLoader._load_for_path.<locals>.<listcomp>c s g | ]}� � |��qS r: r r �r� r: r; r� � s r r� )Zcompile_state_pluginZplugin_subject)r r r� r � primary_keysc s g | ]\}}|� � |��qS r: )Z'_adapt_cached_option_to_uncached_option)r� Zorig_optZ uncached_opt)rk r: r; r� � s ��r T)r: c s g | ]}� � |��qS r: r r� r! r: r; r� � s �c s | j tt�� jj��7 _ d S r2 r� r� r� r: r; r� � s �z?SelectInLoader._load_for_path.<locals>._setup_outermost_orderby)6r4 r r r� r� r� rH r r� r r r� r rF r r r r� r r3 ZBundler" r- r# r, r r$ r% r r� rc rZ r� �filterZin_r* r� ra Zselect_statementZuser_passed_queryr) �zipr� r( r9 rY r� Z_update_compile_optionsr: r r� r� �_load_via_child�_load_via_parent)r\ rk rc r\ r] r� rd r? r r � our_states� none_statesr_ Z related_identr r Z bundle_entZ bundle_sqlZ entity_sqlr~ r| r4 r� Zcached_optionsZuncached_optionsr� r� r: )rk r� rN r\ r� r r; rV ; 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|v r�q|| �| j�� | ||s�| n| g� q|qdq|D ]0\} }}|s�| j|v r�q�| �| j�� | |d � q�d S )Nr c S s i | ]\}}||�qS r: r: )r� r� r� r: r: r; � <dictcomp> s �z2SelectInLoader._load_via_child.<locals>.<dictcomp>r" c s g | ]}� j r|d n|�qS rb �r )r� r4 �r r: r; r� # s �z2SelectInLoader._load_via_child.<locals>.<listcomp>�r� r ) r> �sorted� _chunksizer� r/ r� rJ r4 rZ r[ )r\ r' r( r r~ rk r r> Zour_keys�chunk�datar4 Z related_objr� r� r_ r: r+ r; 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 |v r�q�| � | |�}|�s|�rt |�d kr�t�d | � |�| j ��|||d � q�|�| j ��|||� q�qd S ) Nr: r c s& g | ] \}}}}� j r |d n|�qS rb r* )r� r4 r� r r_ r+ r: r; r� O s �z3SelectInLoader._load_via_parent.<locals>.<listcomp>r" r, c S s | d S ry r: r� r: r: r; r< [ r� z1SelectInLoader._load_via_parent.<locals>.<lambda>c s s | ]}|d V qdS )r Nr: r� r: r: r; r� ] r� z2SelectInLoader._load_via_parent.<locals>.<genexpr>r r� )r> r. r� r� r� r� r� r� r/ r� r� r4 rJ r1 r r2 rZ r[ )r\ r' r r~ rk r r> Z _empty_resultr/ r" r0 r� r� r4 r� r r_ r� r: r+ r; r& E sF � �� �� � �z SelectInLoader._load_via_parent)ro rp rq rs r� � namedtupler r. rY r r r r� rn rV r% r& rt r: r: r^ r; r { s � P T7r c sT �fdd�� � fdd�}� fdd�}t j| d|dddd � t j| d |dddd � d S ) Nc sT |d urP|j � j krP|�t�|��}|rP||urPtjdt�|�| 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) r4 � hasparentr Zinstance_stater� r� r3 Z instance_strrL )r� r� �oldvalue� initiatorr3 )r7 r: r; � _do_checkx s ��z*single_parent_validator.<locals>._do_checkc s � | |d |�S r2 r: )r� r� r5 �r6 r: r; rF � s z'single_parent_validator.<locals>.appendc s � | |||�S r2 r: )r� r� r4 r5 r7 r: r; �set_� s z%single_parent_validator.<locals>.set_rF T)�raw�retvalrC r� )r' �listen)r6 r7 rF r8 r: )r6 r7 r; rG w s �rG )NNNNFN)Wrr � __future__r r� r� �typingr r r r r r � r r r� r r r r r r r r r3 �baser r r r r r r rk r r r r r r r� r! r� r" r r# r$ r% r' r� r( r) r* r� r+ Zsql.selectabler, r- Z util.typingr. rN r/ r0 Z sql.elementsr1 rR ZColumnPropertyZ strategy_forrU Z class_loggerru r� r� r� r� r� r� Z MemoizedSlotsZ Identifiedr� r8 r> rN ra r� r rG r: r: r: r; �<module> s� � Q+Z W� 0% & � 24L c ; }
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????