o XJ@h#@sddlmZddlmZddlmZddlmZddlmZddlmZddlm Z dd lm Z dd lm Z dd lm Z d d l mZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlmZd dlm Z d dlm!Z!d dl"m#Z#d dl$m%Z%dZ&d,d"d#Z'Gd$d!d!eZGd%d&d&eZ(Gd'd(d(e(Z)Gd)d*d*e(Z*d+S)-) annotations)Any)List)Optional)Tuple)Union)_OnConflictIndexElementsT)_OnConflictIndexWhereT)_OnConflictSetT)_OnConflictWhereT)util) coercions)roles)schema)_DMLTableArgument)_exclusive_against) _generative)ColumnCollection)ReadOnlyColumnCollectionInsert) ClauseElement) ColumnElement)KeyedColumnElement) TextClause)alias)Self)rinserttablerreturnrcCst|S)aWConstruct 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"Q/var/www/html/venv/lib/python3.10/site-packages/sqlalchemy/dialects/sqlite/dml.pyr'src@sleZdZdZdZdZejdddZe ddd id Z e e ddddZ e e ddddZ d S)ra?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]]cCst|jddjS)aProvide 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)rr columns)selfr"r"r#r&NszInsert.excluded_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)ZmsgsNindex_elementsr index_wherer set_r wherer rcCst|||||_|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. An expression object representing 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_updatens0zInsert.on_conflict_do_updatecCst|||_|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_nothingszInsert.on_conflict_do_nothing)r!r%NNNN) r+r r,r r-r r.r r!rNN)r+r r,r r!r)__name__ __module__ __qualname____doc__stringify_dialectZ inherit_cacherZmemoized_propertyr&rZ_on_conflict_exclusiverr1r4r"r"r"r#r;s. 3c@s2eZdZUdZded<ded<  d dd d ZdS)OnConflictClauser$z.Optional[List[Union[str, schema.Column[Any]]]]inferred_target_elementsz/Optional[Union[ColumnElement[Any], TextClause]]inferred_target_whereclauseNr+r r,r cCsN|durdd|D|_|durttj||_dSd|_dSd|_|_dS)NcSsg|] }ttj|qSr")rexpectrZDDLConstraintColumnRole).0columnr"r"r# s z-OnConflictClause.__init__..)r=rr?rWhereHavingRoler>r3r"r"r#__init__s  zOnConflictClause.__init__r6)r+r r,r )r7r8r9r;__annotations__rDr"r"r"r#r<s r<c@seZdZdZdS)r2r4N)r7r8r9__visit_name__r"r"r"r#r2sr2cs>eZdZUdZded<ded<    ddfdd ZZS)r/r1z0List[Tuple[Union[schema.Column[Any], str], Any]]update_values_to_setzOptional[ColumnElement[Any]]update_whereclauseNr+r r,r r-r r.r cs~tj||dt|tr|stdnt|trt|}ntddd|D|_|dur:t t j ||_ dSd|_ dS)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 objectcSs"g|] \}}ttj||fqSr")rr?rZ DMLColumnRole)r@keyvaluer"r"r#rBsz/OnConflictDoUpdate.__init__..) superrD isinstancedict ValueErrorritemsrGrr?rrCrHr0 __class__r"r#rDs*    zOnConflictDoUpdate.__init__r5)r+r r,r r-r r.r )r7r8r9rFrErD __classcell__r"r"rPr#r/s r/N)r rr!r)+ __future__rtypingrrrrrZ_typingr r r r rsqlrrrZ sql._typingrZsql.baserrrrZsql.dmlrZStandardInsertZ sql.elementsrrrrZsql.expressionrZ util.typingr__all__rr<r2r/r"r"r"r#sB