o
    ?ÊÆhò   ã                   @  s6  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d„Z G dd„ deƒZG dd„ deƒZ!G d d!„ d!e!ƒZ"G d"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                 C  s   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   © r   úk/var/www/html/HyperOracle/crypto_trader/venv/lib/python3.10/site-packages/sqlalchemy/dialects/sqlite/dml.pyr       s   r   c                   @  sl   e Zd ZdZdZdZejddd„ƒZe	ddd	id
�Z
ee
				dddd„ƒƒZee
		d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                 C  s   t | jd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)Úselfr   r   r   r   G   s   zInsert.excludedÚ_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)ÚmsgsNÚindex_elementsr   Úindex_wherer   Úset_r   Úwherer   r   c                 C  s   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(   r   r   r   Úon_conflict_do_updateg   s   1ÿzInsert.on_conflict_do_updatec                 C  s   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&   r   r   r   Úon_conflict_do_nothing�   s   ÿzInsert.on_conflict_do_nothing)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+   r.   r   r   r   r   r   4   s.    ÿþû4ýc                   @  s:   e Zd ZU dZded< ded< ded< 		dddd„ZdS )ÚOnConflictClauser   ÚNoneÚconstraint_targetr   Úinferred_target_elementsr   Úinferred_target_whereclauseNr%   r&   c                 C  s4   |d urd | _ || _|| _d S d  | _  | _| _d S )N)r;   r<   r=   r-   r   r   r   Ú__init__¿   s   
þzOnConflictClause.__init__r0   )r%   r   r&   r   )r1   r2   r3   r5   Ú__annotations__r>   r   r   r   r   r9   ¸   s   
 ýr9   c                   @  s   e Zd ZdZdS )r,   r.   N)r1   r2   r3   Ú__visit_name__r   r   r   r   r,   Î   s    r,   c                      s,   e Zd ZdZ				dd‡ fdd„Z‡  ZS )r)   r+   Nr%   r   r&   r   r'   r   r(   r   c                   sb   t ƒ j||d� t|tƒr|stdƒ‚nt|tƒrt|ƒ}ntdƒ‚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                 S  s"   g | ]\}}t  tj|¡|f‘qS r   )r   Úexpectr   ÚDMLColumnRole)Ú.0ÚkeyÚvaluer   r   r   Ú
<listcomp>ì   s    ÿÿz/OnConflictDoUpdate.__init__.<locals>.<listcomp>)	Úsuperr>   Ú
isinstanceÚdictÚ
ValueErrorr   ÚitemsÚupdate_values_to_setÚupdate_whereclauser*   ©Ú	__class__r   r   r>   Õ   s"   þ
ÿ

ÿþ
zOnConflictDoUpdate.__init__r/   )r%   r   r&   r   r'   r   r(   r   )r1   r2   r3   r@   r>   Ú__classcell__r   r   rN   r   r)   Ò   s    û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   r9   r,   r)   r   r   r   r   Ú<module>   s4   
 