
    )f                     L   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   )_OnConflictIndexElementsT)_OnConflictIndexWhereT)_OnConflictSetT)_OnConflictWhereT   )util)	coercions)roles)_DMLTableArgument)_exclusive_against)_generative)ColumnCollection)ReadOnlyColumnCollectionInsert)ClauseElement)KeyedColumnElement)alias)Self)r   insertr   c                    t        |       S )aW  Construct a sqlite-specific variant :class:`_sqlite.Insert`
    construct.

    .. container:: inherited_member

        The :func:`sqlalchemy.dialects.sqlite.insert` function creates
        a :class:`sqlalchemy.dialects.sqlite.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:`_sqlite.Insert` construct includes additional methods
    :meth:`_sqlite.Insert.on_conflict_do_update`,
    :meth:`_sqlite.Insert.on_conflict_do_nothing`.

    r   )tables    [/var/www/html/flask-app/venv/lib/python3.12/site-packages/sqlalchemy/dialects/sqlite/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   a?  SQLite-specific implementation of INSERT.

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

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

    .. versionadded:: 1.4

    .. seealso::

        :ref:`sqlite_on_conflict_insert`

    sqliteFc                D    t        | j                  d      j                  S )a  Provide the ``excluded`` namespace for an ON CONFLICT statement

        SQLite'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:`_sqlite.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.

        excluded)name)r   r   columns)selfs    r   r!   zInsert.excludedG   s    , TZZj1999r   _post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)msgsNc                ,    t        ||||      | _        | S )a  
        Specifies a DO UPDATE SET action for ON CONFLICT clause.

        :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 or unique constraint.

        :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:`_sqlite.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).

        )OnConflictDoUpdater%   )r$   index_elementsindex_whereset_wheres        r   on_conflict_do_updatezInsert.on_conflict_do_updateg   s"    b $6Ku$
  r   c                (    t        ||      | _        | S )a  
        Specifies a DO NOTHING action for ON CONFLICT clause.

        :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 or unique constraint.

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

        )OnConflictDoNothingr%   r$   r)   r*   s      r   on_conflict_do_nothingzInsert.on_conflict_do_nothing   s    * $7K$
  r   )returnz6ReadOnlyColumnCollection[str, KeyedColumnElement[Any]]NNNN)
r)   r   r*   r   r+   r   r,   r	   r2   r   NN)r)   r   r*   r   r2   r   )__name__
__module____qualname____doc__stringify_dialectinherit_cacher   memoized_propertyr!   r   _on_conflict_exclusiver   r-   r1    r   r   r   r   4   s     !M	:	?: :. 0! $0
  59.2 $#'212 ,2 	2
 !2 
2  2h  59.21 , 
	  r   c                  D    e Zd ZU dZded<   ded<   ded<   	 	 d
	 	 	 dd	Zy)OnConflictClauser   Noneconstraint_targetr   inferred_target_elementsr   inferred_target_whereclauseNc                ^    |d | _         || _        || _        y d x| _         x| _        | _        y )N)rA   rB   rC   r0   s      r   __init__zOnConflictClause.__init__   sA    
 %%)D",:D)/:D, D" T%B0r   r4   )r)   r   r*   r   )r5   r6   r7   r9   __annotations__rE   r=   r   r   r?   r?      s9     77!77 59.21 ,r   r?   c                      e Zd ZdZy)r/   r1   N)r5   r6   r7   __visit_name__r=   r   r   r/   r/      s    -Nr   r/   c                  <     e Zd ZdZ	 	 	 	 d	 	 	 	 	 	 	 d fdZ xZS )r(   r-   c                b   t         |   ||       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*   z*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)superrE   
isinstancedict
ValueErrorr   itemsr   expectr   DMLColumnRoleupdate_values_to_setupdate_whereclause)r$   r)   r*   r+   r,   keyvalue	__class__s          r   rE   zOnConflictDoUpdate.__init__   s     	)# 	 	

 dD! !MNN./:D$  #jjl%
U e1137?%
! #(	%
s   *0B+r3   )r)   r   r*   r   r+   r   r,   r	   )r5   r6   r7   rH   rE   __classcell__)rV   s   @r   r(   r(      sF    ,N 59.2 $#'(1( ,( 	(
 !( (r   r(   N)r   r   r2   r   )$
__future__r   typingr   _typingr   r   r   r	    r   sqlr   r   sql._typingr   sql.baser   r   r   r   sql.dmlr   StandardInsertsql.elementsr   r   sql.expressionr   util.typingr   __all__r   r?   r/   r(   r=   r   r   <module>re      s    #  / , % '    , * # ( 0 / ) . # 
(A^ AH} ,.* .() (r   