
    )f+                    |   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Z#d&dZ$ G d de      Z G d d e      Z% G d! d"e%      Z& G d# d$e%      Z'y%)'    )annotations)Any)Optional   )ext   )_OnConflictConstraintT)_OnConflictIndexElementsT)_OnConflictIndexWhereT)_OnConflictSetT)_OnConflictWhereT   )util)	coercions)roles)schema)_DMLTableArgument)_exclusive_against)_generative)ColumnCollection)ReadOnlyColumnCollectionInsert)ClauseElement)KeyedColumnElement)alias)Self)r   insertr   c                    t        |       S )as  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    _/var/www/html/flask-app/venv/lib/python3.12/site-packages/sqlalchemy/dialects/postgresql/dml.pyr   r   %   s    " %=    c                      e Zd ZdZdZdZej                  	 	 dd       Z e	dddi      Z
ee
	 	 	 	 	 d	 	 	 	 	 	 	 	 	 	 	 dd	              Zee
	 	 	 d	 	 	 	 	 	 	 dd
              Zy)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                D    t        | j                  d      j                  S )ak  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&   zInsert.excludedF   s    6 TZZj1999r"   _post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)msgsNc                .    t        |||||      | _        | S )aS  
        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. If present, can be a literal SQL
         string or an acceptable expression for 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`

        )OnConflictDoUpdater*   )r)   
constraintindex_elementsindex_whereset_wheres         r!   on_conflict_do_updatezInsert.on_conflict_do_updatek   s$    z $6T5$
  r"   c                *    t        |||      | _        | S )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`

        )OnConflictDoNothingr*   r)   r.   r/   r0   s       r!   on_conflict_do_nothingzInsert.on_conflict_do_nothing   s     @ $7$
  r"   )returnz6ReadOnlyColumnCollection[str, KeyedColumnElement[Any]]NNNNN)r.   r	   r/   r
   r0   r   r1   r   r2   r   r8   r   NNN)r.   r	   r/   r
   r0   r   r8   r   )__name__
__module____qualname____doc__stringify_dialectinherit_cacher   memoized_propertyr&   r   _on_conflict_exclusiver   r3   r7    r"   r!   r   r   9   s    %M	:	?: :8 0! $0
  .248.2 $#'>*> 2> ,	>
 > !> 
>  >@  .248.2	!*! 2! ,	!
 
!  !r"   c                  J    e Zd ZU dZded<   ded<   ded<   	 	 	 d
	 	 	 	 	 dd	Zy)OnConflictClauser$   zOptional[str]constraint_targetr
   inferred_target_elementsr   inferred_target_whereclauseNc                   |Jt        |t              s:t        |t        j                  t        j
                  f      rt        |d      xs |}||t        d      t        |t              r|| _        d | _	        d | _
        nt        |t        j                        r+|j                  }|j                  d   j                  d      }n]t        |t        j
                        r|j                  }|j                   }n*|j                  }|j                  d   j                  d      }|d | _        || _	        || _
        y |d x| _        x| _	        | _
        y y )Nr'   z8'constraint' and 'index_elements' are mutually exclusiver$   r2   )
isinstancestrr   
Constraintr   ExcludeConstraintgetattr
ValueErrorrF   rG   rH   Indexexpressionsdialect_optionsgetr(   r2   r6   s       r!   __init__zOnConflictClause.__init__   sW    !j#.:""C$9$9:4 %Z8FJ
!) N  *c*)3&04-370J5!+!7!7(88FJJ J(=(=>!+!3!3(..!+!3!3(88FJJ %%)D",:D)/:D, D" T%B0  r"   r:   )r.   r	   r/   r
   r0   r   )r;   r<   r=   r?   __annotations__rT   rC   r"   r!   rE   rE      sF    $$$77!77 .248.2	,*, 2, ,	,r"   rE   c                      e Zd ZdZy)r5   r7   N)r;   r<   r=   __visit_name__rC   r"   r!   r5   r5   	  s    -Nr"   r5   c                  B     e Zd ZdZ	 	 	 	 	 d	 	 	 	 	 	 	 	 	 d fdZ xZS )r-   r3   c                   t         |   |||       | j                  | j                  t	        d      t        |t              r|s2t	        d      t        |t              rt        |      }nt	        d      |j                         D cg c]+  \  }}t        j                  t        j                  |      |f- c}}| _        || _        y c c}}w )N)r.   r/   r0   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)superrT   rG   rF   rO   rJ   dictr   itemsr   expectr   DMLColumnRoleupdate_values_to_setupdate_whereclause)	r)   r.   r/   r0   r1   r2   keyvalue	__class__s	           r!   rT   zOnConflictDoUpdate.__init__  s     	!)# 	 	
 ))1&&.D 
 dD! !MNN./:D$  #jjl%
U e1137?%
! #(	%
s   0Cr9   )
r.   r	   r/   r
   r0   r   r1   r   r2   r   )r;   r<   r=   rW   rT   __classcell__)rc   s   @r!   r-   r-     sS    ,N .248.2 $#'&(*&( 2&( ,	&(
 &( !&( &(r"   r-   N)r    r   r8   r   )(
__future__r   typingr   r    r   _typingr	   r
   r   r   r   r   sqlr   r   r   sql._typingr   sql.baser   r   r   r   sql.dmlr   StandardInsertsql.elementsr   r   sql.expressionr   util.typingr   __all__r   rE   r5   r-   rC   r"   r!   <module>rr      s    #    , / , % '     , * # ( 0 / ) . #  (W^ Wt3} 3l.* .)() )(r"   