/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
ext
/
up file
home
� 1��fc @ s� d 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 e j e � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ e j d d � d � � Z e j d d � d � � Z e j � d � � Z e j e j d d � d � � � Z e j e j d d � d � � � Z e j! Z e j" Z e j# Z# d S( s� Baked query extension. Provides a creational pattern for the :class:`.query.Query` object which allows the fully constructed object, Core select statement, and string compiled result to be fully cached. i����Ni ( t exc( t util( t strategy_options( t Query( t Session( t func( t literal_column( t collections_abct Bakeryc B s& e Z d Z d Z d � Z d � Z RS( s� Callable which returns a :class:`.BakedQuery`. This object is returned by the class method :meth:`.BakedQuery.bakery`. It exists as an object so that the "cache" can be easily inspected. .. versionadded:: 1.2 t clst cachec C s | | _ | | _ d S( N( R R ( t selft cls_R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt __init__/ s c G s | j | j | | � S( N( R R ( R t initial_fnt args( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt __call__3 s ( R R ( t __name__t __module__t __doc__t __slots__R R ( ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR ! s t BakedQueryc B s� e Z d Z d Z d d � Z e d d d � � Z d � Z d d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � Z d � Z d d � Z d d � Z d � Z d � Z d � Z d � Z RS( s3 A builder object for :class:`.query.Query` objects.t stepst _bakeryt _cache_keyt _spoiledc C s; d | _ | j | | � | g | _ t | _ | | _ d S( N( ( R t _update_cache_keyR t FalseR R ( R t bakeryR R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR < s i� c C s t | t j | d | �� S( sS Construct a new bakery. :return: an instance of :class:`.Bakery` t size_alert( R R t LRUCache( R t sizet _size_alert( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR C s c C sI t j t � } | j | _ t | j � | _ | j | _ | j | _ | S( N( R t __new__R t listR R R ( R t b1( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt _cloneM s c C s | j | j f | 7_ d S( N( R t __code__( R t fnR ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR U s c C s0 t | t � r | j | � n | j | � | S( N( t isinstancet tuplet add_criteria( R t other( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt __iadd__X s c C s- t | t � r | j | � S| j | � Sd S( N( R' R( t with_criteria( R R* ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt __add___ s c G s$ | j | | � | j j | � | S( s� Add a criteria function to this :class:`.BakedQuery`. This is equivalent to using the ``+=`` operator to modify a :class:`.BakedQuery` in-place. ( R R t append( R R& R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR) e s c G s | j � j | | � S( s� Add a criteria function to a :class:`.BakedQuery` cloned from this one. This is equivalent to using the ``+`` operator to produce a new :class:`.BakedQuery` with modifications. ( R$ R) ( R R& R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR, p s c C s t | | � S( s� Return a :class:`_baked.Result` object for this :class:`.BakedQuery`. This is equivalent to calling the :class:`.BakedQuery` as a Python callable, e.g. ``result = my_baked_query(session)``. ( t Result( R t session( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt for_sessionz s c C s | j | � S( N( R1 ( R R0 ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR � s c C sK | r> | j r> | j � } | j d 7_ | j g | _ n t | _ | S( s� Cancel any query caching that will occur on this BakedQuery object. The BakedQuery can continue to be used normally, however additional creational functions will not be cached; they will be called on every invocation. This is to support the case where a particular step in constructing a baked query disqualifies the query from being cacheable, such as a variant that relies upon some uncacheable value. :param full: if False, only functions added to this :class:`.BakedQuery` object subsequent to the spoil step will be non-cached; the state of the :class:`.BakedQuery` up until this point will be pulled from the cache. If True, then the entire :class:`_query.Query` object is built from scratch each time, with all creational functions being called on each invocation. t _query_only( R2 ( R R$ R t _retrieve_baked_queryR t True( R t fullt _spoil_point( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt spoil� s c C s | j | j f S( s� Return the key that actually goes into the cache dictionary for this :class:`.BakedQuery`, taking into account the given :class:`.Session`. This basically means we also will include the session's query_class, as the actual :class:`_query.Query` object is part of what's cached and needs to match the type of :class:`_query.Query` that a later session will want to use. ( R t _query_cls( R R0 ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt _effective_key� s c C s& | j � } | j | | d | �| S( s) Cloning version of _add_lazyload_options.t cache_path( R$ t _add_lazyload_options( R t optionst effective_pathR: t q( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt _with_lazyload_options� s c s� d } | s � } n xs � D]k } | j s4 | j r | j � } | d k r_ | j d t � q� | d sv t d � � | | d 7} q q W| j � � f d � | j | � d S( s* Used by per-state lazy loaders to add options to the "lazy load" query from a parent query. Creates a cache key based on given load path and query options; if a repeatable cache key cannot be generated, the query is "spoiled" so that it won't use caching. R5 i s� loader options with variable bound parameters not supported with baked queries. Please use new-style select() statements for cached ORM queries.i c s | j � � j � � S( N( t _with_current_pathR< ( R> ( R= R< ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt <lambda>� t N( ( t _is_legacy_optiont _is_compile_statet _generate_cache_keyt NoneR7 R4 t AssertionErrorR) t path( R R< R= R: t keyt optt ck( ( R= R< sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR; � s c C sh | j j | j | � d � } | d k r[ | j | � } | j d � | j | j | � <n | j | � S( N( R t getR9 RF t _as_queryt with_session( R R0 t query( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR3 � s c C sY | j | � } d | _ | j � } | j j rO | | f | j | j | � <n | | f S( N( RM RF R0 t _statement_20t _compile_optionst _bake_okR R9 ( R R0 RO t statement( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt _bake� s c C st t | t � r | } nO t | t � rQ | j } | d k rg t j d � � qg n t d t | � � � | j | � S( sL Return the :class:`_query.Query` object for use as a subquery. This method should be used within the lambda callable being used to generate a step of an enclosing :class:`.BakedQuery`. The parameter should normally be the :class:`_query.Query` object that is passed to the lambda:: sub_bq = self.bakery(lambda s: s.query(User.name)) sub_bq += lambda q: q.filter( User.id == Address.user_id).correlate(Address) main_bq = self.bakery(lambda s: s.query(Address)) main_bq += lambda q: q.filter( sub_bq.to_query(q).exists()) In the case where the subquery is used in the first callable against a :class:`.Session`, the :class:`.Session` is also accepted:: sub_bq = self.bakery(lambda s: s.query(User.name)) sub_bq += lambda q: q.filter( User.id == Address.user_id).correlate(Address) main_bq = self.bakery( lambda s: s.query( Address.id, sub_bq.to_query(q).scalar_subquery()) ) :param query_or_session: a :class:`_query.Query` object or a class :class:`.Session` object, that is assumed to be within the context of an enclosing :class:`.BakedQuery` callable. .. versionadded:: 1.3 s1 Given Query needs to be associated with a Sessions) Query or Session object expected, got %r.N( R' R R R0 RF t sa_exct ArgumentErrort TypeErrort typeRM ( R t query_or_sessionR0 ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt to_query� s & c C s; | j d | � } x! | j d D] } | | � } q! W| S( Ni i ( R ( R R0 RO t step( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRM / s ( R R R R ( N( ( R R R R R t classmethodRF R R$ R R+ R- R) R, R1 R R R7 R9 R? R; R3 RT RZ RM ( ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR 7 s* # 5R/ c B s� e Z 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 � Z d � Z d � Z d � Z d � Z d � Z RS( s Invokes a :class:`.BakedQuery` against a :class:`.Session`. The :class:`_baked.Result` object is where the actual :class:`.query.Query` object gets created, or retrieved from the cache, against a target :class:`.Session`, and is then invoked for results. t bqR0 t _paramst _post_criteriac C s( | | _ | | _ i | _ g | _ d S( N( R] R0 R^ R_ ( R R] R0 ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR C s c O s^ t | � d k r& | j | d � n$ t | � d k rJ t j d � � n | j j | � | S( s@ Specify parameters to be replaced into the string SQL statement.i i sF params() takes zero or one positional argument, which is a dictionary.( t lent updateRU RV R^ ( R R t kw( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt paramsI s c C s | r | j j | � n | S( N( R_ t extend( R t fns( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt _using_post_criteriaV s c C s | j | g � S( s� Add a criteria function that will be applied post-cache. This adds a function that will be run against the :class:`_query.Query` object after it is retrieved from the cache. This currently includes **only** the :meth:`_query.Query.params` and :meth:`_query.Query.execution_options` methods. .. warning:: :meth:`_baked.Result.with_post_criteria` functions are applied to the :class:`_query.Query` object **after** the query's SQL statement object has been retrieved from the cache. Only :meth:`_query.Query.params` and :meth:`_query.Query.execution_options` methods should be used. .. versionadded:: 1.2 ( Rf ( R R& ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt with_post_criteria[ s c C sE | j j | j � j | j � } x | j D] } | | � } q+ W| S( N( R] RM R0 Rc R^ R_ ( R R> R& ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRM t s !c C s t | j � � S( N( t strRM ( R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt __str__z s c C s | j � j � S( N( t _itert __iter__( R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRk } s c C sa | j } | j j s | j r/ | j � j � S| j j | j | j � d � \ } } | d k r} | j | j � \ } } n | j r� | j | j � } n | } x | j D] } | | � } q� W| j } t | j � } | j i | j d 6| j d 6� | j j | | d | �} | j j d t � r9| j � } n | j j d t � r]| j � } n | S( Nt _sa_orm_load_optionst compiled_cachet execution_optionst is_single_entityt filtered( NN( R] R0 t enable_baked_queriesR RM Rj R RL R9 RF RT R^ Rc R_ t dictt _execution_optionsRa t load_optionst executet _attributesR t scalarst unique( R R] RO RS R> R& Rc Rn t result( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRj � s2 c sR t j t d � � � | j j � f d � � } | j | j � j | j � j � S( s� return the 'count'. Equivalent to :meth:`_query.Query.count`. Note this uses a subquery to ensure an accurate count regardless of the structure of the original statement. .. versionadded:: 1.1.6 t *c s | j � � S( N( t _from_self( R> ( t col( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRA � RB ( R t countR R] R, R1 R0 Rc R^ t scalar( R R] ( ( R| sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR} � s c C sJ y. | j � } t | t j � s% | S| d SWn t j k rE d SXd S( s� Return the first element of the first result or None if no rows present. If multiple rows are returned, raises MultipleResultsFound. Equivalent to :meth:`_query.Query.scalar`. .. versionadded:: 1.1.6 i N( t oneR' R t Sequencet orm_exct NoResultFoundRF ( R t ret( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR~ � s c C sI | j j d � � } | j | j � j | j � j | j � j � j � S( sR Return the first row. Equivalent to :meth:`_query.Query.first`. c S s | j d d � S( Ni i ( t slice( R> ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRA � RB ( R] R, R1 R0 Rc R^ Rf R_ Rj t first( R R] ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR� � s c C s | j � j � S( sk Return exactly one result or raise an exception. Equivalent to :meth:`_query.Query.one`. ( Rj R ( R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR � s c C s | j � j � S( s� Return one or zero results, or raise an exception for multiple rows. Equivalent to :meth:`_query.Query.one_or_none`. .. versionadded:: 1.0.9 ( Rj t one_or_none( R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR� � s c C s | j � j � S( sK Return all rows. Equivalent to :meth:`_query.Query.all`. ( Rj t all( R ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR� � s c C s, | j j d | j � } | j | | j � S( s` Retrieve an object based on identity. Equivalent to :meth:`_query.Query.get`. i ( R] R R0 t _get_implt _load_on_pk_identity( R t identRO ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyRL � s c s# | j d j d � � j \ � � � � � � � f d � } � j } | j � } | j � f 7_ | j | t d � � D� � � } t g t � � j � D] \ } } � | j | f ^ q� � } t | j � j � j | � � } t | � } | d k r t j � � n | r| d Sd Sd S( s6 Load the given primary key identity from the database.i t parententityc s� � } | j � } | j � d | _ d � k r� t g t � j � � D]% \ } } | d k rG � | j ^ qG � } t j | | � } n t j | i t d 6� f | _ x � j D] } | | � } q� W| S( Nt _orm_adapt( R$ t _get_conditionRF t _order_byt sett zipt primary_keyRI t sql_utilt adapt_criterion_to_nullt _deep_annotateR4 t _where_criteriaR_ ( RO t _lcl_get_clauseR> R| t valuet nonesR& ( t _get_clauset _get_paramst mappert primary_key_identityR ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt setup s " c s s | ] } | d k Vq d S( N( RF ( t .0t elem( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pys <genexpr>0 s i N( t _raw_columnst _annotationsR� R] R$ R R, R( Rr R� R� RI R" R1 R0 Rc R` R� t MultipleResultsFoundRF ( R R0 RO R� Rb R� R] t id_valR� Rc Ry t l( ( R� R� R� R� R sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR� � s& " 5! ( R] R0 R^ R_ ( R R R R R Rc Rf Rg RM Ri Rk Rj R} R~ R� R R� R� RL R� ( ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR/ 8 s$ ' s 1.2s5 Baked lazy loading is now the default implementation.c C s d S( s� Enable the use of baked queries for all lazyloaders systemwide. The "baked" implementation of lazy loading is now the sole implementation for the base lazy loader; this method has no effect except for a warning. N( ( ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt bake_lazy_loadersF s c C s t d � � d S( sH Disable the use of baked queries for all lazyloaders systemwide. This method now raises NotImplementedError() as the "baked" implementation is the only lazy load implementation. The :paramref:`_orm.relationship.bake_queries` flag may be used to disable the caching of queries on a per-relationship basis. s4 Baked lazy loading is now the default implementationN( t NotImplementedError( ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt unbake_lazy_loadersS s c C s | j | i d d 6� S( sx Indicate that the given attribute should be loaded using "lazy" loading with a "baked" query used in the load. t baked_selectt lazy( t set_relationship_strategy( t loadoptt attr( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt baked_lazyloadd s sF Baked lazy loading is now the default implementation for lazy loading.c G s t j j t j j | t i � S( N( R t _UnboundLoadt _from_keysR� R ( t keys( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyR� m s c G s t j j t j j | t i � S( N( R R� R� R� R4 ( R� ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt baked_lazyload_ally s ($ R t loggingRB R RU R t ormR� R t orm.queryR t orm.sessionR t sqlR R R� R t getLoggerR t logt objectR R R/ t deprecatedR� R� t loader_optionR� t _add_unbound_fnt _add_unbound_all_fnR� t _unbound_fnt _unbound_all_fnR ( ( ( sG /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/ext/baked.pyt <module> sB � �