/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
sql
/
up file
home
� 1��fc @ s� d Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z e Z e Z e Z e j d � Z e j d � Z d e f d � � YZ d e f d � � YZ d � Z d � Z d � Z d � Z d � Z d � Z! d � Z" d � Z# d e j$ j% f d � � YZ& d! e j$ j% f d" � � YZ' e j( d# � d$ � � Z) d% e f d& � � YZ* d' e f d( � � YZ+ d) e f d* � � YZ, d+ e f d, � � YZ- d- e, f d. � � YZ. d/ e/ f d0 � � YZ0 d1 e j1 e0 � f d2 � � YZ2 d3 e2 e f d4 � � YZ3 d5 e f d6 � � YZ4 d7 e j5 e, f d8 � � YZ6 d9 e7 f d: � � YZ8 d; e f d< � � YZ9 d= e f d> � � YZ: d? e f d@ � � YZ; dA e; f dB � � YZ< dC e j= e; f dD � � YZ> dE e j? f dF � � YZ@ e dG � ZA dH � ZB e dI � ZC d S(J s4 Foundational utilities common to many sql modules. i����Ni ( t roles( t visitors( t HasCacheKey( t HasCopyInternals( t MemoizedHasCacheKey( t ClauseVisitor( t ExtendedInternalTraversal( t InternalTraversali ( t exc( t util( t HasMemoized( t hybridmethodt PARSE_AUTOCOMMITt NO_ARGt Immutablec B s8 e Z d Z e Z d � Z d � Z d � Z d � Z RS( s@ mark a ClauseElement as 'immutable' when expressions are cloned.c O s t d � � d S( Ns( Immutable objects do not support copying( t NotImplementedError( t selft optionaldictt kwargs( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt unique_params, s c O s t d � � d S( Ns( Immutable objects do not support copying( R ( R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt params/ s c K s | S( N( ( R t kw( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _clone2 s c K s d S( N( ( R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _copy_internals5 s ( t __name__t __module__t __doc__t Truet _is_immutableR R R R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR ' s t SingletonConstantc B s, e Z d Z e Z d � Z e d � � Z RS( s. Represent SQL constants like NULL, TRUE, FALSEc O s | j S( N( t _singleton( t clst argR ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __new__> s c C s8 t j | � } | j � t | g � | _ | | _ d S( N( t objectR! t __init__t frozensett proxy_setR ( R t obj( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _create_singletonA s ( R R R R t _is_singleton_constantR! t classmethodR' ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR 9 s c G s& t j j g | D] } | j ^ q � S( N( t itertoolst chaint from_iterablet _from_objects( t elementst element( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR- Q s c C s& t j j g | D] } | j ^ q � S( sX expand tables into individual columns in the given list of column expressions. ( R* R+ R, t _select_iterable( R. t c( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _select_iterablesW s c C s+ t j d � � } | | � } | | _ | S( s� non-caching _generative() decorator. This is basically the legacy decorator that copies the object and runs a method on the new copy. c _ s: | j � } | | | | � } | d k s6 t d � � | S( s Mark a method as generative.s, generative methods must have no return valueN( t _generatet Nonet AssertionError( t fnR t argsR t x( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _generativei s ( R t decoratort non_generative( R6 R9 t decorated( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR9 a s c sz | j d i � � | j d i � } g | D]* } | t j | � | j | d � f ^ q+ � t j � � f d � � } | S( Nt msgst defaultsc s� | d } | d } x] � D]U \ } } } | | � | k r � j | d | j | j f � } t j | � � q q W| | | | � S( Ni i s9 Method %s() has already been invoked on this %s construct( t getR t __class__R t InvalidRequestError( R6 R7 R R t namet gettert default_t msg( t gettersR= ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt check� s ( t popt operatort attrgetterR? R4 R R: ( t namesR R> RB RG ( ( RF R= sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _exclusive_againstw s 4c K s | j | � S( N( R ( R/ R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR � s c C s# t j g | D] } | j ^ q � S( s\ expand the given set of ClauseElements to be the set of all 'cloned' predecessors. ( R* R+ t _cloned_set( R. R8 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _expand_cloned� s c s; t t | � � j t | � � � t � f d � | D� � S( s� return the intersection of sets a and b, counting any overlap between 'cloned' predecessors. The returned set is in terms of the entities present within 'a'. c 3 s' | ] } � j | j � r | Vq d S( N( t intersectionRM ( t .0t elem( t all_overlap( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( t setRN RO ( t at b( ( RR sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _cloned_intersection� s !c s; t t | � � j t | � � � t � f d � | D� � S( Nc 3 s' | ] } � j | j � s | Vq d S( N( RO RM ( RP RQ ( RR ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( RS RN RO ( RT RU ( ( RR sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _cloned_difference� s !t _DialectArgViewc B sM e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( sa A dictionary view of dialect-level arguments in the form <dialectname>_<argument_name>. c C s | | _ d S( N( R& ( R R& ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# � s c C sY y | j d d � \ } } Wn, t k rJ } t j t | � d | �n X| | f Sd S( Nt _i t replace_context( t splitt ValueErrorR t raise_t KeyError( R t keyt dialectt value_keyt err( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _key� s c C sg | j | � \ } } y | j j | } Wn/ t j k rZ } t j t | � d | �n X| | Sd S( NRZ ( Rc R& t dialect_optionsR t NoSuchModuleErrorR R] R^ ( R R_ R` Ra t optRb ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __getitem__� s c C sc y | j | � \ } } Wn/ t k rJ } t j t j d � d | �n X| | j j | | <d S( Ns0 Keys must be of the form <dialectname>_<argname>RZ ( Rc R^ R R] R t ArgumentErrorR& Rd ( R R_ t valueR` Ra Rb ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __setitem__� s c C s* | j | � \ } } | j j | | =d S( N( Rc R& Rd ( R R_ R` Ra ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __delitem__� s c C s t d � | j j j � D� � S( Nc s s | ] } t | j � Vq d S( N( t lent _non_defaults( RP R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( t sumR& Rd t values( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __len__� s c s � f d � � j j D� S( Nc 3 s9 | ]/ } � j j | j D] } d | | f Vq q d S( s %s_%sN( R& Rd Rm ( RP t dialect_namet value_name( R ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( R& Rd ( R ( ( R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __iter__� s ( R R R R# Rc Rg Rj Rk Rp Rs ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRX � s t _DialectArgDictc B sD e Z d Z d � Z d � Z d � Z d � Z d � Z d � Z RS( s� A dictionary view of dialect-level arguments for a specific dialect. Maintains a separate collection of user-specified arguments and dialect-specified default arguments. c C s i | _ i | _ d S( N( Rm t _defaults( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# � s c C s t t | j � j | j � � S( N( Rl RS Rm t unionRu ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRp � s c C s t t | j � j | j � � S( N( t iterRS Rm Rv Ru ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRs s c C s) | | j k r | j | S| j | Sd S( N( Rm Ru ( R R_ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRg s c C s | | j | <d S( N( Rm ( R R_ Ri ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRj s c C s | j | =d S( N( Rm ( R R_ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRk s ( R R R R# Rp Rs Rg Rj Rk ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRt � s s sqlalchemy.dialectsc C s8 t j j j j | � } | j d k r+ d St | j � S( N( R t preloadedt dialectst registryt loadt construct_argumentsR4 t dict( Rq t dialect_cls( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _kw_reg_for_dialect s t DialectKWArgsc B s� e Z d Z d e j f g Z e d � � Z e j d � � Z e d � � Z e j e � Z d � Z e j d � � Z d � Z RS( s9 Establish the ability for a class to have dialect-specific arguments with defaults and constructor validation. The :class:`.DialectKWArgs` interacts with the :attr:`.DefaultDialect.construct_arguments` present on a dialect. .. seealso:: :attr:`.DefaultDialect.construct_arguments` Rd c C sZ t j | } | d k r/ t j d | � � n | | k rH i | | <n | | | | <d S( s� Add a new kind of dialect-specific keyword argument for this class. E.g.:: Index.argument_for("mydialect", "length", None) some_index = Index('a', 'b', mydialect_length=5) The :meth:`.DialectKWArgs.argument_for` method is a per-argument way adding extra arguments to the :attr:`.DefaultDialect.construct_arguments` dictionary. This dictionary provides a list of argument names accepted by various schema-level constructs on behalf of a dialect. New dialects should typically specify this dictionary all at once as a data member of the dialect class. The use case for ad-hoc addition of argument names is typically for end-user code that is also using a custom compilation scheme which consumes the additional arguments. :param dialect_name: name of a dialect. The dialect must be locatable, else a :class:`.NoSuchModuleError` is raised. The dialect must also include an existing :attr:`.DefaultDialect.construct_arguments` collection, indicating that it participates in the keyword-argument validation and default system, else :class:`.ArgumentError` is raised. If the dialect does not include this collection, then any keyword argument can be specified on behalf of this dialect already. All dialects packaged within SQLAlchemy include this collection, however for third party dialects, support may vary. :param argument_name: name of the parameter. :param default: default value of the parameter. .. versionadded:: 0.9.4 sR Dialect '%s' does have keyword-argument validation and defaults enabled configuredN( R� t _kw_registryR4 R Rh ( R Rq t argument_namet defaultt construct_arg_dictionary( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt argument_for) s ( c C s t | � S( s9 A collection of keyword arguments specified as dialect-specific options to this construct. The arguments are present here in their original ``<dialect>_<kwarg>`` format. Only arguments that were actually passed are included; unlike the :attr:`.DialectKWArgs.dialect_options` collection, which contains all options known by this dialect including defaults. The collection is also writable; keys are accepted of the form ``<dialect>_<kwarg>`` where the value will be assembled into the list of options. .. versionadded:: 0.9.2 .. versionchanged:: 0.9.4 The :attr:`.DialectKWArgs.dialect_kwargs` collection is now writable. .. seealso:: :attr:`.DialectKWArgs.dialect_options` - nested dictionary form ( RX ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt dialect_kwargs[ s c C s | j S( s4 A synonym for :attr:`.DialectKWArgs.dialect_kwargs`.( R� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR u s c C s� t j | } t � } | d k r< | j j i d d 6� n@ x= t | j j � D]) } | | k rO | j j | | � qO qO W| S( Nt *( R� R� Rt R4 Ru t updatet reversedR@ t __mro__( R Rq R� t dR ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _kw_reg_for_dialect_cls| s c C s t j t j | j � � S( s� A collection of keyword arguments specified as dialect-specific options to this construct. This is a two-level nested registry, keyed to ``<dialect_name>`` and ``<argument_name>``. For example, the ``postgresql_where`` argument would be locatable as:: arg = my_object.dialect_options['postgresql']['where'] .. versionadded:: 0.9.2 .. seealso:: :attr:`.DialectKWArgs.dialect_kwargs` - flat dictionary form ( R t PopulateDictt portable_instancemethodR� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRd � s c C s% | s d Sx| D] } t j d | � } | sB t d | � � n | j d d � \ } } y | j | } Wng t j k r� t j d | | f � t � | j | <} | j j i d d 6� | | | j | <q Xd | k r| | k rt j d | | | j f � � q | | | | <q Wd S( Ns ^(.+?)_(.+)$sG Additional arguments should be named <dialectname>_<argument>, got '%s'i i sH Can't validate argument %r; can't locate any SQLAlchemy dialect named %rR� s9 Argument %r is not accepted by dialect %r on behalf of %r( t ret matcht TypeErrort groupRd R Re R t warnRt Ru R� R4 Rm Rh R@ ( R R t kt mRq t arg_nameR� R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _validate_dialect_kwargs� s0 ( R R R R t dp_dialect_optionst" _dialect_kwargs_traverse_internalsR) R� R t memoized_propertyR� t propertyR R� R R� R� Rd R� ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� s 2 t CompileStatec B s_ e Z d Z d Z i Z e d � � Z d � Z e d � � Z e d � � Z e d � � Z RS( s Produces additional object state necessary for a statement to be compiled. the :class:`.CompileState` class is at the base of classes that assemble state for a particular statement object that is then used by the compiler. This process is essentially an extension of the process that the SQLCompiler.visit_XYZ() method takes, however there is an emphasis on converting raw user intent into more organized structures rather than producing string output. The top-level :class:`.CompileState` for the statement being executed is also accessible when the execution context works with invoking the statement and collecting results. The production of :class:`.CompileState` is specific to the compiler, such as within the :meth:`.SQLCompiler.visit_insert`, :meth:`.SQLCompiler.visit_select` etc. methods. These methods are also responsible for associating the :class:`.CompileState` with the :class:`.SQLCompiler` itself, if the statement is the "toplevel" statement, i.e. the outermost SQL statement that's actually being executed. There can be other :class:`.CompileState` objects that are not the toplevel, such as when a SELECT subquery or CTE-nested INSERT/UPDATE/DELETE is generated. .. versionadded:: 1.4 t statementc K s� | j rd | j j d d � } | j j | | j f d � } | d k rz | j d | j f } qz n | j d | j f } | | k r� | | | | � S| j | | | � Sd S( Nt compile_state_pluginR� ( t _propagate_attrsR? t pluginst _effective_plugin_targetR4 t create_for_statement( R R� t compilerR t plugin_namet klass( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s c K s | | _ d S( N( R� ( R R� R� R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# s c C sx | j j d d � } | rG | | j f } | | j k rG | j | Sn y | j d | j f SWn t k rs d SXd S( NR� R� ( R� R? R4 R� R� R^ ( R R� R� R_ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt get_plugin_class s c C s1 y | j | | j f SWn t k r, d SXd S( N( R� R� R^ R4 ( R R� R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _get_plugin_class_for_plugin s c s � � � f d � } | S( Nc s | � j � � f <| S( N( R� ( t cls_to_decorate( R R� t visit_name( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt decorate" s ( ( R R� R� R� ( ( R R� R� sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt plugin_for s ( R� ( R R R t __slots__R� R) R� R# R� R� R� ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s t Generativec B s e Z d Z d � Z RS( sU Provide a method-chaining pattern in conjunction with the @_generative decorator.c sh | j � | j } | j | � } � rR � f d � | j j � j � D� | _ n | j j � | _ | S( Nc s+ i | ]! \ } } | � k r | | � q S( ( ( RP R� t v( t skip( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <dictcomp>4 s ( t _memoized_keysR@ R! t __dict__t copyt items( R R t s( ( R� sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR3 - s +( R R R R3 ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� ) s t InPlaceGenerativec B s e Z d Z d � Z RS( sk Provide a method-chaining pattern in conjunction with the @_generative decorator that mutates in place.c C s1 | j } x! | D] } | j j | d � q W| S( N( R� R� RH R4 ( R R� R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR3 ? s ( R R R R3 ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� ; s t HasCompileStatec B s) e Z d Z d Z e j � Z e j Z RS( s= A class that has a :class:`.CompileState` associated with it.N( R R R R4 t _compile_state_pluginR t immutabledictt _attributesR� R� t _compile_state_factory( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� F s t _MetaOptionsc B s e Z d Z d � Z d � Z RS( s metaclass for the Options class.c C s9 t t d � | D� � � | _ t j | | | | � d S( Nc s s1 | ]' } | j d � r | d k r | Vq d S( t __t _cache_key_traversalN( R� ( t startswith( RP R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>V s ( t tuplet sortedt _cache_attrst typeR# ( R t classnamet basest dict_( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# S s c C s` | � } t | � j | j � rL t d | t | � j | j � f � � n | j j | � | S( NsB dictionary contains attributes not covered by Options class %s: %r( RS t differenceR� R� R� R� ( R t othert o1( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __add__^ s %( R R R R# R� ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� P s t Optionsc B s� e Z d Z d � Z d � Z d � Z d � Z e d � � Z e d � � Z e d � � Z e j � Z e j d � � Z e d � � Z e d � � Z RS( s, A cacheable option dictionary with defaults.c K s | j j | � d S( N( R� R� ( R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# o s c C s | j j | j � } | j j | j � t | � j | j � rk t d | t | � j | j � f � � n | j j | � | S( NsB dictionary contains attributes not covered by Options class %s: %r( R@ R! R� R� RS R� R� R� ( R R� R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� r s %c C sO xH t j | j | j � D]. \ } } t | | � t | | � k r t Sq Wt S( N( R t zip_longestR� t getattrt FalseR ( R R� RT RU ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __eq__� s % c s0 d � j j d j � f d � � j D� � f S( Ns %s(%s)s , c 3 s5 | ]+ } | � j k r d | � j | f Vq d S( s %s=%rN( R� ( RP R� ( R ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( R@ R t joinR� ( R ( ( R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __repr__� s c C s t | | � S( N( t issubclass( R R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt isinstance� s c C s | i t | | � | | 6S( N( R� ( R RB Ri ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt add_to_element� s c C s | j S( N( R� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _state_dict� s c C s | j S( N( t _state_dict_const( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s c C sx | j � } | | j k rp | j rp t | j � j | j � rp t d | | t | j � j | j � f � � n | | S( Ns] other element %r is not empty, is not of type %s, and contains attributes not covered here %r( R� R@ R� RS R� R� ( R R� R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt safe_merge� s %c C s� | j t | � j | � � } | j | | � } | r� i } xR | D]J } d | } | | k rp | | | | <qC | | k rC | | | | <qC qC W| | } t j � j | i | | 6� } | | f S| | f Sd S( s{ process Options argument in terms of execution options. e.g.:: ( load_options, execution_options, ) = QueryContext.default_load_options.from_execution_options( "_sa_orm_load_options", { "populate_existing", "autoflush", "yield_per" }, execution_options, statement._execution_options, ) get back the Options and refresh "_sa_orm_load_options" in the exec options dict w/ the Options as well RY N( RO RS Rv R? R R� t merge_with( R R_ t attrst exec_optionst statement_exec_optionst check_argnamest existing_optionst resultt argnamet localt new_options( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt from_execution_options� s ( R R R R# R� R� R� R) R� R R� R� R R� R� t classlevelR� R� ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� l s t CacheableOptionsc B s8 e Z e d � � Z e j d � � Z e d � � Z RS( c C s t j | | | � S( N( R t _gen_cache_key( R t anon_mapt bindparams( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s c C s | d f S( N( ( ( R R� R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s c C s t j | � S( N( R t _generate_cache_key_for_object( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _generate_cache_key� s ( R R R R� R� R� ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s t ExecutableOptionc B s& e Z e j Z d Z e Z d � Z RS( t executable_optionc K s+ | j j | j � } t | j � | _ | S( s/ Create a shallow copy of this ExecutableOption.( R@ R! R} R� ( R R R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR s ( R R R t EMPTY_DICTt _annotationst __visit_name__R� t _is_has_cache_keyR ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� s t Executablec B sI e Z d Z e Z e j � Z d Z d Z d Z d e j f d e j f d e j f g Z e Z e Z e Z e Z e Z e Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z d � Z! e j" d d d �d � � Z# e j" d d d �d � � Z$ e e j" d d d d e �d � � � Z% RS( s� Mark a :class:`_expression.ClauseElement` as supporting execution. :class:`.Executable` is a superclass for all "statement" types of objects, including :func:`select`, :func:`delete`, :func:`update`, :func:`insert`, :func:`text`. t _with_optionst _with_context_optionsR� c C s | j S( N( R� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� 1 s c G s# | j t d � | D� � 7_ d S( sK Apply options to this statement. In the general sense, options are any kind of Python object that can be interpreted by the SQL compiler for the statement. These options can be consumed by specific dialects or specific kinds of compilers. The most commonly known kind of option are the ORM level options that apply "eager load" and other loading behaviors to an ORM query. However, options can theoretically be used for many other purposes. For background on specific kinds of options for specific kinds of statements, refer to the documentation for those option objects. .. versionchanged:: 1.4 - added :meth:`.Generative.options` to Core statement objects towards the goal of allowing unified Core / ORM querying capabilities. .. seealso:: :ref:`deferred_options` - refers to options specific to the usage of ORM queries :ref:`relationship_loader_options` - refers to options specific to the usage of ORM queries c s s$ | ] } t j t j | � Vq d S( N( t coercionst expectR t ExecutableOptionRole( RP Rf ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>T s N( R� R� ( R t options( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� 5 s c C s | | _ d S( s| Assign the compile options to a new value. :param compile_options: appropriate CacheableOptions structure N( t _compile_options( R t compile_options( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _set_compile_optionsX s c C s | j | 7_ d S( s* update the _compile_options with new keys.N( R� ( R R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _update_compile_optionsb s c C s | j | | f f 7_ d S( sM Add a context option to this statement. These are callable functions that will be given the CompileState object upon compilation. A second argument cache_args is required, which will be combined with the ``__code__`` identity of the function itself in order to produce a cache key. N( R� ( R t callable_t cache_args( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _add_context_optionh s c K sU d | k r t j d � � n d | k r< t j d � � n | j j | � | _ d S( s� Set non-SQL options for the statement which take effect during execution. Execution options can be set on a per-statement or per :class:`_engine.Connection` basis. Additionally, the :class:`_engine.Engine` and ORM :class:`~.orm.query.Query` objects provide access to execution options which they in turn configure upon connections. The :meth:`execution_options` method is generative. A new instance of this statement is returned that contains the options:: statement = select(table.c.x, table.c.y) statement = statement.execution_options(autocommit=True) Note that only a subset of possible execution options can be applied to a statement - these include "autocommit" and "stream_results", but not "isolation_level" or "compiled_cache". See :meth:`_engine.Connection.execution_options` for a full list of possible options. .. seealso:: :meth:`_engine.Connection.execution_options` :meth:`_query.Query.execution_options` :meth:`.Executable.get_execution_options` t isolation_levels� 'isolation_level' execution option may only be specified on Connection.execution_options(), or per-engine using the isolation_level argument to create_engine().t compiled_cachesm 'compiled_cache' execution option may only be specified on Connection.execution_options(), not per statement.N( R Rh t _execution_optionsRv ( R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt execution_optionsv s ! c C s | j S( s� Get the non-SQL options which will take effect during execution. .. versionadded:: 1.3 .. seealso:: :meth:`.Executable.execution_options` ( R� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt get_execution_options� s s :meth:`.Executable.execute`t alternatives� All statement execution in SQLAlchemy 2.0 is performed by the :meth:`_engine.Connection.execute` method of :class:`_engine.Connection`, or in the ORM by the :meth:`.Session.execute` method of :class:`.Session`.c O sk | j } | d k rO t | d d � p0 | j j } d | } t j | � � n | j | | | t j � � S( s. Compile and execute this :class:`.Executable`.t descriptions� This %s is not directly bound to a Connection or Engine. Use the .execute() method of a Connection or Engine to execute this construct.N( t bindR4 R� R@ R R t UnboundExecutionErrort _execute_clauseelementR R� ( R t multiparamsR t et labelRE ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt execute� s s :meth:`.Executable.scalar`s� Scalar execution in SQLAlchemy 2.0 is performed by the :meth:`_engine.Connection.scalar` method of :class:`_engine.Connection`, or in the ORM by the :meth:`.Session.scalar` method of :class:`.Session`.c O s | j | | � j � S( sn Compile and execute this :class:`.Executable`, returning the result's scalar representation. ( R t scalar( R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR � s s :attr:`.Executable.bind`s5 Bound metadata is being removed as of SQLAlchemy 2.0.t enable_warningsc C s` | j d k r | j SxC t | � D]1 } | | k r; q# n | j } | d k r# | Sq# Wd Sd S( sK Returns the :class:`_engine.Engine` or :class:`_engine.Connection` to which this :class:`.Executable` is bound, or None if none found. This is a traversal which checks locally, then checks among the "from" clauses of associated objects until a bound engine or connection is found. N( t _bindR4 R- R ( R t ft engine( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR � s N( ( (& R R R R t supports_executionR R� R� R4 R R� R� R t dp_executable_optionsR t dp_with_context_optionst dp_propagate_attrst _executable_traverse_internalsR� t is_selectt is_updatet is_insertt is_textt is_deletet is_dmlR� R� R9 R� R� R� R� R R t deprecated_20R R R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� sD # / t prefix_anon_mapc B s e Z d Z d � Z RS( sf A map that creates new keys for missing key access. Considers keys of the form "<ident> <name>" to produce new symbols "<name>_<index>", where "index" is an incrementing integer corresponding to <name>. Inlines the approach taken by :class:`sqlalchemy.util.PopulateDict` which is otherwise usually used for this type of operation. c C sZ | j d d � \ } } | j | d � } | d | | <| d t | � } | | | <| S( Nt i RY ( R[ R? t str( R R_ t identt derivedt anonymous_counterRi ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __missing__ s ( R R R R" ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR � s t SchemaEventTargetc B s e Z d Z d � Z d � Z RS( s� Base class for elements that are the targets of :class:`.DDLEvents` events. This includes :class:`.SchemaItem` as well as :class:`.SchemaType`. c K s d S( s0 Associate with this SchemaEvent's parent object.N( ( R t parentR ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _set_parent t c K s: | j j | | � | j | | � | j j | | � d S( N( t dispatcht before_parent_attachR% t after_parent_attach( R R$ R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _set_parent_with_dispatch s ( R R R R% R* ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# s t SchemaVisitorc B s e Z d Z i e d 6Z RS( s/ Define the visiting for ``SchemaItem`` objects.t schema_visitor( R R R R t __traverse_options__( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR+ s t ColumnCollectionc B s1 e Z d Z d! Z d" d � Z d � Z e d � � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d" d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d" Z d � Z d" d � Z d � Z d � Z d � Z! d � Z" e# d � Z$ RS(# s� Collection of :class:`_expression.ColumnElement` instances, typically for :class:`_sql.FromClause` objects. The :class:`_sql.ColumnCollection` object is most commonly available as the :attr:`_schema.Table.c` or :attr:`_schema.Table.columns` collection on the :class:`_schema.Table` object, introduced at :ref:`metadata_tables_and_columns`. The :class:`_expression.ColumnCollection` has both mapping- and sequence- like behaviors. A :class:`_expression.ColumnCollection` usually stores :class:`_schema.Column` objects, which are then accessible both via mapping style access as well as attribute access style. To access :class:`_schema.Column` objects using ordinary attribute-style access, specify the name like any other object attribute, such as below a column named ``employee_name`` is accessed:: >>> employee_table.c.employee_name To access columns that have names with special characters or spaces, index-style access is used, such as below which illustrates a column named ``employee ' payment`` is accessed:: >>> employee_table.c["employee ' payment"] As the :class:`_sql.ColumnCollection` object provides a Python dictionary interface, common dictionary method names like :meth:`_sql.ColumnCollection.keys`, :meth:`_sql.ColumnCollection.values`, and :meth:`_sql.ColumnCollection.items` are available, which means that database columns that are keyed under these names also need to use indexed access:: >>> employee_table.c["values"] The name for which a :class:`_schema.Column` would be present is normally that of the :paramref:`_schema.Column.key` parameter. In some contexts, such as a :class:`_sql.Select` object that uses a label style set using the :meth:`_sql.Select.set_label_style` method, a column of a certain key may instead be represented under a particular label name such as ``tablename_columnname``:: >>> from sqlalchemy import select, column, table >>> from sqlalchemy import LABEL_STYLE_TABLENAME_PLUS_COL >>> t = table("t", column("c")) >>> stmt = select(t).set_label_style(LABEL_STYLE_TABLENAME_PLUS_COL) >>> subq = stmt.subquery() >>> subq.c.t_c <sqlalchemy.sql.elements.ColumnClause at 0x7f59dcf04fa0; t_c> :class:`.ColumnCollection` also indexes the columns in order and allows them to be accessible by their integer position:: >>> cc[0] Column('x', Integer(), table=None) >>> cc[1] Column('y', Integer(), table=None) .. versionadded:: 1.4 :class:`_expression.ColumnCollection` allows integer-based index access to the collection. Iterating the collection yields the column expressions in order:: >>> list(cc) [Column('x', Integer(), table=None), Column('y', Integer(), table=None)] The base :class:`_expression.ColumnCollection` object can store duplicates, which can mean either two columns with the same key, in which case the column returned by key access is **arbitrary**:: >>> x1, x2 = Column('x', Integer), Column('x', Integer) >>> cc = ColumnCollection(columns=[(x1.name, x1), (x2.name, x2)]) >>> list(cc) [Column('x', Integer(), table=None), Column('x', Integer(), table=None)] >>> cc['x'] is x1 False >>> cc['x'] is x2 True Or it can also mean the same column multiple times. These cases are supported as :class:`_expression.ColumnCollection` is used to represent the columns in a SELECT statement which may include duplicates. A special subclass :class:`.DedupeColumnCollection` exists which instead maintains SQLAlchemy's older behavior of not allowing duplicates; this collection is used for schema level objects like :class:`_schema.Table` and :class:`.PrimaryKeyConstraint` where this deduping is helpful. The :class:`.DedupeColumnCollection` class also has additional mutation methods as the schema constructs have more use cases that require removal and replacement of columns. .. versionchanged:: 1.4 :class:`_expression.ColumnCollection` now stores duplicate column keys as well as the same column in multiple positions. The :class:`.DedupeColumnCollection` class is added to maintain the former behavior in those cases where deduplication as well as additional replace/remove operations are needed. t _collectiont _indext _colsetc C sV t j | d t � � t j | d i � t j | d g � | rR | j | � n d S( NR1 R0 R/ ( R" t __setattr__RS t _initial_populate( R t columns( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# � s c C s | j | � d S( N( t _populate_separate_keys( R t iter_( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR3 � s c C s g | j D] \ } } | ^ q S( N( R/ ( R R� t col( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _all_columns� s c C s g | j D] \ } } | ^ q S( sQ Return a sequence of string key names for all columns in this collection.( R/ ( R R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt keys� s c C s g | j D] \ } } | ^ q S( s� Return a sequence of :class:`_sql.ColumnClause` or :class:`_schema.Column` objects for all columns in this collection.( R/ ( R R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRo � s c C s t | j � S( s� Return a sequence of (key, column) tuples for all columns in this collection each consisting of a string key name and a :class:`_sql.ColumnClause` or :class:`_schema.Column` object. ( t listR/ ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s c C s t | j � S( N( t boolR/ ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __bool__� s c C s t | j � S( N( Rl R/ ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRp � s c C s& t g | j D] \ } } | ^ q � S( N( Rw R/ ( R R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRs � s c C sZ y | j | SWnD t k rU } t | t j � rO t j t | � d | �qV � n Xd S( NRZ ( R0 R^ R� R t int_typesR] t IndexError( R R_ Rb ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRg � s c C sB y | j | SWn, t k r= } t j t | � d | �n Xd S( NRZ ( R0 R^ R R] t AttributeError( R R_ Rb ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __getattr__� s c C s? | | j k r7 t | t j � s3 t j d � � n t St Sd S( Ns' __contains__ requires a string argument( R0 R� R t string_typesR Rh R� R ( R R_ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __contains__� s c C s; x4 t j | | � D] \ } } | | k r t Sq Wt Sd S( sd Compare this :class:`_expression.ColumnCollection` to another based on the names of the keysN( R R� R� R ( R R� t lt r( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt compare� s c C s | j | � S( N( RE ( R R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� � s c C s" | | j k r | j | S| Sd S( s� Get a :class:`_sql.ColumnClause` or :class:`_schema.Column` object based on a string key name from this :class:`_expression.ColumnCollection`.N( R0 ( R R_ R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR? � s c C s' d | j j d j d � | D� � f S( Ns %s(%s)s , c s s | ] } t | � Vq d S( N( R ( RP R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( R@ R R� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __str__� s c C s t � � d S( N( R ( R R_ Ri ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRj � s c C s t � � d S( N( R ( R R_ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRk � s c C s t � � d S( N( R ( R R_ R& ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR2 � s c C s t � � d S( sQ Dictionary clear() is not implemented for :class:`_sql.ColumnCollection`.N( R ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt clear� s c C s t � � d S( sR Dictionary remove() is not implemented for :class:`_sql.ColumnCollection`.N( R ( R t column( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt remove s c C s t � � d S( sR Dictionary update() is not implemented for :class:`_sql.ColumnCollection`.N( R ( R R6 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� s c C s} t | � } | | j (| j j d � | j D� � | j j d � t | j � D� � | j j d � t | j � D� � d S( s* populate from an iterator of (key, column)c s s | ] \ } } | Vq d S( N( ( RP R� R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr> s c s s' | ] \ } \ } } | | f Vq d S( N( ( RP t idxR� R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr> s c S s i | ] \ } } | | � q S( ( ( RP R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <dictcomp> s N( R: R/ R1 R� R0 t enumerateR� ( R R6 t cols( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR5 s c C s} | d k r | j } n t | j � } | j j | | f � | j j | � | | j | <| | j k ry | | j | <n d S( s� Add a column to this :class:`_sql.ColumnCollection`. .. note:: This method is **not normally used by user-facing code**, as the :class:`_sql.ColumnCollection` is usually part of an existing object such as a :class:`_schema.Table`. To add a :class:`_schema.Column` to an existing :class:`_schema.Table` object, use the :meth:`_schema.Table.append_column` method. N( R4 R_ Rl R/ t appendR1 t addR0 ( R RH R_ RC ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRN s c C s i | j d 6| j d 6S( NR/ R0 ( R/ R0 ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __getstate__, s c C sR t j | d | d � t j | d | d � t j | d d � | j D� � d S( NR0 R/ R1 c S s h | ] \ } } | � q S( ( ( RP R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <setcomp>3 s ( R" R2 R/ ( R t state( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt __setstate__/ s c C s? | | j k r7 t | t j � r3 t j d � � n t St Sd S( s3 Checks if a column object exists in this collectionsZ contains_column cannot be used with string arguments. Use ``col_name in table.c`` instead.N( R1 R� R RA R Rh R� R ( R R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt contains_column6 s c C s t | � S( sJ Return an "immutable" form of this :class:`_sql.ColumnCollection`.( t ImmutableColumnCollection( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt as_immutableB s c C s� d � } | | j k r | Sd \ } } | j } g | j D] \ } } | ^ q; } xX| D]P} t t | j � � } | j | � } | rZ | s� | | | � rZ | d k r� | | } } q�t | � t | � k r� | | } } q�| | k r�t j t j g | j � D]* } | j | � r | j j d d � ^ q � } t j t j g | j � D]* } | j | � rU| j j d d � ^ qU� } | | k r�| | } } q�q�qZ qZ W| S( s� Given a :class:`_expression.ColumnElement`, return the exported :class:`_expression.ColumnElement` object from this :class:`_expression.ColumnCollection` which corresponds to that original :class:`_expression.ColumnElement` via a common ancestor column. :param column: the target :class:`_expression.ColumnElement` to be matched. :param require_embedded: only return corresponding columns for the given :class:`_expression.ColumnElement`, if the given :class:`_expression.ColumnElement` is actually present within a sub-element of this :class:`_expression.Selectable`. Normally the column will match if it merely shares a common ancestor with one of the exported columns of this :class:`_expression.Selectable`. .. seealso:: :meth:`_expression.Selectable.corresponding_column` - invokes this method against the collection returned by :attr:`_expression.Selectable.exported_columns`. .. versionchanged:: 1.4 the implementation for ``corresponding_column`` was moved onto the :class:`_expression.ColumnCollection` itself. c S s@ x9 | j | � D]( } t t | g � � j | � s t Sq Wt S( N( R� RS RN RO R� R ( t expanded_proxy_sett target_sett t( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt embeddedh s t weighti N( NN( R1 R4 R% R/ RS RN RO Rl R t reduceRI RN t _uncached_proxy_listt shares_lineageR� R? ( R RH t require_embeddedRX R7 t intersectRV R� R1 RL RU t it sct col_distancet c_distance( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt corresponding_columnH s< " -- ( R/ R0 R1 N(% R R R R� R4 R# R3 R� R8 R9 Ro R� R< Rp Rs Rg R@ RB RE R� R? RF Rj Rk R2 RG RI R� t __hash__R5 RN RO RQ RR RT R� Rc ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR. ! s@ k t DedupeColumnCollectionc B s> e Z d Z d d � Z d � Z d � Z d � Z d � Z RS( su A :class:`_expression.ColumnCollection` that maintains deduplicating behavior. This is useful by schema level objects such as :class:`_schema.Table` and :class:`.PrimaryKeyConstraint`. The collection includes more sophisticated mutator methods as well to suit schema objects which require mutable column collections. .. versionadded:: 1.4 c C s� | d k r- | j | k r- t j d � � n | j } | d k rT t j d � � n | | j k r� | j | } | | k r� d S| j | � t j j | d � nO t | j � } | j j | | f � | j j | � | | j | <| | j | <d S( NsK DedupeColumnCollection requires columns be under the same key as their .keys- Can't add unnamed column to column collectionR% ( R4 R_ R Rh R0 t replaceR R� t resetRl R/ RM R1 RN ( R RH R_ t existingRC ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRN � s$ c C s% t | � } g } x� | D]� \ } } | j | k rF t j d � � n | j | j k rz | j | j k rz | j | � q | j | j k r� | j | � q | | j | <| j j | | f � q W| j j d � | j D� � | j j d � t | j � D� � x | D] } | j | � q Wd S( s* populate from an iterator of (key, column)sK DedupeColumnCollection requires columns be under the same key as their .keyc s s | ] \ } } | Vq d S( N( ( RP R� R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s c s s' | ] \ } \ } } | | f Vq d S( N( ( RP RJ R� R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s N( R: R_ R Rh RB R0 RM R/ R1 R� RK Rf ( R R6 RL t replace_colR� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR5 � s" $ c C s | j d � | D� � d S( Nc s s | ] } | j | f Vq d S( N( R_ ( RP R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>� s ( R5 ( R R6 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt extend� s c C s� | | j k r" t d | � � n | j | j =| j j | � g | j D]$ \ } } | | k rI | | f ^ qI | j (| j j d � t | j � D� � | j t | j � =d S( Ns8 Can't remove column %r; column is not in this collectionc S s% i | ] \ } \ } } | | � q S( ( ( RP RJ R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <dictcomp> s ( R1 R\ R0 R_ RI R/ R� RK Rl ( R RH R� R1 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRI � s 8 c C s� t � } | j | j k rb | j | j k rb | j | j } | j | j k rb | j | � qb n | j | j k r� | j | j | j � n g } t } x^ | j D]S \ } } | | k r� | s� t } | j | j | f � q� q� | j | | f � q� W| r| j j | � n | s3| j | j | f � n | j j | � | | j (| j j � | j j d � t | j � D� � | j j | j � d S( s add the given column to this collection, removing unaliased versions of this column as well as existing columns with the same key. e.g.:: t = Table('sometable', metadata, Column('col1', Integer)) t.columns.replace(Column('col1', Integer, key='columnone')) will remove the original 'col1' from the collection, and add the new column under the name 'columnname'. Used by schema.Column to override columns during table reflection. c S s% i | ] \ } \ } } | | � q S( ( ( RP RJ R� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <dictcomp>6 s N( RS RB R0 R_ RN R� R/ R RM R1 t difference_updateRG R� RK ( R RH t remove_colR� t new_colst replacedR� R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRf s2 $ N( R R R R4 RN R5 Rj RI Rf ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRe � s " RS c B s= e Z d Z d � Z d � Z d � Z e j j Z Z Z RS( t _parentc C sY t j | d | � t j | d | j � t j | d | j � t j | d | j � d S( NRo R1 R0 R/ ( R" R2 R1 R0 R/ ( R t collection( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR# > s c C s i | j d 6S( NRo ( Ro ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRO D s c C s | d } | j | � d S( NRo ( R# ( R RP R$ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRQ G s ( Ro ( R R R� R# RO RQ R t ImmutableContainert _immutableRN Rj RI ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRS ; s t ColumnSetc B s5 e Z d � Z d � Z d � Z d � Z d � Z RS( c C s | | k S( N( ( R R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRR O s c C s" x | D] } | j | � q Wd S( N( RN ( R RL R7 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRj R s c C s t | � t | � S( N( R: ( R R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� V s c C sZ g } xD | D]< } x3 | D]+ } | j | � r | j | | k � q q Wq Wt j | � S( N( R\ RM R. t and_( R R� RC R1 R� ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyR� Y s c C s t t d � | D� � � S( Nc s s | ] } | Vq d S( N( ( RP R8 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pys <genexpr>b s ( t hashR� ( R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRd a s ( R R RR Rj R� R� Rd ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyRs N s c C s� t j d � | j } | s� | j j } t | d t | d d � � } | r_ d | | f } n d | } | d k r� d | } n t j | � � n | S( Ns| The ``bind`` argument for schema methods that invoke SQL against an engine or connection will be required in SQLAlchemy 2.0.t fullnameRB s %s object %rs %s objectsm %s is not bound to an Engine or Connection. Execution can not proceed without a database to execute against.( R t warn_deprecated_20R R@ R R� R4 R R ( t schemaitemRE R RB R t item( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _bind_or_errore s c C sV y | j SWnD t k rQ x4 t j | � D] } t | d � r+ | j Sq+ W� n Xd S( s� Return the nearest .entity_namespace for the given entity. If not immediately available, does an iterate to find a sub-element that has one, if any. t entity_namespaceN( R{ R? R t iteratet hasattr( t entityRQ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _entity_namespace s c C sy y9 t | � } | t k r+ t | | | � St | | � SWn9 t k rt } t j t j d | | f � d | �n Xd S( s� Return an entry from an entity_namespace. Raises :class:`_exc.InvalidRequestError` rather than attribute error on not found. s. Entity namespace for "%s" has no property "%s"RZ N( R R R� R? R R] R RA ( R~ R_ R� t nsRb ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt _entity_namespace_key� s (D R R* RI R� R& R R t traversalsR R R R R R R R R R R4 R� R. t type_apit symbolR R R" R R R- R2 R9 RL R RN RV RW t collections_abct MutableMappingRX Rt t preload_moduleR R� R� R� R� R� R� R� t with_metaclassR� R� R� t StatementRoleR� R} R R# R+ R. Re Rq RS t ordered_column_setRs Rz R R� ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/base.pyt <module> sl < �b � �� ��