mò þ%ÜGc@sÑdklZlZlZlZlZdkZdkZdkZdk l Z l Z de fd„ƒYZ de ifd„ƒYZde ifd„ƒYZd e ifd „ƒYZd e ifd „ƒYZdS( (sschemas exceptionssutilssqlstypesN(sbasesdefaultt TLSessioncBsStZd„Zed„Zd„Zd„Zd„Zd„Zd„Z d„Z RS( NcCs||_d|_dS(Ni(tenginetselft_TLSession__tcount(RR((tA/home/holguin2/public_html/spyce/sqlalchemy/engine/threadlocal.pyt__init__ s cCs;y|iiƒSWn#tj ot|d|ƒSnXdS(Ntclose_with_result(Rt_TLSession__transactiont_increment_connecttAttributeErrort TLConnectionR(RR((Rtget_connection scCs@y|iiƒ|`|`Wntj onXd|_dS(Ni(RRt _force_closet_TLSession__transR R(R((Rtresets  cCs |idjS(Ni(RR(R((Rtin_transactionscCsK|idjo%|iƒ|_|iiƒ|_n|id7_|iS(Nii(RRR Rt_beginR (R((Rtbegins cCs7|idjo#z|iiƒWd|iƒXndS(Ni(RRR t_rollback_implR(R((Rtrollback"s cCsZ|idjo#z|iiƒWd|iƒXn$|idjo|id8_ndS(Ni(RRR t _commit_implR(R((Rtcommit(scCs |idjS(Ni(RR(R((Rtis_begun0s( t__name__t __module__RtFalseR RRRRRR(((RR s       R cBs_tZd„Zed„ƒZd„Zd„Zd„Zd„Zd„Z d„Z d „Z RS( NcCs2tii||id|ƒ||_d|_dS(NRi( tbaset ConnectionRRtsessionRRt_TLConnection__sessiont_TLConnection__opencount(RRR((RR4s cCs|iS(N(tsR(R((Rt8scCs|id7_|S(Ni(RR(R((RR9scCs t||ƒS(N(t TLTransactionRtparent(RR"((Rt_create_transaction<scCstii|ƒS(N(RRRR(R((RR>scCs |iiƒS(N(RRR(R((RR@scCs |iiƒS(N(RRR(R((RRBscCs7|idjotii|ƒn|id8_dS(Ni(RRRRtclose(R((RR$DscCsd|_tii|ƒdS(Ni(RRRRR$(R((RR Hs ( RRRtpropertyRRR#RRRR$R (((RR 3s       R!cBs,tZd„Zd„Zd„Zd„ZRS(NcCstii|ƒdS(N(Rt TransactionRR(R((RRMscCstii|ƒdS(N(RR&RR(R((RROscCs|iiiƒdS(N(Rt connectionRR(R((RRQscCs|iiiƒdS(N(RR'RR(R((RRSs(RRRRRR(((RR!Ls   tTLEnginecBshtZdZd„Zd„Zd„Zd„ZeeddƒZd„Z d„Z d „Z d „Z RS( s‘an Engine that includes support for thread-local managed transactions. This engine is better suited to be used with threadlocal Pool object.cOs,tt|ƒi||Žtiƒ|_dS(sÈthe TLEngine relies upon the ConnectionProvider having "threadlocal" behavior, so that once a connection is checked out for the current thread, you get that same connection repeatedly.N( tsuperR(RRtargstkwargstutilt ThreadLocaltcontext(RR*R+((RRYscCs |iiƒS(sreturns a DBAPI connection.N(Rtconnection_providerR (R((Rtraw_connection_scKsti||iiƒƒS(s‡returns a Connection that is not thread-locally scoped. this is the equilvalent to calling "connect()" on a ComposedSQLEngine.N(RRRR/tunique_connection(RR+((RtconnectbscCs3t|idƒpt|ƒ|i_n|iiS(NR(thasattrRR.RR(R((Rt_sessiongstdocs&returns the current thread's TLSessioncKs|ii|S(s6returns a TLConnection which is thread-locally scoped.N(RRR R+(RR+((Rtcontextual_connectmscCs |iiƒS(N(RRR(R((RRqscCs|iiƒdS(N(RRR(R((RRsscCs|iiƒdS(N(RRR(R((RRus( RRt__doc__RR0R2R4R%RR6RRR(((RR(Vs        tTLocalConnectionProvidercBstZd„ZRS(NcCs |iiƒS(N(Rt_poolR1(R((RR1ys(RRR1(((RR8xs(t sqlalchemytschemat exceptionsR,tsqlttypestStringIOtsystretsqlalchemy.engineRtdefaulttobjectRRR R&R!tEngineR(tPoolConnectionProviderR8(R@R8R R?RCRR,RARR!R=R<R(R>R;((Rt?s%* "