관리-도구
편집 파일: base.cpython-38.pyc
U -?�f; � @ s� U d Z ddlmZ ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lm Z dd lm Z dd lm Z dd lm Z dd lm Z ddlmZ ddlmZ ddlmZ ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z e� e �Z de!d < d d d �d d!�Z"G d"d#� d#�Z#G d$d%� d%ee �Z$G d&d'� d'e$e �Z%d(d)d*�d+d,�Z&G d-d.� d.ee �Z'G d/d0� d0e$e �Z(G d1d2� d2e'e �Z)G d3d4� d4ee �Z*G d5d6� d6e*e �Z+dS )7a� Base implementation classes. The public-facing ``Events`` serves as the base class for an event interface; its public attributes represent different kinds of events. These attributes are mirrored onto a ``_Dispatch`` class, which serves as a container for collections of listener functions. These collections are represented both at the class level of a particular ``_Dispatch`` class as well as within instances of ``_Dispatch``. � )� annotationsN)�Any)�cast)�Dict)�Generic)�Iterator)�List)�Mapping)�MutableMapping)�Optional)�overload)�Tuple)�Type)�Union� )�_ClsLevelDispatch)�_EmptyListener)�_InstanceLevelDispatch)�_JoinedListener)�_ET)� _EventKey� )�util)�Literalz8MutableMapping[str, List[Type[_HasEventsDispatch[Any]]]]� _registrars�str�bool��name�returnc C s | � d� r| dkp | � d�S )N�_�dispatchZ _sa_event)� startswith)r � r# �E/opt/hc_python/lib64/python3.8/site-packages/sqlalchemy/event/base.py�_is_event_name2 s ��r% c @ s e Zd ZdZddd�dd�ZdS )�_UnpickleDispatchz�Serializable callable that re-generates an instance of :class:`_Dispatch` given a particular :class:`.Events` subclass. � Type[_ET]�_Dispatch[_ET])� _instance_clsr c C s> |j D ]*}d|jkrtd|jd j��|� S qtd��d S )Nr! r( z*No class with a 'dispatch' member present.)�__mro__�__dict__r r! � _for_class�AttributeError)�selfr) �clsr# r# r$ �__call__B s �� z_UnpickleDispatch.__call__N)�__name__� __module__� __qualname__�__doc__r0 r# r# r# r$ r& < s r& c @ sL e Zd ZU dZded< ddd�dd�Zd d d �d d �Zedd�dd��ZdS )�_DispatchCommonr# �Optional[Type[_ET]]r) �_DispatchCommon[_ET]�_JoinedDispatcher[_ET]��otherr c C s t � �d S �N��NotImplementedError�r. r: r# r# r$ �_joinQ s z_DispatchCommon._joinr �_InstanceLevelDispatch[_ET]r c C s t � �d S r; r< �r. r r# r# r$ � __getattr__T s z_DispatchCommon.__getattr__� Type[_HasEventsDispatch[_ET]]�r c C s t � �d S r; r< �r. r# r# r$ �_eventsW s z_DispatchCommon._eventsN) r1 r2 r3 � __slots__�__annotations__r? rB �propertyrF r# r# r# r$ r5 L s r5 c @ s� e Zd ZU dZdZded< e�� Zded< ded< d ed < d ed < d ed< ded< d<dd d�dd�Z ddd�dd�Z e dd �d d ��Z d d d!d"�d#d$�Z d%d&d'�d(d)�Zd*d&d+�d,d-�Zd.d/d0�d1d2�Zd3d �d4d5�Zd=d&dd!d7�d8d9�Zd!d �d:d;�ZdS )>� _DispatchaM Mirror the event listening definitions of an Events class with listener collections. Classes which define a "dispatch" member will return a non-instantiated :class:`._Dispatch` subclass when the member is accessed at the class level. When the "dispatch" member is accessed at the instance level of its owner, an instance of the :class:`._Dispatch` class is returned. A :class:`._Dispatch` class is generated for each :class:`.Events` class defined, by the :meth:`._HasEventsDispatch._create_dispatcher_class` method. The original :class:`.Events` classes remain untouched. This decouples the construction of :class:`.Events` subclasses from the implementation used by the event internals, and allows inspecting tools like Sphinx to work in an unsurprising way against the public API. )�_parentr) r+ �_empty_listenersr Z_active_historyz9MutableMapping[Type[_ET], Dict[str, _EmptyListener[_ET]]]�_empty_listener_regz Dict[str, _EmptyListener[_ET]]rL z List[str]� _event_namesr6 r) z Type[_JoinedDispatcher[_ET]]�_joined_dispatch_clsrC rF NzOptional[_Dispatch[_ET]])�parent� instance_clsc sn || _ � | _� rd|d k s t�z| j� | _W qj tk r` � fdd�|jD � | _| j� < Y qjX ni | _d S )Nc s i | ]}|j t|� ��qS r# )r r )�.0�ls�rQ r# r$ � <dictcomp>� s � z&_Dispatch.__init__.<locals>.<dictcomp>)rK r) �AssertionErrorrM rL �KeyError�_event_descriptors)r. rP rQ r# rT r$ �__init__� s �� � z_Dispatch.__init__r r@ r c C sB z| j | }W n tk r* t|��Y nX t| |j|� |S d S r; )rL rW r- �setattrr )r. r rS r# r# r$ rB � s z_Dispatch.__getattr__z Iterator[_ClsLevelDispatch[_ET]]rD c c s | j D ]}t| |�V qd S r; )rN �getattr)r. �kr# r# r$ rX � s z _Dispatch._event_descriptors�_EventKey[_ET]r �None�� event_key�kwr c K s | j j|f|�S r; )rF �_listen�r. r` ra r# r# r$ rb � s z_Dispatch._listenr' r( )rQ r c C s | � | |�S r; )� __class__)r. rQ r# r# r$ r, � s z_Dispatch._for_classr )�instancer c C s |j }| �|�S r; )rd r, )r. re rQ r# r# r$ � _for_instance� s z_Dispatch._for_instancer7 r8 r9 c C s d| j jkst�| �| |�S )z�Create a 'join' of this :class:`._Dispatch` and another. This new dispatcher will dispatch events to both :class:`._Dispatch` objects. rO )rd r+ rV rO r> r# r# r$ r? � s z_Dispatch._joinzUnion[str, Tuple[Any, ...]]c C s t � | jffS r; )r& r) rE r# r# r$ � __reduce__� s z_Dispatch.__reduce__T)r: �only_propagater c C s8 |j D ],}t|t�rqt| |j��| �j||d� qdS )zIPopulate from the listeners in another :class:`_Dispatch` object.)rh N)rX � isinstancer r[ r � for_modify�_update)r. r: rh rS r# r# r$ rk � s �z_Dispatch._updatec C s | j D ]}|�| ��� qd S r; )rX rj �clear)r. rS r# r# r$ �_clear� s z_Dispatch._clear)N)T)r1 r2 r3 r4 rG rH �weakref�WeakKeyDictionaryrM rY rB rI rX rb r, rf r? rg rk rm r# r# r# r$ rJ \ s. � � � rJ rC r^ )r/ r c C s. | j jD ] }t| �| � t| st|= qd S r; )r! rN r �remove)r/ r\ r# r# r$ �_remove_dispatcher� s rq c @ s� e Zd ZU ded< ded< ejr0ddd�dd �Zd d �d d �Zedddd�dd��Z eddddd�dddddd d�dd��Z e dddd �d d ��Z edd d d d!�d"d#��Z d$S )%�_HasEventsDispatchr6 �_dispatch_targetr( r! r r@ r c C s d S r; r# rA r# r# r$ rB � � z _HasEventsDispatch.__getattr__r^ rD c C s | � | j| j| j� dS )zOIntercept new Event subclasses and create associated _Dispatch classes.N)�_create_dispatcher_classr1 � __bases__r+ �r/ r# r# r$ �__init_subclass__� s z$_HasEventsDispatch.__init_subclass__�Union[_ET, Type[_ET]]� Optional[Union[_ET, Type[_ET]]]��target� identifierr c C s t � �d S r; r< )r/ r| r} r# r# r$ � _accept_with� s z _HasEventsDispatch._accept_withF�� propagate�insert�named�asyncior] r �r` r� r� r� r� r c C s t � �d S r; r< �r/ r` r� r� r� r� r# r# r$ rb � s z_HasEventsDispatch._listenrC �Type[_Dispatch[_ET]])�klass� dispatch_clsr c C s |d �| _ | |_| j S r; )r! rF )r� r� r# r# r$ � _set_dispatch s z _HasEventsDispatch._set_dispatchzTuple[type, ...]zMapping[str, Any])� classname�bases�dict_r c C sJ t | d�r| jj}nt}dd� |D �}tdtd| |fd|i��}||_| �| |�}|jD ](}t||t | || �� t | � | � qZ|j D ]B} t | t�r�| tk r�| jjjD ] } t|| j| � |j� | j� q�q�t| dd��r | j} | dk s�t�t | d��rd | jk�rt| �| _n t| �| _td |j tfd|i�} | |_| t� | j< dS ) zVCreate a :class:`._Dispatch` class corresponding to an :class:`.Events` class.r! c S s g | ]}t |�r|�qS r# )r% )rR r\ r# r# r$ � <listcomp>% s z?_HasEventsDispatch._create_dispatcher_class.<locals>.<listcomp>r� z %sDispatchrG rs N�_slots_dispatchzJoined%s)�hasattrr! rd rJ r �typerN r� rZ r r �appendrv � issubclassrF rX r r[ rs rV rG �slots_dispatcher� dispatcherr1 �_JoinedDispatcherrO �globals) r/ r� r� r� Z dispatch_baseZ event_namesr� Z dispatch_instr\ Zsuper_rS Zdispatch_target_clsr� r# r# r$ ru sL �� �� �z+_HasEventsDispatch._create_dispatcher_classN)r1 r2 r3 rH �typing� TYPE_CHECKINGrB rx � classmethodr~ rb � staticmethodr� ru r# r# r# r$ rr � s" � rr c @ s� e Zd ZU dZdZded< ded< ded< ddd�d d �Zd d �d d�Zddd�dd�Zdd dd�dd�Z e dd �dd��Z d S ) r� z5Represent a connection between two _Dispatch objects.��localrP r) r7 r� rP r6 r) )r� rP c C s || _ || _| j j| _d S r; r� )r. r� rP r# r# r$ rY Z s z_JoinedDispatcher.__init__r rD c C s | j | j| jffS r; )rd r� rP rE r# r# r$ rg a s z _JoinedDispatcher.__reduce__r z_JoinedListener[_ET]r c C s. t | j|�}t| j|j|�}t| |j|� |S r; )r[ r� r rP r rZ )r. r rS �jlr# r# r$ rB d s z _JoinedDispatcher.__getattr__r] r^ r_ c K s | j j|f|�S r; )rP rb rc r# r# r$ rb l s z_JoinedDispatcher._listenrC c C s | j jS r; )rP rF rE r# r# r$ rF o s z_JoinedDispatcher._eventsN) r1 r2 r3 r4 rG rH rY rg rB rb rI rF r# r# r# r$ r� Q s r� c @ st e Zd ZdZedddd�dd��Zeddddd �d d d d d d d �dd��Zed d d�dd��Zed d�dd��ZdS )�Eventsz>Define event listening functions for a particular target type.ry r rz r{ c sh ddd�� fdd� }ddd�� fdd� }t � d �rd|| jj�s`|t| jj�s`|t�rd|| jj�rd� S d S ) N� Type[Any]r )�typesr c s t � fdd�| D ��S )Nc 3 s | ]}t � j|�V qd S r; )ri r! )rR �t�r| r# r$ � <genexpr>| s z;Events._accept_with.<locals>.dispatch_is.<locals>.<genexpr>)�all)r� r� r# r$ � dispatch_is{ s z(Events._accept_with.<locals>.dispatch_is)r� r c s t td� j�j| �S )Nr8 )ri r r! rP )r� r� r# r$ �dispatch_parent_is~ s �z/Events._accept_with.<locals>.dispatch_parent_isr! )r� r! rd r� r� )r/ r| r} r� r� r# r� r$ r~ w s � �� �zEvents._accept_withFr r] r r^ r� c C s |j ||||d� d S )Nr )Z base_listenr� r# r# r$ rb � s �zEvents._listen)r` r c C s |� � d S r; )rp )r/ r` r# r# r$ �_remove� s zEvents._removerD c C s | j �� d S r; )r! rm rw r# r# r$ rm � s z Events._clearN) r1 r2 r3 r4 r� r~ rb r� rm r# r# r# r$ r� t s � r� c @ s\ e Zd ZdZdd�dd�Zedddd �d d ��Zed dd d �dd ��Zd dd d �dd �ZdS )r� z�Descriptor used by target classes to deliver the _Dispatch class at the class level and produce new _Dispatch instances for target instances. rC )�eventsc C s |j | _ || _d S r; )r! r� )r. r� r# r# r$ rY � s zdispatcher.__init__z Literal[None]r� r� ��objr/ r c C s d S r; r# �r. r� r/ r# r# r$ �__get__� s zdispatcher.__get__r r7 c C s d S r; r# r� r# r# r$ r� � s c C s` |d kr| j S | j �|�}z||jd< W n2 tk rZ } ztd|f �|�W 5 d }~X Y nX |S )Nr! zGtarget %r doesn't have __dict__, should it be defining _slots_dispatch?)r! rf r+ r- � TypeError)r. r� r/ �dispZaer# r# r$ r� � s ���N)r1 r2 r3 r4 rY r r� r# r# r# r$ r� � s r� c @ s e Zd Zdddd�dd�ZdS )r� r r� r� c C s4 |d kr| j S t|d�r |jS | j �|�}||_|S )Nr� )r! r� r� rf )r. r� r/ r� r# r# r$ r� � s zslots_dispatcher.__get__N)r1 r2 r3 r� r# r# r# r$ r� � s r� ),r4 � __future__r r� r r r r r r r r r r r r r rn �attrr r r r �registryr r � r Z util.typingr � defaultdict�listr rH r% r& r5 rJ rq rr r� r� r� r� r# r# r# r$ �<module> sH � ~p#5#