j$dZddlmZddlZddlmZddlmZmZm Z m Z ddl m Z ddl mZmZdd lmZmZdd lmZdd lmZer dd lmZdd lmZej6j8Zej:j<Zej>e Z!Gdde"Z#Gdde jHZ%Gdde eZ&Gdde&dZ'Gdde&dZ(y)zC Transaction context managers returned by Connection.transaction() ) annotationsN) TracebackType) TYPE_CHECKINGAnyGenericIterator)errors)pqsql)ConnectionTypePQGen)Self)connection_summary) Connection)AsyncConnectionc&eZdZdZdZdddZddZy) Rollbacka Exit the current `Transaction` context immediately and rollback any changes made within this context. If a transaction context is specified in the constructor, rollback enclosing transactions contexts up to and including the one specified. psycopgNc||_yN) transaction)selfrs Z/var/www/html/kelly/kelly-backend/venv/lib/python3.12/site-packages/psycopg/transaction.py__init__zRollback.__init__)s &cN|jjd|jdS)N()) __class__ __qualname__rrs r__repr__zRollback.__repr__,s'..--.a0@0@/C1EErr)rz%Transaction | AsyncTransaction | Nonereturnstr)__name__ __module__r!__doc__rr#rrrrsJ'FrrceZdZdZy)OutOfOrderTransactionNestingz)Out-of-order transaction nesting detectedN)r'r(r!r)r*rrr,r,0s3rr,ceZdZ d ddZeddZddZddZ ddZddZ ddZ dd Z dd Z dd Z dd Zdd Zy)BaseTransactionNc||_|jj|_|xsd|_||_dx|_|_d|_d|_y)NF)_connpgconn_savepoint_nameforce_rollback_entered_exited_outer_transaction _stack_index)r connectionsavepoint_namer5s rrzBaseTransaction.__init__5sO   jj'' -3,',,  "'rc|jS)zV The name of the savepoint; `!None` if handling the main transaction. )r4r"s rr;zBaseTransaction.savepoint_nameCs###rc <|jjd|jj}t|j}|j sd}n|j sd}nd}|jr|jdnd}d|d|d|d |d t|d d S) N.inactiveactive terminated r0) r r(r!rr3r6r7r;id)rclsinfostatussps rr#zBaseTransaction.__repr__Ls**+1T^^-H-H,IJ!$++.}}FF!F,0,?,?##&a (R3%qAfXRvVBtHQ>? * ?/   DdDQ sI"A>AA>AAAA>AA;A61A>6A;;A>c#K|jd}d|_|r||jD]%}|jj |Ed{'y7w)NcommitT)_pop_savepointr7_get_commit_commandsr2rO)rexrPs rrSzBaseTransaction._commit_gen{sS   * H002Gzz//8 8 83 8sAAAAc#0Kt|tr$tj|jdd|j d}d|_|r||jD]%}|jj|Ed{'|jjj|jjj|jEd{t|tr|jr|j|uryy772w)Nz: Explicit rollback from: T)exc_inforollbackF) isinstancerrVdebugr2r_r7_get_rollback_commandsrO _preparedclear maintain_genr)rrYrarPs rrTzBaseTransaction._rollback_gens gx ( LLDJJ<'ABTL R   , H224Gzz//8 8 85 ""$::''44TZZ@@@ gx (&&'*=*=*E 9 As%BDDAD!D"1DDc#.K|jr|jj|jr]t j dj t j|jj|jyyw)Nz SAVEPOINT {}) r8r2_get_tx_start_commandr4r SQLformat Identifieras_bytesr"s rrNz#BaseTransaction._get_enter_commandssh  " "**224 4   't';';<=$**%  sBBc#FK|jrh|js\tjdj tj |jj |j|jr|jjrJdyyw)Nz RELEASE {}sCOMMIT r4r8r rmrnrorpr2_num_transactionsr"s rr`z$BaseTransaction._get_commit_commandssw   (?(? %t';';<=$**%   " "zz33 33O #sBB!c#K|jr|jstjdj tj |jj |jtjdj tj |jj |j|jr|jjrJdyyw)NzROLLBACK TO {n})nz RELEASE {n}sROLLBACKrrr"s rrgz&BaseTransaction._get_rollback_commandss   (?(?)*#..)=)=>?$**%   &#..)=)=>?$**%   " "zz33 33  #sC=C?c^|jjtk(|_|jr|jj r/J|j s!d|jj dz|_|jj |_|jxj dz c_y)z Push the transaction on the connection transactions stack. Also set the internal state of the object and verify consistency. _pg3_r N)r3transaction_statusIDLEr8r2rsr4r9r"s rrMzBaseTransaction._push_savepoints #'++"@"@D"H  " "zz33 33'').tzz/K/Ka/O.P'Q$ JJ88 $$)$rc|jxjdzc_|jj|jk(rytd|d|S)zy Pop the transaction from the connection transactions stack. Also verify the state consistency. r Nz transaction z at the wrong nesting level: )r2rsr9r,)ractions rr_zBaseTransaction._pop_savepointsR $$)$ :: ' '4+<+< <+6("?v F  rNF)r:r r; str | Noner5bool)r%r}r$)r%z PQGen[None])rXtype[BaseException] | NonerYBaseException | NonerZTracebackType | Noner% PQGen[bool])rYrr%r)r%zIterator[bytes])r%None)r{r&r%zException | None)r'r(r!rpropertyr;r#rQr\rSrTrNr`rgrMr_r*rrr.r.4s&*$ " #  $$ B9,&%   29,  "*&  rr.cFeZdZdZdZeddZddZ d dZy) TransactionzO Returned by `Connection.transaction()` to handle a transaction block. rc|jS)z&The connection the object is managing.r2r"s rr:zTransaction.connectionszzrc|jj5|jj|jddd|S#1swY|SxYwrr2lockwaitrQr"s r __enter__zTransaction.__enter__s9 ZZ__ JJOODOO- .  s *A  Ac|jjtk(rL|jj5|jj |j |||cdddSy#1swYyxYwr|r3rIOKr2rrr\rrXrYrZs r__exit__zTransaction.__exit__sR ;;   #zzt~~h'PQ!!s ,A++A4N)r%Connection[Any]r%rrXrrYrrZrr%r~)r'r(r!r)rr:rrr*rrrrsPJ  , & %   rrrcFeZdZdZdZeddZddZ d dZy) AsyncTransactionzT Returned by `AsyncConnection.transaction()` to handle a transaction block. rc|jSrrr"s rr:zAsyncTransaction.connection s zzrcK|jj4d{|jj|jd{dddd{|S7G77 #1d{7swY|SxYwwrrr"s r __aenter__zAsyncTransaction.__aenter__ sW::???**//$//"34 4 4#? # 4#??? sVBA%B-A+A'A+ BA)B'A+)B+A>1A4 2A>9BcDK|jjtk(rd|jj4d{|jj |j |||d{cdddd{Sy7J77 #1d{7swYyxYwwr|rrs r __aexit__zAsyncTransaction.__aexit__sk ;;   #zz!ZZ__T^^Hgv-VWW''W'sV8B BB 0B .B/B 2 B >B ?B B  B  BB BB N)r%AsyncConnection[Any]rr)r'r(r!r)rr:rrr*rrrrsPJ  , & %   rrr))r) __future__rloggingtypesrtypingrrrrr0r er r abcr r_compatrpq.miscrr:rconnection_asyncrTransactionStatusry ConnStatusr getLoggerr'rVrUrProgrammingErrorr,r.rrr*rrrs #88&'&1   ]]   8 $FyF$41#5#54m gn-m `/"34<'=>r