o h1!@s^ddlZddlmZddlmZGdddejZhdZdd d d d ZGd ddej Z dS)N) connresource) exceptionsc@s eZdZdZdZdZdZdZdS)TransactionStaterrN)__name__ __module__ __qualname__NEWSTARTED COMMITTED ROLLEDBACKFAILEDrrg/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/asyncpg/transaction.pyrs r> serializableread_committedrepeatable_readread_uncommittedrrrr)zread committedzread uncommittedrzrepeatable readcseZdZdZdZfddZddZddZej d d Z d d Z d dZ ddZ ddZej ddZej ddZddZZS) TransactionzRepresents a transaction or savepoint block. Transactions are created by calling the :meth:`Connection.transaction() ` function. ) _connection _isolation _readonly _deferrable_state_nested_id_managedcsXt||r|tvrtdt|||_||_||_tj |_ d|_ d|_ d|_ dS)Nz2isolation is expected to be either of {}, got {!r}F)super__init__ISOLATION_LEVELS ValueErrorformatrrrrr rrrr)self connection isolationreadonly deferrable __class__rrr!/s   zTransaction.__init__cs*|jr tdd|_|IdHdS)Nz6cannot enter context: already in an `async with` blockT)r apg_errorsInterfaceErrorstartr%rrr __aenter__?szTransaction.__aenter__cszz|dWntjy|turYdSwz|dur&|IdHn |IdHWd|_dSWd|_dSd|_w)N __aexit__F)_check_conn_validityr,r- GeneratorExit_Transaction__rollback_Transaction__commitr)r%extypeextbrrrr1Fs  zTransaction.__aexit__csp|d|jtjurtd|j}|jdur'|j r#td||_n(|j rL|jj }|dur=t |j dIdH}|j |krLtd |j |d|_|jr_|d|_d |j}n;d }|j d krk|d 7}n|j d kru|d7}n|j dkr|d7}n |j dkr|d7}|jr|d7}|jr|d7}|d7}z |j|IdHWn tytj|_wtj|_dS)z)Enter the transaction or savepoint block.r.z0cannot 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_baserrr r,r-r _top_xact _protocolis_in_transactionrISOLATION_LEVELS_BY_VALUEfetchvalr$r_get_unique_idrrrexecute BaseExceptionr)r%contop_xact_isolationqueryrrrr._sj               zTransaction.startcCsX|jtjurtd||jtjurtd||jtjur*td|dS)Nz/cannot {}; the transaction is already committedz1cannot {}; the transaction is already rolled backz,cannot {}; the transaction is in error state)rrrr,r-r$rrr%opnamerrr__check_state_bases&   zTransaction.__check_state_basecCs:|jtjur|jtjurtd|||dSdS)Nz-cannot {}; the transaction is not yet started)rrr r r,r-r$r<rHrrr __check_states  zTransaction.__check_statect|d|jj|urd|j_|jrd|j}nd}z |j|IdHWn ty3tj |_ wtj |_ dS)NcommitzRELEASE SAVEPOINT {};zCOMMIT;) _Transaction__check_staterr=rr$rrCrDrrrrr%rGrrr__commit    zTransaction.__commitcrL)NrollbackzROLLBACK TO {};z ROLLBACK;) rNrr=rr$rrCrDrrrrrOrrr __rollbackrQzTransaction.__rollbackc$|jr td|IdHdS)z;Exit the transaction or savepoint block and commit changes.z8cannot manually commit from within an `async with` blockN)rr,r-r5r/rrrrM zTransaction.commitcrT)z=Exit the transaction or savepoint block and rollback changes.z:cannot manually rollback from within an `async with` blockN)rr,r-r4r/rrrrRrUzTransaction.rollbackcCsg}|d|jj|jdur||j|jr!|d|jr)|d|jj dr3d}n|jj }d||jj d |t |S)Nzstate:{}r(r)zasyncpg.asyncpgz<{}.{} {} {:#x}> )appendr$rnamelowerrrrr+r startswithr joinid)r%attrsmodrrr__repr__s    zTransaction.__repr__)r r r __doc__ __slots__r!r0r1rguardedr.r<rNr5r4rMrRr` __classcell__rrr*rr$s"  9  r) enumrrr,Enumrr"r@ConnectionResourcerrrrrs