ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
base
/
propertystore
/
Filename :
sql.pyc
back
Copy
� �t�ac @ s� d Z d g Z d d l m Z d d l m Z m Z m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z m Z d d l m Z m Z e j Z d e f d � � YZ d S( s PostgreSQL data store. t PropertyStorei����( t Memcacher( t Selectt Parametert Updatet Insertt TableSyntaxt Delete( t WebDAVDocument( t AllRetriesFailed( t schema( t AbstractPropertyStoret PropertyNamet validKey( t inlineCallbackst returnValuec B s� e Z d Z e d d e d e �Z d � Z e e j e j e j g d e d e j e d � k �Z e e j e j g d e d e j e d � k j e j e d � k � �Z d � Z e d � � Z e e e d d � � � Z e e d � � � Z e e d � � � Z e d � � Z d � Z e i e d � e j 6d e j e d � k j e j e d � k � j e j e d � k � �Z e i e d � e j 6e d � e j 6e d � e j 6e d � e j 6� Z d � Z e! e d e j e d � k j e j e d � k � j e j e d � k � �Z" d � Z# d � Z$ e! e d e j e d � k �Z% e d � � Z& e d � � Z' RS( su We are going to use memcache to cache properties per-resource/per-user. However, we need to be able to invalidate on a per-resource basis, in addition to per-resource/per-user. So we will also track in memcache which resource/uid tokens are valid. That way we can remove the tracking entry to completely invalidate all the per-resource/per-user pairs. s SQL.propst picklet key_normalizationc O s t d � � d S( Ns4 do not construct directly, call PropertyStore.load()( t NotImplementedError( t selft at kw( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt __init__6 s t Fromt Wheret resourceIDt viewerIDc C s d j | j | � S( Ns {0!s}/{1}( t formatt _resourceID( R t userid( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _cacheTokenH s c # sp t � � f d � � } | � j � V� j � j k rI | � j � Vn � j � j k rl | � j � Vn d S( s� Load, or re-load, this object with the given transaction; first from memcache, then pulling from the database again. c 3 sA d } � j d k rw � j j t � j � � V} | d k rI t � } n | | k rw � j j � j | � � V} qw n | d k r� j j � d � j d | �V} � j d k r� j j � j | � | d k r� | n d � V| j | � � j j t � j � | � Vqn x' | D] \ } } | � j | | f <qWd S( NR R ( ( t Nonet _cachert gett strR t setR t _allWithIDViewert ont addt _cached( t uidt rowst valid_cached_userst namet value( R t txn( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _cache_user_propsT s$ " / #N( R t _defaultUsert _perUsert _proxyUser( R R- R. ( ( R R- s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _refreshK s c c s� | j | � } t t | � j | | | � | | _ | | _ | j j � j � s^ d | _ n i | _ | s~ | j | � Vn | | _ t | � d S( s~ @param notifyCallback: a callable used to trigger notifications when the property store changes. N( t __new__t superR R t _txnR t storet queryCachingEnabledR R R' R2 t _notifyCallbackR ( t clst defaultusert shareUsert proxyUserR- R t createdt notifyCallbackR ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt loadz s c c s� t | j j � } t | t j t j t j t j g d t j | t j | k d � d | | k �} | j | � V} | j | | | | | � } t | � d S( s. Load all property stores for all objects in a collection. This is used to optimize Depth:1 operations on that collection, by loading all relevant properties in a single query. @param defaultUser: the UID of the user who owns / is requesting the property stores; the ones whose per-user properties will be exposed. @type defaultUser: C{str} @param txn: the transaction within which to fetch the rows. @type txn: L{IAsyncTransaction} @param childColumn: The resource ID column for the child resources, i.e. the resources of the type for which this method will loading the property stores. @param parentColumn: The resource ID column for the parent resources. e.g. if childColumn is addressbook object's resource ID, then this should be addressbook's resource ID. @return: a L{Deferred} that fires with a C{dict} mapping resource ID (a value taken from C{childColumn}) to a L{PropertyStore} for that ID. R t rightR N( R t modelt tableR t propt RESOURCE_IDt NAMEt VIEWER_UIDt VALUEt joinR% t _createMultipleStoresR ( R9 t defaultUsert shareeUserR< R- t childColumnt parentColumnt parentIDt childTablet queryR) t stores( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt forMultipleResources� s c c s� t t j t j t j t j g d t d t j j t d t | � � � �} | j | d | �V} | j | | | | | � } xm | D]e } | | k r� | j | � } t t | � j | | | � | | _ | | _ i | _ | | | <q� q� Wt | � d S( s� Load all property stores for all specified resources. This is used to optimize Depth:1 operations on that collection, by loading all relevant properties in a single query. Note that the caller of this method must make sure that the number of items being queried for is within a reasonable batch size. If the caller is itself batching related queries, that will take care of itself. @param defaultUser: the UID of the user who owns / is requesting the property stores; the ones whose per-user properties will be exposed. @type defaultUser: C{str} @param txn: the transaction within which to fetch the rows. @type txn: L{IAsyncTransaction} @param resourceIDs: The set of resource ID's to query. @return: a L{Deferred} that fires with a C{dict} mapping resource ID (a value taken from C{childColumn}) to a L{PropertyStore} for that ID. R R t resourceIDsN( R RC RD RE RF RG t InR t lenR% RI R3 R4 R R R5 R R' R ( R9 RJ RK R< R- RS RP R) RQ R R6 ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt# forMultipleResourcesWithResourceIDs� s $ c C s5 i } x(| D] } t | � d k r= | \ } } } } } n d } | \ } } } } | r� | | k r� | j | � } t t | � j | | | � | | _ | | _ i | _ | | | <n | | | j | | f <q | r | j | � } t t | � j | | | � | | _ | | _ i | _ | | | <q q W| S( sG Create a set of stores for the set of rows passed in. i N( RU R R3 R4 R R R5 R R' ( R9 RJ RK R< R- R) t createdStorest rowt object_resource_idt resource_idR+ t view_uidR, R6 ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyRI � s. c C sW t | � y | j | j � | f } Wn t k rF t | � � n Xt j | � j S( N( R R' t toStringt KeyErrorR t fromStringt root_element( R t keyR( R, ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _getitem_uid s R, R+ R( c s� t | � | j � � | j � � g � � � f � j k g � � � j � � f <t � � � � � � f d � � } t � d � r� � j d k r� � j j � j � n � f d � } � j j | � j | � d S( Nc 3 s� � r0 � j | � V� � f � j k g � (n � j t � � d rv � j j | d � j d � d � d � �Vn, � j j | d � j d � d � d � �V� j d k r� � j j � j � � � n d S( Ni R R, R+ R( ( R2 R' t appendt Truet _updateQueryR% R t _insertQueryR R t deleteR ( R- ( t key_strR t triedR( t value_strt wasCached( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt trySetItem% s R8 c s! | j t � � j j d � d S( Ns, setting a property failed; probably nothing.( t trapR t logt error( t f( R ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt justLogIt= s ( R R\ t toxmlR' R t hasattrR8 R R5 t preCommitt subtransactiont addErrback( R R` R, R( Rk Rp ( ( Rg R Rh R( Ri Rj s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _setitem_uid s $ c s� t � � � j � � � j � � f =t � � � � f d � � } t � d � rx � j d k rx � j j � j � n � f d � } � j j | � j | � d S( Nc 3 sa � j j | � f d � d � j d � d � �V� j d k r] � j j � j � � � n d S( Nc s t � � S( N( R] ( ( R` ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt <lambda>Q t R R+ R( ( t _deleteQueryR% R R R Rf R ( R- ( R` Rg R R( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt doItN s R8 c s! | j t � � j j d � d S( Ns, setting a property failed; probably nothing.( Rl R Rm Rn ( Ro ( R ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyRp _ s ( R R\ R' R Rr R8 R R5 Rs Rt Ru ( R R` R( Rz Rp ( ( R` Rg R R( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _delitem_uidH s c c sA x: | j j � D]) \ } } | | k r t j | � Vq q Wd S( N( R' t keysR R^ ( R R( t cachedKeyt cachedUID( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _keys_uidd s c c sU i | _ | j j | j d | j �V| j d k rQ | j j t | j � � n d S( NR ( R' t _deleteResourceQueryR% R5 R R R Rf R" ( R ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt _removeResourcem s c c s | j j | j d | j �V} x� | D]� \ } } } | | f | j k g } | d r� | j j | j d | j d | d | d | �Vq& | j j | j d | j d | d | d | �Vq& Wi | _ | j d k r� | j j t | j � � n | j | j � Vd S( s� Copy all the properties from another store into this one. This needs to be done independently of the UID. R i R, R+ R( N( t _allWithIDR% R5 R R' Rd Re R R Rf R" R2 ( R t otherR) Rg R( Ri Rj ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt copyAllPropertiesw s N(( t __name__t __module__t __doc__R Rc t FalseR R R RC RE RF RG RD R R� t AndR$ R R R2 t classmethodR R? RR RV RI Ra R Rd R Re Rv R Ry R{ R R� R� R� ( ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyR , sT /*, ( N( R� t __all__t twistedcaldav.memcacherR t twext.enterprise.dal.syntaxR R R R R R t txdav.xml.parserR t txdav.common.icommondatastoreR t! txdav.common.datastore.sql_tablesR t txdav.base.propertystore.baseR R R t twisted.internet.deferR R t RESOURCE_PROPERTYRC R ( ( ( s/ /opt/cpanel-ccs/txdav/base/propertystore/sql.pyt <module> s .