+h ddlmZddlmZddlmZddlmZdZdZejZdZdZ d Z Gd d e Z y ) )exc)util)collections_abc) immutabledictc8tjfd}|S)zDecorator, memoize a function in a connection.info stash. Only applicable to functions which take no arguments other than a connection. The memo will be stored in ``connection.info[key]``. c|j} |jS#t$r|||x|j<}|cYSwxYwN)connectinfoKeyError)fnself connectionvalkeys I/var/www/html/venv/lib/python3.12/site-packages/sqlalchemy/engine/util.py decoratedz%connection_memoize..decoratedsS'')  ??3' ' )+D*)= =JOOC 3J s"#AA)r decorator)rrs` rconnection_memoizers# ^^ c||s|r|j|gSgSt|dk(rc|d}t|ttfr%|rt |ddrt |dds|S|gSt |dr|gS|j|ggS|jt |ddrt |dds|S|gS)a Given arguments from the calling form \*multiparams, \**params, return a list of bind parameter structures, usually a list of dictionaries. In the case of 'raw' execution which accepts positional parameters, it may be a list of tuples or lists. __iter__stripkeys)_warn_for_legacy_exec_formatlen isinstancelisttuplehasattrr multiparamsparamszeros r_distill_paramsr(%s    3 3 58OI [ Q 1~ dT5M *47J/Q1 v T6 "6M  3 3 5F8O//1 ;q>: .w NG8  = rc|s|r|gSgSt|dk(rS|d}t|ttfr%|rt |ddrt |dds|S|gSt |dr|gS|ggSt |ddrt |dds|S|gS)z_distill_params without any warnings. more appropriate for "cursor" params that can include tuple arguments, lists of tuples, etc. rrrrr)rr r!r"r#r$s r_distill_cursor_paramsr*Xs  8OI [ Q 1~ dT5M *47J/Q1 v T6 "6MF8O ;q>: .w NG8  = rcj| ttfSt|trC|r8t|dtj t fstjd|ftfSt|t ttfst|tj r |ftfStjd)Nrz9List argument must consist only of tuples or dictionariesz+mapping or sequence expected for parameters) _no_tuple_no_kwr r!rMappingr"r ArgumentErrordictr)r&s r_distill_params_20r1s ~&  FD ! * 1I//7 ##K y&   m$  FO33 4y&   MNNrcHeZdZdZdZdZdZdZdZe dZ dZ d Z y) TransactionalContextzApply Python context manager behavior to transaction objects. Performs validation to ensure the subject of the transaction is not used if the transaction were ended prematurely. Nctr NotImplementedErrorrs r_transaction_is_activez+TransactionalContext._transaction_is_active !##rctr r5r7s r_transaction_is_closedz+TransactionalContext._transaction_is_closedr9rct)aindicates the object is in a state that is known to be acceptable for rollback() to be called. This does not necessarily mean rollback() will succeed or not raise an error, just that there is currently no state detected that indicates rollback() would fail or emit warnings. It also does not mean that there's a transaction in progress, as it is usually safe to call rollback() even if no transaction is present. .. versionadded:: 1.4.28 r5r7s r_rollback_can_be_calledz,TransactionalContext._rollback_can_be_calleds "##rctr r5r7s r _get_subjectz!TransactionalContext._get_subjectr9rcl|j}|r&|jstjdyy)NzCan't operate on closed transaction inside context manager. Please complete the context manager before emitting further commands.)_trans_context_managerr8rInvalidRequestError)clssubject trans_contexts r_trans_ctx_checkz%TransactionalContext._trans_ctx_checks>66  779--8: rch|j}|j}||_||_||_|Sr )r?rA_outer_trans_ctx_trans_subject)rrDrEs r __enter__zTransactionalContext.__enter__s:##% 66 -%)-& rc|j}|duxs|j|u}|C|jr3 |j|s|j|_dx|_|_y |js!|js1|jn |j r|j|s|j|_dx|_|_y#t j 5|j r|jdddn #1swYnxYwYxYw#|s|j|_dx|_|_wxYw#|s|j|_dx|_|_wxYwr ) rIrAr8commitr safe_reraiser=rollbackrHr;close)rtype_value tracebackrDout_of_band_exits r__exit__zTransactionalContext.__exit__sQ%% tO Iw==TI  =T88: C (595J5JG2>BB#d&; C224668 335 '595J5JG2>BB#d&;' (&&((335 ((((595J5JG2>BB#d&;(595J5JG2>BB#d&;s<C'AED(0!D D(D# D(&D++#E#E4) __name__ __module__ __qualname____doc__rIr8r;r=r? classmethodrFrJrTrrrr3r3sAN$$$"$ $Crr3N) rrrrrr,r-r(r*r1objectr3rrrr\sQ" &     0!f+!\O0_C6_Cr