Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/orm/__pycache__/dependency.cpython-39.pyc
Ðазад
a _�hܵ � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z dd lm Z d dlmZ d d lm Z d dlmZ G d d � d e�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Ze ee ee eiZdS )z Relationship dependencies. � )� attributes)�exc)�sync)� unitofwork)�util)� MANYTOMANY)� MANYTOONE)� ONETOMANY� )�sqlc @ s� e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd%d d �Zd d!� Zd"d#� Zd$S )&�DependencyProcessorc C s� || _ |j| _|j| _|j| _|j| _|j| _|j| _|j| _|j| _|j | _ | jr^t j | _ nt j | _ | jrvt j | _nt j | _|j| _| j js�t�d| j ��d S )Nz|Can't build a DependencyProcessor for relationship %s. No target attributes to populate between parent and child are present)�prop�cascade�mapper�parent� secondary� direction� post_update�passive_deletes�passive_updates�enable_typechecksr �PASSIVE_NO_INITIALIZE�_passive_delete_flag� PASSIVE_OFF�_passive_update_flag�key�synchronize_pairs�sa_exc� ArgumentError)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/orm/dependency.py�__init__ s. ��z DependencyProcessor.__init__c C s t |j |�S �N)�_direction_to_processorr )�clsr r r r! �from_relationship6 s z%DependencyProcessor.from_relationshipc C s | j j�| j��|�S )z�return True if the given object instance has a parent, according to the ``InstrumentedAttribute`` handled by this ``DependencyProcessor``. )r Z class_manager�get_implr � hasparent�r �stater r r! r( : s z DependencyProcessor.hasparentc C s |� | d� dS )z�establish actions and dependencies related to a flush. These actions will operate on all relevant states in the aggregate. TN)�register_preprocessor�r �uowr r r! �per_property_preprocessorsB s z.DependencyProcessor.per_property_preprocessorsc C sz t �|| dd�}t �|| dd�}t �|| jj�}t �|| jj�}t �|| jj�}t �|| jj�}| �|||||||� d S �NFT)r � ProcessAll� SaveUpdateAllr �primary_base_mapperr � DeleteAll�per_property_dependencies)r r- � after_save� before_delete� parent_saves� child_saves�parent_deletes� child_deletesr r r! �per_property_flush_actionsK s. �����z.DependencyProcessor.per_property_flush_actionsc C s� | j j}t�||�}t�||�}|r<t�|| dd�}d|_nt�|| dd�}d|_||jvr�||jvsjJ �|df|dfg} d} nd} |s�t�|| jj �} d } }| |jv r�d} n&t�|| jj �} d } }| |jv r�d} |D �]}|j | j j � ||j|r�| jntj�}|�sq�|�r8t�|| d|�}| �rZt�||�} n"t�|| d|�}| �rZt�||�} | �r�g } |D ]\\}}||jv�r�d}n6|j| \}}|�r�t�||�df}nt�||�df}| �|� �qh| D ]"\}}| �|| | |||||� �q�q�dS )z�establish actions and dependencies related to a flush. These actions will operate on all relevant states individually. This occurs only if there are cycles in the 'aggregated' version of events. TFN)NN)r r2 r r1 r3 r0 �disabledZcyclesr � base_mapper�managerr �implZget_all_pending�dictr r r Z ProcessStateZ DeleteStateZSaveUpdateState�states�append�per_state_dependencies)r r- rA �isdeleteZchild_base_mapperr8 r: r6 r5 Z child_actionsZchild_in_cyclesr7 r9 Zparent_in_cyclesr* Zsum_Z child_state�child� child_action�deletedZlistonly� childisdeleter r r! �per_state_flush_actionsg s� � �� � � �z+DependencyProcessor.per_state_flush_actionsc C s dS �NFr �r � uowcommitrA r r r! �presort_deletes� s z#DependencyProcessor.presort_deletesc C s dS rJ r rK r r r! � presort_saves� s z!DependencyProcessor.presort_savesc C s d S r# r rK r r r! �process_deletes� s z#DependencyProcessor.process_deletesc C s d S r# r rK r r r! � process_saves� s z!DependencyProcessor.process_savesc C sp |r | j rtj}n| jtu r$tj}ntj}|D ]&}|�|| j|�}|r.|� � s. dS q.|on| j j on| j |j v S )NT)r r r r r ZPASSIVE_NO_FETCH_RELATEDr �get_attribute_historyr �emptyr Z_is_self_referentialr Zmappers)r rL rA rD �passive�s�historyr r r! �prop_has_changes� s � �z$DependencyProcessor.prop_has_changesc C s� | j jr$|d u r$t�d| j f ��nn|d ur�| jj|| j d�s�| jj|dd�rtt�d|j| j | jj| jd� ��n t�d|j| j | jjd� ��d S )Nz-Can't flush None value found in collection %s)Zallow_subtypesTaE Attempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type. If %(x)s is a subclass of %(z)s, configure mapper "%(zm)s" to load this subtype polymorphically, or set enable_typechecks=False to allow any subtype to be accepted for flush. )�x�y�zZzmz�Attempting to flush an item of type %(x)s as a member of collection "%(y)s". Expected an object of type %(z)s or a polymorphic subclass of this type.)rW rX rY )r �uselistr Z FlushErrorr Z_canloadr �class_r) r r r! �_verify_canload� s6 ��� ������z#DependencyProcessor._verify_canloadc C s t � �d S r# ��NotImplementedError)r r* rE �associationrow� clearkeysrL r r r! � _synchronize" s z DependencyProcessor._synchronizec C s> | j js d S tt| jgdd� | j jD � ��}|�d|ft�S )Nc S s g | ] }|j �qS r )r )�.0�pr r r! � <listcomp>* � zCDependencyProcessor._get_reversed_processed_set.<locals>.<listcomp>Z reverse_key)r �_reverse_property�tuple�sortedr �memo�set)r r- Z process_keyr r r! �_get_reversed_processed_set% s �z/DependencyProcessor._get_reversed_processed_setFc C s8 |D ].}|r|d ur|� |dd� | jjD �� q4qd S )Nc S s g | ] \}}|�qS r r )rb �l�rr r r! rd 2 re z4DependencyProcessor._post_update.<locals>.<listcomp>)Zregister_post_updater r )r r* rL �related� is_m2o_deleterW r r r! � _post_update. s �z DependencyProcessor._post_updatec C s t � �d S r# r] �r rL r* r r r! � _pks_changed6 s z DependencyProcessor._pks_changedc C s d| j j| jf S )Nz%s(%s))� __class__�__name__r )r r r r! �__repr__9 s z DependencyProcessor.__repr__N)F)rt � __module__� __qualname__r" � classmethodr& r( r. r; rI rM rN rO rP rV r\ ra rk rp rr ru r r r r! r s$ p) r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )� OneToManyDPc C s� | j r\t�|| jjd�}t�|| jjd�} |j�||f||f||f|| f| |f| |fg� n6|j�||f||f||f||f||f||f||fg� d S r/ �r r � PostUpdateAllr r2 � dependencies�update) r r- r7 r8 r9 r: r5 r6 �child_post_updates�child_pre_updatesr r r! r4 > s4 � ��� ��z%OneToManyDP.per_property_dependenciesc C s� | j r�t�|| jjd�} t�|| jjd�} |sl|rL|j�||f|| fg� q�|j�||f||f|| fg� q�|r�|j�|| f| |fg� q�|j�|| f| |fg� n<|s�|j�||f||f||fg� n|j�||f||fg� d S r/ rz ) r r- � save_parent� delete_parentrF r5 r6 rD rH r~ r r r r! rC g sR � ������������z"OneToManyDP.per_state_dependenciesc C s� | j j o| jdk }|D ]�}|�|| j| j�}|r|jD ]<}|d ur:| �|�du r:| j jrl|j |dd� q:|� |� q:|r|j D ] }|d ur�|j |d| j d� q�qd S )N�allFT�rD �delete�� operationr ) r r� r rQ r r rG r( � delete_orphan�register_object� unchangedr �r rL rA �should_null_fksr* rU rE r r r! rM � s$ � � �zOneToManyDP.presort_deletesc C sV |� d| ft�}| jj o$| jdk }|D �]$}| �||�}|rF| jrNtj}ntj }|� || j |�}|�r|j D ] } | d urp|j | dd| jd� qp|�|j � |jD ]r} | jjs�|r�|j | dd| jd� q�| �| �du r�|j | dd| jd� | j�d| �D ]\} } } } |j | dd � q�q�|r*|r*|jD ](} | d u�r&|j | d| jd | jd � �q&q*d S ) N�children_addedr� T�add)Z cancel_deleter� r Fr� �rD r� r r� z pk changer� )ri rj r r� r rr r r r r rQ r �addedr� r r} rG r( r �cascade_iteratorr� )r rL rA r� r� r* � pks_changedrS rU rE �c�m�st_�dct_r r r! rN � sf � � ��� �zOneToManyDP.presort_savesc C s� | j s| jdks�|�d| ft�}|D ]�}|�|| j| j�}|r$|jD ]H}|d urD| �|�du rD| � ||d d|d� | j rD|rD| � |||g� qD| j s�| j j s$t|j ��|�D ]:}|d ur�| � ||d d|d� | j r�|r�| � |||g� q�q$d S )Nr� r� FT)r r ri rj rQ r r rG r( ra rp r r� r� � difference)r rL rA r� r* rU rE r r r! rO s: � � � � � � �zOneToManyDP.process_deletesc C s� | j j o| jdk }|D ]�}|�|| jtj�}|r|jD ]6}| �||d d|d� |d ur:| j r:| � |||g� q:|j D ].}|rx| j jsx| � |�sx| �||d d|d� qx| � ||�r|jD ]}| �||d d|d� q�qd S )Nr� FT)r r� r rQ r r r r� ra r rp rG r( rr r� r� r r r! rP / s: � � � ��� � �zOneToManyDP.process_savesc C sp |}|}| � |� |d u s*| js.|�|�r.d S |rHt�|| j| jj� n$t�|| j || j| jj|| j oh|� d S r# ) r\ r � is_deletedr �clearr r r �populater r ) r r* rE r_ r` rL r� �source�destr r r! ra Q s( ���zOneToManyDP._synchronizec C s t �||| j| jj�S r# �r �source_modifiedr r r rq r r r! rr h s �zOneToManyDP._pks_changedN) rt rv rw r4 rC rM rN rO rP ra rr r r r r! ry = s )C>,"ry c @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z ddd�Z dS )� ManyToOneDPc C s. t �| |� | jjD ]}|j�t|�� qd S r# )r r" r Zself_and_descendantsZ_dependency_processorsrB �DetectKeySwitch)r r r r r r! r" o s zManyToOneDP.__init__c C s� | j rbt�|| jjd�}t�|| jjd�} |j�||f||f||f|| f|| f| |f| |fg� n$|j�||f||f||f||fg� d S r/ �r r r{ r r2 r| r} ) r r- r7 r8 r9 r: r5 r6 �parent_post_updates�parent_pre_updatesr r r! r4 t s0 � ��� ��z%ManyToOneDP.per_property_dependenciesc C s� | j r�|sZt�|| jjd�} |r:|j�|| f| |fg� q�|j�||f||f|| fg� q�t�|| jjd�} |j�|| f| |f| |fg� nL|s�|s�|j�||f||fg� q�|j�||fg� n|r�|j�||fg� d S r/ r� ) r r- r� r� rF r5 r6 rD rH r� r� r r r! rC � sD ����� ����z"ManyToOneDP.per_state_dependenciesc C s� | j js| j jr�|D ]�}|�|| j| j�}|r| j jr@|�� }n|�� }|D ]P}|d u rZqL|j|dd| j d� | j � d|�}|D ]\}} } } |j| dd� q�qLqd S )NTr� r� r� ) r r� r� rQ r r �sumZ non_deletedr� r r r� ) r rL rA r* rU ZtodeleterE �tr� r� r� r� r r r! rM � s* � �zManyToOneDP.presort_deletesc C s� |D ]�}|j |d| jd� | jjr|�|| j| j�}|r|jD ]T}| �|�du r>|j |dd| jd� | j � d|�}|D ]\}}} } |j | dd� qvq>qd S )Nr� r� FTr� r� r� ) r� r r r� rQ r r rG r( r r� ) r rL rA r* rU rE r� r� r� r� r� r r r! rN � s$ � �zManyToOneDP.presort_savesc C sn | j rj| jjsj| jdksj|D ]L}| �|d d d|� |r | j r |�|| j| j�}|r | j|||� � dd� q d S )Nr� T)ro ) r r r� r ra rQ r r rp r� )r rL rA r* rU r r r! rO s ��� � �zManyToOneDP.process_deletesc C s~ |D ]t}|� || jtj�}|r|jrF|jD ]}| �||d d|d� q*n|jr`| �|d d d|d� | jr| �|||� � � qd S )NFr� Tr� ) rQ r r r r� ra rG r rp r� )r rL rA r* rU rE r r r! rP s � � �zManyToOneDP.process_savesNc C s� |d u s| j s |�|�r d S |d urX|d urX|j�|�sXt�dt�|�|| jf � d S |sd|d u rzt � || j | jj � n(| � |� t �|| j|| j | jj |d� d S )N�GObject of type %s not in session, %s operation along '%s' won't proceedF)r r� �session�_contains_stater �warn� mapperutil�state_class_strr r r� r r r\ r� r �r r* rE r_ r` rL r� r r r! ra * s< ���� ��� �zManyToOneDP._synchronize)N) rt rv rw r" r4 rC rM rN rO rP ra r r r r! r� n s (: �r� c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� ZdS )r� a� For many-to-one relationships with no one-to-many backref, searches for parents through the unit of work when a primary key has changed and updates them. Theoretically, this approach could be expanded to support transparent deletion of objects referenced via many-to-one as well, although the current attribute system doesn't do enough bookkeeping for this to be efficient. c C s< | j jr,| jrd S ddd� | j jD �v r,d S |�| d� d S )NFc s s | ] }|j V qd S r# )r )rb r r r r! � <genexpr>d s �z=DetectKeySwitch.per_property_preprocessors.<locals>.<genexpr>)r rf r r+ r, r r r! r. _ s �z*DetectKeySwitch.per_property_preprocessorsc C s6 t �|| jj�}t �|| dd�}|j�||fg� d S rJ )r r1 r r= r0 r| r} )r r- r7 r5 r r r! r; l s z*DetectKeySwitch.per_property_flush_actionsc C s d S r# r )r r- rA rD r r r! rI q s z'DetectKeySwitch.per_state_flush_actionsc C s d S r# r rK r r r! rM t s z DetectKeySwitch.presort_deletesc C s | j s| �||� d S r# �r �_process_key_switches)r r- rA r r r! rN w s z DetectKeySwitch.presort_savesc C s" |s | j r | �||�}t|�S dS rJ )r �_key_switchers�bool)r r- rA rD �dr r r! rV } s z DetectKeySwitch.prop_has_changesc C s dsJ �d S rJ r rK r r r! rO � s z DetectKeySwitch.process_deletesc C s | j s J �| �||� d S r# r� rK r r r! rP � s z DetectKeySwitch.process_savesc C sZ |� d| fdd� �\}}|�|�}|D ].}||vr&| �||�rJ|�|� q&|�|� q&|S )NZ pk_switchersc S s t � t � fS r# )rj r r r r! �<lambda>� re z0DetectKeySwitch._key_switchers.<locals>.<lambda>)ri �unionrr r� )r r- rA ZswitchedZ notswitchedZ allstatesrT r r r! r� � s � z DetectKeySwitch._key_switchersc C s� | � ||�}|r�|jj�� D ]�}t|j| jj�s2q |j}|�| j �j ||| j d�}|t j ur |d ur | jjr||srq |d }n|}t �|�}||v r |�|d| j� t�|| j|| j| jj|| j� q d S )N)rS � F)r� r� Z identity_mapZ all_states� issubclassr[ r r@ r' r �getr r ZPASSIVE_NO_RESULTr rZ Zinstance_stater� r r r� r r ) r ZdeplistrL Z switchersr* Zdict_rn Z related_objZ related_stater r r! r� � s@ ��� ��z%DetectKeySwitch._process_key_switchesc C s t |j�o t�||| j| jj�S r# )r� r r r� r r r rq r r r! rr � s �z DetectKeySwitch._pks_changedN)rt rv rw �__doc__r. r; rI rM rN rV rO rP r� r� rr r r r r! r� S s %r� c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dS )� ManyToManyDPc C s: |j �||f||f||f||f||f||f||fg� d S r# �r| r} )r r- r7 r8 r9 r: r5 r6 r r r! r4 � s ��z&ManyToManyDP.per_property_dependenciesc C sX |s<|r"|j �||f||fg� qT|j �||f||fg� n|j �||f||fg� d S r# r� ) r r- r� r� rF r5 r6 rD rH r r r! rC � s ���z#ManyToManyDP.per_state_dependenciesc C s& | j s"|D ]}|�|| j| j� q d S r# )r rQ r r )r rL rA r* r r r! rM � s �z ManyToManyDP.presort_deletesc C s� | j s.|D ]"}| �||�r |�|| jtj�}q | jjs:d S |D ]r}|�|| jtj�}|r>|j D ]P}| � |�du r^|j |dd| j d� | j �d|�D ]\}}}} |j |dd� q�q^q>d S )NFTr� r� r� )r rr rQ r r r r r� r rG r( r� r r r� ) r rL rA r* rU rE r� r� r� r� r r r! rN s2 � � ��zManyToManyDP.presort_savesc s� g }g }g }| � |�}t� }|D ]�� |�� | j| j�}|r |�� D ]F} | d u sB|d urd� | f|v rdqBi } | �� | | d|d�s~qB|�| � qB|�� fdd�|�� D �� q |d ur�|�|� | � ||||� d S )NFr� c 3 s | ]}|� fV qd S r# r �rb r� �r* r r! r� K re z/ManyToManyDP.process_deletes.<locals>.<genexpr>) rk rj rQ r r Z non_addedra rB r} � _run_crud) r rL rA �secondary_delete�secondary_insert�secondary_update� processed�tmprU rE r_ r r� r! rO , sD � � �� �z ManyToManyDP.process_deletesc s� g }g }g }| � |�}t� }|D �]:� | j o8| �|� �}|rFtj} ntj} |�� | j| �} | r | j D ]>} |d ur�� | f|v r�qfi } | � � | | d|d�s�qf|� | � qf| j D ]>} |d urƈ | f|v r�q�i } | � � | | d|d�s�q�|� | � q�|� � fdd�| j | j D �� |r | jD ]D} i } t� � | j| d| jj� t� | | j| d| jj� |� | � �qq |d u�rr|� |� | �||||� d S )NFr� r� c 3 s | ]}|� fV qd S r# r r� r� r r! r� ~ re z-ManyToManyDP.process_saves.<locals>.<genexpr>�old_)rk rj r rr r r r rQ r r� ra rB rG r} r� r r r r r �secondary_synchronize_pairsr� ) r rL rA r� r� r� r� r� Zneed_cascade_pksrS rU rE r_ r r� r! rP T sz � � � �� �zManyToManyDP.process_savesc s |j �| j�}|r~|d � | j�tj� fdd�| jjD �� �}|�||�}|� � r~|j t |�kr~t � d| jjt |�|j f ��|r�|d � | j�tj� fdd�| jjD �� �}|�||�}|� � r�|j t |�kr�t � d| jjt |�|j f ��|�r | j�� }|�||� d S )Nr� c s, g | ]$}|j � v r|tj|j |jd �k�qS )��type_�r r Z bindparam�typer� �r_ r r! rd � s �z*ManyToManyDP._run_crud.<locals>.<listcomp>zRDELETE statement on table '%s' expected to delete %d row(s); Only %d were matched.c s0 g | ](}|j � v r|tjd |j |jd�k�qS )r� r� r� r� r� r r! rd � s �zRUPDATE statement on table '%s' expected to update %d row(s); Only %d were matched.)Z transaction� connectionr r r� r �and_r� �executeZ supports_sane_multi_rowcountZrowcount�lenr ZStaleDataError� descriptionr} �insert)r rL r� r� r� r� Z statement�resultr r� r! r� � s` ��� � ���� ��� � ���� zManyToManyDP._run_crudc C s� | � |� |d u rdS |d urP|j�|�sP|jsLt�dt�|�|| jf � dS t � || j || jj � t � || j || jj� dS )NFr� T)r\ r� r� rG r r� r� r� r r Z populate_dictr r r r� r� r r r! ra � s* ����zManyToManyDP._synchronizec C s t �||| j| jj�S r# r� rq r r r! rr � s �zManyToManyDP._pks_changedN) rt rv rw r4 rC rM rN rO rP r� ra rr r r r r! r� � s "(H=!r� N)r� � r r r r r r� Z interfacesr r r r r �objectr ry r� r� r� r$ r r r r! �<module> s6 & 3 fu ;�
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка