
    +h                         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 G d de      Z
 ee
dd      Z G d de      Z G d de      Z G d de      Zy)   )util)	coercions)roles)_exclusive_against)_generative)ColumnCollection)Insert)ClauseElement)alias)public_factory)r	   insertc                       e Zd ZdZdZdZej                  d        Z e	dddi      Z
ee
	 	 	 	 dd	              Zee
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   tablecolumns)selfs    Q/var/www/html/venv/lib/python3.12/site-packages/sqlalchemy/dialects/sqlite/dml.pyr   zInsert.excluded)   s    ( TZZj1999    _post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)msgsNc                 *    t        ||||      | _        y)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).

        N)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        ||      | _        y)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.

        N)OnConflictDoNothingr   r   r   r   s      r   on_conflict_do_nothingzInsert.on_conflict_do_nothing|   s    " $7K$
 r   NNNNNN)__name__
__module____qualname____doc__stringify_dialectinherit_cacher   memoized_propertyr   r   _on_conflict_exclusiver   r    r$    r   r   r	   r	      s     !M	: :* 0! $0
  1
  1
f 
  
r   r	   z.dialects.sqlite.insertz.dialects.sqlite.Insertc                       e Zd ZdZddZy)OnConflictClauser   Nc                 ^    |d | _         || _        || _        y d x| _         x| _        | _        y )N)constraint_targetinferred_target_elementsinferred_target_whereclauser#   s      r   __init__zOnConflictClause.__init__   s@    %%)D",:D)/:D, 488D" 8-0r   r&   )r'   r(   r)   r+   r6   r/   r   r   r1   r1      s     	8r   r1   c                       e Zd ZdZy)r"   r$   N)r'   r(   r)   __visit_name__r/   r   r   r"   r"      s    -Nr   r"   c                   ,     e Zd ZdZ	 	 	 	 d fd	Z xZS )r   r    c                 j   t         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)superr   r6   
isinstancedict
ValueErrorr   itemsr   expectr   DMLColumnRoleupdate_values_to_setupdate_whereclause)r   r   r   r   r   keyvalue	__class__s          r   r6   zOnConflictDoUpdate.__init__   s     	 $0)# 	1 	

 dD! !MNN./:D$  #jjl%
U e1137?%
! #(	%
s   .0B/r%   )r'   r(   r)   r8   r6   __classcell__)rF   s   @r   r   r      s     ,N ( (r   r   N) r   sqlr   r   sql.baser   r   r   sql.dmlr	   StandardInsertsql.elementsr
   sql.expressionr   util.langhelpersr   __all__r   r1   r"   r   r/   r   r   <module>rQ      sv       * # ( / ) # . y
^ y
x 

%'@

8} 8.* .() (r   