Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
sqlalchemy
/
orm
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: unitofwork.cpython-310.pyc
o [�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 rd S | j }|r5|jr|�d� | jjj� }t�|�}|jj r5|j s+� |j kr5|� |�s5|� |� |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�prop� item_state�r � �D/usr/local/lib/python3.10/dist-packages/sqlalchemy/orm/unitofwork.py�append s" �� � z$track_cascade_events.<locals>.appendc s� |d u rd S | j }| jjj� }|r |jr |�|jr dnd� |d urO|tjurQ|tj urS|j j rUt� |�}|j� |�rW|rJ||jv rJ|�|� d S d|_d S d S d S d S d S d S )Nzcollection removezrelated attribute deleteT)r r r r r r �uselistr � NEVER_SET�PASSIVE_NO_RESULTr � delete_orphanr � _is_orphan�_new�expunge� _orphaned_outside_of_sessionr r r r �remove6 s0 �� � �z$track_cascade_events.<locals>.removec s� ||u r|S | j }|r`|jr|�d� | jjj� }|d ur9t�|�}|jj r9|j s/� |j kr9|� |�s9|� |� |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 �newvalue�oldvaluer r r �newvalue_state�oldvalue_stater r r �set_X s8 �� � � � z"track_cascade_events.<locals>.set_r! T)�raw�retvalr* �setN)r r �listen)� descriptorr r! r* r/ r r r �track_cascade_events s "%r5 c @ s� e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z e j fd d�Z dd� Z dd� Z d'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)r2 r r r r �<lambda>� s z)UOWTransaction.__init__.<locals>.<lambda>) r r r � defaultdictr2 �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 r7 )�boolr? �rA r r r �has_work� s zUOWTransaction.has_workc C sD |j r z |�|tj� W dS tjy | j�|g� Y dS w dS )zVreturn true if the given state is expired and was deleted previously. TF)�expired� _load_expiredr � PASSIVE_OFF�orm_exc�ObjectDeletedErrorr �_remove_newly_deleted�rA r r r r �was_already_deleted� s ��z"UOWTransaction.was_already_deletedc C s || j v o | j | d S )zWreturn true if the given state is marked as deleted within this uowtransaction.� �r? rL r r r � is_deleted� s zUOWTransaction.is_deletedc C s( || j v r | j | S |� | j |< }|S r7 r )rA r � 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.rN TNrO )rA r �isdeleter r r �remove_state_actions� s z#UOWTransaction.remove_state_actionsc C s� d||f}|| j v rD| j | \}}}|t j@ sB|t j@ rB|j| j}|�||jt jt jB �}|r8|jr8|� � }n|}|||f| j |< |S |j| j}|�||j|t jB �}|r_|jr_|� � }n|}|||f| j |< |S )zOfacade to attributes.get_state_history(), including caching of results.�history) r �SQL_OKr �impl� get_history�dictrH �LOAD_AGAINST_COMMITTED� uses_objects�as_state) rA r r �passive�hashkeyrV � state_history�cached_passiverX r r r �get_attribute_history� s6 �� � �� z$UOWTransaction.get_attribute_historyc C s |df| j v S )NT)r< )rA � processorr r r �has_dep � zUOWTransaction.has_depc C s* ||f}|| j vrt||�| j |< d S d S r7 )r< � Preprocess)rA rc � fromparentr r r r �register_preprocessor s �z$UOWTransaction.register_preprocessorFNc C s� | j �|�s |js|d urt�dt�|�||f � dS || jvr@|jj }|| j vr/| � |� | j | � |� ||f| j|< dS |sM|sF|rM|df| j|< dS )NzJObject of type %s not in session, %s operation along '%s' will not proceedFT) r r �deletedr �warn�orm_util�state_class_strr? r r r; �_per_mapper_flush_actions�add)rA r rT �listonly� cancel_delete� operationr r r r r �register_object s$ �� �z UOWTransaction.register_objectc C s0 |j jj}| j| \}}|�|� |�|� d S r7 )r r � base_mapperr@ rn �update)rA r �post_update_colsr r? �colsr r r �register_post_update- s z#UOWTransaction.register_post_updatec C sf t | |j�}t| |j�}| j�||f� |jD ]}|�| � q|jD ]}|jr(q"|j }|�| � q"d S r7 ) � SaveUpdateAllrs � DeleteAllr> rn �_dependency_processors�per_property_preprocessors� relationships�viewonly�_dependency_processor)rA r �saves�deletes�depr r r r rm 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 )NrN r )r �getr r )�tupr r r r8 L � z0UOWTransaction._mapper_for_dep.<locals>.<lambda>)r � PopulateDictrD 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� �mapper_for_depr r � <listcomp>U r� z8UOWTransaction.filter_states_for_dep.<locals>.<listcomp>)r� )rA r� r? r r� r �filter_states_for_depO s z$UOWTransaction.filter_states_for_depc c s@ � ||f}|j jD ]}| j| D ] }| j| |kr |V qq d S r7 )rs �self_and_descendantsr; r? )rA r rT ro �checktupr r r r �states_for_mapper_hierarchyW s � ���z*UOWTransaction.states_for_mapper_hierarchyc sH d}t � j�� �D ] }|�� �rd}q |snqt�� jt � j�� �� � _}|r�t � fdd�|D ��}t � j�D ][}d|v sN|d j sN|d j sN|� |�rU� j� |� q9|d |v ru� j� |� ||d D ] }� j� ||d f� qgq9|d |v r�� j� |� ||d D ] }� j� |d |f� q�q9tdd � � j�� D ���|�S ) z}Generate the full, unsorted collection of PostSortRecs as well as dependency pairs for this UOWTransaction. TFc 3 s" � | ] }|t |�� ��fV qd S r7 )r2 �per_state_flush_actions)r� �recrD r r � <genexpr>v s � �z3UOWTransaction._generate_actions.<locals>.<genexpr>NrN r c S s g | ]}|j s|�qS r ��disabled)r� �ar r r r� � s z4UOWTransaction._generate_actions.<locals>.<listcomp>)�listr< �values�executer � find_cyclesr> r= �cyclesrZ r� � issupersetr* rn r2 � difference)rA rR �actionr� �convert�edger� r rD r �_generate_actions^ sP �� � ���� � ���z UOWTransaction._generate_actionsc C sd | � � }| jr!t�| j|�D ]}|r |�� }|�| |� |sqd S t�| j|�D ]}|�| � q(d S r7 ) r� r� r �sort_as_subsetsr> �pop�execute_aggregate�sortr� )rA r= r/ �nr� r r r r� � s � ��� �zUOWTransaction.executec C s^ | j sdS t| j �}tdd� | j �� D ��}|�|�}|r#| j�|� |r-| j�|� dS 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 r7 r )r� r� rT ro r r r r� � s � � �z8UOWTransaction.finalize_flush_changes.<locals>.<genexpr>)r? r2 �itemsr� r rK �_register_persistent)rA r? �isdel�otherr r r �finalize_flush_changes� s � �z%UOWTransaction.finalize_flush_changes)FFFNN)�__name__� __module__� __qualname__rB �propertyrE rM rP rS rU r �PASSIVE_NO_INITIALIZErb rd rh rr rw rm r �memoized_propertyr� r� r� r� r� r� r r r r r6 � s6 - �/ �" 4 r6 c @ s e Zd Zdd� ZdS )�IterateMappersMixinc s. � j rt� �fdd�� jjjD ��S � jjjS )Nc 3 s$ � | ] }�j |� jf r|V qd S r7 )r� �dependency_processor)r� �m�rA �uowr r r� � s � � �z/IterateMappersMixin._mappers.<locals>.<genexpr>)rg �iterr� �parentr� r r� r r� r �_mappers� s � z IterateMappersMixin._mappersN)r� r� r� r� r r r r r� � s r� c @ � e Zd ZdZdd� Zdd� ZdS )rf )r� rg � processed�setup_flush_actionsc C s || _ || _t� | _d| _d S �NF)r� rg r2 r� r� )rA r� rg r r r rB � s zPreprocess.__init__c C s� t � }t � }| �|�D ]$}|j| �| j�D ]}|j| \}}|s.|r)|�|� q|�|� qq |r?| j�||� | j� |� |rN| j� ||� | j� |� |sR|rp| j sn| j� ||d�se| j� ||d�rn| j� |� d| _ dS dS �NTF)r2 r� r; r� r� r? rn r� �presort_deletesrt � presort_savesr� �prop_has_changes�per_property_flush_actions)rA r� � delete_states� save_statesr r rT ro r r r r� � s> �� ���� zPreprocess.executeN�r� r� r� � __slots__rB r� r r r r rf � s rf c @ r� )� PostSortRecr� c G s< | f| }||j v r|j | S t�| � |j |< }d|_|S r� )r= �object�__new__r� )�clsr� �argsr rR r r r r� � s zPostSortRec.__new__c C s | � |� d S r7 )r� )rA r� �recsr r r r� re 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� rT rg c C s* || _ || _|| _|j|jj �|� d S r7 )r� rT rg r: r� rs rn )rA r� r� rT rg r r r rB s �zProcessAll.__init__c C s4 | � |�}| jr| j�||� d S | j�||� d S r7 )� _elementsrT r� �process_deletes� process_saves)rA r� r? r r r r� s zProcessAll.executec C s t g �S r7 )r� r� r r r r� s z"ProcessAll.per_state_flush_actionsc C s d| j j| j| jf S )Nz%s(%s, isdelete=%s))� __class__r� r� rT rD r r r �__repr__% s �zProcessAll.__repr__c c sH � | � |�D ]}|j| D ]}|j| \}}|| jkr |s |V q qd S r7 )r� r; r? rT )rA r� r r rT ro r r r r� , s ����zProcessAll._elementsN) r� r� r� r� rB r� r� r� r� r r r r r� s r� c @ r� )� PostUpdateAll�r rT c C s || _ || _d S r7 r� )rA r� r rT r r r rB 7 s zPostUpdateAll.__init__c s: �j � j \}}� �fdd�|D �}t�� j|�|� d S )Nc s$ g | ]}�j | d � jkr|�qS �rN )r? rT r� r� r r r� = s $ z)PostUpdateAll.execute.<locals>.<listcomp>)r@ r r � post_update)rA r� r? rv r r� r r� ; s zPostUpdateAll.executeNr� r r r r r� 4 s r� c @ �0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) rx �r c C � || _ ||ju s J �d S r7 �r rs �rA r� r r r r rB E � zSaveUpdateAll.__init__c C s t �| j|�| jdd�|� d S r� )r �save_objr r� r� r r r r� I � �zSaveUpdateAll.executec c s� � t |�| jdd��}| jj}t||�}|D ]}t||�}|j�||f� |V q|j| j D ]}|� ||�}|� ||d� q/d S r� ) r� r� r rs ry �SaveUpdateStater> rn r: r� r� ) rA r� r? rs � delete_allr r� r� �states_for_propr r r r� P � �� �z%SaveUpdateAll.per_state_flush_actionsc C � d| j j| jf S �Nz%s(%s)�r� r� r rD r r r r� a � zSaveUpdateAll.__repr__N�r� r� r� r� rB r� r� r� r r r r rx B � rx c @ r� ) ry r� c C r� r7 r� r� r r r rB h r� zDeleteAll.__init__c C s t �| j|�| jdd�|� d S r� )r � delete_objr r� r� r r r r� l r� zDeleteAll.executec c s� � t |�| jdd��}| jj}t||�}|D ]}t||�}|j�||f� |V q|j| j D ]}|� ||�}|� ||d� q/d S r� ) r� r� r rs rx � DeleteStater> rn r: r� r� ) rA r� r? rs �save_allr r� r� r� r r r r� s r� z!DeleteAll.per_state_flush_actionsc C r� r� r� rD r r r r� � r� zDeleteAll.__repr__Nr� r r r r ry e r� ry c @ �( e Zd ZdZdd� Zdd� Zdd� ZdS ) � ProcessState�r� rT r c C s || _ || _|| _d S r7 r� )rA r� r� rT r r r r rB � s zProcessState.__init__c sl | j � | j�| j�� ��fdd�|D �}|�|� | jgdd� |D � }�r.��||� d S ��||� d S )Nc s. g | ]}|j � u r|j�u r|j�u r|�qS r )r� r� rT �r� �r��cls_r� rT r r r� � s �z2ProcessState.execute_aggregate.<locals>.<listcomp>c S � g | ]}|j �qS r �r r� r r r r� � � )r� r� rT �difference_updater r� r� �rA r� r� �our_recsr? 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� rk � state_strr rT rD r r r r� � s �zProcessState.__repr__N�r� r� r� r� rB r� r� r r r r r� � s r� c @ r� ) r� �r r c C � || _ |jj| _d S r7 �r r rs �rA r� r r r r rB � � zSaveUpdateState.__init__c sN | j � | j�� �fdd�|D �}|�|� t��| jgdd� |D � |� d S )Nc �$ g | ]}|j � u r|j�u r|�qS r �r� r r� �r� r r r r� � � z5SaveUpdateState.execute_aggregate.<locals>.<listcomp>c S r� r r� r� r r r r� � r� )r� r r� r r� r )rA r� r� r� r r r r� � s � �z!SaveUpdateState.execute_aggregatec C � d| j jt�| j�f S r� �r� r� rk r� r rD r r r r� � � �zSaveUpdateState.__repr__Nr� r r r r r� � s r� c @ r� ) r� r� c C r� r7 r� r� r r r rB � r� zDeleteState.__init__c s` | j � | j�� �fdd�|D �}|�|� | jgdd� |D � }t���fdd�|D ��� d S )Nc r r r r� r r r r� � r z1DeleteState.execute_aggregate.<locals>.<listcomp>c S r� r r� r� r r r r� � r� c s g | ] }� j | d r|�qS r� rO r� )r� r r r� � s )r� r r� r r r� r� r )r� r r� r r� � s � �z DeleteState.execute_aggregatec C r r� r rD r r r r� � r zDeleteState.__repr__Nr� r r r r r� � s r� N)�__doc__� r r rI r r rk r r r5 r� r6 r� rf r� r� r� rx ry r� r� r� r r r r �<module> s, i > 2(###
Save
Cancel