hdZddlmZddlmZddlmZmZmZddl m Z gdZ Gdde Z Gd d e Z Gd d e ZGd de Zy)zR Query subclasses which provide extra functionality beyond simple data retrieval. ) FieldError)Q)CURSORGET_ITERATOR_CHUNK_SIZE NO_RESULTS)Query) DeleteQuery UpdateQuery InsertQueryAggregateQueryc eZdZdZdZdZdZy)r zA DELETE SQL query.SQLDeleteCompilerc||j|i|_||_|j|jt}|r|5|j cdddSy#1swYyxYw)Nr) alias_mapwhere get_compiler execute_sqlrrowcount)selftablerusingcursors b/var/www/html/ranktracker/api/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]}|j |_|jtdi|jdz|||tzi||j|jj|j |z }|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 where_classradd_qrattnamerdb_table)rpk_listr num_deletedfieldoffsets r delete_batchzDeleteQuery.delete_batchs  ""As7|-DE \F))+DJ JJq^==6)76&CZ:Z+[\^ _ 4==)A)A4::UZ=[ [K  \ N)__name__ __module__ __qualname____doc__compilerrr*rr+rr r s"Hr+r cTeZdZdZdZfdZdZfdZdZdZ dZ d Z d Z xZ S) r zAn UPDATE SQL query.SQLUpdateCompilercDt||i||jyN)super__init__ _setup_query)rargskwargs __class__s rr6zUpdateQuery.__init__4s! $)&) 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 rr7zUpdateQuery._setup_query8s  !r+cbt|}|jj|_|Sr4)r5cloner>copy)robjr:s rr@zUpdateQuery.cloneAs*gmo"22779 r+c  |j|tdt|tD]`}|j |_|j t|||tz|j|jtby)Nr)pk__in) add_update_valuesr r!rr"rr#rrrr)rr&r<rr)s r update_batchzUpdateQuery.update_batchFst v&As7|-DE =F))+DJ JJq9P0P QR S   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(directrLs rrEzUpdateQuery.add_update_valuesMs   3ID#MMO--d3E,,CU^^1CDZENNHZFKK%%44Ee//E4F4F /167DMMO:::''uc:   ueS1 2 3%%j11r+c|D]D\}}}t|dr|j|dd}|jj|||fFy)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)hasattrrYr<rR)rrTr(rLrVs rrSzUpdateQuery.add_update_fieldscsU ", 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> setdefaultrR)rrLr(values rrQzUpdateQuery.add_related_updateos, ''r2995$:NOr+c|jsgSg}|jjD]Q\}}t|}||_|j|j d|jf|j |S|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. rD)r>rHr r<r= add_filterrR)rresultrLr<querys rget_related_updateszUpdateQuery.get_related_updatesws ##I!11779 !ME6&E!EL+  (D,<, MM%  !  r+)r,r-r.r/r0r6r7r@rFrErSrQrd __classcell__r:s@rr r /s4"H" =2, 4Pr+r c0eZdZdZddfd ZddZxZS)r SQLInsertCompilerF)ignore_conflictscNt||i|g|_g|_||_yr4)r5r6fieldsobjsri)rrir8r9r:s rr6zInsertQuery.__init__s+ $)&)  0r+c.||_||_||_yr4)rkrlraw)rrkrlrns r insert_valueszInsertQuery.insert_valuess  r+)F)r,r-r.r0r6rorerfs@rr r s"H/41 r+r ceZdZdZdZdZy)r zu Take another query as a parameter to the FROM clause and only select the elements in the provided list. SQLAggregateCompilercnd|_|j|jd\|_|_y)NT)with_col_aliases)subqueryras_sql sub_params)rrcrs r add_subqueryzAggregateQuery.add_subquerys1).););E)B)I)I[_)I)`& tr+N)r,r-r.r/r0rwrr+rr r s &Har+r N)r/django.core.exceptionsrdjango.db.models.query_utilsrdjango.db.models.sql.constantsrrrdjango.db.models.sql.queryr__all__r r r r rr+rr}s\.*- I%@W%Wt %  aU ar+