ۇeh1!ddlZddlmZddlmZGddejZhdZdd d d d ZGd dej Z dS)N) connresource) exceptionsc"eZdZdZdZdZdZdZdS)TransactionStaterrN)__name__ __module__ __qualname__NEWSTARTED COMMITTED ROLLEDBACKFAILEDE/var/www/api/venv/lib/python3.11/site-packages/asyncpg/transaction.pyrrs' CGIJ FFFrr> serializableread_committedrepeatable_readread_uncommittedrrrr)zread committedzread uncommittedrzrepeatable readceZdZdZdZfdZdZdZej dZ dZ dZ d Z d Zej d Zej d Zd ZxZS) TransactionzRepresents a transaction or savepoint block. Transactions are created by calling the :meth:`Connection.transaction() ` function. ) _connection _isolation _readonly _deferrable_state_nested_id_managedc&t||r1|tvr(tdt|||_||_||_tj |_ d|_ d|_ d|_ dS)Nz2isolation is expected to be either of {}, got {!r}F)super__init__ISOLATION_LEVELS ValueErrorformatrrrrrr r!r"r#)self connection isolationreadonly deferrable __class__s rr&zTransaction.__init__/s $$$  @*:::!6"2I>>@@ @$!%&*   rcK|jrtjdd|_|d{VdS)Nz6cannot enter context: already in an `async with` blockT)r# apg_errorsInterfaceErrorstartr*s r __aenter__zTransaction.__aenter__?sY = J+HJJ J jjllrcK |dn #tj$r|turYdSwxYw ||d{Vn|d{Vd|_dS#d|_wxYw)N __aexit__F)_check_conn_validityr1r2 GeneratorExit_Transaction__rollback_Transaction__commitr#)r*extypeextbs rr7zTransaction.__aexit__Fs   % %k 2 2 2 2(   &&  "!oo''''''''''mmoo%%%%%%%!DMMMEDM ! ! ! !s777A;; BcK|d|jtjurt jd|j}|j5|j rt jd||_n|j rq|jj }|+t|j dd{V}|j |kr-t jd |j |d|_|jr5|d|_d |j}nbd }|j d kr|d z }n2|j d kr|dz }n!|j dkr|dz }n|j dkr|dz }|jr|dz }|jr|dz }|dz } |j|d{Vtj|_dS#t($rtj|_wxYw)z)Enter the transaction or savepoint block.r3z0cannot start; the transaction is already startedNzEcannot use Connection.transaction() in a manually started transactionzSHOW transaction_isolation;zNnested transaction has a different isolation level: current {!r} != outer {!r}T savepointz SAVEPOINT {};BEGINrz ISOLATION LEVEL READ COMMITTEDrz! ISOLATION LEVEL READ UNCOMMITTEDrz ISOLATION LEVEL REPEATABLE READrz ISOLATION LEVEL SERIALIZABLEz READ ONLYz DEFERRABLE;)_Transaction__check_state_baser rrr1r2r _top_xact _protocolis_in_transactionrISOLATION_LEVELS_BY_VALUEfetchvalr)r!_get_unique_idr"rrexecute BaseExceptionr)r*contop_xact_isolationquerys rr3zTransaction.start_s ((( ;*2 2 2+BDD D = }..00 6 /5666!CMM B%(]%="%-)B".779;;;;;;;;*<&?&888$355;V O-?6A6ABBB DL < ))+66DH#**4844EEE"222::$666<<$555;;N2288~ &% '& SLE 3"**511 1 1 1 1 1 1 1 +2DKKK    *1DK  s GG0cb|jtjur'tjd||jtjur'tjd||jtjur'tjd|dS)Nz/cannot {}; the transaction is already committedz1cannot {}; the transaction is already rolled backz,cannot {}; the transaction is in error state)r rrr1r2r)rrr*opnames r__check_state_basezTransaction.__check_state_bases ;*4 4 4+AHH  ;*5 5 5+CJJ  ;*1 1 1+>EE  2 1rc|jtjurQ|jtjur't jd|||dSdS)Nz-cannot {}; the transaction is not yet started)r rrrr1r2r)rCrPs r __check_statezTransaction.__check_statess ;.6 6 6{.222 /CJJ  !!!  # #F + + + + + 7 6rcTK|d|jj|ur d|j_|jrd|j}nd} |j|d{Vtj|_ dS#t$rtj |_ wxYw)NcommitzRELEASE SAVEPOINT {};zCOMMIT;) _Transaction__check_staterrDr!r)r"rJrrr rKrr*rNs r__commitzTransaction.__commits 8$$$   % - -)-D  & < +2248< )appendr)r namelowerrrrr/r startswithr joinid)r*attrsmods r__repr__zTransaction.__repr__s Z&&t{'7'='='?'?@@AAA ? & LL ) ) ) > % LL $ $ $   ' LL & & & > $ / / ; ; ,CC.+C!(( (#((5//2d88EE Er)r r r __doc__ __slots__r&r5r7rguardedr3rCrWr;r:rVr\rk __classcell__)r/s@rrr$s9I """2737373r   ,,,555&666&   EEEEEEErr) enumrrr1Enumrr'rGConnectionResourcerrrrrts &&&&&&ty'*"( RERERERERE,1REREREREREr