File manager - Edit - /usr/local/CyberPanel/lib/python3.10/site-packages/django/db/models/__pycache__/deletion.cpython-310.pyc
Back
o �hkR � @ s� d dl mZmZ d dlmZmZ d dlmZ d dlm Z m Z d dl m Z m Z mZmZ d dlmZmZmZ G dd� de �ZG d d � d e �Zd d � Zd d� Zdd� Zdd� Zdd� Zde_dd� Z de _dd� Z dd� Z G d d � d �Z d S ) � )�Counter� defaultdict)�partial�reduce)�chain)� attrgetter�or_)�IntegrityError� connections�models� transaction)� query_utils�signals�sqlc � e Zd Z� fdd�Z� ZS )�ProtectedErrorc � || _ t� �||� d S �N)�protected_objects�super�__init__)�self�msgr �� __class__� �O/usr/local/CyberPanel/lib/python3.10/site-packages/django/db/models/deletion.pyr � zProtectedError.__init__��__name__� __module__� __qualname__r � __classcell__r r r r r � r c r )�RestrictedErrorc r r )�restricted_objectsr r )r r r% r r r r r zRestrictedError.__init__r r r r r r$ r# r$ c C sH | j ||jj|j|jdd� |jr t| jjs"| �|d |� d S d S d S )NF)�source� source_attr�nullable�fail_on_restricted) �collect� remote_field�model�name�nullr �features�can_defer_constraint_checks�add_field_update�� collector�field�sub_objs�usingr r r �CASCADE s ��r7 c C s$ t d|jjj|d jj|jf |��)NzoCannot delete some instances of model '%s' because they are referenced through a protected foreign key: '%s.%s'r )r r+ r, r r r- r2 r r r �PROTECT" s ���r8 c C s" | � ||� | �|jj|j� d S r )�add_restricted_objects�add_dependencyr+ r, r2 r r r �RESTRICT/ s r; c s: t � �r � fdd�}n� fdd�}� fdd�|_d|_|S )Nc s | � |� � |� d S r �r1 r2 ��valuer r � set_on_delete7 s zSET.<locals>.set_on_deletec s | � |� |� d S r r< r2 r= r r r? < � c s d� fi fS )Nzdjango.db.models.SETr r r= r r �<lambda>? s zSET.<locals>.<lambda>T)�callable� deconstruct� lazy_sub_objs)r> r? r r= r �SET4 s rE c C s | � |d |� d S r r< r2 r r r �SET_NULLD r@ rF Tc C s | � ||�� |� d S r )r1 � get_defaultr2 r r r � SET_DEFAULTK s rH c C s d S r r r2 r r r � DO_NOTHINGR s rI c C s dd� | j dd�D �S )Nc s s, � | ]}|j r|js|js|jr|V qd S r )� auto_created�concrete� one_to_one� one_to_many)�.0�fr r r � <genexpr>Y s � ���� �z4get_candidate_relations_to_delete.<locals>.<genexpr>T)�include_hidden)� get_fields)�optsr r r �!get_candidate_relations_to_deleteV s �rT c @ s� e Zd Zd"dd�Zd#dd�Zd$dd�Zd d � Zd d � Zd d� Zdd� Z dd� Z d"dd�Z dd� Z d%dd�Z dd� Zd d � Zd d � Zd d!� ZdS )&� CollectorNc C sD || _ || _tt�| _tt�| _tttt��| _g | _ tt�| _ d S r ) r6 �originr �set�data�list� field_updatesr r% � fast_deletes� dependencies)r r6 rV r r r r a s zCollector.__init__Fc C sf |sg S g }|d j }| j| }|D ] }||vr |�|� q|�|� |dur1|s1| j|||d� |S )a7 Add 'objs' to the collection of objects to be deleted. If the call is the result of a cascade, 'source' should be the model that caused it, and 'nullable' should be set to True if the relation can be null. Return a list of all objects that were not already collected. r N��reverse_dependency)r rX �append�updater: ) r �objsr& r( r^ �new_objsr, � instances�objr r r �addv s � z Collector.addc C s> |r||}}| j |jj �|jj� | j�|| j�� � d S r )r\ �_meta�concrete_modelre rX � setdefault�default_factory)r r, � dependencyr^ r r r r: � s �zCollector.add_dependencyc C s | j ||f �|� dS )z� Schedule a field update. 'objs' must be a homogeneous iterable collection of model instances (e.g. a QuerySet). N)rZ r_ )r r4 r> ra r r r r1 � s zCollector.add_field_updatec C s* |r|d j }| j| | �|� d S d S )Nr )r r% r` )r r4 ra r, r r r r9 � s �z Collector.add_restricted_objectsc s4 || j v r� fdd�| j | �� D �| j |< d S d S )Nc s i | ] \}}||� �qS r r )rN r4 �items�ra r r � <dictcomp>� s ��z?Collector.clear_restricted_objects_from_set.<locals>.<dictcomp>)r% rk )r r, ra r rl r �!clear_restricted_objects_from_set� s ��z+Collector.clear_restricted_objects_from_setc C sB || j v r t|jdd� | j | �� D �d��}| �||� d S d S )Nc S s g | ] }|D ]}|j �qqS r ��pk)rN ra rd r r r � <listcomp>� s ���zDCollector.clear_restricted_objects_from_queryset.<locals>.<listcomp>)�pk__in)r% rW �filter�valuesrn )r r, �qsra r r r �&clear_restricted_objects_from_queryset� s ��� �z0Collector.clear_restricted_objects_from_querysetc C s t j�|�p t j�|�S r )r � pre_delete� has_listeners� post_delete)r r, r r r �_has_signal_listeners� s � �z Collector._has_signal_listenersc s� � r � j jtur dS t|d�r|jj}nt|d�r"t|d�r"|j}ndS | �|�r+dS |j}t� fdd�|jjj � � D ��oStdd� t |�D ��oSt dd� |j D �� S ) a� Determine if the objects in the given queryset-like or single object can be fast-deleted. This can be done if there are no cascades, no parents and no signal listeners for the object class. The 'from_field' tells where we are coming from - we need this to determine if the objects are in fact to be deleted. Allow also skipping parent -> child -> parent chain preventing fast delete of the child. Frf r, � _raw_deletec 3 s � | ]}|� kV qd S r r )rN �link�� from_fieldr r rP � s � � �z,Collector.can_fast_delete.<locals>.<genexpr>c s s � | ] }|j jjtu V qd S r )r4 r+ � on_deleterI )rN �relatedr r r rP � s � � �c s s � | ]}t |d �V qdS )�bulk_related_objectsN)�hasattr�rN r4 r r r rP � s � � �)r+ r r7 r� rf r, rz �allrg �parentsrt rT �any�private_fields)r ra r~ r, rS r r} r �can_fast_delete� s* ��� ��zCollector.can_fast_deletec sZ dd� |D �}t t| j j�|��d�� t��� kr*� �fdd�tdt��� �D �S �gS )zT Return the objs in suitably sized batches for the used connection. c S � g | ]}|j �qS r �r- r� r r r rq � � z-Collector.get_del_batches.<locals>.<listcomp>� c s g | ] }�||� � �qS r r )rN �i��conn_batch_sizera r r rq � s ��r )�maxr r6 �ops�bulk_batch_size�len�range)r ra �fields� field_namesr r� r �get_del_batches� s � �zCollector.get_del_batchesTc sx | � |�r | j�|� dS | j||||d�} | sdS | d j} |sF| jj} | jj�� D ]� � rE� fdd�| D �} | j | | � j j dddd� q+|sJdS |rSt | j� � �} tt�}tt�}t| j�D ]�}|rj|j| v rjq`|j}|j j}|tkrvq`|j}| j ||d �r�|| �|� q`| �| |g�}|D ]`}| �||g|�}|jjs�| �|�s�t t� d d � t|j�D ���}|j t |�� }t |d d�s�|r�z || ||| j � W q� t!y� } zd |jj"|j#f }|| |j$7 < W Y d}~q�d}~ww q�q`|�r t!d| j"d�%|�f t t� |�� ����|�&� D ] \}}| �| |�}|D ]}| �|||�}| j�|� �q�q| jj'D ]}t(|d��rI|�)| | j �}| j || ddd� �q1|�r�| j*�&� D ] \}}| �+||� �qS| jD ] } | �,| j| � �qb| j-�� �r�tt�} | j-�&� D ]"\}} | �&� D ]\}}|�r�d |j"|j#f }| | |7 < �q��q|| �r�t.d| j"d�%| �f t t� | �� ����dS dS dS )a� Add 'objs' to the collection of objects to be deleted as well as all parent instances. 'objs' must be a homogeneous iterable collection of model instances (e.g. a QuerySet). If 'collect_related' is True, related objects will be handled by their respective on_delete handler. If the call is the result of a cascade, 'source' should be the model that caused it and 'nullable' should be set to True, if the relation can be null. If 'reverse_dependency' is True, 'source' will be deleted before the current model, rather than after. (Needed for cascading to parent models, the one case in which the cascade follows the forwards direction of an FK rather than the reverse direction.) If 'keep_parents' is True, data of parent model's will be not deleted. If 'fail_on_restricted' is False, error won't be raised even if it's prohibited to delete such objects due to RESTRICT, that defers restricted object checking in recursive calls where the top-level call may need to collect more objects to determine whether restricted ones can be deleted. Nr] r c s g | ]}t |� j��qS r )�getattrr- �rN rd ��ptrr r rq * � z%Collector.collect.<locals>.<listcomp>FT)r& r' �collect_relatedr^ r) r} c s s" � | ] }d d� |j jD �V qdS )c s s � | ]}|j V qd S r )�attname)rN �rfr r r rP U s � z.Collector.collect.<locals>.<genexpr>.<genexpr>N)r4 �foreign_related_fields)rN �relr r r rP T s � � �z$Collector.collect.<locals>.<genexpr>rD z'%s.%s'zhCannot delete some instances of model %r because they are referenced through protected foreign keys: %s.z, r� )r& r( r) ziCannot delete some instances of model %r because they are referenced through restricted foreign keys: %s.)/r� r[ r_ re r rf rg r� rt r* r+ � related_namerW �get_parent_listr rY rT r, r4 r rI � related_modelr� �related_objects�query�select_relatedrz r � from_iterable�only�tupler� r6 r r r- r �joinrk r� r� r� rX rn rv r% r$ ) r ra r& r( r� r' r^ � keep_parentsr) rb r, rg � parent_objsr� �model_fast_deletesr r� r4 r r� �batches�batchr5 �referenced_fields�error�key�related_fieldsrc ru r% r� r r� r r* � s� " � ���� ��� ������� � �� ������zCollector.collectc s6 t jj� fdd�|D �t jjd�}|j�| j��|�S )zQ Get a QuerySet of the related model to objs via related fields. c s g | ] }|j � d �� f�qS )�__inr� )rN � related_fieldrl r r rq � s z-Collector.related_objects.<locals>.<listcomp>)� connector)r �Q�create�OR� _base_managerr6 rs )r r� r� ra � predicater rl r r� � s �zCollector.related_objectsc c s. � | j �� D ]\}}|D ]}||fV q qd S r )rX rk )r r, rc rd r r r �instances_with_model� s � ��z Collector.instances_with_modelc s� g }t � }t� j�}t|�t|�k rGd}|D ]$}||v r q� j�|jj�}|r,|�|�s:|� |� |� |jj� d}q|s?d S t|�t|�k s� fdd�|D �� _d S )NFTc s i | ]}|� j | �qS r )rX )rN r, �r r r rm � r� z"Collector.sort.<locals>.<dictcomp>) rW rY rX r� r\ �getrf rg � differencer_ re )r � sorted_models�concrete_modelsr �foundr, r\ r r� r �sort� s$ �� zCollector.sortc C s | j �� D ]\}}t|td�d�| j |< q| �� t� }t| j �dkrgt|�dkrgt|�d }| �|�rgt � | j �� t � |��|jg| j �}W d � n1 sQw Y t||jjjd � ||jj|ifS t j| j dd��� | �� D ]\}}|jjs�tjj||| j | jd� qt| jD ]}|j | j d�}|r�||j jj |7 < q�| j �� D ]U\\}} } g } g } | D ]}t |t j!�r�|j"d u r�| �#|� q�| �$|� q�| r�t%t&| �} | j'd i |j(| i�� | r�| d j)}t �*|�}|�+td d � | D ��|j(| i| j � q�| j �,� D ]}|�-� �q| j �� D ]<\}}t � |�}d d � |D �}|�|| j �}|�r4||jj |7 < |jj�sK|D ]}tj.j||| j | jd� �q;�qW d � n 1 �sXw Y | j �� D ]\}}|D ] }t||jjjd � �qh�qbt/|�,� �t0|�fS )Nrp )r� r� r F)r6 � savepoint)�sender�instancer6 rV )r6 c S s h | ]}|j �qS r ro r� r r r � <setcomp>� r� z#Collector.delete.<locals>.<setcomp>c S r� r ro r� r r r rq � r� z$Collector.delete.<locals>.<listcomp>r )1rX rk �sortedr r� r r� rY r� r �mark_for_rollback_on_errorr6 r � DeleteQuery� delete_batchrp �setattrrf r� �label�atomicr� rJ r rw �sendrV r[ r{ r, rZ � isinstancer �QuerySet� _result_cacher_ �extendr r r` r- r � UpdateQuery� update_batchrt �reversery �sum�dict)r r, rc �deleted_counterr� �countrd ru r4 r> �instances_list�updatesra �combined_updatesr� �pk_listr r r �delete� s� � ��� � � �� ��� �<�zCollector.deleter )NFF)F)NFTNFFT)r r r! r re r: r1 r9 rn rv rz r� r� r* r� r� r� r� r r r r rU ` s0 , � rU N) � collectionsr r � functoolsr r � itertoolsr �operatorr r � django.dbr r r r �django.db.modelsr r r r r$ r7 r8 r; rE rF rD rH rI rT rU r r r r �<module> s&
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings