o `^h0@sNddlmZGdddZGdddeZGdddeZGdd d eZd S) )excc@sheZdZdZddZeddZeddZdd Zd d Z d d Z ddZ ddZ ddZ ddZdS) 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(). cCs||_|p||_d|_dS)NT) _connection_parent _is_activeself connectionparentr U/home/air/shanriGPT/back/venv/lib/python3.10/site-packages/aiomysql/sa/transaction.py__init__s  zTransaction.__init__cC|jS)z+Return ``True`` if a transaction is active.)rrr r r is_active"zTransaction.is_activecCr)z8Return transaction's connection (SAConnection instance).)rrr r r r 'rzTransaction.connectioncs4|jjsdS|j|ur|IdHdSd|_dS)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)rrrollbackrr r r close,s    zTransaction.closecs&|jjsdS|IdHd|_dS)zRoll back this transaction.NF)rr _do_rollbackrr r r r=s  zTransaction.rollbackc|jIdHdSN)rrrr r r rDzTransaction._do_rollbackcs,|jjs td|IdHd|_dS)zCommit this transaction.This transaction is inactiveNF)rrrInvalidRequestError _do_commitrr r r commitGs   zTransaction.commitcsdSrr rr r r rOzTransaction._do_commitcs|Srr rr r r __aenter__RrzTransaction.__aenter__cs4|r |IdHdS|jr|IdHdSdSr)rrr)rexc_typeexc_valexc_tbr r r __aexit__Us zTransaction.__aexit__N)__name__ __module__ __qualname____doc__r propertyrr rrrrrrr!r r r r rs   rcs,eZdZfddZddZddZZS)RootTransactioncst|ddSrsuperr )rr  __class__r r r _zRootTransaction.__init__crr)r_rollback_implrr r r rbrzRootTransaction._do_rollbackcrr)r _commit_implrr r r rerzRootTransaction._do_commit)r"r#r$r rr __classcell__r r r*r r']s r'cs4eZdZdZdZfddZddZddZZS) 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. Ncst||dSrr(rr*r r r tr,zNestedTransaction.__init__c:|jdus Jd|jr|j|j|jIdHdSdSNzBroken transaction logic) _savepointrr_rollback_to_savepoint_implrrr r r rwzNestedTransaction._do_rollbackcr1r2)r3rr_release_savepoint_implrrr r r r}r5zNestedTransaction._do_commit) r"r#r$r%r3r rrr/r r r*r r0is  r0csDeZdZdZfddZeddZddZdd Zd d Z Z 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. cst|dd|_||_dS)NF)r)r _is_prepared_xid)rr xidr*r r r s zTwoPhaseTransaction.__init__cCr)z Returns twophase transaction id.)r9rr r r r:rzTwoPhaseTransaction.xidcs2|jjs td|j|jIdHd|_dS)zfPrepare this TwoPhaseTransaction. After a PREPARE, the transaction can be committed. rNT)rrrrr_prepare_twophase_implr9r8rr r r prepares   zTwoPhaseTransaction.preparec |jj|j|jdIdHdSN) is_prepared)rrollback_preparedr9r8rr r r rz TwoPhaseTransaction._do_rollbackcr=r>)rcommit_preparedr9r8rr r r rrAzTwoPhaseTransaction._do_commit) r"r#r$r%r r&r:r<rrr/r r r*r r7s   r7N)rrr'r0r7r r r r s W