
    ,h^/                       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 r(S+S" jr) " S# S!\5      r " S$ S%\ 5      r* " S& S'\*5      r+ " S( S)\*5      r,g*),    )annotations)Any)List)Optional)Tuple)Union   )ext   )_OnConflictConstraintT)_OnConflictIndexElementsT)_OnConflictIndexWhereT)_OnConflictSetT)_OnConflictWhereT   )util)	coercions)roles)schema)_DMLTableArgument)_exclusive_against)_generative)ColumnCollection)ReadOnlyColumnCollectionInsert)ClauseElement)ColumnElement)KeyedColumnElement)
TextClause)alias)Self)r   insertr   c                    [        U 5      $ )aG  Construct a PostgreSQL-specific variant :class:`_postgresql.Insert`
construct.

.. container:: inherited_member

    The :func:`sqlalchemy.dialects.postgresql.insert` function creates
    a :class:`sqlalchemy.dialects.postgresql.Insert`.  This class is based
    on the dialect-agnostic :class:`_sql.Insert` construct which may
    be constructed using the :func:`_sql.insert` function in
    SQLAlchemy Core.

The :class:`_postgresql.Insert` construct includes additional methods
:meth:`_postgresql.Insert.on_conflict_do_update`,
:meth:`_postgresql.Insert.on_conflict_do_nothing`.

r   )tables    Z/var/www/auris/envauris/lib/python3.13/site-packages/sqlalchemy/dialects/postgresql/dml.pyr#   r#   *   s    " %=    c                      \ rS rSrSrSrSr\R                    SS j5       r	\
" SSS0S9r\\     S           SS
 jj5       5       r\\   S       SS jj5       5       rSrg	)r   >   zPostgreSQL-specific implementation of INSERT.

Adds methods for PG-specific syntaxes such as ON CONFLICT.

The :class:`_postgresql.Insert` object is created using the
:func:`sqlalchemy.dialects.postgresql.insert` function.


postgresqlFc                >    [        U R                  SS9R                  $ )a  Provide the ``excluded`` namespace for an ON CONFLICT statement

PG's ON CONFLICT clause allows reference to the row that would
be inserted, known as ``excluded``.  This attribute provides
all columns in this row to be referenceable.

.. tip::  The :attr:`_postgresql.Insert.excluded` attribute is an
    instance of :class:`_expression.ColumnCollection`, which provides
    an interface the same as that of the :attr:`_schema.Table.c`
    collection described at :ref:`metadata_tables_and_columns`.
    With this collection, ordinary names are accessible like attributes
    (e.g. ``stmt.excluded.some_column``), but special names and
    dictionary method names should be accessed using indexed access,
    such as ``stmt.excluded["column name"]`` or
    ``stmt.excluded["values"]``.   See the docstring for
    :class:`_expression.ColumnCollection` for further examples.

.. seealso::

    :ref:`postgresql_insert_on_conflict` - example of how
    to use :attr:`_expression.Insert.excluded`

excluded)name)r!   r%   columns)selfs    r&   r,   Insert.excludedK   s    6 TZZj1999r'   _post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)msgsNc                *    [        XX4U5      U l        U $ )a  
Specifies a DO UPDATE SET action for ON CONFLICT clause.

Either the ``constraint`` or ``index_elements`` argument is
required, but only one of these can be specified.

:param constraint:
 The name of a unique or exclusion constraint on the table,
 or the constraint object itself if it has a .name attribute.

:param index_elements:
 A sequence consisting of string column names, :class:`_schema.Column`
 objects, or other column expression objects that will be used
 to infer a target index.

:param index_where:
 Additional WHERE criterion that can be used to infer a
 conditional target index.

:param set\_:
 A dictionary or other mapping object
 where the keys are either names of columns in the target table,
 or :class:`_schema.Column` objects or other ORM-mapped columns
 matching that of the target table, and expressions or literals
 as values, specifying the ``SET`` actions to take.

 .. versionadded:: 1.4 The
    :paramref:`_postgresql.Insert.on_conflict_do_update.set_`
    parameter supports :class:`_schema.Column` objects from the target
    :class:`_schema.Table` as keys.

 .. warning:: This dictionary does **not** take into account
    Python-specified default UPDATE values or generation functions,
    e.g. those specified using :paramref:`_schema.Column.onupdate`.
    These values will not be exercised for an ON CONFLICT style of
    UPDATE, unless they are manually specified in the
    :paramref:`.Insert.on_conflict_do_update.set_` dictionary.

:param where:
 Optional argument. An expression object representing a ``WHERE``
 clause that restricts the rows affected by ``DO UPDATE SET``. Rows not
 meeting the ``WHERE`` condition will not be updated (effectively a
 ``DO NOTHING`` for those rows).


.. seealso::

    :ref:`postgresql_insert_on_conflict`

)OnConflictDoUpdater1   )r/   
constraintindex_elementsindex_whereset_wheres         r&   on_conflict_do_updateInsert.on_conflict_do_updatep   s     x $65$
  r'   c                (    [        XU5      U l        U $ )a  
Specifies a DO NOTHING action for ON CONFLICT clause.

The ``constraint`` and ``index_elements`` arguments
are optional, but only one of these can be specified.

:param constraint:
 The name of a unique or exclusion constraint on the table,
 or the constraint object itself if it has a .name attribute.

:param index_elements:
 A sequence consisting of string column names, :class:`_schema.Column`
 objects, or other column expression objects that will be used
 to infer a target index.

:param index_where:
 Additional WHERE criterion that can be used to infer a
 conditional target index.

.. seealso::

    :ref:`postgresql_insert_on_conflict`

)OnConflictDoNothingr1   )r/   r5   r6   r7   s       r&   on_conflict_do_nothingInsert.on_conflict_do_nothing   s    @ $7$
  r'   )r1   )returnz6ReadOnlyColumnCollection[str, KeyedColumnElement[Any]]NNNNN)r5   r   r6   r   r7   r   r8   r   r9   r   r@   r"   NNN)r5   r   r6   r   r7   r   r@   r"   )__name__
__module____qualname____firstlineno____doc__stringify_dialectinherit_cacher   memoized_propertyr,   r   _on_conflict_exclusiver   r:   r>   __static_attributes__ r'   r&   r   r   >   s    %M	:	?: :8 0! $0
  .248.2 $#'=*= 2= ,	=
 = != 
=  =~  .248.2	!*! 2! ,	!
 
!  !r'   c                  V    \ rS rSr% SrS\S'   S\S'   S\S'      S     SS
 jjrSrg	)OnConflictClause   r*   zOptional[str]constraint_targetz.Optional[List[Union[str, schema.Column[Any]]]]inferred_target_elementsz/Optional[Union[ColumnElement[Any], TextClause]]inferred_target_whereclauseNc                   UbY  [        U[        5      (       dD  [        U[        R                  [        R
                  45      (       a  [        US5      =(       d    UnUb  Ub  [        S5      e[        U[        5      (       a  Xl        S U l	        S U l
        O[        U[        R                  5      (       a+  UR                  nUR                  S   R                  S5      nOb[        U[        R
                  5      (       a  UR                  nUR                   nO*UR                  nUR                  S   R                  S5      nUb  S U l        U Vs/ s H(  n["        R$                  " [&        R(                  U5      PM*     snU l	        UbT  ["        R$                  " [        U[        R
                  5      (       a  [&        R*                  O[&        R,                  U5      OS U l
        g Uc  S =U l        =U l	        U l
        g g s  snf )Nr-   z8'constraint' and 'index_elements' are mutually exclusiver*   r9   )
isinstancestrr   
Constraintr
   ExcludeConstraintgetattr
ValueErrorrQ   rR   rS   Indexexpressionsdialect_optionsgetr.   r9   r   expectr   DDLConstraintColumnRoleStatementOptionRoleWhereHavingRole)r/   r5   r6   r7   columns        r&   __init__OnConflictClause.__init__   s    !j#..:""C$9$9:4 4 %Z8FJ
!) N  *c**)3&04-370J55!+!7!7(88FJJ J(=(=>>!+!3!3(..!+!3!3(88FJJ %%)D" --,F   !>!>G,-D) *    &j#2G2GHH 11"22  ,  D" T%B0  %-s   /H)rQ   rR   rS   rB   )r5   r   r6   r   r7   r   )rC   rD   rE   rF   rH   __annotations__rd   rL   rM   r'   r&   rO   rO      sO    $$$LL"  .248.2	<*< 2< ,	< <r'   rO   c                      \ rS rSrSrSrg)r=   i  r>   rM   N)rC   rD   rE   rF   __visit_name__rL   rM   r'   r&   r=   r=     s    -Nr'   r=   c                  f   ^  \ rS rSr% SrS\S'   S\S'        S	         S
U 4S jjjrSrU =r$ )r4   i#  r:   z0List[Tuple[Union[schema.Column[Any], str], Any]]update_values_to_setzOptional[ColumnElement[Any]]update_whereclausec                *  > [         TU ]  UUUS9  U R                  c  U R                  c  [	        S5      e[        U[        5      (       a  U(       d  [	        S5      eO,[        U[        5      (       a  [        U5      nO[	        S5      eUR                  5        VVs/ s H,  u  pg[        R                  " [        R                  U5      U4PM.     snnU l        Ub+  [        R                  " [        R                  U5      U l        g S U l        g s  snnf )N)r5   r6   r7   zVEither constraint or index_elements, but not both, must be specified unless DO NOTHINGz*set parameter dictionary must not be emptyzqset parameter must be a non-empty dictionary or a ColumnCollection such as the `.c.` collection of a Table object)superrd   rR   rQ   rZ   rU   dictr   itemsr   r_   r   DMLColumnRolerj   rb   rk   )	r/   r5   r6   r7   r8   r9   keyvalue	__class__s	           r&   rd   OnConflictDoUpdate.__init__)  s    	!)# 	 	
 ))1&&.D 
 dD!! !MNN .//:D$  #jjl%
*
 e1137?*%
!   U22E: 	  		%
s   3D)rj   rk   rA   )
r5   r   r6   r   r7   r   r8   r   r9   r   )	rC   rD   rE   rF   rh   rf   rd   rL   __classcell__)rs   s   @r&   r4   r4   #  s_    ,NJJ44 .248.2 $#'*
**
 2*
 ,	*

 *
 !*
 *
r'   r4   N)r%   r   r@   r   )-
__future__r   typingr   r   r   r   r    r
   _typingr   r   r   r   r   r   sqlr   r   r   sql._typingr   sql.baser   r   r   r   sql.dmlr   StandardInsertsql.elementsr   r   r   r    sql.expressionr!   util.typingr"   __all__r#   rO   r=   r4   rM   r'   r&   <module>r      s    #       , / , % '     , * # ( 0 / ) ) . & #  (V^ VrE} EP.* .0
) 0
r'   