
    ,h                     V   S r SSKJr  SSKJr  SSKrSSKJr  SSKrSSKJ	r	  SSKJ
r
  SSKJr  SS	KJr  SS
KJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSK J!r!  SSK J"r"  SSK J#r#  SSK$J%r%  SS K$J&r&  SS!K'J(r(  SS"K)J*r*  SS#K+J,r,  SS$K+J-r-  SS%K+J.r.  SS&K+J/r/  SS'K+J0r0  SS(K+J1r1  SS)K+J2r2  SS*K+J3r3  SS+K+J4r4  SS,K+J5r5  SS-K+J6r6  SS.K+J7r7  SS/K+J8r8  SS0K9J:r:  SS1K;J<r<  SS2K;J=r=  SS3K;J>r>  SS4K;J?r?  SS5K;J@r@  SS6K;JArA  SS7K;JBrB  SS8KJCrC  S9S:KJDrD  S9S;KJErE  S9S<KFJGrG  S9S=KFJHrH  \R,                  (       a`  SS>KJIrI  SS?KJJrJ  SS@KJKrK  SSAK+JLrL  SSBK+JMrM  SSCK;JNrN  SSDK;JOrO  SSEK;JPrP  SSFKJQrQ  SSGKJRrR  SSHKJSrS  S9SIKTJUrU  S9SJKTJVrV  S9SKKTJWrW  S9SLKTJXrX  S9SMKYJZrZ  \" SNSOSP9r[  S|         S}SQ jjr\      S~SR jr]      SSS jr^        SST jr_      SSU jr`SVSVSVSVSVSW.             SSX jjraSSY jrbSZ rcS[ rdS\ reSS] jrfS^ rgSS_ jrhS` riSSa jrjSb rkSc rl " Sd Se5      rmSf rn " Sg Sh\m5      ro " Si Sj\p5      rq " Sk Sl\m5      rrSSm jrs S       SSn jjrt\        SSo j5       ru\        SSp j5       ru        SSq jru   SSr jrv " Ss St\R                  5      rx " Su Sv\H5      ry " Sw Sx\x5      rz  S|       SSy jjr{    SSz jr|          SS{ jr}g)z;High level utilities which build upon other modules here.

    )annotations)dequeN)chain)AbstractSet)Any)Callable)cast)
Collection)Dict)Iterable)Iterator)List)Optional)overload)Sequence)Tuple)TYPE_CHECKING)TypeVar)Union   )	coercions)	operators)roles)visitorsis_text_clause)_deep_annotate)_deep_deannotate)_shallow_annotate)_expand_cloned)_from_objects)HasCacheKey)sort_tables)_find_columns)_label_reference)_textual_label_reference)BindParameter)ClauseElement)ColumnClause)ColumnElement)Grouping)KeyedColumnElement)Label)NamedColumn)Null)UnaryExpression)Column)Alias)
FromClause)FromGrouping)Join)ScalarSelect)
SelectBase)TableClause)_ET   )exc)util)Literal)Protocol)_EquivalentColumnMap)_LimitOffsetType)_TypeEngineArgument)BinaryExpression)
TextClause)_JoinTargetElement)_SelectIterable)
Selectable)_TraverseCallableType)ExternallyTraversible)ExternalTraversal)_AnyExecuteParams)_AnyMultiExecuteParams)_AnySingleExecuteParams)_CoreSingleExecuteParams)Row_CEColumnElement[Any])boundc                0    [         R                  " U UUUS9$ )a  Create a join condition between two tables or selectables.

e.g.::

    join_condition(tablea, tableb)

would produce an expression along the lines of::

    tablea.c.id == tableb.c.tablea_id

The join is determined based on the foreign key relationships
between the two selectables.   If there are multiple ways
to join, or no way to join, an error is raised.

:param a_subset: An optional expression that is a sub-component
    of ``a``.  An attempt will be made to join to just this sub-component
    first before looking at the full ``a`` construct, and if found
    will be successful even if there are other ways to join to ``a``.
    This allows the "right side" of a join to be passed thereby
    providing a "natural join".

)a_subsetconsider_as_foreign_keys)r5   _join_condition)abrS   rT   s       K/var/www/auris/envauris/lib/python3.13/site-packages/sqlalchemy/sql/util.pyjoin_conditionrY   _   s#    8 		!9	     c                    [        [        U5      5      n/ n[        U 5       H7  u  pEU H,  nUR                  U5      (       d  M  UR	                  U5        M.     M9     U$ )ap  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

)listr!   	enumerateis_derived_fromappend)clausesjoin_toselectablesidxifss          rX   find_join_sourcerg      sV    & }W-.K
C'"A  ##

1  # JrZ   c                   [        [        U5      5      n/ n[        U 5       H8  u  pEU H-  nUR                  U5      (       d  M  UR	                  U5          M6     M:     [        U5      S:  af  / nU HU  nX   nU HH  n[        [        U5      5      R                  [        U5      5      (       d  M6  UR	                  U5          MS     MW     U(       a  U$ U$ )zGiven a list of FROM clauses and a selectable,
return the indexes from the list of
clauses which is derived from the selectable.

r   )	r\   r!   r]   r^   r_   lensetsurface_selectablesintersection)	r`   	join_fromrb   liberal_idxrd   re   rf   conservative_idxrc   s	            rX   #find_left_clause_that_matches_givenrp      s     }Y/0KK'"A   ##""1%  #" ;!CA *1-.;;'*  %++C0 !  ##rZ   c           
     "   / n[        [        U5      5      n[        U 5      S:  a  Ub  Sn[        U5      nOSnSn[	        U 5       H  u  pxUR                  U/5       H  n	U(       a]  Uc   e[        UR                  5      R                  U	R                  5      R                  U5      (       a  UR                  U5          M|  Mg  Uc  [        R                  " X5      (       d  M  UR                  U5          M     M     [        U5      S:  aQ  [        [        U  Vs/ s H  n[        UR                  5      PM     sn6 5      n
U Vs/ s H  opU   U
;  d  M  UPM     nnU(       d   Ub  [        [!        [        U 5      5      5      $ U$ s  snf s  snf )a  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.

r   NTF)rj   r!   ri   r$   r]   
differencecunion
issupersetr_   r5   	_can_joinr   r    _hide_fromsr\   range)r`   ra   onclauserc   rb   resolve_ambiguitycols_in_onclauserd   re   rf   toremoves              rX   find_left_clause_to_join_fromr}      sb     CmG,-K 7|aH0 (2!'"'',A '333qss8>>!##&112BCCJJqM D %)=)=

1 - # 3x!| 7C7aN1==17CD
 <#Q8!;q#< 8'E#g,'((
 D<s   FFFc                H   ^ ^^ / mSU UU4S jjm[        T" U5      5        Smg)a  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:

.. sourcecode:: text

    a <eq> q
    a <eq> e
    a <eq> f
    b <eq> q
    b <eq> e
    b <eq> f
    j <eq> r

That is, every combination of "left" and
"right" that doesn't further contain
a binary comparison is passed as pairs.

c              3  2  >#    [        U [        5      (       a  U v   g U R                  S:X  a  [        R                  " U R
                  5      (       a  TR                  SU 5        T" U R                  5       H(  nT" U R                  5       H  nT" TS   X5        M     M*     TR                  S5        U R                  5        H  nT" U5        M     g [        U [        5      (       a  U v   U R                  5        H  nT" U5       S h  vN   M     g  N	7f)Nbinaryr   )
isinstancer6   __visit_name__r   is_comparisonoperatorinsertleftrightpopget_childrenr)   )elementlrelemfnstackvisits       rX   r   #visit_binary_product.<locals>.visit-  s     g|,, M##x/I4K4K5
 5
 LLG$7<<(w}}-AuQx& . ) IIaL,,.d / '<00,,. ;&& /&s   DDD
DN)r   r(   returnzIterator[ColumnElement[Any]])r\   )r   exprr   r   s   ` @@rX   visit_binary_productr     s(    N *,E' '* 	tErZ   F)check_columnsinclude_aliasesinclude_joinsinclude_selectsinclude_crudc               `  ^ / m0 nU(       a  TR                   =US'   US'   U(       a  TR                   US'   U(       a  TR                   =US'   =US'   =US'   US'   U(       a  U4S j=US	'   =US
'   US'   U(       a
  U4S jnXvS'   TR                   US'   [        R                  " U 0 U5        T$ )z1locate Table objects within the given expression.selectcompound_selectjoinaliassubquerytablesamplelateralc                :   > TR                  U R                  5      $ Nr_   table)enttabless    rX   <lambda>find_tables.<locals>.<lambda>a  s    cii0rZ   r   updatedeletec                <   > TR                  U R                  5        g r   r   )columnr   s    rX   visit_column!find_tables.<locals>.visit_columnf  s    MM&,,'rZ   r   r   )r_   r   traverse)	clauser   r   r   r   r   	_visitorsr   r   s	           @rX   find_tablesr   F  s     !#F79I=C]]J	(i(9:"MM	& $*==	1	' 	1Yz2 	1Y6
i 0	
	( 	
i1Ih4G 	( +(Igfb),MrZ   c                R   [         R                  " 5       n/ n[        U /5      nU(       Ga{  UR                  5       n[	        U[
        5      (       Ga#  [	        U[        5      (       a%  [        R                  " UR                  5      (       d  [	        U[        5      (       a_  [	        UR                  [        5      (       d@  UR                  n[	        U[        5      (       a  UR                  nUR                  U5        M  [	        U[        5      (       a   UR                  nUR                  U5        GM  [	        U[         5      (       a  GM)  XA;  a"  UR#                  U5        UR                  U5        O(UR%                  5        H  nUR                  U5        M     U(       a  GM{  U$ )zmBreak up an 'order by' expression into individual column-expressions,
without DESC/ASC/NULLS FIRST/NULLS LAST)r<   
column_setr   popleftr   r*   r0   r   is_ordering_modifiermodifierr-   r   r6   r+   r_   r%   r&   addr   )r   colsresultr   trs   s         rX   unwrap_order_byr   q  s/    ??DF6(OE MMOa''1o..11!**==!U##J		<- - IIa**		AQA/00IIQ!688}a  ^^%Q &9 %< MrZ   c                H          SS jn[         R                  " U 0 U5      $ )Nc                ~    [        U [        5      (       a  U R                  $ [        U [        5      (       a   S5       eg )Nz&can't unwrap a textual label reference)r   r%   r   r&   )r   kws     rX   replace'unwrap_label_reference.<locals>.replace  s8     g/00??"!9::BBB5rZ   )r   rH   r   r   r   Optional[ExternallyTraversible])r   replacement_traverse)r   r   s     rX   unwrap_label_referencer     s6    &.1	( (("g>>rZ   c           
         U  Vs1 s H  nUR                   b  UR                  OUiM      nn[        [        U Vs/ s H  n[	        U5      PM     sn6 5      nU Vs/ s H  o"U;  d  M
  UPM     sn$ s  snf s  snf s  snf )zGiven 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.

)_order_by_label_elementr   r\   r   r   )collistorder_bycolcols_already_presentoto_look_fors         rX    expand_column_list_from_order_byr     s     C 22>CG  
 u8D8aq18DEFK&J;C5I*IC;JJ
 EJs   %A1A6	A;(A;c                6    [        U5       H
  nX:X  d  M
    g   g)zGiven 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.

TF)rk   )r   searchr   s      rX   clause_is_presentr     s      $F+> , rZ   c              #  &  #    [        U [        5      (       a;  [        U R                  5       S h  vN   [        U R                  5       S h  vN   g [        U [
        5      (       a  [        U R                  5       S h  vN   g U v   g  NZ N? N7fr   )r   r5   tables_from_leftmostr   r   r4   r   )r   s    rX   r   r     se     &$'444'555	FL	)	)'777 	557s3   .BBBB2B BBBBc              #  6  #    U /nU(       a  UR                  5       nUv   [        U[        5      (       a(  UR                  UR                  UR
                  45        O0[        U[        5      (       a  UR                  UR                  5        U(       a  M  g g 7fr   )	r   r   r5   extendr   r   r4   r_   r   r   r   r   s      rX   rk   rk     si     HE
yy{
dD!!LL$))TZZ01l++LL& %s   BBBc              #    #    U /nU(       a  UR                  5       n[        U[        [        45      (       a  Uv   [        U[        5      (       a(  UR                  UR                  UR                  45        O{[        U[        5      (       a  UR                  UR                  5        OJ[        U[        5      (       a.  UR                  b  UR                  UR                  5        OUv   OUb  Uv   U(       a  M  g g 7fr   )r   r   r8   r2   r5   r   r   r   r4   r_   r   r)   r   r   s      rX   surface_selectables_onlyr     s     HE
yy{d[%011JdD!!LL$))TZZ01l++LL&l++zz%TZZ(
J %s   C9C?=C?c                $   [         [        4n[        U /5      nU(       aq  UR                  5       nXR                  ;   a  UR                  U   $ UR                  5        H&  n[        XR5      (       a  M  UR                  U5        M(     U(       a  Mq  g r   )r4   r7   r   r   _annotationsr   r   r_   )r   annotation_namefilter_r   r   subs         rX   extract_first_column_annotationr     s{    Z(G6(OE
}}///$$_55$$&C#''LL '	 % rZ   c                l    [        [        [        U 5      5      R                  [        U5      5      5      $ )z:Return True if left/right have some overlapping selectable)boolrj   rk   rl   )r   r   s     rX   selectables_overlapr     s0     %&334G4NO rZ   c                L   ^ / mU4S jn[         R                  " U 0 SU05        T$ )zReturn 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                <   > TR                  U R                  5        g r   )r_   effective_value)bindvs    rX   visit_bindparam$bind_values.<locals>.visit_bindparam  s    	%%&rZ   	bindparam)r   r   )r   r   r   s     @rX   bind_valuesr     s-     	A' fb;"@AHrZ   c                p    [        U [        5      (       a  U R                  SS5      n SU -  $ [        U 5      $ )N'z''z'%s')r   strr   repr)r   s    rX   _quote_ddl_exprr      s4    '3//#t,G}rZ   c                  X    \ rS rSr% SrS\S'   SrS\S'   SrS\S'   S	rS\S
'   SS jr	Sr
g)
_repr_basei(  r   int_LISTr   _TUPLEr:   _DICT)	max_charsr   c                    [        U5      n[        U5      nX0R                  :  a,  U R                  S-  nUSU SX0R                  -
  -  -   X$* S  -   nU$ )Nr:   r   z# ... (%d characters truncated) ... )r   ri   r   )selfvaluereplenrepsegment_lengths        rX   trunc_repr_base.trunc1  sk    5kSNN"!^^q0NAn%9.0
 o&'(  
rZ    N)r   r   r   r   )__name__
__module____qualname____firstlineno__r   __annotations__r   r   	__slots__r   __static_attributes__r   rZ   rX   r   r   (  s,    E3NFCOE3NINrZ   r   c                F    [        5       nSUl        UR                  U 5      $ )N,  )r   r   r   )r   rps     rX   _repr_single_valuer
  A  s    	BBL88E?rZ   c                  4    \ rS rSrSrSrSS	S jjrS
S jrSrg)	_repr_rowiG  zProvide a string view of a row.)rowc                    Xl         X l        g r   )r  r   )r   r  r   s      rX   __init___repr_row.__init__L  s    "rZ   c                   ^ U R                   mSSR                  U4S jU R                   5       5      < [        U R                  5      S:X  a  SOS< S3$ )N(, c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   .0r   r   s     rX   	<genexpr>%_repr_row.__repr__.<locals>.<genexpr>S  s     9ueEll   r   , ))r   r   r  ri   )r   r   s    @rX   __repr___repr_row.__repr__P  sC    

II999txx=A%C2-
 	
rZ   )r   r  N)r  )r  zRow[Any]r   r   r   r   )	r   r  r  r  __doc__r  r  r  r  r   rZ   rX   r  r  G  s    )I#
rZ   r  c                      \ rS rSrSS jrSrg)_long_statementiX  c                    [        U 5      nUS:  a  SnSnX-
  U-
  nU SU  SU SX* S   3$ [        R                  U 5      $ )Ni     d   r    ... z characters truncated ... )ri   r   __str__)r   lselflleftlrightr   s        rX   r'  _long_statement.__str__Y  se    D	3;EFMF*E%=/ug .,,0N+;=
 ;;t$$rZ   r   Nr  )r   r  r  r  r'  r  r   rZ   rX   r"  r"  X  s    %rZ   r"  c                      \ rS rSrSrSr   S         SS jjrSS jr      SS jrSS jr	      SS	 jr
SS
 jrSS jrSS jrSrg)_repr_paramsig  zProvide a string view of bound parameters.

Truncates display to a given number of 'multi' parameter sets,
as well as long values to a given number of characters.

)paramsbatchesismulti
max_paramsNc                @    Xl         XPl        X l        X@l        X0l        g r   )r.  r0  r/  r   r1  )r   r.  r/  r1  r   r0  s         rX   r  _repr_params.__init__q  s     "$rZ   c           	     r   U R                   c  U R                  U R                  5      $ [        U R                  [        5      (       a  U R
                  nOs[        U R                  [        5      (       a  U R                  nOG[        U R                  [        5      (       a  U R                  nOU R                  U R                  5      $ U R                   (       a  [        SU R                  5      n[        U R                  5      U R                  :  ap  SnSR                  U R                  US U R                  S-
   U5      SS X0R                  [        U R                  5      4-  U R                  USS  U5      SS  45      $ U R                  X!5      $ U R                  [        S	U R                  5      U5      $ )
NrK   z8 ... displaying %i of %i total bound parameter sets ...  r:   r   r   rL   )r0  r   r.  r   r\   r   tupler   dictr   r	   ri   r/  r   _repr_multir-  )r   typmulti_paramsmsgs       rX   r  _repr_params.__repr__  sx   <<::dkk**dkk4((**CU++++CT****C::dkk**<<(L
 4;;$,,.N  xx((();4<<!+;< B  ||S-=>>((bc):C@D	 	 ''::$$-KK  rZ   c                  ^ ^ U(       a  [        US   [        5      (       a  T R                  mO`[        US   [        5      (       a  T R                  mO;[        US   [
        5      (       a  T R                  mO S[        US   5      -  5       eSR                  UU 4S jU 5       5      nOSnUT R                  :X  a  SU-  $ SU-  $ )Nr   zUnknown parameter type %sr  c              3  H   >#    U  H  nTR                  UT5      v   M     g 7fr   )r-  )r  r.  	elem_typer   s     rX   r  +_repr_params._repr_multi.<locals>.<genexpr>  s$      !CO!!&)44<s   "r  [%s]z(%s))	r   r\   r   r8  r   r9  r   typer   )r   r<  r;  elementsrA  s   `   @rX   r:  _repr_params._repr_multi  s    
 ,q/400 JJ	LOU33 KK	LOT22 JJ	9a) u yy !CO! H H$**H$$H$$rZ   c                    [        U5      n[        U5      nX0R                  :  a&  U R                  S-  nUSU X$* S  X0R                  -
  4$ US S 4$ )Nr:   r   )r\   ri   r1  )r   r.  lparams	lenparamsr)  s        rX   _get_batches_repr_params._get_batches  sc    v,L	&OOq(E%  OO+  D$&&rZ   c                    X R                   L a  U R                  [        SU5      5      $ X R                  L a  U R	                  [        SU5      5      $ U R                  U5      $ )NrM   Sequence[Any])r   _repr_param_dictr	   r   _repr_param_tuple_repr_param_list)r   r.  r;  s      rX   r-  _repr_params._repr_params  sa    
 **((/8  KK))$*GHH((00rZ   c                D  ^ U R                   mU R                  UR                  5       5      u  nnnU(       aJ  SSR                  U4S jU 5       5      -  nUSU S3-  nUSSR                  U4S jU 5       5      -  -  nU$ SSR                  U4S	 jU 5       5      -  nU$ )
Nz{%sr  c              3  D   >#    U  H  u  pU< S T" U5       3v   M     g7fz: Nr   r  keyr   r   s      rX   r  0_repr_params._repr_param_dict.<locals>.<genexpr>  )      &7
 gRe~.&7    r&   parameters truncated ... z%s}c              3  D   >#    U  H  u  pU< S T" U5       3v   M     g7frT  r   rU  s      rX   r  rW    s)      &8
 gRe~.&8rY  z{%s}c              3  D   >#    U  H  u  pU< S T" U5       3v   M     g7frT  r   rU  s      rX   r  rW    rX  rY  )r   rJ  itemsr   r   r.  items_first_batchitems_second_batchtrunclentextr   s         @rX   rN  _repr_params._repr_param_dict  s    


 flln-		
 		 &7 D eH:%?@@DE		 &8  D  		 &7 D rZ   c                V  ^ U R                   mU R                  U5      u  nnnU(       aK  SSR                  U4S jU 5       5      -  nUSU S3-  nUSR                  U4S jU 5       5      < S3-  nU$ SSR                  U4S	 jU 5       5      < [        U5      S
:X  a  SOS< S3nU$ )Nz(%sr  c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   r  s     rX   r  1_repr_params._repr_param_tuple.<locals>.<genexpr>       F4E5%,,4Er  r&  rZ  c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   r  s     rX   r  rf         G4F5%,,4Fr  r  r  c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   r  s     rX   r  rf    rg  r  r   r  r  )r   rJ  r   ri   r^  s         @rX   rO  _repr_params._repr_param_tuple  s    

 f%		
 		F4EFFD eH:%?@@D		G4FGG D   		F4EFF,-2:D rZ   c                (  ^ U R                   mU R                  U5      u  nnnU(       aJ  SSR                  U4S jU 5       5      -  nUSU S3-  nUSSR                  U4S jU 5       5      -  -  nU$ SSR                  U4S	 jU 5       5      -  nU$ )
Nz[%sr  c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   r  s     rX   r  0_repr_params._repr_param_list.<locals>.<genexpr>$  rg  r  r&  rZ  z%s]c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   r  s     rX   r  rn  (  ri  r  rC  c              3  4   >#    U  H  nT" U5      v   M     g 7fr   r   r  s     rX   r  rn  ,  rg  r  )r   rJ  r   r^  s         @rX   rP  _repr_params._repr_param_list  s    


 f%		
 		F4EFFD eH:%?@@DE		G4FGG D  		F4EFFD rZ   )r/  r0  r   r1  r.  )r%  r  N)
r.  zOptional[_AnyExecuteParams]r/  r   r1  r   r   r   r0  zOptional[bool]r  )r<  rK   r;  r   r   r   )r.  zIterable[Any]r   r   )r.  rL   r;  r   r   r   )r.  rM   r   r   )r.  rM  r   r   )r.  rL   r   r   )r   r  r  r  r   r  r  r  r:  rJ  r-  rN  rO  rP  r  r   rZ   rX   r-  r-  g  s     =I "&%+% % 	%
 %  %+Z%,% % 
	%8'1'1 1 
	1>0rZ   r-  c                D   ^ U4S jn[         R                  " U 0 SU05      $ )zOgiven criterion containing bind params, convert selected elements
to IS NULL.

c                  > [        U R                  [        5      (       ae  U R                  R                  T;   aK  U R                  U l        [        5       U l        [        R                  U l        [        R                  U l
        g [        U R                  [        5      (       aU  U R                  R                  T;   a:  [        5       U l        [        R                  U l        [        R                  U l
        g g g r   )r   r   r'   _identifying_keyr   r/   r   is_r   is_notnegate)r   nullss    rX   visit_binary-adapt_criterion_to_null.<locals>.visit_binary7  s    v{{M22,,5 !,,FK6FL'mmFO%,,FMv||]33--66FL'mmFO%,,FM	 7 4rZ   r   )r   cloned_traverse)critrx  ry  s    ` rX   adapt_criterion_to_nullr}  1  s$    -$ ##D"x.FGGrZ   c                   U c  U$ US 4/n[        U 5      nS nU(       a  UR                  5       u  p[        U[        5      (       aR  XLaN  UR	                  5       nUR                  UR                  5      Ul        UR                  UR                  U45        OUR                  U5      nUb  Uc   eXl        Uc  UnU(       a  M  U$ r   )	ClauseAdapterr   r   r5   _cloner   ry   r_   r   )r   r   stop_onr   adapterret	prevrights          rX   splice_joinsr  L  s    
 |AFED!G
C
"YY[eT""u';LLNE$--enn=ENLL%**e,-$$U+E $$$"N;C % JrZ   c                    g r   r   columnsr`   r   s      rX   reduce_columnsr  i  s    
 $'rZ   c                    g r   r   r  s      rX   r  r  q  s    
 7:rZ   c                <  ^^^ UR                  SS5      nUR                  SS5      m[        R                  " U 5      nUR                  S U 5       5      m[        R                  " 5       mT H  n[        UR                   Vs/ s H  ofR                  PM     sn6  Hl  nT Hc  nXeL a  M	   UR                  nUR                  U5      (       d  M.  T(       a  UR                  UR                  :X  d  MQ  TR                  U5          Mj     Mn     M     U(       a0  UUU4S jn	U H"  n
U
c  M  [        R                   " U
0 SU	05        M$     UR                  T5      $ s  snf ! [        R                   a    U(       a   M  e [        R                   a    U(       a   M  e f = f)a  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.

ignore_nonexistent_tablesFonly_synonymsc              3  J   #    U  H  n[        U5      (       d  M  Uv   M     g 7fr   r   )r  rs   s     rX   r  !reduce_columns.<locals>.<genexpr>  s      Na!2:s   #	#c                   > U R                   [        R                  :X  a  [        R                  " [        TR                  T5       Vs/ s H  oR                  PM     sn6 5      nU R                  U;   a  U R                  U;   as  [        T5       Hc  nUR                  U R                  5      (       d  M%  T(       a&  UR                  U R                  R                  :X  d  MR  TR                  U5          g    g g g g s  snf r   )r   r   eqr<   r   r   rr   	proxy_setr   r   reversedshares_lineagenamer   )r   rs   r   cset_no_textomitr  s      rX   ry  $reduce_columns.<locals>.visit_binary  s    ),,./;/F/Ft/LM/L!++/LM
 ;;$&6<<4+?%l3++FLL99 -6;;;K;K1K HHQK! 4 ,@& / Ns   C;r   )r   r<   
OrderedSetrr   r   r   r  foreign_keysr   r;   NoReferencedColumnErrorNoReferencedTableErrorr  r  r   r   r   )r  r`   r   r  r   r   rs   fkfk_colry  r   r  r  r  s              @@@rX   r  r  y  sl   0 !#'BE JFF?E2M)J8B8M8M NN 9L ??D#--@-Q..-@AB!8YYF ((++%388);HHSM/ " B 6 	" F!!!&"x.FG    &&_ A 22  1 11  1 s   E
+EF	;F	F	c                   ^^^^^ T(       a  T(       a  [         R                  " S5      eS mUUUUU4S jn/ m[        R                  " U 0 SU05        T$ )z9traverse an expression and locate binary criterion pairs.zSCan only specify one of 'consider_as_foreign_keys' or 'consider_as_referenced_keys'c                $    U R                  U5      $ r   )compare)rV   rW   s     rX   col_is"criterion_as_pairs.<locals>.col_is  s    yy|rZ   c                
  > T(       d  U R                   [        R                  La  g [        U R                  [
        5      (       a  [        U R                  [
        5      (       d  g T(       a  U R                  T;   aZ  T" U R                  U R                  5      (       d  U R                  T;  a(  TR                  U R                  U R                  45        g U R                  T;   a[  T" U R                  U R                  5      (       d  U R                  T;  a(  TR                  U R                  U R                  45        g g g T(       a  U R                  T;   aZ  T" U R                  U R                  5      (       d  U R                  T;  a(  TR                  U R                  U R                  45        g U R                  T;   a[  T" U R                  U R                  5      (       d  U R                  T;  a(  TR                  U R                  U R                  45        g g g [        U R                  [        5      (       a  [        U R                  [        5      (       a  U R                  R                  U R                  5      (       a(  TR                  U R                  U R                  45        g U R                  R                  U R                  5      (       a(  TR                  U R                  U R                  45        g g g g r   )
r   r   r  r   r   r*   r   r_   r1   
references)r   any_operatorr  rT   consider_as_referenced_keyspairss    rX   ry  (criterion_as_pairs.<locals>.visit_binary  s   y|| C&++}55ZLL->
 >
 #{{66v||V[[11<<'??fllFKK89!99v{{FLL11;;&>>fkk6<<89 ? :
 ){{99v||V[[11<<'BBfkk6<<89!<<v{{FLL11;;&AAfllFKK89 B = &++v..:f4 4 ;;))&,,77LL&,,!<=\\,,V[[99LL&++v||!<= :4.rZ   r   )r;   ArgumentErrorr   r   )
expressionrT   r  r  ry  r  r  s    ``` @@rX   criterion_as_pairsr    sX      $?,
 	
%> %>N BDEj"x&>?LrZ   c                      \ rS rSrSrSr      S             SS jjr\(       a  \SS j5       r	\SS j5       r	    SS jr	\
R                  4S	 jr\
R                  " S
5       S     SS jj5       rSrg)r  i  a	  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

)__traverse_options__
selectable
include_fn
exclude_fnequivalentsadapt_on_namesadapt_from_selectablesNc                    U/US.U l         Xl        X0l        X@l        [        R
                  " U=(       d    0 5      U l        XPl        Xpl        g )N)r  anonymize_labels)	r  r  r  r  r<   column_dictr  r  r  )r   r  r  r  r  r  r  r  s           rX   r  ClauseAdapter.__init__5  sK     #| 0%
! %$$++K,=2>,&<#rZ   c                    g r   r   r   objs     rX   r   ClauseAdapter.traverseL  s    8;rZ   c                    g r   r   r  s     rX   r   r  W  s    -0rZ   c                    g r   r   r  s     rX   r   r  Z  s    .1rZ   c                   U R                   R                  XS9nUcR  XR                  ;   aC  X;  a>  U R                  U    H+  nU R                  UUUR	                  U/5      S9nUc  M)  Us  $    U R
                  (       aG  UcD  [        U[        5      (       a/  U R                   R                  R                  UR                  5      nU$ )Nrequire_embedded)r  _seen)r  corresponding_columnr  _corresponding_columnrt   r  r   r.   exported_columnsgetr  )r   r   r  r  newcolequivs         rX   r  #ClauseAdapter._corresponding_column^  s     55 6 
 >c%5%55#:J))#.33%5++se, 4 
 %!M / 3,,__5599#((CFrZ   zsqlalchemy.sql.functionsc                t   [         R                  R                  nU R                  (       a  U R                  U5      (       d  g U R                  (       a  U R	                  U5      (       a  g [        U[        5      (       a  [        XR                  5      (       d  U R                  R                  U5      (       aT  U R                  (       a7  U R                   H&  nUR                  U5      (       d  M    U R                  $    g U R                  $ [        U[        5      (       a!  [        UR                  [        5      (       a  U$ g [        U[        5      (       d  g U(       d  UR                  (       a  g SUR                   ;   a  UR                   S   n["        (       a  [        U[$        5      (       d   eU R                  (       aB  XR&                  ;  a3  U R                   H"  nUR(                  R+                  US5      c  M"    O   g ["        (       a  [        U[$        5      (       d   eU R-                  USS9$ )Nadapt_columnFTr  )r<   	preloadedsql_functionsr  r  r   r3   FunctionElementr  r^   r  r2   r   r8   r*   _is_singleton_constantr   r   r,   r  rs   r  r  )r   r   _include_singleton_constants	functionsadps        rX   r   ClauseAdapter.replacev  s    NN00	 ??4??3#7#7__!5!5c:&&z**0
 0
 ..s33..#::..s33! &  ;  $&C''J[- - 

 C//-#2L2L S---"">2C=c#56666&&36F6F+F2255--c59E 3 =c#56666))$ * 
 	
rZ   )r  r  r  r  r  r  r  )NNNFFN)r  rF   r  Optional[_EquivalentColumnMap]r  )Optional[Callable[[ClauseElement], bool]]r  r  r  r   r  r   r  !Optional[AbstractSet[FromClause]]r  zLiteral[None]r   Noner  r9   r   r9   r  r   r   r   )F)r   r9   r  r   r   zOptional[_ET])r   r  r  r  r   r  r  r   r   r   r<   	EMPTY_SETr  preload_moduler   r  r   rZ   rX   r  r    s    <I 7;@D@D$!&DH== 4= >	=
 >= = = !B=* 	; 
; 
0 
0	26	2,	2
 ,0>>0 
34=BF
F
6:F
	F
 5F
rZ   r  c                  n    \ rS rSr\S	S j5       r\S
S j5       r\SS j5       r\SS j5       rSS jrSrg)_ColumnLookupi  c                    g r   r   r   rV  s     rX   __getitem___ColumnLookup.__getitem__  s    .1rZ   c                    g r   r   r  s     rX   r  r    s    HKrZ   c                    g r   r   r  s     rX   r  r    s    JMrZ   c                    g r   r   r  s     rX   r  r    s    ,/rZ   c                    g r   r   r  s     rX   r  r    s    CrZ   r   N)rV  r  r   r  )rV  ColumnClause[Any]r   r  )rV  rP   r   rP   )rV  r9   r   r9   )rV  r   r   r   )r   r  r  r  r   r  r  r   rZ   rX   r  r    s=    1 1K KM M/ //rZ   r  c                  <  ^  \ rS rSr% SrSrS\S'           S                 SU 4S jjjr " S S5      rS	 r	\
SS
 j5       r\
SS j5       r    SS jrSU 4S jjr\(       a
  \SS j5       r\r\R$                  r    SS jr    SS jrSrU =r$ )ColumnAdapteri  a+  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

)r  adapt_requiredallow_label_resolve_wrap__weakref__r  r  c
           
        > [         T
U ]  UUUUUUU	S9  [        R                  " U R                  5      U l        U R                  (       d  U R                  (       a   U R                  X R
                  5      U l        X0l	        Xpl
        S U l        g )N)r  r  r  r  r  )superr  r<   WeakPopulateDict_locate_colr  r  r  _IncludeExcludeMappingr  r  r  )r   r  r  r  r  r  r  r  r  r  	__class__s             rX   r  ColumnAdapter.__init__  s|     	!!)-#9 	 	
 ,,T-=-=>??doo66t\\JDL,#6 
rZ   c                       \ rS rSrS rS rSrg)$ColumnAdapter._IncludeExcludeMappingi  c                    Xl         X l        g r   )parentr  )r   r  r  s      rX   r  -ColumnAdapter._IncludeExcludeMapping.__init__  s     K"LrZ   c                   U R                   R                  (       a   U R                   R                  U5      (       a;  U R                   R                  (       a`  U R                   R                  U5      (       a@  U R                   R                  (       a#  U R                   R                  R                  U   $ U$ U R                  U   $ r   )r  r  r  r  r  r  s     rX   r  0ColumnAdapter._IncludeExcludeMapping.__getitem__  s    &&t{{/E/Ec/J/J++((T[[-C-CC-H-H;;$$;;,,44S99J<<$$rZ   )r  r  N)r   r  r  r  r  r  r  r   rZ   rX   r  r    s    	#	%rZ   r  c                   [         R                   " U 5      nXl        [        R                  " UR                  5      Ul        UR                  (       d  UR                  (       a   U R                  X"R
                  5      Ul        U$ r   )	copyr  r<   r  r  r  r  r  r  )r   r  acs      rX   wrapColumnAdapter.wrap%  sR    YYt_**2>>:
==BMM44RDBJ	rZ   c                    g r   r   r  s     rX   r   ColumnAdapter.traverse.  s    47rZ   c                    g r   r   r  s     rX   r   r  1  s    ),rZ   c                     U R                   U   $ r   )r  r  s     rX   r   r  4  s     ||C  rZ   c                P   > [        U[        5      (       d   e[        TU ]  U5      $ r   )r   r  r  r   )r   visitorr  s     rX   r   ColumnAdapter.chain9  s%    '=1111w}W%%rZ   c                    g r   r   )r   s    rX   visitor_iteratorColumnAdapter.visitor_iterator@  s    ?BrZ   c                T    U R                   U   nX!L a  U R                  US5      c  g U$ )NT)r  r  )r   r   r  s      rX   adapt_check_present!ColumnAdapter.adapt_check_presentF  s1     c"=T77TBJrZ   c                `   UR                   (       a+  U R                   H  nUR                  USS9nUc  M    O   UnO[        R	                  X5      nU R
                  (       a   U R
                  R                  U5      nUb  UnU R                  (       a  X1L a  g X1La  U R                  Ul	        U$ )NT)r  )
_is_immutabler	  r   r  r   r  r  r  r  _allow_label_resolve)r   r   visrs   c2s        rX   r  ColumnAdapter._locate_colP  s     ,,KK$KG= -
 &&t1A::''*B~18 <%)%=%=A"rZ   )r  r  r  r  )NFNNFTFN)r  rF   r  r  r  r   r  r  r  r  r  r   r  r   r  r   r  r  r  r  r  )r  rI   r   r  )r   zIterator[ColumnAdapter])r   rP   r   Optional[ColumnElement[Any]])r   r  r  r  r   r  r  r  r  r  r   r   r   r   propertyr	  adapt_clauser  copy_and_process
adapt_listr  r  r  __classcell__)r  s   @rX   r  r    s-   <I 
 7;$@D@D$$(!&DH 4 	
 > >  "  !B :% % 7 7, ,!2!	(!
&
 	B 
BL//J%	%*%*	%* *rZ   r  c                J    [         R                  " [        R                  XUS9$ )zConvert the given value to an "offset or limit" clause.

This handles incoming integers and converts to an expression; if
an expression is already given, it is passed through.

)r  type_)r   expectr   LimitOffsetRole)r   r  r  s      rX   _offset_or_limit_clauser  }  s$     w rZ   c                t    U c  g[        U S5      (       a"  U R                  n[        R                  " U5      $ U $ )z\Return the offset or limit clause as a simple integer if possible,
else return the clause.

N_limit_offset_value)hasattrr   r<   asint)r   r   s     rX   )_offset_or_limit_clause_asint_if_possibler#    s9     ~v,--**zz%  rZ   c                .   UbF  UbC  [        U5      nUc  SnUS:w  a  X-   nUS:X  a  SnOUc   e[        U5      n[        X2-
  5      n X4$ Uc  Ub  [        U5      n X4$ Ub3  Uc0  [        U5      nUc  SnUS:w  a  X-   nUS:X  a  SnX4$ [        U5      nX4$ )z0Compute LIMIT/OFFSET in terms of slice start/endNr   )r#  r  )limit_clauseoffset_clausestartstops       rX   _make_slicer)    s     T-A
  MA:)1MA M ,,,3MBM.t|<& &&# 
4+.t4  && 
	t|A
  MA:)1MA M && 4MBM&&rZ   )NN)
rV   r3   rW   r3   rS   Optional[FromClause]rT   z(Optional[AbstractSet[ColumnClause[Any]]]r   zColumnElement[bool])r`   zList[FromClause]ra   r3   r   	List[int])r`   Sequence[FromClause]rm   r3   r   r+  )r`   r,  ra   rD   ry   r  r   r+  )r   zOCallable[[BinaryExpression[Any], ColumnElement[Any], ColumnElement[Any]], None]r   rP   r   r  )r   r(   r   r   r   r   r   r   r   r   r   r   r   zList[TableClause])r   r   r   r   )r   r3   r   zIterator[FromClause])r   r(   r   zIterator[ClauseElement])r   r3   r   r3   r   r   )r|  rO   rx  zCollection[Any]r   rO   r   )r   r*  r   r*  r  r*  r   r*  )r  zIterable[ColumnElement[Any]]r`   Optional[ClauseElement]r   r   r   zSequence[ColumnElement[Any]])r  rE   r`   r-  r   r   r   z/Sequence[Union[ColumnElement[Any], TextClause]])r  rE   r`   r-  r   r   r   z1Collection[Union[ColumnElement[Any], TextClause]])NNF)r   r@   r  zOptional[str]r  z"Optional[_TypeEngineArgument[int]]r   zColumnElement[int])r   r@   r   r@   )
r%  r@   r&  r@   r'  r   r(  r   r   zATuple[Optional[ColumnElement[int]], Optional[ColumnElement[int]]])~r   
__future__r   collectionsr   r  	itertoolsr   typingr   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r  r   r   r   r   _typingr   
annotationr   r   r   baser    r!   	cache_keyr"   ddlr#   rE  r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   schemar1   r  r2   r3   r4   r5   r6   r7   r8   r9   r;   r<   util.typingr=   r>   r?   r@   rA   rB   rC   rD   rE   rF   rG   rH   rI   engine.interfacesrJ   rK   rL   rM   
engine.rowrN   rO   rY   rg   rp   r}   r   r   r   r   r   r   r   rk   r   r   r   r   r   r   r
  r  r   r"  r-  r}  r  r  r  ReplacingExternalTraversalr  r  r  r  r#  r)  r   rZ   rX   <module>r<     s!   #                          # 8 < >    1 + 4 & . # # " #  (  !  %   " $  $ " #    ! "	-),*$.+&//+5:;< e/0 &*IM	!!! #! G	!
 !H(28)!).8))X6!66 +6 	6r?	? 	?
 
?J  !!(( ( 	(
 ( ( ( (V,^
?K" '&& 2

 
"%c %G: GTH< %)
 " 	: 
')'%' ' "	' 
' 
::%: : 5	: 
:Q'Q'%Q' Q' 7	Q'l " $	<~q
H77 q
h0H 0 jM j^ 04
 . 	  2'"2'#2' 2' 	2'
 G2'rZ   