Ñò
Š„[Jc @ s‹ d Z d d k l Z d d k l Z d e f d „ ƒ YZ d e i f d „ ƒ YZ d e i f d „ ƒ YZ
d
e i f d „ ƒ YZ d S(
s: Provides a thread-local transactional wrapper around the root Engine class.
The ``threadlocal`` module is invoked when using the ``strategy="threadlocal"`` flag
with :func:`~sqlalchemy.engine.create_engine`. This module is semi-private and is
invoked automatically when the threadlocal engine strategy is used.
iÿÿÿÿ( t util( t baset TLSessionc B sz e Z d „ Z e d „ Z d „ Z d „ Z d „ Z d „ Z d d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z RS(
c C s | | _ d | _ d S( Ni ( t enginet _TLSession__tcount( t selfR ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt __init__ s c C sM y | i i ƒ SWn5 t j
o) | i i | | i i i ƒ d | ƒSXd S( Nt close_with_result( t _TLSession__transactiont _increment_connectt AttributeErrorR t TLConnectiont poolt connect( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt get_connection s c C s@ y | i i ƒ | ` | ` Wn t j
o n Xd | _ d S( Ni ( R t _force_closet _TLSession__transR
R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt reset s
c C s2 | i d j o | i i i ƒ | i ƒ n d S( Ni ( R R t _transt rollbackR ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt _conn_closed s c C s
| i d j S( Ni ( R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt in_transaction$ s c C s( | i d j o | i i i ƒ n d S( Ni ( R R R t prepare( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR ' s c C sQ | i d j o+ | i ƒ | _ | i i d | ƒ | _ n | i d 7_ | i S( Ni t xidi ( R R R t _begin_twophaseR ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt begin_twophase+ s
c K sN | i d j o( | i ƒ | _ | i i | | _ n | i d 7_ | i S( Ni i ( R R R t _beginR ( R t kwargs( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt begin2 s
c C s: | i d j o& z | i i i ƒ Wd | i ƒ Xn d S( Ni ( R R R R R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR 9 s c C s] | i d j o& z | i i i ƒ Wd | i ƒ Xn$ | i d j o | i d 8_ n d S( Ni ( R R R t commitR ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR @ s c C sE | i d j o | i ƒ n$ | i d j o | i d 8_ n d S( Ni ( R R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt closeI s c C s
| i d j S( Ni ( R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt is_begunO s N( t __name__t
__module__R t FalseR R R R R t NoneR R R R R R ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR s R c B s† e Z d „ Z d „ Z d „ Z e e ƒ Z d „ Z d „ Z d d „ Z d „ Z
d „ Z d d „ Z d „ Z
d
„ Z d „ Z RS(
c K s2 t i i | | i | | | | _ d | _ d S( Ni ( R t
ConnectionR R t _TLConnection__sessiont _TLConnection__opencount( R t sessiont
connectionR ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR T s c C s | i i | i | i d t ƒS( Nt _branch( R R$ R( t True( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR) Y s c C s | i S( N( R% ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR' \ s c C s | i d 7_ | S( Ni ( R& ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR ` s c K s" t t t | ƒ i | | i ƒ S( N( t
TLTransactiont superR R R% ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR d s c C s% t t t | ƒ i d | ƒ | i ƒ S( NR ( R+ R, R R R% ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR h s c C s
| i i ƒ S( N( R' R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR l s c K s | i i | S( N( R' R ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR o s c C s | i i d | ƒ S( NR ( R' R ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR r s c C s t d ƒ ‚ d S( Ns6 SAVEPOINT transactions with the 'threadlocal' strategy( t NotImplementedError( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt begin_nestedu s c C sD | i d j o! t i i | ƒ | i i ƒ n | i d 8_ d S( Ni ( R& R R$ R R% R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR x s c C s d | _ t i i | ƒ d S( Ni ( R& R R$ R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR ~ s N( R R! R R) R' t propertyR R R# R R R R R. R R ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR S s R+ c B sq e Z d „ Z d „ Z e e ƒ Z d „ Z e e ƒ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z RS( c C s | | _ | | _ d S( N( R t _session( R t transR' ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR „ s c C s
| i i S( N( R R( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR( ˆ s c C s
| i i S( N( R t is_active( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR2 Œ s c C s | i i ƒ d S( N( R0 R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR s c C s | i i ƒ d S( N( R0 R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR “ s c C s | i i ƒ d S( N( R0 R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR – s c C s | i i ƒ d S( N( R0 R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR ™ s c C s | S( N( ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt __enter__œ s c C s | i i | | | ƒ d S( N( R t __exit__( R t typet valuet traceback( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR4 Ÿ s ( R R! R R( R/ R2 R R R R R3 R4 ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR+ ƒ s t TLEnginec B st e Z d Z d „ Z d „ Z e e ƒ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d
„ Z
RS( s An Engine that includes support for thread-local managed transactions.
The TLEngine relies upon its Pool having "threadlocal" behavior,
so that once a connection is checked out for the current thread,
you get that same connection repeatedly.
c O sg t t | ƒ i | | Ž t i i ƒ | _ | i d ƒ } | o t i t
| ƒ | _
n
t
| _
d S( s Construct a new TLEngine.t proxyN( R, R8 R R t threadingt localt contextt getR t _proxy_connection_clsR ( R t argsR R9 ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR « s c C s3 t | i d ƒ p t | ƒ | i _ n | i i S( s& Returns the current thread's TLSessionR' ( t hasattrR< R R' ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR' · s c K s | i i | S( s5 Return a TLConnection which is thread-locally scoped.( R' R ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt contextual_connect¿ s c K s | i i | S( N( R' R ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR Ä s c C s t d ƒ ‚ d S( Ns6 SAVEPOINT transactions with the 'threadlocal' strategy( R- ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR. Ç s c K s | i i | S( N( R' R ( R R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR Ê s c C s | i i ƒ d S( N( R' R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR Í s c C s | i i ƒ d S( N( R' R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR Ð s c C s | i i ƒ d S( N( R' R ( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR Ó s c C s d t | i ƒ S( Ns TLEngine(%s)( t strt url( R ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt __repr__Ö s ( R R! t __doc__R R' R/ RA R R. R R R R RD ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyR8 £ s N(
RE t
sqlalchemyR t sqlalchemy.engineR t objectR R$ R t TransactionR+ t EngineR8 ( ( ( sA /usr/lib/python2.6/site-packages/sqlalchemy/engine/threadlocal.pyt s H0