ó i4Vdc@sàdZddlmZddlmZddlmZddlmZm Z m Z ddl m Z ddl mZdd d d gZde fd „ƒYZd e fd „ƒYZd e fd„ƒYZd e fd„ƒYZdS(sR Query subclasses which provide extra functionality beyond simple data retrieval. iÿÿÿÿ(t FieldError(t connections(tQ(tCURSORtGET_ITERATOR_CHUNK_SIZEt NO_RESULTS(tQuery(tsixt DeleteQueryt UpdateQueryt InsertQuerytAggregateQuerycBs2eZdZdZd„Zdd„Zd„ZRS(so Delete queries are done through this class, since they are more constrained than general queries. tSQLDeleteCompilercCs>|g|_||_|j|ƒjtƒ}|r:|jSdS(Ni(ttablestwheret get_compilert execute_sqlRtrowcount(tselfttableRtusingtcursor((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pytdo_querys  cCs¨d}|s|jƒj}nxƒtdt|ƒtƒD]i}|jƒ|_|jti|||t!|j d6ƒ||j |jƒj |jd|ƒ7}q7W|S(sº 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. it__inR( tget_metatpktrangetlenRt where_classRtadd_qRtattnameRtdb_table(Rtpk_listRtfieldt num_deletedtoffset((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyt delete_batchs #,c Cs8|j}|jƒ|jƒg|jD]}|j|r'|^q'}| s\||jkrk|j|_n¤|jjj}t|j j s¿t |j ddt ƒƒ}|s¯dS|j||ƒS|jƒ|j|jƒƒg|_|}|jƒ|_|jtd|ƒƒ|j|ƒjtƒ}|r4|jSdS(sÌ Delete the queryset in one SQL query (if possible). For simple queries this is done by copying the query.query.where to self.query, for complex queries by using subquery. Rtflatitpk__in(tquerytget_initial_aliasR talias_refcountRtmodelt_metaRRtfeaturestupdate_can_self_selecttlistt values_listtTrueR$tclear_select_clausetget_coltselectRRRRRRR( RR'Rtinnerqtttinnerq_used_tablesRtvaluesR((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyt delete_qs1s(    N(t__name__t __module__t__doc__tcompilerRtNoneR$R8(((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRs   cBs_eZdZdZd„Zd„Zd d„Zd„Zd„Z d„Z d„Z d „Z RS( s+ Represents an "update" SQL query. tSQLUpdateCompilercOs'tt|ƒj||Ž|jƒdS(N(tsuperR t__init__t _setup_query(Rtargstkwargs((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyR@\scCs1g|_d|_t|dƒs-i|_ndS(sÐ Runs on initialization and after cloning. Any attributes that would normally be set in __init__ should go in here, instead, so that they are also set up after a clone() call. trelated_updatesN(R7R=t related_idsthasattrRD(R((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRA`s  cKs(tt|ƒj|d|jjƒ|S(NRD(R?R tcloneRDtcopy(RtklassRC((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRGkscCsz|j|ƒxftdt|ƒtƒD]L}|jƒ|_|jtd|||t!ƒƒ|j|ƒj t ƒq&WdS(NiR&( tadd_update_valuesRRRRRRRRRR(RR R7RR#((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyt update_batchos  !cCsåg}xÏtj|ƒD]¾\}}|jƒj|ƒ}|joG|j pR|j }|jjj}| s}|j r|j rt d|ƒ‚n||jƒjk r¾|j |||ƒqn|j |||fƒqW|j|ƒS(s± 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. sMCannot update model field %r (only non-relations and foreign keys permitted).(Rt iteritemsRt get_fieldt auto_createdtconcreteR*R+tconcrete_modelt is_relationt many_to_manyRtadd_related_updatetappendtadd_update_fields(RR7t values_seqtnametvalR!tdirectR*((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRJvs cCs|jj|ƒdS(só 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. N(R7textend(RRV((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRUŒscCs)|jj|gƒj|d|fƒdS(s  Adds (name, value) to an update query for an ancestor model. Updates are coalesced so that we only run one update query per ancestor. N(RDt setdefaultRTR=(RR*R!tvalue((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRS”scCs„|js gSg}xjtj|jƒD]V\}}t|ƒ}||_|jdk ro|jd|jfƒn|j|ƒq&W|S(sâ Returns 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. R&N( RDRRLR R7RER=t add_filterRT(RtresultR*R7R'((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pytget_related_updatesœs   N( R9R:R;R<R@RAR=RGRKRJRURSR_(((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyR Us      cBs/eZdZd„Zdd„Zed„ZRS(tSQLInsertCompilercOs/tt|ƒj||Žg|_g|_dS(N(R?R R@tfieldstobjs(RRBRC((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyR@±s cKsLi|jd6|jd6|jd6}|j|ƒtt|ƒj||S(NRaRbtraw(RaRbRctupdateR?R RG(RRIRCtextras((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyRG¶s     cCs||_||_||_dS(s¢ Set up the insert query from the 'insert_values' dictionary. The dictionary gives the model field names and their target values. If 'raw_values' is True, the values in the 'insert_values' dictionary are inserted directly into the query, rather than passed as SQL parameters. This provides a way to insert NULL and DEFAULT keywords into the query, for example. N(RaRbRc(RRaRbRc((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyt insert_values¿s  N(R9R:R<R@R=RGtFalseRf(((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyR ®s  cBseZdZdZd„ZRS(s‰ An AggregateQuery takes another query as a parameter to the FROM clause and only selects the elements in the provided list. tSQLAggregateCompilercCs1|j|ƒjdtdtƒ\|_|_dS(Ntwith_col_aliasestsubquery(Rtas_sqlR0Rjt sub_params(RR'R((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyt add_subqueryÖs(R9R:R;R<Rm(((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pyR ÎsN(R;tdjango.core.exceptionsRt django.dbRtdjango.db.models.query_utilsRtdjango.db.models.sql.constantsRRRtdjango.db.models.sql.queryRt django.utilsRt__all__RR R R (((sm/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/django/db/models/sql/subqueries.pytsDY