관리-도구
편집 파일: dynamic.cpython-38.pyc
U -?�fX& � @ s d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z dd lm Z dd lm Z dd lm Z dd lm Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlm Z ddlmZ ddl m!Z! e �r�d dlm"Z" d d l#m$Z$ d d lm%Z% d d lm&Z& d d l'm(Z( d d lm)Z) dd!l*m+Z+ dd"l,m-Z- e d#ed$�Z.G d%d&� d&e e. �Z/G d'd(� d(e �Z0ej1j2d)d*�G d+d,� d,e ��Z3G d-d.� d.e e. �Z4G d/d0� d0e4e. ee. �Z5d1d2d3�d4d5�Z6d6S )7z�Dynamic collection API. Dynamic collections act like Query() objects for read operations and support basic add/delete mutation. .. legacy:: the "dynamic" loader is a legacy feature, superseded by the "write_only" loader. � )� annotations)�Any)�Iterable)�Iterator)�List)�Optional)�Tuple)�Type)� TYPE_CHECKING)�TypeVar)�Union� )� attributes)�exc)� relationships)�util)� PassiveFlag)�Query)�object_session)�AbstractCollectionWriter)�WriteOnlyAttributeImpl)�WriteOnlyHistory)�WriteOnlyLoader� )�result)�QueryableAttribute)�Mapper)�_RelationshipOrderByArg)�Session)� InstanceState)� AliasedClass)� _Dispatch)� ColumnElement�_T)�boundc @ s$ e Zd Zd dddddd�dd �ZdS ) �DynamicCollectionHistoryN�DynamicAttributeImpl�InstanceState[_T]r z&Optional[DynamicCollectionHistory[_T]]�None)�attr�state�passive�apply_to�returnc C s` |r8t ||��d�}t�|�| _|j| _|j| _d| _n$t�� | _t�� | _t�� | _d| _d S )NFT)� AppenderQuery� autoflushr ZOrderedIdentitySetZunchanged_items� added_itemsZ deleted_itemsZ_reconcile_collection)�selfr) r* r+ r, Zcoll� r2 �F/opt/hc_python/lib64/python3.8/site-packages/sqlalchemy/orm/dynamic.py�__init__> s z!DynamicCollectionHistory.__init__)N)�__name__� __module__� __qualname__r4 r2 r2 r2 r3 r% = s �r% c @ s@ e Zd ZU dZee Zded< dddddd d d d d �dd�ZdS )r& TzType[AppenderMixin[Any]]� query_classNz#Union[Type[Any], AliasedClass[Any]]�strz"_Dispatch[QueryableAttribute[Any]]z Mapper[_T]r z!Optional[Type[AppenderMixin[_T]]]r r( )�class_�key�dispatch� target_mapper�order_byr8 �kwr- c K sZ t jj| ||d |f|� || _|r,t|�| _|s8t| _n t|� � krL|| _n t |�| _d S �N) r Z AttributeImplr4 r= �tupler> r. r8 � AppenderMixin�mro�mixin_user_query)r1 r: r; r< r= r> r8 r? r2 r2 r3 r4 W s" �� z DynamicAttributeImpl.__init__)N) r5 r6 r7 Z_supports_dynamic_iterationr% r Zcollection_history_cls�__annotations__r4 r2 r2 r2 r3 r& R s �r& Zdynamic)Zlazyc @ s e Zd ZeZdS )� DynaLoaderN)r5 r6 r7 r& Z impl_classr2 r2 r2 r3 rF o s rF c s e Zd ZU dZdZded< ded< ddd d �� fd d � Zed d�dd��Zej dd d�dd��Zdd�dd�Z e r�dd�dd�Z ddd �d d �Z d d�d d!�Zd4d d"d#�d$d%�Zd&d d'�d(d)�Zd*d d+�d,d-�Zd&d d'�d.d/�Zd*d d+�d0d1�Zd*d d+�d2d3�Z� ZS )5rB zTA mixin that expects to be mixing in a Query class with AbstractAppender. NzOptional[Type[Query[_T]]]r8 z Tuple[ColumnElement[Any], ...]�_order_by_clausesr& r' r( )r) r* r- c s" t �| |jd � t� �||� d S r@ )r r4 r= �super)r1 r) r* �� __class__r2 r3 r4 ~ s �zAppenderMixin.__init__zOptional[Session])r- c C sB t | j�}|d k r*|jr*| j|kr*|�� t�| j�s:d S |S d S r@ )r �instancer/ �flush�orm_utilZ has_identity�r1 �sessr2 r2 r3 �session� s zAppenderMixin.sessionr )rP r- c C s || _ d S r@ )rO )r1 rP r2 r2 r3 rP � s z1Union[result.ScalarResult[_T], result.Result[_T]]c C s� | j }|d krpt�| j�}|jr4t�dt�|� � t j t � | j j jg�t| j �t�| j�tj�j�dd��� S | �|��� S d S )Nz�Instance %s is detached, dynamic relationship cannot return a correct result. This warning will become a DetachedInstanceError in a future release.T)Z_source_supports_scalars)rP r �instance_staterK Zdetachedr �warnrM Z state_strr ZIteratorResultZSimpleResultMetaDatar) r: r5 �iter�_get_collection_historyr �PASSIVE_NO_INITIALIZEr0 Zscalars� _generate�_iter)r1 rO r* r2 r2 r3 rW � s( �� ��� zAppenderMixin._iterz Iterator[_T]c C s d S r@ r2 )r1 r2 r2 r3 �__iter__� � zAppenderMixin.__iter__r zUnion[_T, List[_T]])�indexr- c C s@ | j }|d kr,| j�t�| j�tj��|�S | � |�� |�S d S r@ ) rP r) rT r rQ rK r rU ZindexedrV � __getitem__)r1 rZ rO r2 r2 r3 r[ � s ��zAppenderMixin.__getitem__�intc C s> | j }|d kr,t| j�t�| j�tj�j �S | � |�� � S d S r@ ) rP �lenr) rT r rQ rK r rU r0 rV �countrN r2 r2 r3 r^ � s ��zAppenderMixin.countz Query[_T])rO r- c C s~ | j }|d kr:t|�}|d kr:t�dt�|�| jjf ��| jrT| j| jj |d�}n|� | jj �}| j |_ | j |_ | j |_ |S )Nz�Parent instance %s is not bound to a Session, and no contextual session is established; lazy load operation of attribute '%s' cannot proceed)rP )rK r �orm_excZDetachedInstanceErrorrM Z instance_strr) r; r8 r= �queryZ_where_criteriaZ _from_objrG )r1 rO rK r` r2 r2 r3 rV � s ��zAppenderMixin._generatez Iterable[_T])�iteratorr- c C s | � |� dS )a~ Add an iterable of items to this :class:`_orm.AppenderQuery`. The given items will be persisted to the database in terms of the parent instance's collection on the next flush. This method is provided to assist in delivering forwards-compatibility with the :class:`_orm.WriteOnlyCollection` collection class. .. versionadded:: 2.0 N�Z _add_all_impl�r1 ra r2 r2 r3 �add_all� s zAppenderMixin.add_allr# )�itemr- c C s | � |g� dS )ap Add an item to this :class:`_orm.AppenderQuery`. The given item will be persisted to the database in terms of the parent instance's collection on the next flush. This method is provided to assist in delivering forwards-compatibility with the :class:`_orm.WriteOnlyCollection` collection class. .. versionadded:: 2.0 Nrb �r1 re r2 r2 r3 �add� s zAppenderMixin.addc C s | � |� dS )z�Add an iterable of items to this :class:`_orm.AppenderQuery`. The given items will be persisted to the database in terms of the parent instance's collection on the next flush. Nrb rc r2 r2 r3 �extend s zAppenderMixin.extendc C s | � |g� dS )z�Append an item to this :class:`_orm.AppenderQuery`. The given item will be persisted to the database in terms of the parent instance's collection on the next flush. Nrb rf r2 r2 r3 �append s zAppenderMixin.appendc C s | � |� dS )z�Remove an item from this :class:`_orm.AppenderQuery`. The given item will be removed from the parent instance's collection on the next flush. N)Z _remove_implrf r2 r2 r3 �remove s zAppenderMixin.remove)N)r5 r6 r7 �__doc__r8 rE r4 �propertyrP �setterrW r rX r[ r^ rV rd rg rh ri rj � __classcell__r2 r2 rI r3 rB t s( � rB c @ s e Zd ZdZdS )r. z�A dynamic query that supports basic collection storage operations. Methods on :class:`.AppenderQuery` include all methods of :class:`_orm.Query`, plus additional methods used for collection persistence. N)r5 r6 r7 rk r2 r2 r2 r3 r. s r. r ztype[AppenderMixin[Any]])�clsr- c C s d| j }t|t| fd| i�S )zAReturn a new class with AppenderQuery functionality layered over.ZAppenderr8 )r5 �typerB )ro �namer2 r2 r3 rD ) s rD N)7rk � __future__r �typingr r r r r r r r r r � r r r_ r r rM �baser r` r rP r Z writeonlyr r r r Zenginer r Zmapperr r r r* r r �eventr! Z sql.elementsr" r# r% r& ZRelationshipPropertyZ strategy_forrF rB r. rD r2 r2 r2 r3 �<module> sT +