Ñò
…=vIc @ sí d d k Z d d k l Z d d k l Z l Z d d k l Z d d k l
Z
d Z d Z d Z
e Z e d g ƒ Z h Z d
e f d „ ƒ YZ d e f d
„ ƒ YZ d d d „ ƒ YZ e d „ Z d „ Z d e f d „ ƒ YZ d S( iÿÿÿÿN( t
implements( t ISavepointDataManagert IDataManagerSavepoint( t SessionExtension( t Enginet activet changedt readonlyt sqlitet SessionDataManagerc B s e Z d Z e e ƒ d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
e d
„ ƒ Z d „ Z RS( sm Integrate a top level sqlalchemy session transaction into a zope transaction
One phase variant.
c C s< | i i ƒ d | _ | | _ | t t | ƒ s c C s | i i ƒ d S( N( R t flush( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt tpc_beginB s c C s5 t t | i ƒ } | t j o | i d ƒ n d S( Ns no work( R R R t STATUS_INVALIDATEDR ( R R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt commitE s
c C s2 | i d j o | i i ƒ | i d ƒ n d S( Nt committed( R
R R R ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt tpc_voteJ s
c C s d S( N( ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt
tpc_finishP s c C s d S( N( ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt tpc_abortS s c C s d t | i ƒ S( Ns ~sqlalchemy:%d( R R
( R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt sortKeyV s c C sF t d „ | i i i i ƒ Dƒ ƒ i t ƒ o t d ƒ ‚ n | i S( sS Savepoints are only supported when all connections support subtransactions
c s s3 x, | ]% } t | t ƒ o | i i Vq q Wd S( N( t
isinstanceR t urlt
drivername( t .0t engine( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pys f s t savepoint( t setR R t _connectionst keyst intersectiont NO_SAVEPOINT_SUPPORTt AttributeErrort
_savepoint( R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR* \ s
c C s
t | i ƒ S( N( t SessionSavepointR ( R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR1 m s ( t __name__t
__module__t __doc__R R R R R R R R! R" R# R$ t propertyR* R1 ( ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR & s
t TwoPhaseSessionDataManagerc B s2 e Z d Z d „ Z d „ Z d „ Z d „ Z RS( s Two phase variant.
c C s. | i d j o | i i ƒ d | _ n d S( Nt voted( R
R t prepareR ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR! t s
c C s2 | i d j o | i i ƒ | i d ƒ n d S( NR ( R
R R R ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR" y s
c C s2 | i d j o | i i ƒ | i d ƒ n d S( Ns aborted commit( R
R t rollbackR ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR# ~ s
c C s d t | i ƒ S( Ns sqlalchemy.twophase:%d( R R
( R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR$ ƒ s ( R3 R4 R5 R! R" R# R$ ( ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR7 q s
R2 c B s$ e Z e e ƒ d „ Z d „ Z RS( c C s& | | _ | i ƒ | _ | i ƒ d S( N( R t begin_nestedR R ( R R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR ‹ s c C s | i i ƒ | i i ƒ d S( N( R R: R t clear( R ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR: s
( R3 R4 R R R R: ( ( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyR2 ˆ s
c C sZ t i t | ƒ d ƒ d j o7 | i o t p t } t i ƒ i | | | ƒ ƒ n d S( s: Join a session to a transaction using the appropriate datamanager.
It is safe to call this multiple times, if the session is already joined
then it just returns.
`initial_state` is either STATUS_ACTIVE, STATUS_INVALIDATED or STATUS_READONLY
If using the default initial status of STATUS_ACTIVE, you must ensure that
dirty_session(session) is called when data is written to the database.
The DirtyAfterFlush SessionExtension can be used to ensure that this is
called automatically after session write operations.
N( R t getR R t twophaseR7 R t zope_transactiont join( R t
initial_statet DataManager( ( s? /usr/lib/python2.6/site-packages/zope/sqlalchemy/datamanager.pyt join_transaction– s c C s t t t | ƒ s K