N?F d Z ddlmZ ddlmZ ddlmZ i Z ej dd d Zd Z G d
d e
Z d S )
zDBAPI proxy utility.
Provides transparent connection pooling on top of a Python DBAPI.
This is legacy SQLAlchemy functionality that is not typically used
today.
) QueuePool )util) threadingz1.3zYThe :func:`.pool.manage` function is deprecated, and will be removed in a future release.c t | S # t $ r) t | t | fi | cY S w xY w)aH Return 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*
)proxiesKeyError
setdefault_DBProxy)moduleparamss o/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/pool/dbapi_proxy.pymanager s] ,Fv F F F!!&(6*D*DV*D*DEEEEEFs 0AAc t D ]} | t dS )zYRemove all current DB-API 2.0 managers.
All pools and connections are disposed.
N)r valuescloseclear)managers r clear_managersr 5 s= >>##
MMOOOOO c F e Zd ZdZefdZd Zd Zd Zd Z d Z
d Z d Z d
S ) r a 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.
c n || _ || _ || _ i | _ t j | _ dS )zInitializes 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 kw poolclasspoolsr Lock_create_pool_mutex)selfr r r s r __init__z_DBProxy.__init__I s6 "
"+."2"2 r c D t | j D ]
}| j |= d S N)listr r keys r r z_DBProxy.close\ s0
## C
3 r c . | d S r! )r )r s r __del__z_DBProxy.__del__` s
r c , t | j | S r! )getattrr r# s r __getattr__z_DBProxy.__getattr__c s t{C(((r c j i } j | S # t $ r j | j vrU dd j fdfi j }| j |< | j cY S j | j cY S # j w xY ww xY w)N sa_pool_keyc ( j j i S r! )r connect)argsr r s r z#_DBProxy.get_pool..p s 3 3T @R @ @ r )
_serializer r r acquirepopr r release)r r. r r$ pools ``` r get_poolz_DBProxy.get_poolf s* dot*r** 2:c? "
2
2
2 # + + - - -
2dj((FF=$///)4>@@@@@@ DHG D '+DJsO '//111111 :c?'//111111'//1111
2s. #C(AC C(! C -C( C$$C(c @ | j |i | S )a, 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.
)r5 r- r r. r s r r- z_DBProxy.connecty s' t}d)b))11333r c T | j |i |} | j |= dS # t $ r Y dS w xY w)z;Dispose the pool referenced by the given connect arguments.N)r0 r r )r r. r r$ s r disposez_DBProxy.dispose sN dot*r**
3 DD s
''c dv rd S t t | fdt D z S )Nr+ c $ g | ] }|| f
S r< ).0kr s r
z'_DBProxy._serialize.. s! "B"B"B!Ar!u:"B"B"Br )tupler" sortedr7 s `r r0 z_DBProxy._serialize sM B m$ $T$ZZ"B"B"B"Bvbzz"B"B"BBCCCr N)
__name__
__module__ __qualname____doc__r r r r& r) r5 r- r9 r0 r< r r r r @ s *3 3 3 3 3& ) ) )2 2 2&4 4 4 D D D D Dr r N) rE implr r r r
deprecatedr r objectr r< r r rJ s
#
F F
F. VD VD VD VD VDv VD VD VD VD VDr