Ñò
sÖIc @ sý d d k Z d d k Z d d k l Z d d k l Z l Z d d k l Z l Z d d k l
Z
l Z d d k l
Z
l Z y d d k Z Wn e j
o e d ƒ ‚ n Xe i e ƒ Z d e f d „ ƒ YZ d
e f d „ ƒ YZ d d
„ Z d S( iÿÿÿÿN( t datetime( t OpenResourceNamespaceManagert Container( t InvalidCacheBackendErrort MissingCacheParameter( t file_synchronizert null_synchronizer( t verify_directoryt SyncDicts? SQLAlchemy, which is required by this backend, is not installedt SqlaNamespaceManagerc B sƒ e Z e ƒ Z e ƒ Z d d d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z RS( c s× t i | | ƒ | o
| | _ n | o | d | _ n | i o t | i ƒ n | i i i t ˆ i ƒ ‡ f d † ƒ | _ | i i
i d ˆ i ˆ i f ‡ f d † ƒ | _ h | _
t | _ t | _ d S( sQ Create 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_lockc s ˆ S( ( ( ( t bind( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt * s s %s:%sc s ˆ S( ( ( ( t table( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyR , s N( R t __init__t lock_dirR t __class__t bindst gett strt urlR
t tablest nameR t hasht Falset _is_newt loaded( t selft namespaceR
R t data_dirR t kwargs( ( R
R s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyR
s
- c C s t ƒ S( N( R ( R ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt get_access_lock1 s c C s t d d | i d | i ƒ S( Nt
identifiers databasecontainer/funclock/%sR ( R R R ( R t key( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt get_creation_lock4 s
c C s | i o | | _ d St i | i i i g | i i i | i j ƒ } | i i | ƒ i
ƒ } | p t | _ h | _
nn t | _ y t i t | d ƒ ƒ | _
WnA t t t t i f j
o& t i d ƒ h | _
t | _ n X| | _ t | _ d S( Nt datas. Couln't load pickle data, creating new storage( R t flagst sat selectR t cR" R R
t executet fetchonet TrueR R R t cPicklet loadsR t IOErrort OSErrort EOFErrort PickleErrort logt debug( R R# R% t result( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt do_open9 s$
c
C sö | i d j oÙ | i d j p | i d j o¹ t i | i ƒ } | i oS | i i ƒ } | i i | d | i
d | d t i ƒ d t i ƒ ƒt
| _ qé | i i | i i i
| i
j ƒ } | i i | d | d t i ƒ ƒn d | _ d S( NR& t wR R" t accessedt created( R# t NoneR* t dumpsR R R t insertR
R' R R t nowR t updateR& ( R R" R9 R; ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt do_closeN s 0
$&c C sJ | i i | i i i | i j ƒ } | i i | ƒ h | _ t | _ d S( N( R t deleteR& R R
R' R R) R ( R R= ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt do_remove\ s $ c C s | i | S( N( R ( R R ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt __getitem__b s c C s | i i | ƒ S( N( R t has_key( R R ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt __contains__e s c C s | | i | R? RA RC RD RE ( ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyR s t
SqlaContainerc B s e Z e Z RS( ( RF RG R t namespace_manager( ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyRH r s t beaker_cachec C sy t i | | t i d t i d ƒ d t ƒt i d t i d t ƒt i d t i d t ƒt i d t i ƒ d t ƒƒ S( su Return a ``Table`` object suitable for storing cached values for the
namespace manager. Do not create the table.R iÿ t primary_keyR5 t nullableR6 R" ( R$ t Tablet Columnt StringR) t DateTimeR t BLOB( t metadatat
table_name( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt make_cache_tableu s
( R* t loggingR t beaker.containerR R t beaker.exceptionsR R t beaker.synchronizationR R t beaker.utilR R t
sqlalchemyR$ t ImportErrort getLoggerRF R0 R RH RT ( ( ( s3 /usr/lib/python2.6/site-packages/beaker/ext/sqla.pyt s a