U
|
¸ý°d( ã @ sà d dl mZ ddl mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z dd lm
|
Z
|
dd
|
l m Z dd lmZ dd lmZ dd lmZ dZdd ZG dd de Z G dd deZG dd deZG dd deZdS )é )Úexté )Úutil)Ú coercions)Úroles)Úschema)Ú_exclusive_against)Ú _generative)ÚColumnCollection©ÚInsert)Ú ClauseElement)Úalias)ÚSelf)r Úinsertc C s t | S )as Construct a PostgreSQL-specific variant :class:`_postgresql.Insert`
|
construct.
|
|
.. container:: inherited_member
|
|
The :func:`sqlalchemy.dialects.postgresql.insert` function creates
|
a :class:`sqlalchemy.dialects.postgresql.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:`_postgresql.Insert` construct includes additional methods
|
:meth:`_postgresql.Insert.on_conflict_do_update`,
|
:meth:`_postgresql.Insert.on_conflict_do_nothing`.
|
|
r )Útable© r úYd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/dialects/postgresql/dml.pyr s r c @ sf e Zd ZdZdZdZejdd Ze dddidZ
|
e e
|
de d
|
d d Z e e
|
de d
|
d dZd S )r zð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.
|
|
Ú
|
postgresqlFc C s t | jddjS )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 r Úcolumns)Úselfr r r r ; s zInsert.excludedÚ_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)ZmsgsN)Úreturnc C s t |||||| _| 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).
|
|
|
.. seealso::
|
|
:ref:`postgresql_insert_on_conflict`
|
|
)ÚOnConflictDoUpdater ©r Ú
|
constraintÚindex_elementsÚ index_whereÚset_Úwherer r r Úon_conflict_do_update^ s = ÿz Insert.on_conflict_do_updatec C s t |||| _| 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.
|
|
.. seealso::
|
|
:ref:`postgresql_insert_on_conflict`
|
|
)Ú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 Zmemoized_propertyr r Z_on_conflict_exclusiver r r" r% r r r r r . s:
|
ÿþ úù@ üûr c @ s e Zd ZdZdddZdS )ÚOnConflictClauser Nc C sö |d k r2t |ts2t |tjtjfr2t|dp0|}|d k r¼|d k rJtdt |trh|| _d | _ d | _
|
nTt |tj r|j }|j d d¡}n0t |tjr¦|j}|j}n|j}|j d d¡}|d k rØd | _|| _ || _
|
n|d kròd | _ | _ | _
|
d S )Nr z8'constraint' and 'index_elements' are mutually exclusiver r! )Ú
|
isinstanceÚstrr Z
|
Constraintr ZExcludeConstraintÚgetattrÚ
|
ValueErrorÚconstraint_targetÚinferred_target_elementsZinferred_target_whereclauseZIndexZ expressionsZdialect_optionsÚgetr r! r$ r r r Ú__init__É sJ
|
þÿ
|
|
ÿ
|
ÿþþzOnConflictClause.__init__)NNN)r& r' r( r* r3 r r r r r+ Æ s r+ c @ s e Zd ZdZdS )r# r% N)r& r' r( Ú__visit_name__r r r r r# ô s r# c s" e Zd ZdZd fdd Z ZS )r r" Nc s t j|||d | jd kr.| jd kr.tdt|trF|sbtdn t|trZt|}ntddd | ¡ 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 tj|¡|fqS r )r Úexpectr Z DMLColumnRole)Ú.0ÚkeyÚvaluer r r Ú
|
<listcomp> s ÿz/OnConflictDoUpdate.__init__.<locals>.<listcomp>) Úsuperr3 r1 r0 r/ r, Údictr
|
ÚitemsZupdate_values_to_setZupdate_whereclauser ©Ú __class__r r r3 û s0 ýÿþÿ
|
|
|
|
ÿþzOnConflictDoUpdate.__init__)NNNNN)r& r' r( r4 r3 Ú __classcell__r r r= r r ø s úr N)Ú r r Zsqlr r r Zsql.baser r r
|
Zsql.dmlr ZStandardInsertZ sql.elementsr Zsql.expressionr Z util.typingr Ú__all__r r+ r# r r r r r Ú<module> s$ .
|
