HEX

File: //proc/self/root/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyc
�
7Y�Kc@s�ddlZddlZddlZddlmZddlmZmZddlmZm	Z	ddl
mZmZddl
mZmZeje�Zdadefd��YZd	efd
��YZdd�ZdS(
i����N(tdatetime(tOpenResourceNamespaceManagert	Container(tInvalidCacheBackendErrortMissingCacheParameter(tfile_synchronizertnull_synchronizer(tverify_directorytSyncDicttSqlaNamespaceManagercBs�eZe�Ze�Zed��Zddd�Zd�Z	d�Z
d�Zd�Zd�Z
d�Zd�Zd	�Zd
�Zd�ZRS(
cCsDtdk	rdSyddlaWntk
r?td��nXdS(Ni����s?SQLAlchemy, which is required by this backend, is not installed(tsatNonet
sqlalchemytImportErrorR(tcls((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt_init_dependenciess
cs�tj||�|r"||_n|r8|d|_n|jrQt|j�n|jjjt�j��fd��|_	|jj
jd�j�jf�fd��|_i|_
t|_t|_dS(sQCreate a namespace manager for use with a database table via
        SQLAlchemy.

        ``bind``
            SQLAlchemy ``Engine`` or ``Connection`` object

        ``table``
            SQLAlchemy ``Table`` object in which to store namespace data.
            This should usually be something created by ``make_cache_table``.
        s/container_db_lockcs�S(N(((tbind(s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt<lambda>4ss%s:%scs�S(N(((ttable(s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyR6sN(Rt__init__tlock_dirRt	__class__tbindstgettstrturlRttablestnameRthashtFalset_is_newtloaded(tselft	namespaceRRtdata_dirRtkwargs((RRs@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyRs	-		cCst�S(N(R(R ((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pytget_access_lock;scCstdd|jd|j�S(Nt
identifiersdatabasecontainer/funclock/%sR(RR!R(R tkey((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pytget_creation_lock>s
c	Cs�|jr||_dStj|jjjg|jjj|jk�}|jj	|�j
�}|syt|_i|_
nbt|_y|d|_
WnEttttjtjfk
r�tjd�i|_
t|_nX||_t|_dS(Ntdatas.Couln't load pickle data, creating new storage(RtflagsR
tselectRtcR(R!RtexecutetfetchonetTrueRRRtIOErrortOSErrortEOFErrortcPickletPickleErrortpickletlogtdebug(R R)R*tresult((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pytdo_openCs&				
	
	cCs�|jdk	r�|jdks-|jdkr�|jr�|jj�}|jj|d|jd|jdt	j
�dt	j
��t|_q�|jj|jj
j|jk�}|jj|d|jdt	j
��nd|_dS(NR+twR!R(taccessedtcreated(R)RRRtinsertRR,R!RRtnowRtupdateR+(R R<R>((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pytdo_closeYs-	!$(cCsJ|jj|jjj|jk�}|jj|�i|_t|_dS(N(	RtdeleteR+R!RR,RR.R(R R@((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt	do_removees$	cCs|j|S(N(R(R R&((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt__getitem__kscCs|jj|�S(N(Rthas_key(R R&((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt__contains__nscCs||j|<dS(N(R(R R&tvalue((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt__setitem__qscCs|j|=dS(N(R(R R&((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt__delitem__tscCs
|jj�S(N(Rtkeys(R ((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyRHwsN(t__name__t
__module__RRRtclassmethodRRRR$R'R8R?RARBRDRFRGRH(((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyR	s											t
SqlaContainercBseZeZRS((RIRJR	tnamespace_manager(((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyRL{stbeaker_cachecCsvtj||tjdtjd�dt�tjdtjdt�tjdtjdt�tjdtjdt��S(suReturn a ``Table`` object suitable for storing cached values for the
    namespace manager.  Do not create the table.R!i�tprimary_keyR:tnullableR;R((R
tTabletColumntStringR.tDateTimeRt
PickleType(tmetadatat
table_name((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pytmake_cache_table~s
(R2tloggingR4Rtbeaker.containerRRtbeaker.exceptionsRRtbeaker.synchronizationRRtbeaker.utilRRt	getLoggerRIR5RR
R	RLRX(((s@/opt/alt/python27/lib/python2.7/site-packages/beaker/ext/sqla.pyt<module>sk