Ng+ddlmZddlmZddlmZddlmZddlmZddlm Z dd lm Z dd lm Z dd lm Z d d lm Z d dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlm Z d dl!m"Z"dZ#d)d Z$Gd!deZGd"d#eZ%Gd$d%e%Z&Gd&d'e%Z'd(S)*) annotations)Any)Optional)ext)_OnConflictConstraintT)_OnConflictIndexElementsT)_OnConflictIndexWhereT)_OnConflictSetT)_OnConflictWhereT)util) coercions)roles)schema)_DMLTableArgument)_exclusive_against) _generative)ColumnCollection)ReadOnlyColumnCollectionInsert) ClauseElement)KeyedColumnElement)alias)Self)rinserttablerreturnrc t|S)asConstruct 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)rs ^/var/www/html/ai-engine/env/lib/python3.11/site-packages/sqlalchemy/dialects/postgresql/dml.pyrr%s" %==ceZdZdZdZdZejddZe dddi Z e e dddZ e e dddZ d S)rzPostgreSQL-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. postgresqlFr 6ReadOnlyColumnCollection[str, KeyedColumnElement[Any]]c8t|jdjS)akProvide 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)rrcolumns)selfs r"r(zInsert.excludedFs6TZj11199r#_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)msgsN constraintr index_elementsr index_wherer set_r wherer rc6t||||||_|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+r.r/r0r1r2s r"on_conflict_do_updatezInsert.on_conflict_do_updateks)z$6  T5$ $   r#c2t||||_|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/r0s r"on_conflict_do_nothingzInsert.on_conflict_do_nothings%@$7  $ $   r#)r r&NNNNN) r.r r/r r0r r1r r2r r rNNN)r.r r/r r0r r r)__name__ __module__ __qualname____doc__stringify_dialect inherit_cachermemoized_propertyr(r_on_conflict_exclusiverr5r9r#r"rr9s%M ::::80/ !$0 .248.2 $#' >>>>[>@.248.2 !!!![!!!r#cBeZdZUdZded<ded<ded< ddd ZdS)OnConflictClauser%z Optional[str]constraint_targetr inferred_target_elementsr inferred_target_whereclauseNr.r r/r0c|Mt|ts8t|tjtjfrt |dp|}||tdt|tr||_d|_ d|_ nt|tj r(|j }|j dd}nPt|tjr|j}|j}n'|j}|j dd}|d|_||_ ||_ dS|dx|_x|_ |_ dSdS)Nr)z8'constraint' and 'index_elements' are mutually exclusiver%r2) isinstancestrr ConstraintrExcludeConstraintgetattr ValueErrorrGrHrIIndex expressionsdialect_optionsgetr*r2r8s r"__init__zOnConflictClause.__init__s  !j#.. G:"C$9:44 G%Z88FJ  !) N*c** )3&04-3700J 55 !+!7(8FJJ J(=>> !+!3(. !+!3(8FJJ   %%)D ",:D )/:D , , ,   D " T%B000 r#r;)r.r r/r r0r )r<r=r>r@__annotations__rUrDr#r"rFrFsd$$$$$77777777.248.2 ,,,,,,,r#rFceZdZdZdS)r7r9N)r<r=r>__visit_name__rDr#r"r7r7 s-NNNr#r7c0eZdZdZ ddfd ZxZS)r4r5Nr.r r/r r0r r1r r2r ct||||j|jt dt |t r|st dn4t |trt |}nt dd|D|_ ||_ dS)N)r.r/r0zVEither 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 objectcVg|]&\}}tjtj||f'SrD)rexpectr DMLColumnRole).0keyvalues r" z/OnConflictDoUpdate.__init__..2sA% % % U e13 7 7 ?% % % r#) superrUrHrGrPrKdictritemsupdate_values_to_setupdate_whereclause)r+r.r/r0r1r2 __class__s r"rUzOnConflictDoUpdate.__init__s !)#      ) 1&.D  dD ! !  O !MNNN O . / / ::DD$  % % "jjll% % % !#(r#r:) r.r r/r r0r r1r r2r )r<r=r>rXrU __classcell__)rgs@r"r4r4 sX,N.248.2 $#' &(&(&(&(&(&(&(&(&(&(&(r#r4N)rrr r)( __future__rtypingrrr_typingr r r r r rsqlrrr sql._typingrsql.baserrrrsql.dmlrStandardInsert sql.elementsrrsql.expressionr util.typingr__all__rrFr7r4rDr#r"rvs~#""""",,,,,,//////,,,,,,%%%%%%'''''',,,,,,******######((((((000000//////))))))......###### (WWWWW^WWWt33333}333l.....*...)()()()()())()()()()(r#