+ jARt^RIHt^RIHtHt!RR]4t!RR4t!RR4t !R R 4t RR .t R #) zg An asynchronous mapping to U{DB-API 2.0}. )threads)logreflectc]tRt^tRtRtR#)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;/usr/lib/python3/dist-packages/twisted/enterprise/adbapi.pyrrsrrcBa]tRt^toRtRtRtRtRtRt Rt Vt R#) 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@WnRVnVP4R#N)_pool _connection reconnect)selfpools&&r__init__Connection.__init__s  rcR#rrrs&rcloseConnection.close$s rcVPP'gVPP4R#VPP4VPP 4pVP VPP 4VP4VPP4R# \d\P!RR4Mi;iTPPTP4TPP'd\P!R4\4h)NRollback failedzConnection lost.)rrrrollbackcursorexecutegood_sqlrcommit BaseExceptionrerr disconnectnoisymsgr)rcurss& rr!Connection.rollback.szz###    % % '  -    % % '##**,D LL,, - JJL    # # %  - GGD+ , - d../ ::    GG& 'sBB??"C$#C$cVPe&VPPVP4VPP4VnR#r)rrr(connectrs&rrConnection.reconnectDs;    ' JJ ! !$"2"2 3::--/rc.\VPV4#r)getattrrrnames&&r __getattr__Connection.__getattr__Ist''..r)rrN) rr r r r rrr!rr4r __classdictcell__ __classdict__s@rrrs(  ,0 //rrcFa]tRt^MtoRtRtRtRtRtRt Rt Rt Vt R#) Transactiona A lightweight wrapper for a DB-API 'cursor' object. Relays attribute access to the DB cursor. That is, you can call C{execute()}, C{fetchall()}, etc., and they will be called on the underlying DB-API cursor object. Attributes will also be retrieved from there. Nc>WnW nVP4R#r)rrreopen)rr connections&&&rrTransaction.__init__Ys % rcLVPpRVnVP4R#r)_cursorr)rr@s& rrTransaction.close^s,,  rcVPeVP4VPP4VnR# \d8TP P 'gh\P!RR4Mi;iTP P'd\P!R4TP 4TPP4TnR#)NzCursor creation failedzConnection lost, reconnecting) r@rrr"r&rrrr'r)r*rs&rr<Transaction.reopencs << # JJL 8++224DL  8::'''67  8 ::    GG3 4 ''..0 sA&B(BBcHVPP4RVnR#r)rrr@rs&rrTransaction.reconnectvs ""$ rc.\VPV4#r)r1r@r2s&&rr4Transaction.__getattr__zst||T**r)rr@r) rr r r r r@rrr<rr4r r6r7s@rr:r:Ms/G  1&++rr:ca]tRt^~toRtRP 4tRt^t^t Rt Rt Rt Rt Rt]t]tRtRtRtRtR tR tR tR tR tRtRtRtRtRt Rt!Rt"Rt#Rt$Rt%Rt&Vt'R#)ConnectionPoolaV 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 RWn\P!V4Vn\ VPRR4R8wd\ P !R4\ VPR^4^8d\ P !R4VPRR4pVf^RIH pW@n W n W0n VPF$pR V 2pWc9gK\WW6,4W6K& \VPVP 4Vn\!VPVP 4Vn/Vn^R IHpHpVP*VnVP/VPVP 4VnVPP1VP24VnR#) 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. threadsafetyz+DB API module not sufficiently thread-safe. cp_reactor)reactorcp_) threadable threadpool) dbapiNamer namedModuledbapir1rr*poptwisted.internetrN_reactorconnargsconnkwCP_ARGSsetattrminmax connectionstwisted.pythonrPrQ getThreadIDthreadID ThreadPoolcallWhenRunning_startstartID) rrRrXrYrNargcpArgrPrQs &&*, rrConnectionPool.__init__s6F#((3 4::z4 0E 9 GG= > 4::~q 1A 5 GGA B**\40 ? 0   <,(( MM4??D,C,CT LP TV  rcVPV4pV!V.VO5/VBpVP4V# \d<TP4h \d\P !RR4hi;ii;iNr )connectionFactoryr%r&r!rr')rrwrxryconnresults&&*, rrv!ConnectionPool._runWithConnections~%%d+ $,,,F KKMM  1  ! 1/0  1 s,1 A7A A7"A30A72A33A7c x\P!VPVPVPV.VO5/VB#)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}. )rrurWrQ_runInteraction)r interactionrxrys&&*,rrunInteractionConnectionPool.runInteraction$sE8(( MM OO         rc BVP!VP.VO5/VB#)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 _runQueryrrxrys&*,rrunQueryConnectionPool.runQueryIs#$""4>>?D?B??rc BVP!VP.VO5/VB#)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#5CCCCrc VP'd-VPPVP4RVnVP'd-VPPVP4RVnVP 4R#)z3 Close all pool connections and shutdown the pool. N)rrrWremoveSystemEventTriggerrerqrs&rrConnectionPool.closersZ ??? MM 2 24?? C"DO <<< MM 2 24<< @DL rc RVnVPP4RVnVPP 4FpVP V4K VPP4R#)z5 This should only be called by the shutdown trigger. NF)rrrQstopror^values_closeclearrrs& rrqConnectionPool.finalClose~sY  $$++-D KK .  rc VP4pVPPV4pVfVP'd$\P !RVP 24VPP!VP/VPBpVPeVPV4W PV&V#)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: ) rar^getr)rr*rRrTr.rXrYopenfun)rtidrs& rr.ConnectionPool.connectsmmo##C( <zzz-dnn-=>?::%%t}}D DD||' T"$(  S ! rc VP4pWPPV4Jd \R4hVe!VP V4VPVR#R#)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)rar^r Exceptionr)rrrs&& rr(ConnectionPool.disconnectsWmmo ''++C0 09: :   KK   % rcVP'd$\P!RVP 24VP 4R# \ d\P !RR4R#i;i)zadbapi closing: NzConnection close failed)r)rr*rRrr&r'rs&&rrConnectionPool._closesP ::: GG&t~~&67 8 5 JJL 5 GGD3 4 5sA "A/.A/c6VPV4pVPW4pV!V.VO5/VBpVP4VP4V# \d<TP 4h \d\ P!RR4hi;ii;ir})r~transactionFactoryrr%r&r!rr')rrrxryrtransrs&&*, rrConnectionPool._runInteractions%%d+''3  444F KKM KKMM  1  ! 1/0  1 s/-A BA/.B/"BBBBcFVP!V/VBVP4#r)r#fetchallrrrxrys&&*,rrConnectionPool._runQuerys  t"r"~~rc*VP!V/VBR#r)r#rs&&*,rrConnectionPool._runOperations t"r"rcRVPRVPRVPRVPRVPRVP RVP RVP/#rRr\r]r)rr$rXrYrrs&r __getstate__ConnectionPool.__getstate__sT  488 488 TZZ    dkk  rczWnVP!VP.VPO5/VPBR#r)__dict__rrRrXrY)rstates&&r __setstate__ConnectionPool.__setstate__s)  dnnDt}}D Dr)rrWrXr^rYrTrRr]r\rorrrerarQ)(rr r r r splitrZr)r\r]r3rrr$rorr~r:rrrrrdrjrzrvrrrrrqr.r(rrrrrrr r6r7s@rrIrI~s&>CCEG E C C DGIHG"$JEBN   4 # J@(D*  !. &5  #  EErrIN) r rVrr_rrrrrr:rI__all__rrrrsP  %'Y4/4/n.+.+b]E]E@ * +r