/opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql
Edit: /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyo (29578B)
4]c @ s, d 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 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! 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' j( e! j) d! Z* d" Z+ d# Z, d$ Z- d% Z. e/ e/ e/ e/ e/ d& Z0 d' Z1 d( Z2 d) Z3 d* Z4 d+ Z5 d, Z6 e7 d- Z8 d. Z9 d/ Z: d0 Z; d1 e< f d2 YZ= d3 e= f d4 YZ> d5 e= f d6 YZ? d7 Z@ d? d8 ZB d9 ZC d? d? e/ d: ZD d; e jE f d< YZF d= eF f d> YZG d? S(@ s; High level utilities which build upon other modules here.
i( t deque( t chaini ( t operators( t visitors( t _deep_annotate( t _deep_deannotate( t _shallow_annotate( t
_from_objects( t ColumnSet( t sort_tables( t _expand_cloned( t
_find_columns( t _label_reference( t _textual_label_reference( t
BindParameter( t ColumnClause( t
ColumnElement( t Null( t UnaryExpression( t Column( t Alias( t
FromClause( t FromGrouping( t Join( t ScalarSelect( t
SelectBase( t TableClausei ( t exc( t utils .sql.util.join_conditionc C si t t | } g } xJ t | D]< \ } } x- | D]% } | j | r8 | j | q8 q8 Wq% W| S( s Given a list of FROM clauses and a selectable,
return the first index and element from the list of
clauses which can be joined against the selectable. returns
None, None if no match is found.
e.g.::
clause1 = table1.join(table2)
clause2 = table4.join(table5)
join_to = table2.join(table3)
find_join_source([clause1, clause2], join_to) == clause1
( t listR t enumeratet is_derived_fromt append( t clausest join_tot selectablest idxt it ft s( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt find_join_source1 s
c C s t t | } g } xK t | D]= \ } } x. | D]& } | j | r8 | j | Pq8 q8 Wq% Wt | d k r g } x[ | D]S } | | } x@ | D]8 } t t | j t | r | j | Pq q Wq W| r | Sn | S( s Given a list of FROM clauses and a selectable,
return the indexes from the list of
clauses which is derived from the selectable.
i ( R R R R R t lent sett surface_selectablest intersection( R! t join_fromR# t liberal_idxR% R& R' t conservative_idxR$ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt# find_left_clause_that_matches_givenK s&
c C s g } t t | } t | d k rK | d k rK t } t | } n t } d } x t | D] \ } } x | j | g D]s } | r t | j j
| j j | r | j | Pq q t
j | | s | d k r | j | Pq q Wqd Wt | d k rjt t g | D] } t | j ^ q }
g | D] } | | |
k rE| ^ qE} n | r| d k rt t | S| Sd S( s Given a list of FROM clauses, a selectable,
and optional ON clause, return a list of integer indexes from the
clauses list indicating the clauses that can be joined from.
The presence of an "onclause" indicates that at least one clause can
definitely be joined from; if the list of clauses is of length one
and the onclause is given, returns that index. If the list of clauses
is more than length one, and the onclause is given, attempts to locate
which clauses contain the same columns.
i N( R* R R) t Nonet TrueR t FalseR t
differencet ct uniont
issupersetR R t _can_joinR R
t _hide_fromst range( R! R" t onclauseR$ R# t resolve_ambiguityt cols_in_onclauseR% R& R' t toremove( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt find_left_clause_to_join_fromu s. $
+,c s/ g f d t | d S( s Produce a traversal of the given expression, delivering
column comparisons to the given function.
The function is of the form::
def my_fn(binary, left, right)
For each binary expression located which has a
comparison operator, the product of "left" and
"right" will be delivered to that function,
in terms of that binary.
Hence an expression like::
and_(
(a + b) == q + func.sum(e + f),
j == r
)
would have the traversal::
a
q
a e
a f
b q
b e
b f
j r
That is, every combination of "left" and
"right" that doesn't further contain
a binary comparison is passed as pairs.
c 3 s t | t r | Vn | j d k r t j | j r j d | xE | j D]4 } x+ | j D] } d | | qn WqX W j d xk | j
D] } | q WnJ t | t r | Vn x0 | j
D]" } x | D] } | Vq Wq Wd S( Nt binaryi ( t
isinstanceR t __visit_name__R t
is_comparisont operatort insertt leftt rightt popt get_childrenR ( t elementt lt rt elemt e( t fnt stackt visit( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyRQ s
N( R ( RO t expr( ( RO RP RQ sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt visit_binary_product s #c s g i } | r* j | d <| d t RE t updatet deletec s j | j d S( N( R RX ( t column( RZ ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt visit_column s R_ RX t column_collections( R R t traverseR3 ( t clauset
check_columnst include_aliasest
include_joinst include_selectst include_crudt _visitorsR` ( ( RZ sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt find_tables s
&
c C s t j } g } t | g } x | r | j } t | t r t | t sh t j | j r t | t
r | j } n t | t r q$ n | | k r | j
| | j | q q$ x! | j D] } | j | q Wq$ W| S( sq Break up an 'order by' expression into individual column-expressions,
without DESC/ASC/NULLS FIRST/NULLS LAST( R t
column_setR t popleftRA R R R t is_ordering_modifiert modifierR RJ R
t addR RI ( Rc t colst resultRP t tR5 ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt unwrap_order_by s$
c C s d } t j | i | S( Nc S s t | t t f r | j Sd S( N( RA R R
RJ ( RM ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt replace* s ( R t replacement_traverse( RJ Rt ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt unwrap_label_reference) s c C sy t g | D]$ } | j d k r( | j n | ^ q
} g t g | D] } t | ^ qD D] } | | k r] | ^ q] S( s Given the columns clause and ORDER BY of a selectable,
return a list of column expressions that can be added to the collist
corresponding to the ORDER BY, without repeating those already
in the collist.
N( R* t _order_by_label_elementR1 RJ R Rs ( t collistt order_byt colt cols_already_presentt o( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt expand_column_list_from_order_by1 s 1)c C s/ x( t | D] } | | k r
t Sq
Wt Sd S( s Given a target clause and a second to search within, return True
if the target is plainly present in the search without any
subqueries or aliases involved.
Basically descends through Joins.
N( R+ R2 R3 ( Rc t searchRM ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt clause_is_presentF s c c sx | g } xh | rs | j } | Vt | t rN | j | j | j f q t | t r | j | j q q Wd S( N( RH RA R t extendRF RG R R RJ ( Rc RP RM ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR+ V s c c s | g } x | r | j } t | t t f r; | Vn t | t rf | j | j | j f q t | t r | j | j
q t | t r | j | j q q Wd S( N(
RH RA R R R R RF RG R R RJ R RX ( Rc RP RM ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt surface_selectables_onlya s c c s t f } | s | t f 7} n t | g } xT | r | j } | Vx6 | j D]( } t | | rp qU n | j | qU Wq1 Wd S( s traverse and yield only outer-exposed column elements, such as would
be addressable in the WHERE clause of a SELECT if this element were
in the columns clause.N( R R R Rl RI RA R ( Rc t include_scalar_selectst filter_RP RM t sub( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt surface_column_elementso s c C s% t t t | j t | S( s: Return True if left/right have some overlapping selectable( t boolR* R+ R, ( RF RG ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt selectables_overlap s c s3 g f d } t j | i i | d 6 S( s Return an ordered list of "bound" values in the given clause.
E.g.::
>>> expr = and_(
... table.c.foo==5, table.c.foo==7
... )
>>> bind_values(expr)
[5, 7]
c s j | j d S( N( R t effective_value( t bind( t v( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt visit_bindparam s t bindparam( R Rb ( Rc R ( ( R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt bind_values s c C s: t | t j r, | j d d } d | St | Sd S( Nt 's ''s '%s'( RA R t string_typesRt t repr( RJ ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt _quote_ddl_expr s t
_repr_basec B s) e Z d Z d Z d Z d Z d Z RS( i i i t max_charsc C s` t | } t | } | | j k r\ | j d } | d | !d | | j | | } n | S( Ni i s# ... (%d characters truncated) ... ( R R) R ( t selft valuet rept lenrept segment_length( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt trunc s
(( R ( t __name__t
__module__t _LISTt _TUPLEt _DICTt __slots__R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s
t _repr_rowc B s) e Z d Z d Z d d Z d Z RS( s Provide a string view of a row.t rowi, c C s | | _ | | _ d S( N( R R ( R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt __init__ s c sN | j d d j f d | j D t | j d k rF d n d f S( Ns (%s%s)s , c 3 s | ] } | Vq d S( N( ( t .0R ( R ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pys s i t ,R\ ( R RV R R) ( R ( ( R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt __repr__ s ( R ( R R t __doc__R R R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s t _repr_paramsc B s; e Z d Z d Z d d Z d Z d Z d Z RS( s Provide a string view of bound parameters.
Truncates display to a given numnber of 'multi' parameter sets,
as well as long values to a given number of characters.
t paramst batchesi, c C s | | _ | | _ | | _ d S( N( R R R ( R R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s c C sx t | j t rF | j } | j o@ t | j d t t t f } nz t | j t r | j } | j o t | j d t t t f } n4 t | j t r | j } t } n | j | j S| rHt
| j | j k rHd } d j | j
| j | j d | d d !| | j t
| j f | j
| j d | d f S| ra| j
| j | S| j | j | Sd S( Ni s8 ... displaying %i of %i total bound parameter sets ... t i iii ( RA R R R t dictt tupleR R R3 R R) R RV t _repr_multiR ( R t typt ismultit msg( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s, !c s | r t | d t r% j n> t | d t rD j n t | d t rc j n d j f d | D } n d } | j k r d | Sd | Sd S( Ni s , c 3 s! | ] } j | Vq d S( N( R ( R R ( t elem_typeR ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pys
s R\ s [%s]s (%s)( RA R R R R R R RV ( R t multi_paramsR t elements( ( R R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s c s | j | | j k r? d d j f d | j D S| | j k r d d j f d | D t | d k r d n d f Sd d j f d
| D Sd S( Ns {%s}s , c 3 s+ | ]! \ } } d | | f Vq d S( s %r: %sN( ( R t keyR ( R ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pys s s (%s%s)c 3 s | ] } | Vq d S( N( ( R R ( R ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pys " s i R R\ s [%s]c 3 s | ] } | Vq d S( N( ( R R ( R ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pys & s ( R R RV t itemsR R) ( R R R ( ( R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s ( R R ( R R R R R R R R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s ! c s) f d } t j | i i | d 6 S( sW given criterion containing bind params, convert selected elements
to IS NULL.
c s t | j t rW | j j k rW | j | _ t | _ t j | _ t j | _
nK t | j t r | j j k r t | _ t j | _ t j | _
n d S( N( RA RF R t _identifying_keyRG R R t is_RD t isnott negate( R@ ( t nulls( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt visit_binary/ s R@ ( R t cloned_traverse( t critR R ( ( R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt adapt_criterion_to_null) s c C s | d k r | S| d f g } t | } d } x | r | j \ } } t | t r | | k r | j } | j | j | j | _ | j | j
| f n | j | } | d k r | | _
n | d k r4 | } q4 q4 W| S( N( R1 t
ClauseAdapterRH RA R t _clonet _reset_exportedRb R; R RF ( RF RG t stop_onRP t adaptert rett prevright( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt splice_joinsD s$
c
s | j d t } | j d t t j t j x D] } x t g | j D] } | j ^ q\ D] } x D] } | | k r q n y
| j } WnE t j
k
r | r q q n# t j k
r | r q q n X| j | r s| j
| j
k r j | Pq q Wqr WqF W| r f d } x: | D]/ } | d k rSt j | i i | d 6 qSqSWn t j S( sC given a list of columns, return a 'reduced' set based on natural
equivalents.
the set is reduced to the smallest list of columns which have no natural
equivalent present in the list. A "natural equivalent" means that two
columns will ultimately represent the same value because they are related
by a foreign key.
\*clauses is an optional list of join clauses which will be traversed
to further identify columns that are "equivalent".
\**kw may specify 'ignore_nonexistent_tables' to ignore foreign keys
whose tables are not yet configured, or columns that aren't yet present.
This function is primarily used to determine the most minimal "primary
key" from a selectable, by reducing the set of primary key columns present
in the selectable to just those that are not repeated.
t ignore_nonexistent_tablest
only_synonymsc s | j t j k r t j t g j D] } | j ^ q+ } | j | k r | j | k r xV t
D]E } | j | j rq s | j | j j k rq j
| Pqq qq Wq n d S( N( RD R t eqR Rk R R4 t proxy_setRF RG t reversedt shares_lineaget nameRo ( R@ R5 Rp ( t columnst omitR ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s .
R@ N( RH R3 R t ordered_column_setRk R R t foreign_keysR_ R t NoReferencedColumnErrort NoReferencedTableErrorR R Ro R1 R Rb R R4 (
R R! t kwR Rz R5 t fkt fk_colR Rc ( ( R R R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt reduce_columns] s:
,
$c sf r r t j d n d f d } g t j | i i | d 6 S( s9 traverse an expression and locate binary criterion pairs.sS Can only specify one of 'consider_as_foreign_keys' or 'consider_as_referenced_keys'c S s
| j | S( N( t compare( t at b( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt col_is s c s" r | j t j k r d St | j t sC t | j t rG d S r | j k r | j | j s | j k r j | j | j f q | j k r | j | j s | j k r j | j | j f q n0 r| j k rC | j | j s'| j k rC j | j | j f q | j k r | j | j sv| j k r j | j | j f q n t | j t r t | j t r | j j | j r j | j | j f q | j j | j r j | j | j f q n d S( N(
RD R R RA RF R RG R R t
references( R@ ( t any_operatorR t consider_as_foreign_keyst consider_as_referenced_keyst pairs( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s: R@ ( R t
ArgumentErrorR Rb ( t
expressionR R R R ( ( R R R R R sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt criterion_as_pairs s 'R c B s> e Z d Z d d d e e d Z e j d Z d Z RS( s5 Clones and modifies clauses based on column correspondence.
E.g.::
table1 = Table('sometable', metadata,
Column('col1', Integer),
Column('col2', Integer)
)
table2 = Table('someothertable', metadata,
Column('col1', Integer),
Column('col2', Integer)
)
condition = table1.c.col1 == table2.c.col1
make an alias of table1::
s = table1.alias('foo')
calling ``ClauseAdapter(s).traverse(condition)`` converts
condition to read::
s.c.col1 == table2.c.col1
c C sZ i | g d 6| d 6| _ | | _ | | _ | | _ t j | pD i | _ | | _ d S( NR t anonymize_labels( t __traverse_options__t
selectablet
include_fnt
exclude_fnR t column_dictt equivalentst adapt_on_names( R R R R R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s
c C s | j j | d | } | d k r | | j k r | | k r xO | j | D]= } | j | d | d | j | g } | d k rM | SqM Wn | j r | d k r | j j j | j } n | S( Nt require_embeddedt _seen(
R t corresponding_columnR1 R t _corresponding_columnR6 R R5 t getR ( R Rz R R t newcolt equiv( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s ' c C s t | t r( | j j | r( | j St | t s; d S| j rX | j | rX d S| j rt | j | rt d S| j | t Sd S( N(
RA R R R R R1 R R R R2 ( R Rz ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyRt ( s N(
R R R R1 R3 R R t EMPTY_SETR Rt ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s
t
ColumnAdapterc B s~ e Z d Z d e d d e e e d Z d e f d YZ d Z d Z
e
Z e j
Z d Z d Z d Z RS(
s Extends ClauseAdapter with extra utility functions.
Key aspects of ColumnAdapter include:
* Expressions that are adapted are stored in a persistent
.columns collection; so that an expression E adapted into
an expression E1, will return the same object E1 when adapted
a second time. This is important in particular for things like
Label objects that are anonymized, so that the ColumnAdapter can
be used to present a consistent "adapted" view of things.
* Exclusion of items from the persistent collection based on
include/exclude rules, but also independent of hash identity.
This because "annotated" items all have the same hash identity as their
parent.
* "wrapping" capability is added, so that the replacement of an expression
E can proceed through a series of adapters. This differs from the
visitor's "chaining" feature in that the resulting object is passed
through all replacing functions unconditionally, rather than stopping
at the first one that returns non-None.
* An adapt_required option, used by eager loading to indicate that
We don't trust a result row column that is not translated.
This is to prevent a column from being interpreted as that
of the child row in a self-referential scenario, see
inheritance/test_basic.py->EagerTargetingTest.test_adapt_stringency
c C s t j | | | d | d | d | d | t j | j | _ | j sR | j rm | j | | j | _ n | | _ | | _
d | _ d S( NR R R R (
R R R t populate_column_dictt _locate_colR R R t _IncludeExcludeMappingt adapt_requiredt allow_label_resolveR1 t _wrap( R R R R R R R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR V s R c B s e Z d Z d Z RS( c C s | | _ | | _ d S( N( t parentR ( R R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s s c C sl | j j r | j j | s= | j j ra | j j | ra | j j rZ | j j j | S| Sn | j | S( N( R R R R R ( R R ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt __getitem__w s ( R R R R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR r s c C sw | j j | j } | j j | j | | _ t j | j | _ | j sX | j
rs | j | | j | _ n | S( N( t __class__t __new__t __dict__R] R R R R R R R R ( R R t ac( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt wrap s c C s | j | S( N( R ( R t obj( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyRb s c C sn t j | | } | j rE | j j | } | d k rE | } qE n | j r^ | | k r^ d S| j | _ | S( N( R Rb R R R1 R R t _allow_label_resolve( R Rz R5 t c2( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR s c C s | j j } | d =| S( NR ( R t copy( R t d( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt __getstate__ s c C s) | j j | t j | j | _ d S( N( R R] R t PopulateDictR R ( R t state( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt __setstate__ s N( R R R R1 R3 R2 R t objectR R Rb t adapt_clauseR t copy_and_processt
adapt_listR R R
( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyR 7 s
N(H R t collectionsR t itertoolsR R\ R R t
annotationR R R t baseR R t ddlR R R
R R R
R R R R R t schemaR R R R R R R R R R R t langhelperst public_factoryt _join_conditiont join_conditionR( R0 R? RS R3 Rj Rs Rv R} R R+ R R2 R R R R R R R R R R1 R R R t ReplacingCloningVisitorR R ( ( ( sF /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/sql/util.pyt
sz * 4 @ " Z M ;P