֛hA~SrSSKJr SSKJrJr "SS\5r"SS5r"SS 5r "S S 5r S S /r g ) zg An asynchronous mapping to U{DB-API 2.0}. )threads)logreflectc\rSrSrSrSrg)ConnectionLostzV This exception means that a db connection has been lost. Client code may try again. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r ]C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/enterprise/adbapi.pyrrsrrc6\rSrSrSrSrSrSrSrSr Sr g ) Connectionz A wrapper for a DB-API connection instance. The wrapper passes almost everything to the wrapped connection and so has the same API. However, the L{Connection} knows about its pool and also handle reconnecting should when the real connection dies. c>XlSUlUR5 gN)_pool _connection reconnect)selfpools r__init__Connection.__init__s  rcgrr rs rcloseConnection.close$s rcURR(dURR5 gURR5 URR 5nUR URR 5 UR5 URR5 g![a [R"SS5 Of=fURRUR5 URR(a[R"S5 [5e)NRollback failedzConnection lost.)rrrrollbackcursorexecutegood_sqlr commit BaseExceptionrerr disconnectnoisymsgr)rcurss rr$Connection.rollback.szz##    % % '  -    % % '##**,D LL,, - JJL    # # %  - GGD+ , - d../ ::   GG& 'sBB<A?cFURR5 SUlgr)rrrArs rrTransaction.reconnectvs ""$ rc.[URU5$r)r4rAr5s rr7Transaction.__getattr__zst||T**r)rrAr) r r r r rrArr r=rr7rr rrr:r:Ms'G  1&+rr:c\rSrSrSrSR 5rSrSrSr Sr Sr Sr Sr Sr\r\rSrS rS rS rS rS rSrSrSrSrSrSrSrSr Sr!Sr"Sr#Sr$Sr%Sr&g)ConnectionPool~aV Represent a pool of connections to a DB-API 2.0 compliant database. @ivar connectionFactory: factory for connections, default to L{Connection}. @type connectionFactory: any callable. @ivar transactionFactory: factory for transactions, default to L{Transaction}. @type transactionFactory: any callable @ivar shutdownID: L{None} or a handle on the shutdown event trigger which will be used to stop the connection pool workers when the reactor stops. @ivar _reactor: The reactor which will be used to schedule startup and shutdown events. @type _reactor: L{IReactorCore} provider z-min max name noisy openfun reconnect good_sqlFNzselect 1c@Xl[R"U5Ul[ URSS5S:wa[ R "S5 [ URSS5S:a[ R "S5 URS S5nUcSS KJ n X@l X l X0l URHnS U3nXc;dM[XX65 X6 M! [URUR 5Ul[!URUR 5Ul0UlSS KJnJn UR*UlUR/URUR 5UlURR1UR25Ulg) a Create a new L{ConnectionPool}. Any positional or keyword arguments other than those documented here are passed to the DB-API object when connecting. Use these arguments to pass database names, usernames, passwords, etc. @param dbapiName: an import string to use to obtain a DB-API compatible module (e.g. C{'pyPgSQL.PgSQL'}) @keyword cp_min: the minimum number of connections in pool (default 3) @keyword cp_max: the maximum number of connections in pool (default 5) @keyword cp_noisy: generate informational log messages during operation (default C{False}) @keyword cp_openfun: a callback invoked after every C{connect()} on the underlying DB-API object. The callback is passed a new DB-API connection object. This callback can setup per-connection state such as charset, timezone, etc. @keyword cp_reconnect: detect connections which have failed and reconnect (default C{False}). Failed connections may result in L{ConnectionLost} exceptions, which indicate the query may need to be re-sent. @keyword cp_good_sql: an sql query which should always succeed and change no state (default C{'select 1'}) @keyword cp_reactor: use this reactor instead of the global reactor (added in Twisted 10.2). @type cp_reactor: L{IReactorCore} provider apilevelNz2.0z'DB API module not DB API 2.0 compliant. threadsafetyrz+DB API module not sufficiently thread-safe. cp_reactor)reactorcp_) threadable threadpool) dbapiNamer namedModuledbapir4rr-poptwisted.internetrS_reactorconnargsconnkwCP_ARGSsetattrminmax connectionstwisted.pythonrUrV getThreadIDthreadID ThreadPoolcallWhenRunning_startstartID) rrWr]r^rSargcpArgrUrVs rrConnectionPool.__init__s6F#((3 4::z4 0E 9 GG= > 4::~q 1A 5 GGA B**\40 ? 0   <,(( MM4??D,C,CT LP TV  rcURU5nU"U/UQ70UD6nUR5 U$![a: UR5 e![a [R "SS5 ef=ff=fNr#)connectionFactoryr(r)r$rr*)rr|r}r~connresults rr{!ConnectionPool._runWithConnections~%%d+ $,,,F KKMM  1  ! 1/0  1 s,1 A5A  A5 !A1.A50A11A5cx[R"URURURU/UQ70UD6$)a( Interact with the database and return the result. The 'interaction' is a callable object which will be executed in a thread using a pooled connection. It will be passed an L{Transaction} object as an argument (whose interface is identical to that of the database cursor for your DB-API module of choice), and its results will be returned as a L{Deferred}. If running the method raises an exception, the transaction will be rolled back. If the method returns a value, the transaction will be committed. NOTE that the function you pass is *not* run in the main thread: you may have to worry about thread-safety in the function you pass to this if it tries to use non-local objects. @param interaction: a callable object whose first argument is an L{adbapi.Transaction}. @param args: additional positional arguments to be passed to interaction @param kw: keyword arguments to be passed to interaction @return: a Deferred which will fire the return value of C{interaction(Transaction(...), *args, **kw)}, or a L{twisted.python.failure.Failure}. )rrzr\rV_runInteraction)r interactionr}r~s rrunInteractionConnectionPool.runInteraction$sE8(( MM OO         rcBUR"UR/UQ70UD6$)a Execute an SQL query and return the result. A DB-API cursor which will be invoked with C{cursor.execute(*args, **kw)}. The exact nature of the arguments will depend on the specific flavor of DB-API being used, but the first argument in C{*args} be an SQL statement. The result of a subsequent C{cursor.fetchall()} will be fired to the L{Deferred} which is returned. If either the 'execute' or 'fetchall' methods raise an exception, the transaction will be rolled back and a L{twisted.python.failure.Failure} returned. The C{*args} and C{**kw} arguments will be passed to the DB-API cursor's 'execute' method. @return: a L{Deferred} which will fire the return value of a DB-API cursor's 'fetchall' method, or a L{twisted.python.failure.Failure}. )r _runQueryrr}r~s rrunQueryConnectionPool.runQueryIs#$""4>>?D?B??rcBUR"UR/UQ70UD6$)a Execute an SQL query and return L{None}. A DB-API cursor which will be invoked with C{cursor.execute(*args, **kw)}. The exact nature of the arguments will depend on the specific flavor of DB-API being used, but the first argument in C{*args} will be an SQL statement. This method will not attempt to fetch any results from the query and is thus suitable for C{INSERT}, C{DELETE}, and other SQL statements which do not return values. If the 'execute' method raises an exception, the transaction will be rolled back and a L{Failure} returned. The C{*args} and C{*kw} arguments will be passed to the DB-API cursor's 'execute' method. @return: a L{Deferred} which will fire with L{None} or a L{twisted.python.failure.Failure}. )r _runOperationrs r runOperationConnectionPool.runOperation]s%&""4#5#5CCCCrcUR(a,URRUR5 SUlUR(a,URRUR5 SUlUR 5 g)z3 Close all pool connections and shutdown the pool. N)rwr\removeSystemEventTriggerrjrvrs rr ConnectionPool.closersV ?? MM 2 24?? C"DO << MM 2 24<< @DL rcSUlURR5 SUlURR 5HnUR U5 M URR5 g)z5 This should only be called by the shutdown trigger. NF)rwrVstoprtrcvalues_closeclearrrs rrvConnectionPool.finalClose~sY  $$++-D KK .  rcUR5nURRU5nUcUR(a#[R "SUR 35 URR"UR0URD6nURbURU5 X RU'U$)a] Return a database connection when one becomes available. This method blocks and should be run in a thread from the internal threadpool. Don't call this method directly from non-threaded code. Using this method outside the external threadpool may exceed the maximum number of connections in the pool. @return: a database connection from the pool. zadbapi connecting: ) rfrcgetr,rr-rWrYr1r]r^openfun)rtidrs rr1ConnectionPool.connectsmmo##C( <zz-dnn-=>?::%%t}}D DD||' T"$(  S ! rcUR5nXRRU5La [S5eUbUR U5 URU gg)z Disconnect a database connection associated with this pool. Note: This function should only be used by the same thread which called L{ConnectionPool.connect}. As with C{connect}, this function is not used in normal non-threaded Twisted code. zwrong connection for threadN)rfrcr Exceptionr)rrrs rr+ConnectionPool.disconnectsWmmo ''++C0 09: :   KK   % rcUR(a#[R"SUR35 UR 5 g![ a [R "SS5 gf=f)Nzadbapi closing: zConnection close failed)r,rr-rWr r)r*rs rrConnectionPool._closesN :: GG&t~~&67 8 5 JJL 5 GGD3 4 5sA!A+*A+c2URU5nURX5nU"U/UQ70UD6nUR5 UR5 U$![a: UR 5 e![a [ R"SS5 ef=ff=fr)rtransactionFactoryr r(r)r$rr*)rrr}r~rtransrs rrConnectionPool._runInteractions%%d+''3  444F KKM KKMM  1  ! 1/0  1 s/-A BA.-B.!BBBBcFUR"U0UD6 UR5$r)r&fetchallrrr}r~s rrConnectionPool._runQuerys  t"r"~~rc(UR"U0UD6 gr)r&rs rrConnectionPool._runOperations t"r"rc URURURURURUR UR URS.$)NrWrarbr,rr'r]r^rrs r __getstate__ConnectionPool.__getstate__sD8888ZZ  kk  rcxXlUR"UR/URQ70URD6 gr)__dict__rrWr]r^)rstates r __setstate__ConnectionPool.__setstate__s)  dnnDt}}D Dr)rr\r]rcr^rYrWrbrartrwrjrfrV)'r r r r rsplitr_r,rarbr6rrr'rtrrr:rrwrrirorr{rrrr rvr1r+rrrrrrrr rrrJrJ~s&>CCEG E C C DGIHG"$JEBN   4 # J@(D*  !. &5  #  ErrJN) rr[rrdrrrrrr:rJ__all__r rrrsP  %'Y4/4/n.+.+b]E]E@ * +r