LKiSSKrSSKrSSKJrJr SSKJrJr SSKrSSK J r SSK J r "SS5r "SS \5r"S S \5r"S S \5rg)N)ABCabstractmethod)AnySet)override) Annotatedc \rSrSr%SrS\S'\\S'\R\S'SSS\S \ S \ S \ 4 S jr SS \S\R4Sjjr SSjrSSjrS\R4SjrSSjrSrg) Connection zBA threadpool connection that returns itself to the pool on close()Pool_pool_db_file_connpooldb_fileis_uriargskwargscXlX l[R"U/UQ7SSUS.UD6UlSURlg)NiF)timeoutcheck_same_threaduri)r rsqlite3connectrisolation_level)selfrrrrrs ^/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/db/impl/sqlite_pool.py__init__Connection.__init__sK  __  IM !U QW  &* "sqlreturncxUSLaURRU5$URRX5$)N.)rexecute)rr! parameterss rr$Connection.executes4  ::%%c* *zz!!#22r Nc8URR5 gN)rcommitrs rr)Connection.commit s r c8URR5 gr()rrollbackr*s rr-Connection.rollback#s r c6URR5$r()rcursorr*s rr0Connection.cursor&szz  ""r c8URR5 g)z(Actually closes the connection to the dbN)rcloser*s r close_actualConnection.close_actual)s r )rrr ).r"N)__name__ __module__ __qualname____firstlineno____doc____annotations__strrr boolrrCursorr$r)r-r0r4__static_attributes__r rr r s~L MM   **%(*26*?B*NQ*3337>>3 ##r r c\rSrSrSr\S\S\SS4Sj5r\S\ S \ S\ 4S j5r \SS j5r \S \ SS4S j5r Srg)r .zCAbstract base class for a pool of connections to a sqlite database.rrr"Ncgr(rArrrs rr Pool.__init__1 r rrcg)z"Return a connection from the pool.NrA)rrrs rr Pool.connect5 r cg)z"Close all connections in the pool.NrAr*s rr3 Pool.close:rJr conncg)z Return a connection to the pool.NrArrMs rreturn_to_poolPool.return_to_pool?rJr rAr6)r7r8r9r:r;rr=r>rrr rr3rPr@rAr rr r .sM  T d   S C J     : $  r r c\rSrSr%Sr\\\R\ 4\ S'\ R\ S'\ R\ S'\\ S'\\ S'SS\S \4S jjr\S \S \S \ 4Sj5r\S\ S S4Sj5r\SSj5rSrg)LockPoolEa=A pool that has a single connection per thread but uses a lock to ensure that only one thread can use it at a time. This is used because sqlite does not support multithreaded access with connection timeouts when using the shared cache mode. We use the shared cache mode to allow multiple threads to share a database. _connections_lock _connectionr_is_urirrc[5Ul[R"5Ul[R "5UlXlX lgr() setrU threadinglocalrWRLockrVrrXrEs rrLockPool.__init__Qs3E$??,__&   r rrr"cURR5 [URS5(a-URRbURR$[ XR UR/UQ70UD6nX0RlURR[R"U55 U$NrM) rVacquirehasattrrWrMr rrXrUaddweakrefrefrrrnew_connections rrLockPool.connectXs  4##V , ,1A1A1F1F1R##(( ('mmT\\48! !r rMNcZURR5 g![a gf=fr()rVrelease RuntimeErrorrOs rrPLockPool.return_to_pooles)  JJ      s  **c&URH"nU"5cM U"5R5 M$ URR5 [R"5UlUR R5 g![a gf=fr() rUr4clearr[r\rWrVrjrkrOs rr3LockPool.closelsr%%Dv!##%& !$??,  JJ      s(B BBrWrUrrXrVFr6)r7r8r9r:r;rrrd ReferenceTyper r<r[r]r\r=r>rrrrrPr3r@rAr rrSrSEs i 5 5z ABCC ?? M MT "S "C "J " ":$   r rSc\rSrSr%Sr\\\R\ 4\ S'\ R\ S'\ R\ S'\\ S'\\ S'SS\S \4S jjr\S \S \S \ 4Sj5r\SSj5r\S\ S S4Sj5rSrg) PerThreadPoolyzMaintains a connection per thread. For now this does not maintain a cap on the number of connections, but it could be extended to do so and block on connect() if the cap is reached. rUrVrWr_is_uri_rrc[5Ul[R"5Ul[R "5UlXlX lgr() rZrUr[r\rWLockrVrrXrEs rrPerThreadPool.__init__s3E$??,^^%   r rrr"c[URS5(a-URRbURR$[XRUR /UQ70UD6nX0RlUR  URR[R"U55 SSS5 U$!,(df  U$=fr`) rbrWrMr rrXrVrUrcrdrerfs rrPerThreadPool.connects 4##V , ,1A1A1F1F1R##(( ('mmT\\48rrrrr3rPr@rAr rrtrtysi 5 5z ABCC >> MNT "S "C "J " "11 : $  r rt)rrdabcrrtypingrrr[ overridesrtyping_extensionsrr r rSrtrAr rrsJ#'!!H 3 .1t1h* D* r