g RddlmZmZddlmZmZddlmZddlm Z m Z ddl m Z m Z mZmZddlmZmZmZGdde ZGd d e Zd Zd Zd ZdZdZde_dZdZdZGddZy))Counter defaultdict)partialreduce)chain) attrgetteror_)IntegrityError connectionsmodels transaction) query_utilssignalssqlceZdZfdZxZS)ProtectedErrorc4||_t| ||yN)protected_objectssuper__init__)selfmsgr __class__s W/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/django/db/models/deletion.pyrzProtectedError.__init__ s!2 /0__name__ __module__ __qualname__r __classcell__rs@rrr s 11rrceZdZfdZxZS)RestrictedErrorc4||_t| ||yr)restricted_objectsrr)rrr&rs rrzRestrictedError.__init__s"4 01rrr"s@rr$r$s 22rr$c|j||jj|j|jd|jr2t |j js|j|d|yyy)NF)source source_attrnullablefail_on_restricted) collect remote_fieldmodelnamenullr featurescan_defer_constraint_checksadd_field_update collectorfieldsub_objsusings rCASCADEr9sn !!''JJ  zz+e,55QQ""5$9Rzrc td|jjjd|djjd|j d|)Nz'Cannot delete some instances of model 'z@' because they are referenced through a protected foreign key: 'r.')rr-r.rrr/r4s rPROTECTr="sJ     $ $ - - QK ! ! * * JJ     rc|j|||j|jj|jyr)add_restricted_objectsadd_dependencyr-r.r4s rRESTRICTrA/s2 $$UH5 U//55u{{CrcVtrfd}n fd}d|_fd|_|S)Nc6|j||yrr3r5r6r7r8values r set_on_deletezSET..set_on_delete7s  & &uegx @rc,|j||yrrDrEs rrGzSET..set_on_delete<s  & &ueX >rTcdfifS)Nzdjango.db.models.SET)rFsrzSET..As)?%2(Nr)callable lazy_sub_objs deconstruct)rFrGs` rSETrO4s- A  ?'+ # NM rc*|j|d|yrrDr4s rSET_NULLrQEs udH5rTcF|j||j|yr)r3 get_defaultr4s r SET_DEFAULTrTLs ue&7&7&98DrcyrrJr4s r DO_NOTHINGrVPsrc4d|jdDS)Nc3K|]6}|jr(|js|js |jr|8ywr) auto_createdconcrete one_to_one one_to_many).0fs r z4get_candidate_relations_to_delete..Ws1  >>!**!,,!--  s<>T)include_hidden) get_fields)optss r!get_candidate_relations_to_deletercTs 5 rc~eZdZddZddZddZdZdZdZdZ d Z dd Z d Z dd Z d ZdZdZdZy) CollectorNc||_||_tt|_tt |_tttt|_g|_ tt|_ yr) r8originrsetdatalist field_updatesrr& fast_deletes dependencies)rr8rgs rrzCollector.__init___sV  $ (."-gk3.G"H(,rc|sgSg}|dj}|j|}|D]}||vs|j||j|||s|j ||||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. rreverse_dependency)rriappendupdater@) robjsr(r*rpnew_objsr. instancesobjs raddz Collector.addtsIQ!!IIe$  %C)#$ % "  h   BT  Urc|r||}}|j|jjj|jj|jj ||jj yr)rm_metaconcrete_modelrwri setdefaultdefault_factory)rr. dependencyrps rr@zCollector.add_dependencysc  *E:E %++44599    + +  Z)B)B)DErcD|j||fj|y)z Schedule a field update. 'objs' must be a homogeneous iterable collection of model instances (e.g. a QuerySet). N)rkrq)rr6rFrss rr3zCollector.add_field_updates! 5%<(//5rcj|r1|dj}|j||j|yy)Nr)rr&rr)rr6rsr.s rr?z Collector.add_restricted_objectss7 G%%E  # #E *5 1 8 8 > rc||jvrB|j|jDcic] \}}|||z  c}}|j|<yycc}}wr)r&items)rr.rsr6rs r!clear_restricted_objects_from_setz+Collector.clear_restricted_objects_from_sets` D++ +%)$;$;E$B$H$H$J. E5ut|#.D # #E * ,.sAc ||jvrjt|j|j|jDcgc]}|D]}|jc}}}|j ||yycc}}w)N)pk__in)r&rhfiltervaluespkr)rr.qsrsrvs r&clear_restricted_objects_from_querysetz0Collector.clear_restricted_objects_from_querysets D++ + %)$;$;E$B$I$I$K #' D  2 25$ ? ,sA:ctjj|xstjj|Sr)r pre_delete has_listeners post_delete)rr.s r_has_signal_listenerszCollector._has_signal_listenerss7!!//  6  . .u 5 6rcrjjturyt|dr|jj }n&t|drt|dr |j }ny|j |ry|j}tfd|jjjjDxr:tdt|Dxrtd|jD 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. Fryr. _raw_deletec3(K|] }|k( ywrrJ)r]link from_fields rr_z,Collector.can_fast_delete..s "sc3hK|]*}|jjjtu,ywr)r6r- on_deleterV)r]relateds rr_z,Collector.can_fast_delete..s- **44 Bs02c34K|]}t|dyw)bulk_related_objectsN)hasattr)r]r6s rr_z,Collector.can_fast_delete..s E#9:)r-rr9rryr.rallrzparentsrrcanyprivate_fields)rrsrr.rbs ` rcan_fast_deletezCollector.can_fast_deletes *11;;7J 4 !JJ$$E T7 #m(DJJE  % %e ,{{  //55==DDF   @F   !%!4!4 rc,|Dcgc]}|j}}tt|jjj ||d}t ||kDr*tdt ||Dcgc] }||||z c}S|gScc}wcc}w)zT Return the objs in suitably sized batches for the used connection. r)r/maxr r8opsbulk_batch_sizelenrange)rrsfieldsr6 field_namesconn_batch_sizeis rget_del_batcheszCollector.get_del_batchess066euzz6 6  # ' ' 7 7 T JA  t9 &q#d)_=Q_,-  6M7 s B 7Bc Z |j|r|jj|y|j||||} | sy| dj} |s| j j } | j jjD]S} | s| D cgc]} t| | j}} |j|| | jjdddU|sytt}tt}t!| j D]S}|r#|j"| j j$vr)|j&}|jj(}|t*k(rU|j,}|j||r||j||j/| |g}|D]}|j1||g|}|j2j4sa|j7|sPt9t;j<dt!|j D}|j>tA|}t|d ds|s |||||jBV|rVtEd | jFd djK|d t9t;j<|j|jMD]L\}}|j/| |}|D]0}|j1|||}|jj|2N| j jND]@}tQ|ds|jS| |jB}|j|| ddB|rK|jTjMD]\}}|jW|||jD]}|jY|j"| |jZjrtt}|jZjMD]J\}}|jMD]2\}}|s d |jFd |jd }||xx|z cc<4L|rVt]d | jFddjK|d t9t;j<|jyyycc} w#tD$rI}d |j"jFd |jd }||xx|jHz cc<Yd}~jd}~wwxYw)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. NrorFT)r(r)collect_relatedrpr+)rc3VK|]!}d|jjD#yw)c34K|]}|jywr)attname)r]rfs rr_z.Collector.collect...QsSBRZZSrN)r6foreign_related_fields)r]rels rr_z$Collector.collect..Ps+, #T#))2R2RSS,s')rMr<r;z&Cannot delete some instances of model z= because they are referenced through protected foreign keys: z, r)r(r*r+z> because they are referenced through restricted foreign keys: )/rrlrqrwrryrzrrgetattrr/r,r- related_namerrjrcr. all_parentsr6rrV related_modelrrelated_objectsqueryselect_relatedrrhr from_iterableonlytupler8rrrjoinrrrrrirrr&r$) rrsr(r*rr)rp keep_parentsr+rtr.rzptrrv parent_objsmodel_fast_deletesrrr6rrbatchesbatchr7referenced_fieldserrorkeyrelated_fieldsrurr&rs rr,zCollector.collectsD    %    $ $T * 88 &(7I   %%#[[77N%++33::< EM"Nc73#9"NK"NLL#$$'$4$4$A$A(-+/+0 !  (.'-8E' JG 1H1H HMME**44IJ&#11M##Me#D"=188?**8eW=G  J// wNNN1111-@(+++,'H - 3 3(,)% -x}}e4E.FGH9ou=J!$xD/ J' JP  NNII/0  E''(9(@(@(BCD .@-E-E-G 3 )M>**8^DG  3// ~uU!!((2 3 3 [[// Eu45 55h K UTe   -1IIOO,= Q( y66}iP Q'' J;;BHHbI J&&--/%0%6"-1-D-D-J-J-L<)M6'-||~< t/T%%T*c tjj|Dcgc]}|jd|fc}tjj}|j j |j j|Scc}w)zQ Get a QuerySet of the related model to objs via related fields. __in) connector)rQcreater/OR _base_managerr8r)rrrrs related_field predicates rrzCollector.related_objectssy MM((FT U]##$D)4 0 U!mm&&) **00<CCINN VsB c#jK|jjD]\}}|D]}||f ywr)rir)rr.rurvs rinstances_with_modelzCollector.instances_with_models> $  1 ! E9  !Sj  ! !s13c g}t}t|j}t|t|krd}|D]}||vr|jj |j j}|r|j|rK|j||j|j jd}|syt|t|kr|Dcic]}||j|c}|_ycc}w)NFT) rhrjrirrmgetryrz differencerqrw)r sorted_modelsconcrete_modelsr foundr.rms rsortzCollector.sorts %dii- 3v;.E !M)#0044U[[5O5OP $)@)@)Q!((/#'' (B(BC E !- 3v;.;HHUDIIe,,H Hs!Dc  |jjD](\}}t|td|j|<*|j t }t |jdk(rt dk(rt|d}|j|rtj|j5tjj|jg|j}dddt!|j"jj$d|j"j&|ifStj(|jd5|j+D]S\}}|j"j,rt.j0j3|||j|j4U|j6D]L}|j9|j}|s"||j:j"j&xx|z cc<N|j<jD]\\}} } g} g} | D]K}t?|t@jBr|jD| jG|;| jI|M| r.tKtL| } | jNd i|jP| i| s| djR}tjT|}|jWt| Dchc]}|jc}|jP| i|j|jjYD]}|j[|jjD]\}}tj|}|Dcgc]}|j}}|j||j}|r!||j"j&xx|z cc<|j"j,r|D]9}t.j\j3|||j|j4; ddd|jjD]7\}}|D]-}t!||j"jj$d/9t_|jYta|fS#1swYxYwcc}wcc}w#1swYxYw) Nr)rrrF)r8 savepoint)senderinstancer8rg)r8rJ)1rirsortedrrrrrjrr mark_for_rollback_on_errorr8r DeleteQuery delete_batchrsetattrryrlabelatomicrrYrrsendrgrlrr.rk isinstancer QuerySet _result_cacherqextendrr rrr/r UpdateQuery update_batchrreversersumdict)rr.rudeleted_counterrcountrvrr6rFinstances_listupdatesrscombined_updatesrpk_lists rdeletezCollector.deletes; $  1 G E9%iZ5EFDIIe  G !) tyy>Q 3y>Q#6Iq)H##H- ;;DJJGOOE2??! tzzE%++.."8"8$?u{{00%888   djjE B: "779  s{{//&&++$!$"jj#{{ , '' CTZZ8#BHHNN$8$89UB9 C 372D2D2J2J2L .!//I"9foo>%33;y1 I./'-c7';$+$++Buzz5.AB G--EOOE2E&&5cff56U8KTZZ# ,"YY--/ $ !!# $%)IIOO$5  y.-67c36677**7DJJ?#EKK$5$56%?6{{//(++00#(%("&**#';; 1 Y: x!%  1 @ E9% @%++.."8"8$? @ @?))+,d?.CCCMV68]: : sS;S--S4A&S4CS48S4S*$B S41S/AS4AS4S'* S44S=r)NFF)F)NFTNFFT)rrr rrwr@r3r?rrrrrr,rrrrrJrrrere^sm-*0F6?  @6 * X& XtO! I$VDrreN) collectionsrr functoolsrr itertoolsroperatorrr django.dbr r r r django.db.modelsrrrrr$r9r=rArOrQrMrTrVrcrerJrrrsw,%$FF661^1 2n2 : D "6E hDhDr