U µ©Þa-ã@sòddlmZmZddlmZmZmZmZmZGdd„deƒZ d)dd„Z d*dd „Z d+d d „Z d,d d „Z d-dd„Zd.dd„Zd/dd„Zd0dd„Zd1dd„Zd2dd„Zd3dd„Zed4dd„ƒZd5dd„ZGd d!„d!eƒZd6d#d$„Zd%d&„Zd7d'd(„ZdS)8é)ÚContextDecoratorÚcontextmanager)ÚDEFAULT_DB_ALIASÚ DatabaseErrorÚErrorÚProgrammingErrorÚ connectionsc@seZdZdZdS)ÚTransactionManagementErrorz*Transaction management is used improperly.N)Ú__name__Ú __module__Ú __qualname__Ú__doc__©rrú„/home/adriano.carvalho/ftp/files/BrinquedotecaVirtual/brinquedotecavirtual/venv/lib/python3.8/site-packages/django/db/transaction.pyr sr NcCs|dkr t}t|S)z‚ Get a database connection by name, or the default database connection if no name is provided. This is a private API. N)rr©ÚusingrrrÚget_connection srcCs t|ƒ ¡S)z,Get the autocommit status of the connection.)rÚget_autocommitrrrrrsrcCst|ƒ |¡S)z,Set the autocommit status of the connection.)rÚset_autocommit)Z autocommitrrrrrsrcCst|ƒ ¡dS)zCommit a transaction.N)rÚcommitrrrrr!srcCst|ƒ ¡dS)zRoll back a transaction.N)rÚrollbackrrrrr&srcCs t|ƒ ¡S)zÏ Create a savepoint (if supported and required by the backend) inside the current transaction. Return an identifier for the savepoint that will be used for the subsequent rollback or commit. )rÚ savepointrrrrr+srcCst|ƒ |¡dS)zn Roll back the most recent savepoint (if one exists). Do nothing if savepoints are not supported. N)rÚsavepoint_rollback©Úsidrrrrr4srcCst|ƒ |¡dS)zk Commit the most recent savepoint (if one exists). Do nothing if savepoints are not supported. N)rÚsavepoint_commitrrrrr<srcCst|ƒ ¡dS)zQ Reset the counter used to generate unique savepoint ids in this thread. N)rÚclean_savepointsrrrrrDsrcCs t|ƒ ¡S)z9Get the "needs rollback" flag -- for *advanced use* only.)rÚ get_rollbackrrrrrKsrcCst|ƒ |¡S)aã Set or unset the "needs rollback" flag -- for *advanced use* only. When `rollback` is `True`, trigger a rollback when exiting the innermost enclosing atomic block that has `savepoint=True` (that's the default). Use this to force a rollback without raising an exception. When `rollback` is `False`, prevent such a rollback. Use this only after rolling back to a known-good state! Otherwise, you break the atomic block and data corruption may occur. )rÚ set_rollback)rrrrrrPs rccs:z dVWn*tk r4t|ƒ}|jr.d|_‚YnXdS)ab Internal low-level utility to mark a transaction as "needs rollback" when an exception is raised while not enforcing the enclosed block to be in a transaction. This is needed by Model.save() and friends to avoid starting a transaction when in autocommit mode and a single query is executed. It's equivalent to: connection = get_connection(using) if connection.get_autocommit(): yield else: with transaction.atomic(using=using, savepoint=False): yield but it uses low-level utilities to avoid performance overhead. NT)Ú ExceptionrÚin_atomic_blockÚneeds_rollback)rÚ connectionrrrÚmark_for_rollback_on_error_s r#cCst|ƒ |¡dS)z› Register `func` to be called when the current transaction is committed. If the current transaction is rolled back, `func` will not be called. N)rÚ on_commit)Úfuncrrrrr${sr$c@s(eZdZdZdd„Zdd„Zdd„ZdS) ÚAtomica‚ Guarantee the atomic execution of a given block. An instance can be used either as a decorator or as a context manager. When it's used as a decorator, __call__ wraps the execution of the decorated function in the instance itself, used as a context manager. When it's used as a context manager, __enter__ creates a transaction or a savepoint, depending on whether a transaction is already in progress, and __exit__ commits the transaction or releases the savepoint on normal exit, and rolls back the transaction or to the savepoint on exceptions. It's possible to disable the creation of savepoints if the goal is to ensure that some code runs within a transaction without creating overhead. A stack of savepoints identifiers is maintained as an attribute of the connection. None denotes the absence of a savepoint. This allows reentrancy even if the same AtomicWrapper is reused. For example, it's possible to define `oa = atomic('other')` and use `@oa` or `with oa:` multiple times. Since database connections are thread-local, this is thread-safe. This is a private API. cCs||_||_dS©N©rr)ÚselfrrrrrÚ__init__¤szAtomic.__init__cCs~t|jƒ}|js0d|_d|_| ¡s0d|_d|_|jrf|jrX|jsX| ¡}|j |¡qz|j d¡n|j dddd|_dS)NTF)Z.force_begin_transaction_with_broken_autocommit) rrr Úcommit_on_exitr!rrÚ savepoint_idsÚappendr)r)r"rrrrÚ __enter__¨s  zAtomic.__enter__c CsÐt|jƒ}|jr|j ¡}nd|_zZ|jr0nL|dkrø|j sø|jr¨|dk röz|  |¡Wqöt k r¤z|  |¡|  |¡Wnt k rœd|_ YnX‚YqöXnNz | ¡Wn@t k rôz | ¡Wnt k rì| ¡YnX‚YnXn„d|_ |jrP|dkrd|_ n6z|  |¡|  |¡Wnt k rLd|_ YnXn,z | ¡Wnt k rz| ¡YnXW5|js¤|jr˜d|_n | d¡n&|jsÊ|jsÊ|jrÄd|_nd|_XdS)NFT)rrr,Úpopr Zclosed_in_transactionr"rr+r!rrrrrrÚclose)r)Úexc_typeÚ exc_valueÚ tracebackr"rrrrÚ__exit__Äs`            zAtomic.__exit__N)r r r r r*r.r4rrrrr&‡sr&TcCs$t|ƒrtt|ƒ|ƒSt||ƒSdSr')Úcallabler&rr(rrrÚatomicsr6cCs2z|j |¡Wntk r,|h|_YnX|Sr')Ú_non_atomic_requestsÚaddÚAttributeError)Úviewrrrrr7's r7cs.tˆƒrtˆtƒSˆdkrt‰‡fdd„SdS)Ncs t|ˆƒSr')r7)r:rrrÚ5óz%non_atomic_requests..)r5r7rrrrrÚnon_atomic_requests/s  r=)N)N)N)N)N)N)N)N)N)N)N)N)N)NT)N)Ú contextlibrrZ django.dbrrrrrr rrrrrrrrrrrr#r$r&r6r7r=rrrrÚs*