U
    ÌZjn%  ã                   @   sä   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G dd„ deƒZeeddƒZG dd„ deƒZG dd„ deƒZG dd„ deƒZdS )é   )Úexté   )Úutil)Ú	coercions)Úroles)Úschema)Ú_exclusive_against)Ú_generative)ÚColumnCollection)ÚInsert)ÚClauseElement)Úalias)Úpublic_factory)r   Úinsertc                   @   sZ   e Zd ZdZdZdZejdd„ ƒZe	dddid�Z
ee
dd
d„ƒƒZee
ddd„ƒƒZd	S )r   a  PostgreSQL-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.

    .. versionadded:: 1.1

    Ú
postgresqlFc                 C   s   t | jd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   ÚtableÚcolumns)Úself© r   úe/var/www/html/TRUCKING_PROJECT/venv/lib/python3.8/site-packages/sqlalchemy/dialects/postgresql/dml.pyr   (   s    zInsert.excludedÚ_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)ZmsgsNc                 C   s   t |||||ƒ| _d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).

         .. versionadded:: 1.1


        .. seealso::

            :ref:`postgresql_insert_on_conflict`

        N)ÚOnConflictDoUpdater   ©r   Ú
constraintÚindex_elementsÚindex_whereÚset_Úwherer   r   r   Úon_conflict_do_updateK   s    ?    ÿzInsert.on_conflict_do_updatec                 C   s   t |||ƒ| _d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.

         .. versionadded:: 1.1

        .. seealso::

            :ref:`postgresql_insert_on_conflict`

        N)ÚOnConflictDoNothingr   ©r   r   r   r   r   r   r   Úon_conflict_do_nothingŽ   s
      ÿzInsert.on_conflict_do_nothing)NNNNN)NNN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ústringify_dialectZinherit_cacher   Zmemoized_propertyr   r   Z_on_conflict_exclusiver	   r    r#   r   r   r   r   r      s2   
 ÿþ     úA     ÿr   z.dialects.postgresql.insertz.dialects.postgresql.Insertc                   @   s   e Zd ZdZddd„ZdS )ÚOnConflictClauser   Nc                 C   sþ   |d k	r8t |tjƒs8t |tjtjtjfƒr8t|dƒp6|}|d k	rÄ|d k	rPt	dƒ‚t |tjƒrp|| _
d | _d | _nTt |tjƒr”|j}|jd  d¡}n0t |tjƒr®|j}|j}n|j}|jd  d¡}|d k	ràd | _
|| _|| _n|d krúd  | _
 | _| _d S )Nr   z8'constraint' and 'index_elements' are mutually exclusiver   r   )Ú
isinstancer   Ústring_typesr   ÚIndexÚ
Constraintr   ZExcludeConstraintÚgetattrÚ
ValueErrorÚconstraint_targetÚinferred_target_elementsZinferred_target_whereclauseZexpressionsZdialect_optionsÚgetr   r   r"   r   r   r   Ú__init__º   sJ    þÿ
ÿ
ÿþþzOnConflictClause.__init__)NNN)r$   r%   r&   r(   r3   r   r   r   r   r)   ·   s   r)   c                   @   s   e Zd ZdZdS )r!   r#   N)r$   r%   r&   Ú__visit_name__r   r   r   r   r!   å   s   r!   c                       s"   e Zd ZdZd‡ fdd„	Z‡  ZS )r   r    Nc                    s„   t t| ƒj|||d� | jd kr2| jd kr2tdƒ‚t|tƒrJ|sftdƒ‚nt|tƒr^t|ƒ}ntdƒ‚dd„ | 	¡ D ƒ| _
|| _d S )N)r   r   r   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 objectc                 S   s"   g | ]\}}t  tj|¡|f‘qS r   )r   Úexpectr   ZDMLColumnRole)Ú.0ÚkeyÚvaluer   r   r   Ú
<listcomp>  s   ÿz/OnConflictDoUpdate.__init__.<locals>.<listcomp>)Úsuperr   r3   r1   r0   r/   r*   Údictr
   ÚitemsZupdate_values_to_setZupdate_whereclauser   ©Ú	__class__r   r   r3   ì   s0    
ýÿþÿ



ÿþzOnConflictDoUpdate.__init__)NNNNN)r$   r%   r&   r4   r3   Ú__classcell__r   r   r=   r   r   é   s        úr   N)Ú r   r   Úsqlr   r   r   Zsql.baser   r	   r
   Zsql.dmlr   ZStandardInsertZsql.elementsr   Zsql.expressionr   Zutil.langhelpersr   Ú__all__r   r)   r!   r   r   r   r   r   Ú<module>   s,      ÿ.