U yc@sddlZddlmZddlmZddlmZddlmZddlmZddlm Z dd l m Z dd l mZdd lmZd Zd dZejdddZGddde Z GdddeZGdddeZGdddeZdS)N)util) coercions)roles)_exclusive_against) _generative)ColumnCollectionInsert) ClauseElement)alias)r insertcCst|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 )tablerk/var/www/sbouman/reportbro-server-tornado/env/lib/python3.8/site-packages/sqlalchemy/dialects/sqlite/dml.pyr sr SelfInsertr )boundc@sjeZdZdZdZdZejddZe dddidZ e e de e d d d Z e e de e d d dZd 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` sqliteFcCst|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)r rcolumns)selfrrrrCszInsert.excluded_post_values_clausezCThis Insert construct already has an ON CONFLICT clause established)ZmsgsN)rreturncCst|||||_|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). )OnConflictDoUpdaterrindex_elements index_whereset_whererrron_conflict_do_updateas1zInsert.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. )OnConflictDoNothingrrrrrrron_conflict_do_nothings zInsert.on_conflict_do_nothing)NNNN)NN)__name__ __module__ __qualname____doc__stringify_dialectZ inherit_cacherZmemoized_propertyrrZ_on_conflict_exclusiverrr r#rrrrr 0s: 4c@seZdZdZdddZdS)OnConflictClauserNcCs2|dk rd|_||_||_nd|_|_|_dS)N)Zconstraint_targetZinferred_target_elementsZinferred_target_whereclauser"rrr__init__szOnConflictClause.__init__)NN)r$r%r&r(r*rrrrr)sr)c@seZdZdZdS)r!r#N)r$r%r&__visit_name__rrrrr!sr!cs"eZdZdZdfdd ZZS)rr Ncsbtj||dt|tr(|sDtdnt|trsz/OnConflictDoUpdate.__init__..) superr* isinstancedict ValueErrorritemsZupdate_values_to_setZupdate_whereclauser __class__rrr*s     zOnConflictDoUpdate.__init__)NNNN)r$r%r&r+r* __classcell__rrr6rrs r)typingrsqlrrZsql.baserrrZsql.dmlr ZStandardInsertZ sql.elementsr Zsql.expressionr __all__r TypeVarrr)r!rrrrr s"