³ņ ®d|Mc @s‚dZddkZddkZddkZddklZlZddklZddk lZl Z l Z l Z hZ d„Zd„Zdeifd „ƒYZd efd „ƒYZdd „ZeƒZd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(s{Connection pooling for DB-API connections. Provides a number of connection pool implementations for a variety of usage scenarios and thread behavior requirements imposed by the application, DB-API or database itself. Also provides a DB-API 2.0 connection proxying mechanism allowing regular DB-API connect() methods to be transparently managed by a SQLAlchemy connection pool. i’’’’N(texctlog(tqueue(t threadingtpicklet as_interfacetmemoized_propertycKs?y t|SWn,tj o ti|t||ƒSnXdS(sIReturn a proxy for a DB-API module that automatically pools connections. Given a DB-API 2.0 module and pool management parameters, returns a proxy for the module that will automatically pool connections, creating new connection pools for each distinct set of connection arguments sent to the decorated module's connect() function. :param module: a DB-API 2.0 database module :param poolclass: the class used by the pool module to provide pooling. Defaults to :class:`QueuePool`. :param \*\*params: will be passed through to *poolclass* N(tproxiestKeyErrort setdefaultt_DBProxy(tmoduletparams((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytmanages cCs/xtiƒD]}|iƒq WtiƒdS(sYRemove all current DB-API 2.0 managers. All pools and connections are disposed. N(Rt itervaluestclosetclear(tmanager((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytclear_managers1s tPoolcBsŒeZdZddededd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „Zd „Zd „Zd „ZRS(s)Abstract base class for connection pools.i’’’’c CsŅ|o||_|_n d|_ti|d|ƒ|_tiƒ|_||_ ||_ ||_ ||_ ||_ g|_g|_g|_g|_g|_|o"x|D]}|i|ƒq³WndS(sł Construct a Pool. :param creator: a callable function that returns a DB-API connection object. The function will be called with parameters. :param recycle: If set to non -1, number of seconds between connection recycling, which means upon checkout, if this timeout is surpassed the connection will be closed and replaced with a newly opened connection. Defaults to -1. :param logging_name: String identifier which will be used within the "name" field of logging records generated within the "sqlalchemy.pool" logger. Defaults to a hexstring of the object's id. :param echo: If True, connections being pulled and retrieved from the pool will be logged to the standard output, as well as pool sizing information. Echoing can also be achieved by enabling logging for the "sqlalchemy.pool" namespace. Defaults to False. :param use_threadlocal: If set to True, repeated calls to :meth:`connect` within the same application thread will be guaranteed to return the same connection object, if one has already been retrieved from the pool and has not been returned yet. Offers a slight performance advantage at the cost of individual transactions by default. The :meth:`unique_connection` method is provided to bypass the threadlocal behavior installed into :meth:`connect`. :param reset_on_return: If true, reset the database state of connections returned to the pool. This is typically a ROLLBACK to release locks and transaction resources. Disable at your own peril. Defaults to True. :param listeners: A list of :class:`~sqlalchemy.interfaces.PoolListener`-like objects or dictionaries of callables that receive events when DB-API connections are created, checked out and checked in to the pool. techoflagN(t logging_namet_orig_logging_nametNoneRtinstance_loggertloggerRtlocalt _threadconnst_creatort_recyclet_use_threadlocalt_reset_on_returntechot listenerst _on_connectt_on_first_connectt _on_checkoutt _on_checkint add_listener( tselftcreatortrecycleR tuse_threadlocalRtreset_on_returnR!tl((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt__init__>s&1           cCst|ƒiƒS(säProduce a DBAPI connection that is not referenced by any thread-local context. This method is different from :meth:`.Pool.connect` only if the ``use_threadlocal`` flag has been set to ``True``. (t_ConnectionFairytcheckout(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytunique_connection…s cCs t|ƒS(s6Called by subclasses to create a new ConnectionRecord.(t_ConnectionRecord(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytcreate_connectionscCs tƒ‚dS(sReturn a new :class:`.Pool`, of the same class as this one and configured with identical creation arguments. This method is used in conjunection with :meth:`dispose` to close out an entire :class:`.Pool` and create a new one in its place. N(tNotImplementedError(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytrecreate•s cCs tƒ‚dS(sDispose of this pool. This method leaves the possibility of checked-out connections remaining open, It is advised to not reuse the pool once dispose() is called, and to instead use a new pool constructed by the recreate() method. N(R3(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytdispose”s cCs‡|ipt|ƒiƒSny(|iiƒ}|o|iƒSnWntj onXt|ƒ}ti|ƒ|i_|iƒS(sŹReturn a DBAPI connection from the pool. The connection is instrumented such that when its ``close()`` method is called, the connection will be returned to the pool. (RR.R/RtcurrenttAttributeErrortweakreftref(R'trectagent((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytconnect­s  cCs;|io t|idƒo |i`n|i|ƒdS(sµGiven a _ConnectionRecord, return it to the :class:`.Pool`. This method is called when an instrumented DBAPI connection has its ``close()`` method called. R6N(RthasattrRR6tdo_return_conn(R'trecord((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt return_connĆs cCs |iƒS(s§Return a non-instrumented DBAPI connection from this :class:`.Pool`. This is called by ConnectionRecord in order to get its DBAPI resource. (tdo_get(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytgetĪscCs tƒ‚dS(s7Implementation for :meth:`get`, supplied by subclasses.N(R3(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRA×scCs tƒ‚dS(s?Implementation for :meth:`return_conn`, supplied by subclasses.N(R3(R'tconn((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR>ÜscCs tƒ‚dS(N(R3(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytstatusįscCs¶t|ddƒ}|ii|ƒt|dƒo|ii|ƒnt|dƒo|ii|ƒnt|dƒo|ii|ƒnt|dƒo|ii|ƒndS(s Add a ``PoolListener``-like object to this pool. ``listener`` may be an object that implements some or all of PoolListener, or a dictionary of callables containing implementations of some or all of the named methods in PoolListener. tmethodsR<t first_connectR/tcheckinN(sconnects first_connectscheckoutscheckin(RR!tappendR=R"R#R$R%(R'tlistener((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR&äs  N(t__name__t __module__t__doc__RtFalsetTrueR-R0R2R4R5R<R@RBRAR>RDR&(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR;s C     R1cBsAeZd„Zd„Zdd„Zd„Zd„Zd„ZRS(cCs¤||_|iƒ|_h|_|iiddƒ}|dj o(x%|D]}|i|i|ƒqJWn|io+x(|iD]}|i |i|ƒqWndS(NR#( t_ConnectionRecord__poolt_ConnectionRecord__connectt connectiontinfot__dict__tpopRRFR"R<(R'tpooltlsR,((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR-ūs     cCs€|idj ol|iiid|iƒy|iiƒWq|ttfj o ‚q||iiid|iƒq|XndS(NsClosing connection %rsException closing connection %r(RQRRORtdebugRt SystemExittKeyboardInterrupt(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRscCsf|dj o)|iiid|i|ii|ƒn|iiid|iƒ|iƒd|_dS(Ns(Invalidate connection %r (reason: %s:%s)sInvalidate connection %r(RRORRRRQt __class__RJt_ConnectionRecord__close(R'te((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt invalidates     cCs#|idjo[|iƒ|_|iiƒ|iio.x+|iiD]}|i|i|ƒqFWqn²|iidjožt i ƒ|i |iijo~|ii id|iƒ|i ƒ|iƒ|_|iiƒ|iio.x+|iiD]}|i|i|ƒq÷Wqn|iS(Ni’’’’s)Connection %r exceeded timeout; recycling( RQRRPRRRROR"R<Rttimet starttimeRR[(R'R,((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytget_connections(          cCs}y*|iiid|iƒ|iiƒWnLttfj o ‚n2tj o%}|iiid|i|ƒnXdS(NsClosing connection %rs)Connection %r threw an error on close: %s(RORRWRQRRXRYt Exception(R'R\((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt__close1s cCsqy<tiƒ|_|iiƒ}|iiid|ƒ|SWn.tj o"}|iiid|ƒ‚nXdS(NsCreated new connection %rsError on connect(): %s(R^R_RORRRWRa(R'RQR\((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt __connect<sN( RJRKR-RRR]R`R[RP(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR1śs   cCsPti|ƒ|dj o(|i|j pt|tƒodSn|dj o‘y7|io|iƒn|djo|iƒnWqąt j oG}|dj o|i d|ƒnt|t t fƒo‚qÜqąXn|dj o_d|_|i id|ƒ|io(x%|iD]}|i||ƒqWn|i|ƒndS(NR\s$Connection %r being returned to pool(t_refstdiscardRtfairyt isinstancet AssertionPoolRtrollbackRRaR]RXRYRRWR%RGR@(RQtconnection_recordRUR9R\R,((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt_finalize_fairyGs0          R.cBsŒeZdZdZd„Zed„ƒZed „ƒZed „ƒZdd „Z d „Z d „Z d„Z d„Zd„Zd„ZRS(sKProxies a DB-API connection and provides return-on-dereference support.t_poolt __counterRQt_connection_recordt __weakref__t_detached_infocs­ˆ|_d|_y^ˆiƒ‰|_|iiƒ‰|_ti|‡‡‡fd†ƒˆ_t i ˆƒWnd|_d|_‚nX|ii i d|iƒdS(Nicstˆˆˆ|ƒS((Rk(R9(R:RURC(sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytuss#Connection %r checked out from pool(Rlt_ConnectionFairy__counterRBRnR`RQR8R9RfRdtaddRRRW(R'RU((RUR:RCsl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR-ms    cCs |iiS(N(RlR(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt_logger€scCs |idj S(N(RQR(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytis_valid„scCs}y|iiSWnhtj o\|idjotidƒ‚ny |iSWqytj oh|_}|SqyXnXdS(s4An info collection unique to this DB-API connection.sThis connection is closedN(RnRRR7RQRRtInvalidRequestErrorRp(R'tvalue((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRRˆs  cCsa|idjotidƒ‚n|idj o|iid|ƒnd|_|iƒdS(s·Mark this connection as invalidated. The connection will be immediately closed. The containing ConnectionRecord will create a new connection when next used. sThis connection is closedR\N(RQRRRvRnR]t_close(R'R\((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR]—s  cOsUy&|ii||Ž}t||ƒSWn(tj o}|id|ƒ‚nXdS(NR\(RQtcursort _CursorFairyRaR](R'targstkwargstcR\((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRy„s cCst|i|ƒS(N(tgetattrRQ(R'tkey((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt __getattr__­scCs8|idjotidƒ‚n|id7_|ii p|idjo|Snd}x§|djo™y8x-|iiD]}|i|i|i|ƒq~W|SWqati j oK}|ii i d|ƒ|ii |ƒ|ii ƒ|_|d8}qaXqaW|ii i dƒ|i ƒtidƒ‚dS(NsThis connection is closediiis&Disconnection detected on checkout: %ss+Reconnection attempts exhausted on checkout(RQRRRvRrRlR$R/RntDisconnectionErrorRRRR]R`(R'tattemptsR,R\((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR/°s,     cCsq|idj o]ti|iƒd|i_d|i_|ii|iƒ|iii ƒ|_ d|_ndS(s"Separate this connection from its Pool. This means that the connection will no longer be returned to the pool when closed, and will instead be literally closed. The containing ConnectionRecord is separated from the DB-API connection, and will create a new connection when next used. Note that any overall connection limiting constraints imposed by a Pool implementation may be violated after a detach, as the detached connection is removed from the pool's knowledge and control. N( RnRRdtremoveRfRQRlR>RRtcopyRp(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytdetachŹs   cCs1|id8_|idjo|iƒndS(Nii(RrRx(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRąscCs/t|i|i|iƒd|_d|_dS(N(RkRQRnRlR(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRxås (s_pools __counters connections_connection_records __weakref__s_detached_infoN(RJRKRLt __slots__R-tpropertyRtRuRRRR]RyR€R/R…RRx(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR.fs       RzcBsGeZd Zd„Zd d„Zd„Zd„Zd„Zd„Z RS( t_parentRytexecutecCs"||_||_|i|_dS(N(RˆRyR‰(R'tparentRy((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR-ķs  cCs|iid|ƒdS(NR\(RˆR](R'R\((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR]ņscCs t|iƒS(N(titerRy(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt__iter__õscCs’y|iiƒWnztj on}yt|ƒ}Wntj ot|ƒ}nX|iiid|ƒt |t t fƒo‚qŽnXdS(NsError closing cursor: %s( RyRRatstrt TypeErrortreprRˆRttwarnRgRXRY(R'R\tex_text((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRųscCs>||ijoti|||ƒnt|i||ƒdS(N(R†tobjectt __setattr__tsetattrRy(R'RRw((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR“scCst|i|ƒS(N(R~Ry(R'R((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR€ s(s_parentscursorsexecuteN( RJRKR†R-RR]RŒRR“R€(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRzźs    tSingletonThreadPoolcBsYeZdZdd„Zd„Zd„Zd„Zd„Zd„Zd„Z d „Z RS( sA Pool that maintains one connection per thread. Maintains one connection per each thread, never moving a connection to a thread other than the one which it was created in. This is used for SQLite, which both does not handle multithreading by default, and also requires a singleton connection if a :memory: database is being used. Options are the same as those of :class:`Pool`, as well as: :param pool_size: The number of threads in which to maintain connections at once. Defaults to five. icKsEt|dMscCs”y"|iiƒ}|o|SnWntj onX|iƒ}ti|ƒ|i_|ii|ƒt|iƒ|i jo|i ƒn|S(N( R–R6R7R2R8R9R˜RsRR™Rž(R'R}((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRAPs  ( RJRKRLR-R4R5RœRžRDR>RA(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR•s      t QueuePoolcBsqeZdZdddd„Zd„Zd„Zd„Zd„Zd „Zd „Z d „Z d „Z d „Z RS(s>A Pool that imposes a limit on the number of open connections.ii icKsnti|||ti|ƒ|_d||_||_||_|idjo ti ƒpd|_ dS(sz Construct a QueuePool. :param creator: a callable function that returns a DB-API connection object. The function will be called with parameters. :param pool_size: The size of the pool to be maintained, defaults to 5. This is the largest number of connections that will be kept persistently in the pool. Note that the pool begins with no connections; once this number of connections is requested, that number of connections will remain. ``pool_size`` can be set to 0 to indicate no size limit; to disable pooling, use a :class:`~sqlalchemy.pool.NullPool` instead. :param max_overflow: The maximum overflow size of the pool. When the number of checked-out connections reaches the size set in pool_size, additional connections will be returned up to this limit. When those additional connections are returned to the pool, they are disconnected and discarded. It follows then that the total number of simultaneous connections the pool will allow is pool_size + `max_overflow`, and the total number of "sleeping" connections the pool will allow is pool_size. `max_overflow` can be set to -1 to indicate no overflow limit; no limit will be placed on the total number of concurrent connections. Defaults to 10. :param timeout: The number of seconds to wait before giving up on returning a connection. Defaults to 30. :param recycle: If set to non -1, number of seconds between connection recycling, which means upon checkout, if this timeout is surpassed the connection will be closed and replaced with a newly opened connection. Defaults to -1. :param echo: If True, connections being pulled and retrieved from the pool will be logged to the standard output, as well as pool sizing information. Echoing can also be achieved by enabling logging for the "sqlalchemy.pool" namespace. Defaults to False. :param use_threadlocal: If set to True, repeated calls to :meth:`connect` within the same application thread will be guaranteed to return the same connection object, if one has already been retrieved from the pool and has not been returned yet. Offers a slight performance advantage at the cost of individual transactions by default. The :meth:`unique_connection` method is provided to bypass the threadlocal behavior installed into :meth:`connect`. :param reset_on_return: If true, reset the database state of connections returned to the pool. This is typically a ROLLBACK to release locks and transaction resources. Disable at your own peril. Defaults to True. :param listeners: A list of :class:`~sqlalchemy.interfaces.PoolListener`-like objects or dictionaries of callables that receive events when DB-API connections are created, checked out and checked in to the pool. ii’’’’N( RR-t sqla_queuetQueueRlt _overflowt _max_overflowt_timeoutRtLockRt_overflow_lock(R'R(Ršt max_overflowttimeoutR›((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR-asB   cCsh|iidƒt|id|iid|id|id|id|i d|i d|i d |i ƒS( NsPool recreatingRšRØR©R)R RR*R!( RRRR RRltmaxsizeR¤R„RR RRR!(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR4«s    cCsˆy|ii|tƒWnjtij o[|idjo|id8_q„|iiƒz|id8_Wd|ii ƒXnXdS(Ni( RltputRMR”tFullR§RR£tacquiretrelease(R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR>µs cCs{y<|idjo|i|ij}|ii||iƒSWn8tij o)|idjoW|i|ijoD|p|iƒSq·ti d|i ƒ|i ƒ|ifƒ‚n|i dj o|i iƒn|idjoB|i|ijo/|i dj o|i iƒn|iƒSnz|iƒ}|id7_Wd|i dj o|i iƒnX|SnXdS(Ni’’’’sPQueuePool limit of size %d overflow %d reached, connection timed out, timeout %di(R¤R£RlRBR„R”tEmptyRARt TimeoutErrorR™toverflowR§RR­R®R2(R'twaittcon((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRAĀs2& cCsyxFto>y |iitƒ}|iƒWqtij oPqXqWd|iƒ|_|i i d|i ƒƒdS(NisPool disposed. %s( RNRlRBRMRR”RÆR™R£RRRRD(R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR5ćs cCs,d|iƒ|iƒ|iƒ|iƒfS(Ns_Pool size: %d Connections in pool: %d Current Overflow: %d Current Checked out connections: %d(R™t checkedinR±t checkedout(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRDīs    cCs |iiS(N(RlRŖ(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR™öscCs |iiƒS(N(Rltqsize(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR“łscCs|iS(N(R£(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR±üscCs|ii|iiƒ|iS(N(RlRŖR¶R£(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRµ’s( RJRKRLR-R4R>RAR5RDR™R“R±Rµ(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR ^sJ !    tNullPoolcBsDeZdZd„Zd„Zd„Zd„Zd„Zd„ZRS(sQA Pool which does not pool connections. Instead it literally opens and closes the underlying DB-API connection per each connection open/close. Reconnect-related functions such as ``recycle`` and connection invalidation are not supported by this Pool implementation, since no connections are held persistently. cCsdS(NR·((R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRDscCs|iƒdS(N(R(R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR>scCsdS(N((R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytdo_return_invalidscCs |iƒS(N(R2(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRAsc CsJ|iidƒt|id|id|id|id|id|iƒS(NsPool recreatingR)R RR*R!( RRRR·RRR RRR!(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR4s     cCsdS(N((R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR5$s( RJRKRLRDR>RøRAR4R5(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR·s      t StaticPoolcBskeZdZed„ƒZed„ƒZd„Zd„Zd„Zd„Z d„Z d„Z d „Z RS( s.A Pool of exactly one connection, used for all requests. Reconnect-related functions such as ``recycle`` and connection invalidation (which is also used to support auto-reconnect) are not currently supported by this Pool implementation but may be implemented in a future release. cCs |iƒS(N(R(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR–2scCs t|ƒS(N(R1(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRQ6scCsdS(NR¹((R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRD:scCs.d|ijo|iiƒd|_ndS(NR–(RSR–RR(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR5=s cCsY|iidƒ|id|id|id|id|id|id|id|i ƒS( NsPool recreatingR(R)R*R+R RR!( RRRRZRRRRR RR!(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR4Bs     cCs|iS(N(R–(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR2LscCsdS(N((R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR>OscCsdS(N((R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRøRscCs|iS(N(RQ(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRAUs( RJRKRLRR–RQRDR5R4R2R>RøRA(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR¹(s     RhcBsMeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(sśA Pool that allows at most one checked out connection at any given time. This will raise an exception if more than one connection is checked out at a time. Useful for debugging code that is using more connections than desired. cOs)d|_t|_ti|||ŽdS(N(RR–RMt _checked_outRR-(R'R{R›((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR-bs  cCsdS(NRh((R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRDgscCs>|iptdƒ‚nt|_||ijpt‚dS(Nsconnection is not checked out(RŗtAssertionErrorRMR–(R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR>js  cCsd|_t|_dS(N(RR–RMRŗ(R'RC((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRøps cCs(t|_|io|iiƒndS(N(RMRŗR–R(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR5ts  cCs8|iidƒt|id|id|id|iƒS(NsPool recreatingR RR!(RRRRhRR RR!(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR4ys cCsG|iotdƒ‚n|ip|iƒ|_nt|_|iS(Ns!connection is already checked out(RŗR»R–R2RN(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRAs    ( RJRKRLR-RDR>RøR5R4RA(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRhXs      R cBsYeZdZed„Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z RS( s Layers connection pooling behavior on top of a standard DB-API module. Proxies a DB-API 2.0 connect() call to a connection pool keyed to the specific connect parameters. Other functions and attributes are delegated to the underlying DB-API module. cKs7||_||_||_h|_tiƒ|_dS(sŲInitializes a new proxy. module a DB-API 2.0 module poolclass a Pool class, defaulting to QueuePool Other parameters are sent to the Pool object's constructor. N(R R›t poolclasstpoolsRR¦t_create_pool_mutex(R'R R¼R›((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR-‘s    cCs(x!|iiƒD]}|i|=qWdS(N(R½tkeys(R'R((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR¤scCs|iƒdS(N(R(R'((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyt__del__ØscCst|i|ƒS(N(R~R (R'R((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR€«scs±ˆiˆˆŽ}yˆi|SWn‰tj o}ˆiiƒzX|ˆijo9ˆi‡‡‡fd†ˆi}|ˆi|<|Sn ˆi|SWdˆiiƒXnXdS(NcsˆiiˆˆŽS((R R<((R'R{R›(sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRq¶s(t _serializeR½RR¾R­R¼R›R®(R'R{R›RRU((R'R{R›sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pytget_pool®s   cOs|i||ŽiƒS(s,Activate a connection to the database. Connect to the database using this DBProxy's module and the given connect arguments. If the arguments match an existing pool, the connection will be returned from the pool's current thread-local connection instance, or if there is no thread-local connection instance it will be checked out from the set of pooled connections. If the pool has no available connections and allows new connections to be created, a new database connection will be made. (RĀR<(R'R{R›((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR<æscOs:|i||Ž}y|i|=Wntj onXdS(s;Dispose the pool referenced by the given connect arguments.N(RĮR½R(R'R{R›R((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR5Ļs cOsti||gƒS(N(Rtdumps(R'R{R›((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyRĮŲs( RJRKRLR R-RRĄR€RĀR<R5RĮ(((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyR ‰s       ( RLR8R^Rt sqlalchemyRRRR”tsqlalchemy.utilRRRRR Rt IdentifiedRR’R1RRkR—RdR.RzR•R R·R¹RhR (((sl/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/SQLAlchemy-0.6.6-py2.5.egg/sqlalchemy/pool.pyss&$"  æM  „$P¤&01