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: dependency.cpython-310.pyc
o [�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 | _ | jr;t j | _nt j | _|j| _| j jsOt�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 �D/usr/local/lib/python3.10/dist-packages/sqlalchemy/orm/dependency.py�__init__ s0 ���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 � 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|_n t�|| dd�}d|_||jvr@||jvs5J �|df|dfg} d} nd} |sXt�|| jj �} d } }| |jv rWd} nt�|| jj �} d } }| |jv rkd} |D ]�}|j | j j � ||j|r~| jntj�}|s�qm|r�t�|| d|�}| r�t�||�} nt�|| d|�}| r�t�||�} | r�g } |D ]+\}}||jvr�d}n|j| \}}|r�t�||�df}nt�||�df}| �|� q�| D ]\}}| �|| | |||||� q�qmdS )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 r3 r r2 r4 r1 �disabled�cyclesr � base_mapper�managerr �impl�get_all_pending�dictr r r � ProcessState� DeleteState�SaveUpdateState�states�append�per_state_dependencies)r r. rG �isdelete�child_base_mapperr9 r; r7 r6 � child_actions�child_in_cyclesr8 r: �parent_in_cyclesr+ �sum_� child_state�child� child_action�deleted�listonly� childisdeleter r r! �per_state_flush_actionsg s� � � �� � � � ���z+DependencyProcessor.per_state_flush_actionsc C � dS �NFr �r � uowcommitrG r r r! �presort_deletes� � z#DependencyProcessor.presort_deletesc C rW rX r rY r r r! � presort_saves� r\ z!DependencyProcessor.presort_savesc C � d S r# r rY r r r! �process_deletes� r\ z#DependencyProcessor.process_deletesc C r^ r# r rY r r r! � process_saves� r\ z!DependencyProcessor.process_savesc C sp |r| j r tj}n | jtu rtj}ntj}|D ]}|�|| j|�}|r*|� � s* dS q|o7| j j o7| j |j v S )NT)r r r r r �PASSIVE_NO_FETCH_RELATEDr �get_attribute_historyr �emptyr �_is_self_referentialr �mappers)r rZ rG rJ �passive�s�historyr r r! �prop_has_changes� s �� �z$DependencyProcessor.prop_has_changesc C s� | j jr|d u rt�d| j f ��|d urG| jj|| j d�sI| jj|dd�r8t�d|j| j | jj| jd� ��t�d|j| j | jjd� ��d S d S )Nz-Can't flush None value found in collection %s)�allow_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�z�zmz�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.)rk rl rm )r �uselistr � FlushErrorr �_canloadr �class_r* r r r! �_verify_canload� s8 ��� �������z#DependencyProcessor._verify_canloadc C � t � �r# ��NotImplementedError)r r+ rQ �associationrow� clearkeysrZ r r r! � _synchronize" � z DependencyProcessor._synchronizec C s> | j jsd S tt| jgdd� | j jD � ��}|�d|ft�S )Nc S s g | ]}|j �qS r )r )�.0�pr r r! � <listcomp>* s zCDependencyProcessor._get_reversed_processed_set.<locals>.<listcomp>� reverse_key)r �_reverse_property�tuple�sortedr �memo�set)r r. � process_keyr r r! �_get_reversed_processed_set% s �z/DependencyProcessor._get_reversed_processed_setFc C s: |D ]}|r |d ur|� |dd� | jjD �� d S qd S )Nc S s g | ]\}}|�qS r r )r{ �l�rr r r! r} 2 s z4DependencyProcessor._post_update.<locals>.<listcomp>)�register_post_updater r )r r+ rZ �related� is_m2o_deleterk r r r! � _post_update. s ���z DependencyProcessor._post_updatec C rt r# ru �r rZ r+ r r r! � _pks_changed6 rz 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)r� � __module__� __qualname__r" � classmethodr& r) r/ r< rV r[ r] r_ r` ri rs ry r� r� r� r� 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� d S |j�||f||f||f||f||f||f||fg� d S r0 �r r � PostUpdateAllr r3 � dependencies�update) r r. r8 r9 r: r; r6 r7 �child_post_updates�child_pre_updatesr r r! r5 > s4 � ��� ��z%OneToManyDP.per_property_dependenciesc C s� | j rVt�|| jjd�} t�|| jjd�} |s8|r'|j�||f|| fg� d S |j�||f||f|| fg� d S |rH|j�|| f| |fg� d S |j�|| f| |fg� d S |si|j�||f||f||fg� d S |j�||f||fg� d S r0 r� ) r r. � save_parent� delete_parentrR r6 r7 rJ rU r� r� r r r! rI g sR � ������������z"OneToManyDP.per_state_dependenciesc C s� | j j o | jdk }|D ]D}|�|| j| j�}|rQ|jD ] }|d ur;| �|�du r;| j jr6|j |dd� q |� |� q |rQ|j D ]}|d urP|j |d| j d� qAq d S )N�allFT�rJ �delete�� operationr ) r r� r rb r r rS r) � delete_orphan�register_object� unchangedr �r rZ rG �should_null_fksr+ rh rQ r r r! r[ � s* � � � ���zOneToManyDP.presort_deletesc C sN |� d| ft�}| jj o| jdk }|D ]�}| �||�}|r"| jr&tj}ntj }|� || j |�}|r�|j D ]} | d urF|j | dd| jd� q6|�|j � |jD ]9} | jjsc|rb|j | dd| jd� qP| �| �du r�|j | dd| jd� | j�d| �D ] \} } } } |j | dd � q{qP|r�|r�|jD ]} | d ur�|j | d| jd | jd � q�qd S ) N�children_addedr� T�add)� cancel_deleter� r Fr� �rJ r� r r� z pk changer� )r� r� r r� r r� r r r r rb r �addedr� r r� rS r) r �cascade_iteratorr� )r rZ rG r� r� r+ � pks_changedrf rh rQ �c�m�st_�dct_r r r! r] � sp � �� ����� ���zOneToManyDP.presort_savesc C s� | j s| jdksu|�d| ft�}|D ]d}|�|| j| j�}|rt|jD ]$}|d urF| �|�du rF| � ||d d|d� | j rF|rF| � |||g� q"| j sN| j j stt|j ��|�D ] }|d urs| � ||d d|d� | j rs|rs| � |||g� qVqd S d S )Nr� r� FT)r r r� r� rb r r rS r) ry r� r r� r� � difference)r rZ rG r� r+ rh rQ r r r! r_ s> � � � � � ���zOneToManyDP.process_deletesc C s� | j j o | jdk }|D ]]}|�|| jtj�}|rj|jD ]}| �||d d|d� |d ur8| j r8| � |||g� q |j D ]}|rS| j jsS| � |�sS| �||d d|d� q<| � ||�rj|jD ] }| �||d d|d� q]q d S )Nr� FT)r r� r rb r r r r� ry r r� rS r) r� r� r� r r r! r` / sB � � �� ��� �� ���zOneToManyDP.process_savesc C sr |}|}| � |� |d u s| js|�|�rd S |r%t�|| j| jj� d S t�|| j || j| jj|| j o5|� d S r# ) rs r � is_deletedr �clearr r r �populater r ) r r+ rQ rw rx rZ r� �source�destr r r! ry Q s( ���zOneToManyDP._synchronizec C � t �||| j| jj�S r# �r �source_modifiedr r r r� r r r! r� h � �zOneToManyDP._pks_changedN) r� r� r� r5 rI r[ r] r_ r` ry r� r r r r! r� = s )C>," r� c @ sP e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z ddd�Z dS )� ManyToOneDPc C s. t �| |� | jjD ] }|j�t|�� q d S r# )r r" r �self_and_descendants�_dependency_processorsrH �DetectKeySwitch)r r r r r r! r" o s �zManyToOneDP.__init__c C s� | j r2t�|| jjd�}t�|| jjd�} |j�||f||f||f|| f|| f| |f| |fg� d S |j�||f||f||f||fg� d S r0 �r r r� r r3 r� r� ) r r. r8 r9 r: r; r6 r7 �parent_post_updates�parent_pre_updatesr r r! r5 t s0 � ��� ��z%ManyToOneDP.per_property_dependenciesc C s� | j rI|s/t�|| jjd�} |r |j�|| f| |fg� d S |j�||f||f|| fg� d S t�|| jjd�} |j�|| f| |f| |fg� d S |sf|s[|j�||f||fg� d S |j�||fg� d S |rs|j�||fg� d S d S r0 r� ) r r. r� r� rR r6 r7 rJ rU r� r� r r r! rI � sF ����� �����z"ManyToOneDP.per_state_dependenciesc C s� | j js| j jrP|D ]G}|�|| j| j�}|rO| j jr |�� }n|�� }|D ](}|d u r-q&|j|dd| j d� | j � d|�}|D ] \}} } } |j| dd� q@q&q d S d S )NTr� r� r� ) r r� r� rb r r �sum� non_deletedr� r r r� ) r rZ rG r+ rh �todeleterQ �tr� r� r� r� r r r! r[ � s2 � ����zManyToOneDP.presort_deletesc C s� |D ]H}|j |d| jd� | jjrJ|�|| j| j�}|rJ|jD ]*}| �|�du rI|j |dd| jd� | j � d|�}|D ] \}}} } |j | dd� q;q qd S )Nr� r� FTr� r� r� ) r� r r r� rb r r rS r) r r� ) r rZ rG r+ rh rQ r� r� r� r� r� r r r! r] � s( � ���zManyToOneDP.presort_savesc C sz | j r5| jjs7| jdks9|D ],}| �|d d d|� |r4| j r4|�|| j| j�}|r4| j|||� � dd� qd S d S d S d S )Nr� T)r� ) r r r� r ry rb r r r� r� )r rZ rG r+ rh r r r! r_ s& �� � ���zManyToOneDP.process_deletesc C s~ |D ]:}|� || jtj�}|r<|jr#|jD ] }| �||d d|d� qn |jr0| �|d d d|d� | jr<| �|||� � � qd S )NFr� Tr� ) rb r r r r� ry rS r r� r� )r rZ rG r+ rh rQ r r r! r` s& � �� ���zManyToOneDP.process_savesNc C s� |d u s | j s|�|�rd S |d ur,|d ur,|j�|�s,t�dt�|�|| jf � d S |s2|d u r>t � || j | jj � d S | � |� 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 rs r� r �r r+ rQ rw rx rZ r� r r r! ry * s8 �� ��� �zManyToOneDP._synchronizer# ) r� r� r� r" r5 rI r[ r] r_ r` ry 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| jr d S ddd� | j jD �v rd S |�| d� d S )NFc s s � | ]}|j V qd S r# )r )r{ r r r r! � <genexpr>d s � � �z=DetectKeySwitch.per_property_preprocessors.<locals>.<genexpr>)r r r r, r- r r r! r/ _ s �z*DetectKeySwitch.per_property_preprocessorsc C s6 t �|| jj�}t �|| dd�}|j�||fg� d S rX )r r2 r r? r1 r� r� )r r. r8 r6 r r r! r< l s z*DetectKeySwitch.per_property_flush_actionsc C r^ r# r )r r. rG rJ r r r! rV q r\ z'DetectKeySwitch.per_state_flush_actionsc C r^ r# r rY r r r! r[ t r\ z DetectKeySwitch.presort_deletesc C s | j s | �||� d S d S r# �r �_process_key_switches)r r. rG r r r! r] w s �z DetectKeySwitch.presort_savesc C s" |s| j r| �||�}t|�S dS rX )r �_key_switchers�bool)r r. rG rJ �dr r r! ri } s z DetectKeySwitch.prop_has_changesc C s J �r# r rY r r r! r_ � r\ z DetectKeySwitch.process_deletesc C s | j sJ �| �||� d S r# r� rY r r r! r` � s z DetectKeySwitch.process_savesc C sZ |� d| fdd� �\}}|�|�}|D ]}||vr*| �||�r%|�|� q|�|� q|S )N� pk_switchersc S s t � t � fS r# )r� r r r r! �<lambda>� s z0DetectKeySwitch._key_switchers.<locals>.<lambda>)r� �unionr� r� )r r. rG �switched� notswitched� allstatesrg r r r! r� � s � �z DetectKeySwitch._key_switchersc C s� | � ||�}|rb|jj�� D ]U}t|j| jj�sq|j}|�| j �j ||| j d�}|t j ura|d ura| jjr>|s9q|d }n|}t �|�}||v ra|�|d| j� t�|| j|| j| jj|| j� qd S d S )N)rf � F)r� r� � identity_map� all_states� issubclassrr r rC r( r �getr r �PASSIVE_NO_RESULTr ro �instance_stater� r r r� r r ) r �deplistrZ � switchersr+ �dict_r� � related_obj� related_stater r r! r� � sB � ����z%DetectKeySwitch._process_key_switchesc C s t |j�ot�||| j| jj�S r# )r� r r r� r r r r� r r r! r� � s �z DetectKeySwitch._pks_changedN)r� r� r� �__doc__r/ r< rV r[ r] ri r_ r` r� r� r� 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. r8 r9 r: r; r6 r7 r r r! r5 � s ��z&ManyToManyDP.per_property_dependenciesc C s\ |s |r|j �||f||fg� d S |j �||f||fg� d S |j �||f||fg� d S r# r� ) r r. r� r� rR r6 r7 rJ rU r r r! rI � s ���z#ManyToManyDP.per_state_dependenciesc C s* | j s|D ] }|�|| j| j� qd S d S r# )r rb r r )r rZ rG r+ r r r! r[ � s ��z ManyToManyDP.presort_deletesc C s� | j s|D ]}| �||�r|�|| jtj�}q| jjs d S |D ]9}|�|| jtj�}|rX|j D ](}| � |�du rW|j |dd| j d� | j �d|�D ] \}}}} |j |dd� qIq/q d S )NFTr� r� r� )r r� rb r r r r r� r rS r) r� r r r� ) r rZ rG r+ rh rQ r� r� r� r� r r r! r] s8 �� � ����zManyToManyDP.presort_savesc s� g }g }g }| � |�}t� }|D ]C� |�� | j| j�}|rS|�� D ]#} | d u s1|d ur2� | f|v r2q!i } | �� | | d|d�s?q!|�| � q!|�� fdd�|�� D �� q|d ur]|�|� | � ||||� d S )NFr� c 3 � � | ]}|� fV qd S r# r �r{ r� �r+ r r! r� K � � z/ManyToManyDP.process_deletes.<locals>.<genexpr>) r� r� rb r r � non_addedry rH r� � _run_crud) r rZ rG �secondary_delete�secondary_insert�secondary_update� processed�tmprh rQ rw r r� r! r_ , s@ � � � �z ManyToManyDP.process_deletesc s� g }g }g }| � |�}t� }|D ]�� | j o| �|� �}|r"tj} ntj} |�� | j| �} | r�| j D ] } |d ur?� | f|v r?q2i } | � � | | d|d�sLq2|� | � q2| j D ] } |d urb� | f|v rbqUi } | � � | | d|d�soqU|� | � qU|� � fdd�| j | j D �� |r�| jD ]!} i } t� � | j| d| jj� t� | | j| d| jj� |� | � q�q|d ur�|� |� | �||||� d S )NFr� r� c 3 r� r# r r� r� r r! r� ~ r� z-ManyToManyDP.process_saves.<locals>.<genexpr>�old_)r� r� r r� r r r rb r r� ry rH rS r� r� r r r r r �secondary_synchronize_pairsr� ) r rZ rG r� r� r� r� r� �need_cascade_pksrf rh rQ rw r r� r! r` T s| � � � �� � �zManyToManyDP.process_savesc s |j �| j�}|r?|d � | j�tj� fdd�| jjD �� �}|�||�}|� � r?|j t |�kr?t � d| jjt |�|j f ��|rw|d � | j�tj� fdd�| jjD �� �}|�||�}|� � rw|j t |�krwt � d| jjt |�|j f ��|r�| j�� }|�||� d S d S )Nr� c s, g | ]}|j � v r|tj|j |jd �k�qS )��type_�r r � bindparam�typer� �rw r r! r} � 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! r} � s �zRUPDATE statement on table '%s' expected to update %d row(s); Only %d were matched.)� transaction� connectionr r r� r �and_r� �execute� supports_sane_multi_rowcount�rowcount�lenr �StaleDataError� descriptionr� �insert)r rZ r� r� r� r� � statement�resultr r� r! r� � s^ ��� ���� ��� ���� �zManyToManyDP._run_crudc C s� | � |� |d u r dS |d ur(|j�|�s(|js&t�dt�|�|| jf � dS t � || j || jj � t � || j || jj� dS )NFr� T)rs r� r� rS r r� r� r� r r � populate_dictr r r r� r� r r r! ry � s* ����zManyToManyDP._synchronizec C r� r# r� r� r r r! r� � r� zManyToManyDP._pks_changedN) r� r� r� r5 rI r[ r] r_ r` r� ry r� r r r r! r� � s "(H= !r� N)r� � r r r r r r� � interfacesr r r r r �objectr r� r� r� r� r$ r r r r! �<module> s8 & 3 fu ;�
Save
Cancel