P'^c@sddlZddlZddlZddlZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZmZmZmZddlmZmZddlZddlmZmZddlmZdd lmZdd lmZm Z dd l!m"Z"dd l#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,m-Z-ddl.m/Z/m0Z0m1Z1m2Z2m3Z3ddl4m5Z5ddl6m7Z7m8Z8m9Z9ddl:m;Z;ddl<m=Z=m>Z>m?Z?ddl@mAZAddlBmCZCdddfZDiZEe8fddZFdZGdZHdeIfdYZJdZKejLZMd eIfd!YZNeOeOeOeOeOeOed"ZPed#ZQdS($iN(trandom(t select_keystcached_propertytoncetonce_pertmonkeytwrapstwalktchain(tlmaptmaptlcatt join_withi(tpickletmd5(t smart_strt force_text(tImproperlyConfigured(tDEFAULT_DB_ALIAS(tManagertModel(tQuerySet(tEmptyResultSet(tpre_savet post_savet post_deletet m2m_changed(t model_profiletsettingstALL_OPS(t monkey_mixt stamp_fieldstfunc_cache_keytcached_view_fabtfamily_has_profile(t get_prefix(t redis_clientthandle_connection_failuret load_script(tdnfs(tinvalidate_objtinvalidate_dicttno_invalidation(ttransaction_states(t cache_readt cached_astcached_view_astinstall_cacheopstc Csctj|rdStdtjd|||gdtj|dtj|dt|gdS(s Writes data to cache and creates appropriate invalidators. If precall_key is not the empty string, the data will only be cached if the precall_key is set to avoid caching stale data. Nt cache_thingtkeystargsitdefault( R+tis_dirtyR&Rt CACHEOPS_LRUR tdumpstjsontstr(tprefixt cache_keytdatat cond_dnfsttimeouttdbst precall_key((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR1#s cs|jdd|jdd}|jdt|jdd|jdt|sotdn|rtddj|nt|d krt|d trd Sd }t ||}td |Dt t t t |g|D]}|jdt^q j|dkrZtd|Dndkrtd|Dnfd}|S(sG Caches results of a function and invalidates them same way as given queryset(s). NOTE: Ignores queryset cached ops settings, always caches. If keep_fresh is True, this will prevent caching if the given querysets are invalidated during the function call. This prevents prolonged caching of stale data. R>textratkey_functlockt keep_freshs3Pass a queryset, a model or an object to cache likesUnexpected keyword arguments %ss, iicSs|S(N((tfunc((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytNR0cSsqt|tr-|jjjd|j}n6t|tr]t|tr]|jj}n|}|j |S(Ntpk( t isinstanceRt __class__tobjectstfilterRGttypet issubclasstallt_require_cacheprofile(tsampletqueryset((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt _get_querysetPs cSsh|]}|jqS((tdb(t.0tqs((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pys ]s R:css|]}|jdVqdS(R>N(t _cacheprofile(RTRU((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pys bscss|]}|jdVqdS(RCN(RV(RTRU((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pys dsc s4tfd}|S(NcsHtj stjr&||Stddd}|d||}tj|d}tjdddd|dk |dk rt j |Sr||t g}|d|}t ||d dnd }||}t |||dd ||SWdQXdS( NREt _cond_dnfsR?sas:RCtsenderthitsasp:tPRECALLR0R@(RtCACHEOPS_ENABLEDR+R5R#R$tgettingR,tsendtNoneR tloadsRR1(R3tkwargsR:R;t cache_datatsuffixR@tresult(R=R?RERDt key_extraRBRCR>(s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytwrappergs" "  (R(RERe(R=R?RDRdRBRCR>(REs0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt decoratorfs0"N(tpopR^R tFalset TypeErrortjointlenRHtlistR R R R R't _cache_keytappendtmintany(tsamplesR`RARRt querysetsRURf((R=R?RDRdRBRCR>s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR-8s. % %   !$cOstt||S(N(R!R-(RqR`((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR.st QuerySetMixincBs.eZedZedZdZedZedZedZ dZ dZ ddddZ d Zd d Zd ZejdkrdZdZndedZdedZdZdZdZdZdZdZdZdZdZRS(cCs#t|j}|r|jSdS(N(RtmodeltcopyR^(tselftprofile((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRVscCsdS(Ni((Rv((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt_cloningscCs>|jdkr:td|jjj|jjjfndS(Ns|Cacheops is not enabled for %s.%s model. If you don't want to cache anything by default you can configure it with empty ops.(RVR^RRtt_metat app_labelt model_name(Rv((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyROscCst}|jd|jj|jjf|jd|jj|jjf|jt|jym|jj|j j \}}y||}Wn$t k r|t t |}nX|jt|Wntk rnX|jr|jd r|j|j nt|dd}|rH|jd|j|jfnt|drp|jt|jnd|j}|r|j|S|S(s7 Compute a cache key for this queryset s%s.%st db_agnostict_iterable_classtflatsq:%sN(RtupdateRIt __module__t__name__RtRtqueryt get_compilerRStas_sqltUnicodeDecodeErrorRRRRRVtgetattrR^thasattrR9R~t hexdigestt_prefix(RvR:tmdtsqltparamstsql_strtit_classR;((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRms, ##!   cCs td|S(Nt _queryset(R#(Rv((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRscCs t|S(N(R'(Rv((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRWscCs3t|j|||j|jdd|jgdS(NR>R?(R1RRWRVRS(RvR;tresults((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt_cache_resultsscCsAtjo@|jo@||jdko@|j o@t|jj S(Ntops(RR[RVt _for_writeR+RSR5(Rvtop((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt _should_caches  cCs|j|dks"|dkr+t}nt|trF|h}nt||jd<|dk ru||jdRCN(ROR^RRHR9tsetRV(RvRR>RC((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytcaches     cCs'|jdkr|S|jdgSdS(sI Convinience method, turns off caching for this queryset RN(RVR^R(Rv((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytnocachesicCs ||_|S(N(Rx(Rvtcloning((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRs cCs |jdS(Ni(R(Rv((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytinplacesii cKs.|jr|j|S|jj||SdS(N(Rxtclonet__dict__R(RvR`((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt_clones  cKs_|jj||}|jr+|jdnd|_|jjdr[|jj|_n|S(NiiRV(t _no_monkeyRRxRtgetRVRu(RvR`R((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR s c s}jrj|||S|dk rejjfd}|j_j|||Sjj|SdS(Ncsj_jS(N(RR((toriginal_query_cloneRv(s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt query_clones (RxRR^RRR(RvtklasstsetupR`R((RRvs0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRs    cKse|jj||||}|jr1|jdnd|_|jjdra|jj|_n|S(NiiRV(RRRxRRRVRu(RvRRR`R((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR$s c Cs|jdk s|jd r/|jj|S|j}|jd}tj|d|}t j d|j ddd|dk |dk rt j ||_nRt|drt|j||_nt|j|_|j||jWdQX|jj|S(NtfetchRCRXRERYR}(t _result_cacheR^RRt _fetch_allRmRVR$R\R,R]RtR R_RRlR}titeratorR(RvR;RCRa((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR,s  % cs[jdrGjdk r+tjStfdSjjSdS(NtcountcsjjS(N(RR((Rv(s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRFKR0(RRR^RkR-RR(Rv((Rvs0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyREs  csjdrjxD]}||js tpk__inR( RRRRRlRRtRJRKRRSRR((RvR`RRJtrowstpkst new_objectsR((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytinvalidated_updates  $N(ii (RRRRVRxRORRmRRWRRR^RRRRtdjangotVERSIONRRRhRRRRRRRRR(((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRss4  "         )    cCs>|j}g|_|j|d|dt|j|7_dS(NRXtweak(t receiverstconnectRh(tsignaltreceiverRXt old_receivers((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt connect_firsts  t ManagerMixincBseeZeddZdZdZdZdZdZdZ dZ d Z RS( tclscCs~tt|jd|tt|jd|tt|jd|tj|j }t ||j szt ||j |ndS(NRX( RRt _pre_saveRt _post_saveRt _post_deletetsystmodulesRRRtsetattr(RvRtmodule((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt_install_cacheopss cCsE|jj||||jdkrAt|rA|j|ndS(Nt__fake__(Rtcontribute_to_classRR"R(RvRtname((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRscKsw|jdkp!|jjp!tjssy5|jj|jd|jt j ||jf,sR(RRR(ii (RR(Ryt auto_createdRRtnextt many_to_manytm2m_column_nametm2m_reverse_nameRJRRKRGR(R)(RXRRttactiontpk_settreverseRR`Rtinstance_columnt model_columnRJRRG((RRXs0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytinvalidate_m2ms*    / %      c s$ttttttddlm}x|jdtD]}t |r=t |j tst d|j j|j jfn|j j|tjdkrdnd}d |j jd tD}xl|D]a}t|d r|nt|||}|jj }tjtd |jd |j|jfqWq=q=W|jdrddlm}t|fdntjrddl }|j!t"dntj#rddl$} | j!t%dndt&j'kodknr ddl(m)fd} | _*ndS(s6 Installs cacheops by numerous monkey patches i(tappstinclude_auto_createdsRCan't install cacheops for %s.%s model: non-django model class or manager is used.ii RRcss|]}|jr|VqdS(N(R(RTR((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pys Wstinclude_hiddenRRXt dispatch_uidsdjango.contrib.admin(t ModelAdmincsj||jS(N(toriginalR(Rvtrequest(R(s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRbsNcSstt|ffS(N(tbuffertbytes(tb((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRFiR0cSstt|ffS(N(t memoryviewR(R ((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyRFlR0ii(tQcs9t|jdt|tt|jdS(NR(tsupert__init__RlRR(RvR3R`(R (s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyt Q__init__rs(ii (ii(ii(+RRRRRst django.appsRt get_modelsRR"RHt_default_managerRRyRzR{RRRt get_fieldsRRRRRRt is_installedtdjango.contrib.admin.optionsRRtsixtPY2tcopy_regR RtPY3tcopyregR Rt version_infotdjango.db.models.query_utilsR R ( RRttrel_attrtm2msRRtoptsRRRR((R Rs0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pyR/As:    '     (RRR8t threadingRRtfuncyRRRRRRRRt funcy.py3R R R R tcrossR RRtdjango.utils.encodingRRtdjango.core.exceptionsRt django.dbRtdjango.db.modelsRRtdjango.db.models.queryRt#django.db.models.sql.datastructuresRtdjango.db.models.signalsRRRRtconfRRRtutilsRRR R!R"tshardingR#tredisR$R%R&ttreeR't invalidationR(R)R*t transactionR+tsignalsR,t__all__RR1R-R.tobjectRsRtlocalRRR^RR/(((s0/tmp/pip-unpacked-wheel-CLcuMp/cacheops/query.pytsJ    :" "( U "  ` %