gdZddlmZddlmZmZmZddlmZgdZ GddeZ Gdd eZ Gd d eZ Gd d eZ y)zR Query subclasses which provide extra functionality beyond simple data retrieval. ) FieldError)CURSORGET_ITERATOR_CHUNK_SIZE NO_RESULTS)Query) DeleteQuery UpdateQuery InsertQueryAggregateQueryc eZdZdZdZdZdZy)rzA DELETE SQL query.SQLDeleteCompilerc||j|i|_||_|j|jt}|r|5|j cdddSy#1swYyxYw)Nr) alias_mapwhere get_compiler execute_sqlrrowcount)selftablerusingcursors ]/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/django/db/models/sql/subqueries.pydo_queryzDeleteQuery.do_querysa!67 ""5)55f=  ' ' ' 's  AA&c`d}|jj}tdt|tD]t}|j |j |jd|||tz||j|jj|j|z }v|S)z Set up and execute delete queries for all the objects in pk_list. More than one physical query may be executed if there are a lot of values in pk_list. r__in)r) get_metapkrangelenr clear_where add_filterattnamerdb_tabler)rpk_listr num_deletedfieldoffsets r delete_batchzDeleteQuery.delete_batchs  ""As7|-DE F     OO==/&*A!AB  4== (($**E) K  N)__name__ __module__ __qualname____doc__compilerrr(r)rrr s"Hr)rcTeZdZdZdZfdZdZfdZdZdZ dZ d Z d Z xZ S) r zAn UPDATE SQL query.SQLUpdateCompilercDt||i||jyN)super__init__ _setup_query)rargskwargs __class__s rr5zUpdateQuery.__init__5s! $)&) r)c.g|_d|_i|_y)z Run on initialization and at the end of chaining. Any attributes that would normally be set in __init__() should go here instead. N)values related_idsrelated_updates)rs rr6zUpdateQuery._setup_query9s  !r)cbt|}|jj|_|Sr3)r4cloner=copy)robjr9s rr?zUpdateQuery.cloneBs*gmo"22779 r)c|j|tdt|tD]R}|j |j d|||tz|j |jtTy)Nrpk__in) add_update_valuesrrrr r!rrr)rr$r;rr's r update_batchzUpdateQuery.update_batchGsr v&As7|-DE =F     OO'&64K+KL    e $ 0 0 <  =r)cg}|jD]\}}|jj|}|jxr |j xs |j }|j j j}|r|jr|jrtd|z||jjur|j||||j|||f|j|S)z Convert a dictionary of field name to value mappings into an update query. This is the entry point for the public update() method on querysets. zMCannot update model field %r (only non-relations and foreign keys permitted).)itemsr get_field auto_createdconcretemodel_metaconcrete_model is_relation many_to_manyradd_related_updateappendadd_update_fields)rr; values_seqnamevalr&directrKs rrDzUpdateQuery.add_update_valuesPs   3ID#MMO--d3E''>,>?Uu~~CU KK%%44Ee//E4F4F /167DMMO:::''uc:   ueS1 2 3%%j11r)c|D]Q\}}}|jrt|dr|j|dd}|jj |||fSy)z Append a sequence of (field, model, value) triples to the internal list that will be used to generate the UPDATE query. Might be more usefully called add_update_targets() to hint at the extra information here. resolve_expressionFT) allow_joinsfor_saveN) generatedhasattrrXr;rQ)rrSr&rKrUs rrRzUpdateQuery.add_update_fieldshs_ ", 4 E5#s01,,Tut,T KK  uc2 3 4r)c`|jj|gj|d|fy)z Add (name, value) to an update query for an ancestor model. Update are coalesced so that only one update query per ancestor is run. N)r= setdefaultrQ)rrKr&values rrPzUpdateQuery.add_related_updatews, ''r2995$:NOr)c|jsgSg}|jjD]S\}}t|}||_|j|j d|j||j |U|S)z Return a list of query objects: one for each update required to an ancestor model. Each query will have the same filtering conditions as the current query but will only update a single table. rC)r=rGr r;r<r!rQ)rresultrKr;querys rget_related_updateszUpdateQuery.get_related_updatess ##I!11779 !ME6&E!EL+  4+;+;E+BC MM%  !  r))r*r+r,r-r.r5r6r?rErDrRrPrc __classcell__r9s@rr r 0s4"H" =20 4Pr)r c4eZdZdZddddfd ZddZxZS)r SQLInsertCompilerN) on_conflict update_fields unique_fieldsczt||i|g|_g|_||_|xsg|_|xsg|_yr3)r4r5fieldsobjsrhrirj)rrhrirjr7r8r9s rr5zInsertQuery.__init__sG $)&)  &*0b*0br)c.||_||_||_yr3)rlrmraw)rrlrmros r insert_valueszInsertQuery.insert_valuess  r))F)r*r+r,r.r5rprdres@rr r s"H"&T1r)r c&eZdZdZdZfdZxZS)r zu Take another query as a parameter to the FROM clause and only select the elements in the provided list. SQLAggregateCompilerc2||_t| |yr3) inner_queryr4r5)rrKrtr9s rr5zAggregateQuery.__init__s& r))r*r+r,r-r.r5rdres@rr r s &H  r)r N)r-django.core.exceptionsrdjango.db.models.sql.constantsrrrdjango.db.models.sql.queryr__all__rr r r r/r)rrysQ.VV, I!%!H^%^B%&  U  r)