dh0fddlmZGddZGddeZGddeZGdd eZy ) )excc`eZdZdZdZedZedZdZdZ dZ dZ d Z d Z d Zy ) TransactionaRepresent a database transaction in progress. The Transaction object is procured by calling the SAConnection.begin() method of SAConnection: with (yield from engine) as conn: trans = yield from conn.begin() try: yield from conn.execute("insert into x (a, b) values (1, 2)") except Exception: yield from trans.rollback() else: yield from trans.commit() The object provides .rollback() and .commit() methods in order to control transaction boundaries. See also: SAConnection.begin(), SAConnection.begin_twophase(), SAConnection.begin_nested(). c6||_|xs||_d|_y)NT) _connection_parent _is_active)self connectionparents Q/var/www/netwell/bot/venv/lib/python3.12/site-packages/aiomysql/sa/transaction.py__init__zTransaction.__init__s%~ c|jS)z+Return ``True`` if a transaction is active.)r r s r is_activezTransaction.is_active"src|jS)z8Return transaction's connection (SAConnection instance).)rrs r r zTransaction.connection'srcK|jjsy|j|ur|jd{yd|_y7 w)a0Close this transaction. If this transaction is the base transaction in a begin/commit nesting, the transaction will rollback(). Otherwise, the method returns. This is used to cancel a Transaction without affecting the scope of an enclosing transaction. NF)rr rollbackrs r closezTransaction.close,s?||&&  <<4 --/ ! !#DO "s9A A A c|K|jjsy|jd{d|_y7 w)zRoll back this transaction.NF)rr _do_rollbackrs r rzTransaction.rollback=s4||&& !!! "s +<: <cTK|jjd{y7wN)rrrs r rzTransaction._do_rollbackDsll##%%% (&(cK|jjstjd|j d{d|_y7 w)zCommit this transaction.This transaction is inactiveNF)rr rInvalidRequestError _do_commitrs r commitzTransaction.commitGsC||&&))*HI Ioo s?AA Ac Kywrrs r rzTransaction._do_commitOs  scK|Swrr"rs r __aenter__zTransaction.__aenter__Rs  scK|r|jd{y|jr|jd{yy7+7wr)rr r )r exc_typeexc_valexc_tbs r __aexit__zTransaction.__aexit__Us> --/ ! !kkm## "$sAA$AAAAN)__name__ __module__ __qualname____doc__rpropertyrr rrrr rr$r)r"rr rrsW,   $" &  $rrc*eZdZfdZdZdZxZS)RootTransactionc&t||dyrsuperr)r r __class__s r rzRootTransaction.__init___s T*rcTK|jjd{y7wr)r_rollback_implrs r rzRootTransaction._do_rollbackbs--///rcTK|jjd{y7wr)r _commit_implrs r rzRootTransaction._do_commites++---r)r*r+r,rrr __classcell__r4s@r r0r0]s+0.rr0c2eZdZdZdZfdZdZdZxZS)NestedTransactionzRepresent a 'nested', or SAVEPOINT transaction. A new NestedTransaction object may be procured using the SAConnection.begin_nested() method. The interface is the same as that of Transaction class. Nc&t|||yrr2)r r r r4s r rzNestedTransaction.__init__ts V,rcK|jJd|jr9|jj|j|jd{yy7wNzBroken transaction logic) _savepointr r_rollback_to_savepoint_implrrs r rzNestedTransaction._do_rollbackwsX*F,FF* ??"">>/ / /  /AAAAcK|jJd|jr9|jj|j|jd{yy7wr?)r@r r_release_savepoint_implrrs r rzNestedTransaction._do_commit}sX*F,FF* ??""::/ / /  /rB) r*r+r,r-r@rrrr9r:s@r r<r<isJ-/ /rr<cDeZdZdZfdZedZdZdZdZ xZ S)TwoPhaseTransactionzRepresent a two-phase transaction. A new TwoPhaseTransaction object may be procured using the SAConnection.begin_twophase() method. The interface is the same as that of Transaction class with the addition of the .prepare() method. cBt||dd|_||_y)NF)r3r _is_prepared_xid)r r xidr4s r rzTwoPhaseTransaction.__init__s! T*! rc|jS)z Returns twophase transaction id.)rIrs r rJzTwoPhaseTransaction.xidsyyrcK|jjstjd|jj |j d{d|_y7 w)zfPrepare this TwoPhaseTransaction. After a PREPARE, the transaction can be committed. rNT)rrrrr_prepare_twophase_implrIrHrs r preparezTwoPhaseTransaction.preparesS ||%%))*HI I55dii@@@  AsAA%A# A%cK|jj|j|jd{y7wN) is_prepared)rrollback_preparedrIrHrs r rz TwoPhaseTransaction._do_rollbacks800 II4#4#416 6 6 5?=?cK|jj|j|jd{y7wrP)rcommit_preparedrIrHrs r rzTwoPhaseTransaction._do_commits8.. II4#4#4/6 6 6rS) r*r+r,r-rr.rJrNrrr9r:s@r rFrFs0  !66rrFN)rrr0r<rFr"rr rWs;T$T$n .k ./ /6%6+%6r