MERGE INTO

Применимо к: Databricks SQL Databricks Runtime

Объединяет набор обновлений, вставок и удалений из исходной таблицы в целевую таблицу Delta.

Это утверждение поддерживается только для таблиц Delta Lake.

Эта страница содержит сведения об использовании правильного синтаксиса с командой MERGE . Для получения дополнительной информации об использовании операций для управления данными см. MERGE.

Синтаксис

[ common_table_expression ]
  MERGE [ WITH SCHEMA EVOLUTION ] INTO target_table_name [target_alias]
     USING source_table_reference [source_alias]
     ON merge_condition
     { WHEN MATCHED [ AND matched_condition ] THEN matched_action |
       WHEN NOT MATCHED [BY TARGET] [ AND not_matched_condition ] THEN not_matched_action |
       WHEN NOT MATCHED BY SOURCE [ AND not_matched_by_source_condition ] THEN not_matched_by_source_action } [...]

matched_action
 { DELETE |
   UPDATE SET * |
   UPDATE SET { column = { expr | DEFAULT } } [, ...] }

not_matched_action
 { INSERT * |
   INSERT (column1 [, ...] ) VALUES ( expr | DEFAULT ] [, ...] )

not_matched_by_source_action
 { DELETE |
   UPDATE SET { column = { expr | DEFAULT } } [, ...] }

Параметры

• общее табличное выражение

  Распространенные табличные выражения (CTE) — это один или несколько именованных запросов, которые можно повторно использовать несколько раз в основном блоке запросов, чтобы избежать повторяющихся вычислений или улучшить удобочитаемость сложных вложенных запросов.

• WITH SCHEMA EVOLUTION

  Область применения: Databricks Runtime 15.2 и выше

  Включает автоматическую эволюцию схемы для этой операции MERGE. При включении схема целевой разностной таблицы автоматически обновляется, чтобы она соответствовала схеме исходной таблицы.

• target_table_name

  Имя таблицы , указывающее таблицу, которая изменяется. Ссылающаяся таблица должна быть таблицей Delta.

  Имя не должно включать указание параметров.

  Таблица не должна быть внешней таблицей.

• целевой_псевдоним

  Псевдоним таблицы для целевой таблицы. Псевдоним не должен содержать список столбцов.

• ссылка_на_таблицу_источника

  Имя таблицы , определяющее исходную таблицу, для объединения с целевой таблицей.

• source_alias

  Псевдоним таблицы для исходной таблицы. Псевдоним не должен содержать список столбцов.

• ON условие_слияния

  Как строки из одной реляции объединяются со строками из другой реляции. Выражение с булевым типом возвращаемого значения.

• WHEN MATCHED [ AND соответствующее_условие]

  WHEN MATCHED предложения выполняются, когда исходная строка соответствует целевой строке таблицы на основе merge_condition и необязательной match_condition.

• соответствующее_действие

  • DELETE

    Удаляет соответствующую целевую строку таблицы.

    Несколько совпадений разрешены, когда совпадения удаляются безусловно. Безусловное удаление не является неоднозначным, даже если имеется несколько совпадений.

  • UPDATE

    Обновляет соответствующую целевую строку таблицы.

    Чтобы обновить все столбцы целевой таблицы Delta с соответствующими столбцами исходного набора данных, используйте UPDATE SET *. Это эквивалентно UPDATE SET col1 = source.col1 [, col2 = source.col2 ...] для всех столбцов целевой таблицы Delta. Поэтому это действие предполагает, что исходная таблица имеет те же столбцы, что и в целевой таблице, в противном случае запрос вызовет ошибку анализа.

    Примечание.

    Это поведение изменяется при включенной автоматической эволюции схемы. Подробнее см. в разделе "Автоматическая эволюция схемы для слияния".

    Область применения: Databricks SQL Databricks Runtime 11.3 LTS и выше

    Можно указать DEFAULT как expr, чтобы явно обновить столбец до значения по умолчанию.

  Если существует несколько предложений WHEN MATCHED, они вычисляются в том порядке, в котором указаны. Каждое предложение WHEN MATCHED, кроме последнего, должно иметь значение matched_condition. В противном случае запрос возвращает ошибку NON_LAST_MATCHED_CLAUSE_OMIT_CONDITION .

  Если не выполняется ни одно из условий WHEN MATCHED для пары исходной и целевой строк, соответствующих merge_condition, целевая строка остается неизменной.

• WHEN NOT MATCHED [BY TARGET] [ AND не_совпадающее_условие]

  условия WHEN NOT MATCHED вставляют строку, если исходная строка не соответствует целевой строке на основе merge_condition и необязательного not_matched_condition.

  Область применения: Databricks SQL Databricks Runtime 12.2 LTS и выше

  WHEN NOT MATCHED BY TARGET можно использовать в качестве псевдонима для WHEN NOT MATCHED.

  not_matched_condition должно быть логическим выражением.

  • INSERT *

    Вставляет все столбцы целевой таблицы Delta с соответствующими столбцами исходного набора данных. Это эквивалентно INSERT (col1 [, col2 ...]) VALUES (source.col1 [, source.col2 ...]) для всех столбцов целевой таблицы Delta. Для этого действия требуется, чтобы исходная таблица содержит те же столбцы, что и в целевой таблице.

    Примечание.

    Это поведение изменяется при включенной автоматической эволюции схемы. Подробнее см. в разделе "Автоматическая эволюция схемы для слияния".

  • INSERT ( ... ) VALUES ( ... )

    Новая строка создается на основе указанного столбца и соответствующих выражений. Все столбцы в целевой таблице не нужно указывать. Если целевые столбцы не указаны, вставляется значение по умолчанию столбца, или NULL, если его нет.

    Область применения: Databricks SQL Databricks Runtime 11.3 LTS и выше

    Вы можете указать DEFAULT как выражение, чтобы явно вставить столбец по умолчанию для целевого столбца.

  Если существует несколько предложений WHEN NOT MATCHED, они вычисляются в том порядке, в котором указаны. Все предложения WHEN NOT MATCHED, за исключением последнего, должны иметь условия not_matched_condition. В противном случае запрос возвращает ошибку NON_LAST_NOT_MATCHED_CLAUSE_OMIT_CONDITION.

• WHEN NOT MATCHED BY SOURCE [ AND не_соответствует_условию_источника]

  Область применения: Databricks SQL Databricks Runtime 12.2 LTS и выше

  WHEN NOT MATCHED BY SOURCE предложения выполняются, если целевая строка не соответствует ни одной строке в исходной таблице на основе merge_condition, а необязательный not_match_by_source_condition оценивается как true.

  not_matched_by_source_condition должно быть логическим выражением, которое ссылается только на столбцы из целевой таблицы.

• не_соответствует_действию_источника

  • DELETE

    Удаляет целевую строку таблицы.

  • UPDATE

    Обновляет целевую строку таблицы. expr может ссылаться только на столбцы из целевой таблицы, в противном случае запрос вызовет ошибку анализа.

    Область применения: Databricks SQL Databricks Runtime 11.3 LTS и выше

    Можно указать DEFAULT как expr, чтобы явно обновить столбец до значения по умолчанию.

  Внимание

  Добавление предложения WHEN NOT MATCHED BY SOURCE для обновления или удаления целевых строк, когда merge_condition оценивается как false, может привести к большому количеству изменяемых целевых строк. Чтобы повысить производительность, примените not_matched_by_source_conditions, чтобы ограничить количество целевых строк, обновленных или удаленных.

  Если существует несколько WHEN NOT MATCHED BY SOURCE clauses, то они вычисляются в указанном порядке. Каждое предложение WHEN NOT MATCHED BY SOURCE, кроме последнего, должно иметь значение not_matched_by_source_condition. В противном случае запрос возвращает ошибку NON_LAST_NOT_MATCHED_BY_SOURCE_CLAUSE_OMIT_CONDITION .

  Если ни одно из WHEN NOT MATCHED BY SOURCE условий не соответствует целевой строке, которая не соответствует ни одной строке в исходной таблице на основе merge_condition, то целевая строка остается без изменений.

Примеры

Вы можете использовать MERGE INTO для сложных операций, таких как дедупликация данных, вставка или обновление изменяемых данных, применение операций SCD Type 2 и т. д. См. пример вставки в таблицу Delta Lake с использованием слияния ().

WHEN MATCHED

-- Delete all target rows that have a match in the source table.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN MATCHED THEN DELETE

-- Conditionally update target rows that have a match in the source table using the source value.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN MATCHED AND target.updated_at < source.updated_at THEN UPDATE SET *

-- Multiple MATCHED clauses conditionally deleting matched target rows and updating two columns for all other matched rows.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN MATCHED AND target.marked_for_deletion THEN DELETE
  WHEN MATCHED THEN UPDATE SET target.updated_at = source.updated_at, target.value = DEFAULT

WHEN NOT MATCHED [BY TARGET]

-- Insert all rows from the source that are not already in the target table.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN NOT MATCHED THEN INSERT *

-- Conditionally insert new rows in the target table using unmatched rows from the source table.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN NOT MATCHED BY TARGET AND source.created_at > now() - INTERVAL “1” DAY THEN INSERT (created_at, value) VALUES (source.created_at, DEFAULT)

WHEN NOT MATCHED BY SOURCE

-- Delete all target rows that have no matches in the source table.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN NOT MATCHED BY SOURCE THEN DELETE

-- Multiple NOT MATCHED BY SOURCE clauses conditionally deleting unmatched target rows and updating two columns for all other matched rows.
> MERGE INTO target USING source
  ON target.key = source.key
  WHEN NOT MATCHED BY SOURCE AND target.marked_for_deletion THEN DELETE
  WHEN NOT MATCHED BY SOURCE THEN UPDATE SET target.value = DEFAULT

WITH SCHEMA EVOLUTION

-- Multiple MATCHED and NOT MATCHED clauses with schema evolution enabled.
> MERGE WITH SCHEMA EVOLUTION INTO target USING source
  ON source.key = target.key
  WHEN MATCHED THEN UPDATE SET *
  WHEN NOT MATCHED THEN INSERT *
  WHEN NOT MATCHED BY SOURCE THEN DELETE

Связанные статьи

• общее табличное выражение
• УДАЛИТЬ
• INSERT В
• UPDATE