ó ¿b›]c@shdZddlZddlmZddlmZdejfd„ƒYZd ejfd „ƒYZdS( s8Provides 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ÿÿÿÿNi(tbasei(tutilt TLConnectioncBs,eZd„Zd„Zd„Zd„ZRS(cOs&tt|ƒj||Žd|_dS(Ni(tsuperRt__init__t_TLConnection__opencount(tselftargtkw((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyRscCs|jd7_|S(Ni(R(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyt_increment_connectscCs5|jdkr"tjj|ƒn|jd8_dS(Ni(RRt Connectiontclose(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR scCsd|_tjj|ƒdS(Ni(RRR R (R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyt _force_close$s (t__name__t __module__RR R R (((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyRs   tTLEnginecBs¶eZdZeZejddƒd„ƒZd„Zd„Z dd„Z d„Z d„Z d „Zd „Zd „Zd „Zd „Zd„Zed„ƒZd„Zd„ZRS(sPAn Engine that includes support for thread-local managed transactions. s1.3sThe 'threadlocal' engine strategy is deprecated, and will be removed in a future release. The strategy is no longer relevant to modern usage patterns (including that of the ORM :class:`.Session` object) which make use of a :class:`.Connection` object in order to invoke statements.cOs/tt|ƒj||Žtjjƒ|_dS(N(RRRRt threadingtlocalt _connections(Rtargstkwargs((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR1s cKs |j|S(N(t_contextual_connect(RR((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pytcontextual_connect=scKsˆt|jdƒsd}n|jjƒ}|dks?|jr~|j||j|jj|ƒ|}t j |ƒ|j_n|j ƒS(Ntconn( thasattrRtNoneRtclosedt_tl_connection_clst_wrap_pool_connecttpooltconnecttweakreftrefR (RRt connection((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR@s  cCsJt|jdƒs!g|j_n|jjj|jƒjd|ƒƒ|S(Nttranstxid(RRR"tappendRtbegin_twophase(RR#((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR%Rs  cCsDt|jdƒs!g|j_n|jjj|jƒjƒƒ|S(NR"(RRR"R$Rt begin_nested(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR&Zs  cCsDt|jdƒs!g|j_n|jjj|jƒjƒƒ|S(NR"(RRR"R$Rtbegin(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR'bscCs|S(N((R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyt __enter__hscCs'|dkr|jƒn |jƒdS(N(Rtcommittrollback(Rttype_tvaluet traceback((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyt__exit__ks  cCs<t|jdƒ s |jj r$dS|jjdjƒdS(NR"iÿÿÿÿ(RRR"tprepare(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR/qs cCsGt|jdƒ s |jj r$dS|jjjdƒ}|jƒdS(NR"iÿÿÿÿ(RRR"tpopR)(RR"((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR)ys  cCsGt|jdƒ s |jj r$dS|jjjdƒ}|jƒdS(NR"iÿÿÿÿ(RRR"R0R*(RR"((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR*‚s  cCs)tjjƒ|_tt|ƒjƒdS(N(RRRRRRtdispose(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR1‹scCs8t|jdƒ p7|jjƒdkp7|jjƒjS(NR(RRRRR(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyRscCsN|jsJ|jƒjƒ|jjƒ}|jƒ|j`g|j_ndS(N(RRR RRR R"(RR!((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR —s    cCs d|jS(Ns TLEngine(%r)(turl(R((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyt__repr__ŸsN(R Rt__doc__RRRt deprecatedRRRRR%R&R'R(R.R/R)R*R1tpropertyRR R3(((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyR)s&          ( R4RtRRR RtEngineR(((s<lib/python2.7/site-packages/sqlalchemy/engine/threadlocal.pyts