
    Ng                     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Zd$dZ  G d de          Z G d de          Z! G d d e!          Z" G d! d"e!          Z#d#S )%    )annotations)Any   )_OnConflictIndexElementsT)_OnConflictIndexWhereT)_OnConflictSetT)_OnConflictWhereT   )util)	coercions)roles)_DMLTableArgument)_exclusive_against)_generative)ColumnCollection)ReadOnlyColumnCollectionInsert)ClauseElement)KeyedColumnElement)alias)Self)r   inserttabler   returnr   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   )r   s    Z/var/www/html/ai-engine/env/lib/python3.11/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d
S )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`

    sqliteFr   6ReadOnlyColumnCollection[str, KeyedColumnElement[Any]]c                8    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    , TZj11199r   _post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)msgsNindex_elementsr   index_wherer   set_r   wherer	   r   c                4    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&   r)   r*   r+   r,   s        r   on_conflict_do_updatezInsert.on_conflict_do_updateg   s'    b $6Ku$
 $
  r   c                0    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   )r   r!   NNNN)
r)   r   r*   r   r+   r   r,   r	   r   r   NN)r)   r   r*   r   r   r   )__name__
__module____qualname____doc__stringify_dialectinherit_cacher   memoized_propertyr#   r   _on_conflict_exclusiver   r/   r3    r   r   r   r   4   s          !M	: : : :. 0/! $0
    59.2 $#'2 2 2 2  [2h  59.2     [  r   c                  @    e Zd ZU dZded<   ded<   ded<   	 	 dddZdS )OnConflictClauser    Noneconstraint_targetr   inferred_target_elementsr   inferred_target_whereclauseNr)   r*   c                b    |d | _         || _        || _        d S d x| _         x| _        | _        d S )N)rB   rC   rD   r2   s      r   __init__zOnConflictClause.__init__   sM    
 %%)D",:D)/:D,,, D" T%B000r   r5   )r)   r   r*   r   )r6   r7   r8   r:   __annotations__rF   r>   r   r   r@   r@      sa          77777777 59.2      r   r@   c                      e Zd ZdZdS )r1   r3   N)r6   r7   r8   __visit_name__r>   r   r   r1   r1      s        -NNNr   r1   c                  .     e Zd ZdZ	 	 	 	 dd fdZ xZS )r.   r/   Nr)   r   r*   r   r+   r   r,   r	   c                X   t                                          ||           t          |t                    r|st	          d          n4t          |t
                    rt          |          }nt	          d          d |                                D             | _        || _        d S )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 objectc                V    g | ]&\  }}t          j        t          j        |          |f'S r>   )r   expectr   DMLColumnRole).0keyvalues      r   
<listcomp>z/OnConflictDoUpdate.__init__.<locals>.<listcomp>   sA     %
 %
 %
U e1377?%
 %
 %
r   )	superrF   
isinstancedict
ValueErrorr   itemsupdate_values_to_setupdate_whereclause)r&   r)   r*   r+   r,   	__class__s        r   rF   zOnConflictDoUpdate.__init__   s     	)# 	 	
 	
 	

 dD!! 
	 O !MNNNO.// 	::DD$  
%
 %
"jjll%
 %
 %
! #(r   r4   )r)   r   r*   r   r+   r   r,   r	   )r6   r7   r8   rI   rF   __classcell__)rZ   s   @r   r.   r.      sU        ,N 59.2 $#'( ( ( ( ( ( ( ( ( ( (r   r.   N)r   r   r   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@   r1   r.   r>   r   r   <module>ri      s3   # " " " " "       / / / / / / , , , , , , % % % % % % ' ' ' ' ' '                   , , , , , , * * * * * * # # # # # # ( ( ( ( ( ( 0 0 0 0 0 0 / / / / / / ) ) ) ) ) ) . . . . . . # # # # # #      
   (A A A A A^ A A AH    }   ,. . . . .* . . .( ( ( ( () ( ( ( ( (r   