Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/sqlalchemy/orm/__pycache__/unitofwork.cpython-39.pyc
Ðазад
a _�h�` � @ s d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z d d � Z G d d � d e �Z G d d� de �Z G dd� de �ZG dd� de �ZG dd� de e�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e�Zd!S )"z�The internals for the unit of work system. The session's flush() process passes objects to a contextual object here, which assembles flush tasks based on mappers and their properties, organizes them in order of dependency, and executes. � �� attributes)�exc)� persistence)�util� )�event)� topologicalc sj |j � � fdd�}� fdd�}� fdd�}tj| d|ddd � tj| d |ddd � tj| d |ddd � d S ) z\Establish event listeners on object attributes which handle cascade-on-set/append. c sn |d u r d S | j }|rj|jr&|�d� | jjj� }t�|�}|jj rj|j sV� |j krj|� |�sj|� |� |S )Nzcollection append)�session�_warn_on_events�_flush_warning�manager�mapper�_propsr �instance_state�_cascade� save_update�cascade_backrefs�key�_contains_state�_save_or_update_state��state�item� initiator�sess�propZ item_state�r � ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/sqlalchemy/orm/unitofwork.py�append s$ ���� z$track_cascade_events.<locals>.appendc s� |d u r d S | j }| jjj� }|r>|jr>|�|jr8dnd� |d ur�|tjur�|tj ur�|j j r�t� |�}|j� |�r�|r�||jv r�|�|� nd|_d S )Nzcollection removezrelated attribute deleteT)r r r r r r Zuselistr � NEVER_SET�PASSIVE_NO_RESULTr � delete_orphanr � _is_orphan�_new�expungeZ _orphaned_outside_of_sessionr r r r �remove6 s. ������ z$track_cascade_events.<locals>.removec s� ||u r |S | j }|r�|jr&|�d� | jjj� }|d urrt�|�}|jj rr|j s^� |j krr|� |�sr|� |� |d ur�|tjur�|tjur�|jjr�t�|�}||jv r�|j�|�r�|�|� |S )Nzrelated attribute set)r r r r r r r r r r r r r r r! r" r# r% r$ r& )r ZnewvalueZoldvaluer r r Znewvalue_stateZoldvalue_stater r r �set_X s@ ���� ���� � z"track_cascade_events.<locals>.set_r T)�raw�retvalr' �setN)r r �listen)Z descriptorr r r' r( r r r �track_cascade_events s " %r- c @ s� e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z e j fd d�Z dd� Z dd� Zd'dd�Zdd� Zdd� Zejdd � �Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� ZdS )(�UOWTransactionc C sR || _ i | _t�t�| _t�t�| _i | _i | _t� | _ i | _ t�dd� �| _ d S )Nc S s t � t � fS �N)r+ r r r r �<lambda>� � z)UOWTransaction.__init__.<locals>.<lambda>) r r r � defaultdictr+ �deps�mappers�presort_actions�postsort_actions� dependencies�states�post_update_states)�selfr r r r �__init__� s zUOWTransaction.__init__c C s t | j�S r/ )�boolr8 �r: r r r �has_work� s zUOWTransaction.has_workc C sB |j r>z|�|tj� W n$ tjy< | j�|g� Y dS 0 dS )zZReturn ``True`` if the given state is expired and was deleted previously. TF)ZexpiredZ _load_expiredr � PASSIVE_OFF�orm_excZObjectDeletedErrorr �_remove_newly_deleted�r: r r r r �was_already_deleted� s z"UOWTransaction.was_already_deletedc C s || j v o| j | d S )z[Return ``True`` if the given state is marked as deleted within this uowtransaction.� �r8 rB r r r � is_deleted� s zUOWTransaction.is_deletedc C s, || j v r| j | S |� | j |< }|S d S r/ r )r: r Z callable_�retr r r �memo� s zUOWTransaction.memoc C s | j | d }|df| j |< dS )z;Remove pending actions for a state from the uowtransaction.rD TNrE )r: r �isdeleter r r �remove_state_actions� s z#UOWTransaction.remove_state_actionsc C s� d||f}|| j v r�| j | \}}}|t j@ s�|t j@ r�|j| j}|�||jt jt jB �}|rp|jrp|� � }n|}|||f| j |< nJ|j| j}|�||j|t jB �}|r�|jr�|� � }n|}|||f| j |< |S )zOFacade to attributes.get_state_history(), including caching of results.�history) r ZSQL_OKr �implZ get_history�dictr? ZLOAD_AGAINST_COMMITTEDZ uses_objectsZas_state) r: r r ZpassiveZhashkeyrK Z state_historyZcached_passiverL r r r �get_attribute_history� s4 �� � � z$UOWTransaction.get_attribute_historyc C s |df| j v S )NT)r5 )r: � processorr r r �has_dep s zUOWTransaction.has_depc C s& ||f}|| j vr"t||�| j |< d S r/ )r5 � Preprocess)r: rO � fromparentr r r r �register_preprocessor s z$UOWTransaction.register_preprocessorFNc C s� | j �|�s8|js4|d ur4t�dt�|�||f � dS || jvr~|jj }|| j vr^| � |� | j | � |� ||f| j|< n|s�|s�|r�|df| j|< dS )NzJObject of type %s not in session, %s operation along '%s' will not proceedFT) r r Zdeletedr �warn�orm_utilZstate_class_strr8 r r r4 �_per_mapper_flush_actions�add)r: r rI �listonlyZ cancel_deleteZ operationr r r r r �register_object s" �� z UOWTransaction.register_objectc C s0 |j jj}| j| \}}|�|� |�|� d S r/ )r r � base_mapperr9 rW �update)r: r Zpost_update_colsr r8 �colsr r r �register_post_update- s z#UOWTransaction.register_post_updatec C sf t | |j�}t| |j�}| j�||f� |jD ]}|�| � q.|jD ] }|jrPqD|j }|�| � qDd S r/ ) � SaveUpdateAllrZ � DeleteAllr7 rW Z_dependency_processorsZper_property_preprocessorsZ relationshipsZviewonlyZ_dependency_processor)r: r ZsavesZdeletes�depr r r r rV 3 s z(UOWTransaction._per_mapper_flush_actionsc C s t �dd� �S )a return a dynamic mapping of (Mapper, DependencyProcessor) to True or False, indicating if the DependencyProcessor operates on objects of that Mapper. The result is stored in the dictionary persistently once calculated. c S s | d j �| d j�| d ju S )NrD r )r �getr r )�tupr r r r0 L r1 z0UOWTransaction._mapper_for_dep.<locals>.<lambda>)r Z PopulateDictr= r r r �_mapper_for_depA s �z UOWTransaction._mapper_for_depc s | j �� �fdd�|D �S )zmFilter the given list of InstanceStates to those relevant to the given DependencyProcessor. c s g | ]}�|j j� f r|�qS r )r r ��.0�s�r` Zmapper_for_depr r � <listcomp>U r1 z8UOWTransaction.filter_states_for_dep.<locals>.<listcomp>)rc )r: r` r8 r rg r �filter_states_for_depO s z$UOWTransaction.filter_states_for_depc c s> ||f}|j jD ](}| j| D ]}| j| |kr |V q qd S r/ )rZ �self_and_descendantsr4 r8 )r: r rI rX Zchecktupr r r r �states_for_mapper_hierarchyW s z*UOWTransaction.states_for_mapper_hierarchyc sJ d}t � j�� �D ]}|�� �rd}q|s q.q t�� jt � j�� �� � _}|�r,t � fdd�|D ��}t � j�D ]�}d|v s�|d j s�|d j s�|� |�r�� j� |� qr|d |v r� j� |� ||d D ]}� j� ||d f� q�qr|d |v rr� j� |� ||d D ]}� j� |d |f� �qqrtdd � � j�� D ���|�S ) z}Generate the full, unsorted collection of PostSortRecs as well as dependency pairs for this UOWTransaction. FTc 3 s | ]}|t |�� ��fV qd S r/ )r+ �per_state_flush_actions)re �recr= r r � <genexpr>v s z3UOWTransaction._generate_actions.<locals>.<genexpr>NrD r c S s g | ]}|j s|�qS r ��disabled)re �ar r r rh � r1 z4UOWTransaction._generate_actions.<locals>.<listcomp>)�listr5 �values�executer Z find_cyclesr7 r6 �cyclesrM rp � issupersetr' rW r+ � difference)r: rG �actionru �convert�edger` r r= r �_generate_actions^ sH � ����� ��z UOWTransaction._generate_actionsc C s` | � � }| jr>t�| j|�D ] }|r |�� }|�| |� q q n t�| j|�D ]}|�| � qLd S r/ ) r{ ru r Zsort_as_subsetsr7 �pop�execute_aggregate�sortrt )r: r6 r( �nrm r r r rt � s �zUOWTransaction.executec C sZ | j s dS t| j �}tdd� | j �� D ��}|�|�}|rF| j�|� |rV| j�|� dS )z�Mark processed objects as clean / deleted after a successful flush(). This method is called within the flush() method after the execute() method has succeeded and the transaction has been committed. Nc s s | ]\}\}}|r|V qd S r/ r )re rf rI rX r r r rn � s z8UOWTransaction.finalize_flush_changes.<locals>.<genexpr>)r8 r+ �itemsrw r rA Z_register_persistent)r: r8 Zisdel�otherr r r �finalize_flush_changes� s � z%UOWTransaction.finalize_flush_changes)FFFNN)�__name__� __module__� __qualname__r; �propertyr> rC rF rH rJ r ZPASSIVE_NO_INITIALIZErN rP rS rY r] rV r Zmemoized_propertyrc ri rk r{ rt r� r r r r r. � s4 - � / � " 4r. c @ s e Zd Zdd� ZdS )�IterateMappersMixinc s2 � j r$t� �fdd�� jjjD ��S � jjjS d S )Nc 3 s" | ]}�j |� jf r|V qd S r/ )rc �dependency_processor)re �m�r: �uowr r rn � s �z/IterateMappersMixin._mappers.<locals>.<genexpr>)rR �iterr� �parentrj r r� r r� r �_mappers� s �z IterateMappersMixin._mappersN)r� r� r� r� r r r r r� � s r� c @ s e Zd ZdZdd� Zdd� ZdS )rQ )r� rR � processed�setup_flush_actionsc C s || _ || _t� | _d| _d S �NF)r� rR r+ r� r� )r: r� rR r r r r; � s zPreprocess.__init__c C s� t � }t � }| �|�D ]H}|j| �| j�D ]0}|j| \}}|s,|rR|�|� q,|�|� q,q|r~| j�||� | j� |� |r�| j� ||� | j� |� |s�|r�| j s�| j� ||d�s�| j� ||d�r�| j� |� d| _ dS dS d S �NTF)r+ r� r4 rw r� r8 rW r� Zpresort_deletesr[ Z presort_savesr� Zprop_has_changesZper_property_flush_actions)r: r� Z delete_statesZ save_statesr r rI rX r r r rt � s: ���� zPreprocess.executeN�r� r� r� � __slots__r; rt r r r r rQ � s rQ c @ s e Zd ZdZdd� Zdd� ZdS )� PostSortRecro c G s@ | f| }||j v r |j | S t�| � |j |< }d|_|S d S r� )r6 �object�__new__rp )�clsr� �argsr rG r r r r� � s zPostSortRec.__new__c C s | � |� d S r/ )rt )r: r� �recsr r r r} s z PostSortRec.execute_aggregateN)r� r� r� r� r� r} r r r r r� � s r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � ProcessAll)r� rI rR c C s* || _ || _|| _|j|jj �|� d S r/ )r� rI rR r3 r� rZ rW )r: r� r� rI rR r r r r; s �zProcessAll.__init__c C s2 | � |�}| jr | j�||� n| j�||� d S r/ )� _elementsrI r� �process_deletes� process_saves)r: r� r8 r r r rt s zProcessAll.executec C s t g �S r/ )r� r� r r r rl s z"ProcessAll.per_state_flush_actionsc C s d| j j| j| jf S )Nz%s(%s, isdelete=%s))� __class__r� r� rI r= r r r �__repr__% s �zProcessAll.__repr__c c sF | � |�D ]6}|j| D ]&}|j| \}}|| jkr|s|V qq d S r/ )r� r4 r8 rI )r: r� r r rI rX r r r r� , s zProcessAll._elementsN) r� r� r� r� r; rt rl r� r� r r r r r� s r� c @ s e Zd ZdZdd� Zdd� ZdS )� PostUpdateAll�r rI c C s || _ || _d S r/ r� )r: r� r rI r r r r; 7 s zPostUpdateAll.__init__c s: �j � j \}}� �fdd�|D �}t�� j|�|� d S )Nc s$ g | ] }�j | d � jkr|�qS �rD )r8 rI rd r� r r rh = r1 z)PostUpdateAll.execute.<locals>.<listcomp>)r9 r r Z post_update)r: r� r8 r\ r r� r rt ; s zPostUpdateAll.executeNr� r r r r r� 4 s r� c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) r^ �r c C s || _ ||ju sJ �d S r/ �r rZ �r: r� r r r r r; E s zSaveUpdateAll.__init__c C s t �| j|�| jdd�|� d S r� )r �save_objr rk r� r r r rt I s �zSaveUpdateAll.executec c s� t |�| jdd��}| jj}t||�}|D ]$}t||�}|j�||f� |V q*|j| j D ] }|� ||�}|� ||d� q\d S r� ) rr rk r rZ r_ �SaveUpdateStater7 rW r3 ri rl ) r: r� r8 rZ Z delete_allr rx r` �states_for_propr r r rl P s � z%SaveUpdateAll.per_state_flush_actionsc C s d| j j| jf S �Nz%s(%s)�r� r� r r= r r r r� a s zSaveUpdateAll.__repr__N�r� r� r� r� r; rt rl r� r r r r r^ B s r^ c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) r_ r� c C s || _ ||ju sJ �d S r/ r� r� r r r r; h s zDeleteAll.__init__c C s t �| j|�| jdd�|� d S r� )r � delete_objr rk r� r r r rt l s �zDeleteAll.executec c s� t |�| jdd��}| jj}t||�}|D ]$}t||�}|j�||f� |V q*|j| j D ] }|� ||�}|� ||d� q\d S r� ) rr rk r rZ r^ � DeleteStater7 rW r3 ri rl ) r: r� r8 rZ Zsave_allr rx r` r� r r r rl s s � z!DeleteAll.per_state_flush_actionsc C s d| j j| jf S r� r� r= r r r r� � s zDeleteAll.__repr__Nr� r r r r r_ e s r_ c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � ProcessState�r� rI r c C s || _ || _|| _d S r/ r� )r: r� r� rI r r r r r; � s zProcessState.__init__c sj | j � | j�| j�� ��fdd�|D �}|�|� | jgdd� |D � }�rZ��||� n ��||� d S )Nc s. g | ]&}|j � u r|j�u r|j�u r|�qS r )r� r� rI �re �r��cls_r� rI r r rh � s �z2ProcessState.execute_aggregate.<locals>.<listcomp>c S s g | ] }|j �qS r �r r� r r r rh � r1 )r� r� rI �difference_updater r� r� �r: r� r� �our_recsr8 r r� r r} � s � z ProcessState.execute_aggregatec C s d| j j| jt�| j�| jf S )Nz%s(%s, %s, delete=%s))r� r� r� rU � state_strr rI r= r r r r� � s �zProcessState.__repr__N�r� r� r� r� r; r} r� r r r r r� � s r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r� �r r c C s || _ |jj| _d S r/ �r r rZ �r: r� r r r r r; � s zSaveUpdateState.__init__c sN | j � | j�� �fdd�|D �}|�|� t��| jgdd� |D � |� d S )Nc s$ g | ] }|j � u r|j�u r|�qS r �r� r r� �r� r r r rh � s z5SaveUpdateState.execute_aggregate.<locals>.<listcomp>c S s g | ] }|j �qS r r� r� r r r rh � r1 )r� r r� r r� r )r: r� r� r� r r� r r} � s � �z!SaveUpdateState.execute_aggregatec C s d| j jt�| j�f S r� �r� r� rU r� r r= r r r r� � s �zSaveUpdateState.__repr__Nr� r r r r r� � s r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r� r� c C s || _ |jj| _d S r/ r� r� r r r r; � s zDeleteState.__init__c s` | j � | j�� �fdd�|D �}|�|� | jgdd� |D � }t���fdd�|D ��� d S )Nc s$ g | ] }|j � u r|j�u r|�qS r r� r� r� r r rh � s z1DeleteState.execute_aggregate.<locals>.<listcomp>c S s g | ] }|j �qS r r� r� r r r rh � r1 c s g | ]}� j | d r|�qS r� rE rd )r� r r rh � r1 )r� r r� r r r� r� r )r� r r� r r} � s � �z DeleteState.execute_aggregatec C s d| j jt�| j�f S r� r� r= r r r r� � s �zDeleteState.__repr__Nr� r r r r r� � s r� N)�__doc__� r r r@ r r rU r r r- r� r. r� rQ r� r� r� r^ r_ r� r� r� r r r r �<module> s* i > 2(###
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка