/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
engine
/
up file
home
� 1��fc @ s� d d l m Z d d l m Z d d l m Z d d l m Z d � Z d Z e j � Z d � Z d � Z d � Z d e f d � � YZ d S( i ( t exc( t util( t collections_abc( t immutabledictc s t j � f d � � } | S( s� Decorator, 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 sN | j � } y | j � SWn, t k rI | | | � | j � <} | SXd S( N( t connectt infot KeyError( t fnt selft connectiont val( t key( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt decorated s ( R t decorator( R R ( ( R sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt connection_memoize s c C s� | s$ | r | j � | g Sg Sn� t | � d k r� | d } t | t t f � r� | s� t | d d � r� t | d d � r� | S| g Sq� t | d � r� | g S| j � | g g Sn< | j � t | d d � r� t | d d � r� | S| g Sd S( s 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. i i t __iter__t stript keysN( t _warn_for_legacy_exec_formatt lent isinstancet listt tuplet hasattr( R t multiparamst paramst zero( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _distill_params% s, c C s� | s | r | g Sg Sn� t | � d k r� | d } t | t t f � r� | sy t | d d � r} t | d d � r} | S| g Sq� t | d � r� | g S| g g Sn2 t | d d � r� t | d d � r� | S| g Sd S( s� _distill_params without any warnings. more appropriate for "cursor" params that can include tuple arguments, lists of tuples, etc. i i R R R N( R R R R R ( R R R R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _distill_cursor_paramsX s& c C s� | d k r t t f St | t � rg | rZ t | d t j t f � rZ t j d � � n | f t f St | t t t f � s� t | t j � r� | f t f St j d � � d S( Ni s9 List argument must consist only of tuples or dictionariess+ mapping or sequence expected for parameters( t Nonet _no_tuplet _no_kwR R R t MappingR R t ArgumentErrort dictR ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _distill_params_20� s t TransactionalContextc B sY e Z d Z d Z d � Z d � Z d � Z d � Z e d � � Z d � Z d � Z RS( s� Apply 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. c C s t � � d S( N( t NotImplementedError( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _transaction_is_active� s c C s t � � d S( N( R% ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _transaction_is_closed� s c C s t � � d S( s indicates 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 N( R% ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _rollback_can_be_called� s c C s t � � d S( N( R% ( R ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _get_subject� s c C s4 | j } | r0 | j � s0 t j d � � q0 n d S( Ns� Can't operate on closed transaction inside context manager. Please complete the context manager before emitting further commands.( t _trans_context_managerR& R t InvalidRequestError( t clst subjectt trans_context( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt _trans_ctx_check� s c C s4 | j � } | j } | | _ | | _ | | _ | S( N( R) R* t _outer_trans_ctxt _trans_subject( R R- R. ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt __enter__� s c C s" | j } | d k p! | j | k } | d k r� | j � r� zH y | j � Wn3 t j � � | j � ry | j � n Wd QXn XWd | s� | j | _ n d | _ | _ Xnn zE | j � s� | j � s� | j � q� n | j � r� | j � n Wd | s | j | _ n d | _ | _ Xd S( N( R1 R R* R& t commitR t safe_reraiseR( t rollbackR0 R' t close( R t type_t valuet tracebackR- t out_of_band_exit( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt __exit__� s, N( t __name__t __module__t __doc__R R1 R& R' R( R) t classmethodR/ R2 R; ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyR$ � s N( ( t R R R R R R R R R R# t objectR$ ( ( ( sI /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/engine/util.pyt <module> s 3 .