Tecnica
Applicare un flusso di modifiche
Riduci un lotto di modifiche all'ultima per chiave, eliminazioni comprese, poi applicalo con un solo MERGE.
Prima QUALIFY ROW_NUMBER() OVER (PARTITION BY key ORDER BY seq DESC) = 1: un MERGE con due righe sorgente per una
chiave fallisce o ne tiene una a caso. Poi WHEN MATCHED AND op = 'D' THEN DELETE, WHEN MATCHED THEN UPDATE,
WHEN NOT MATCHED AND op <> 'D' THEN INSERT. Non scartare mai prima le eliminazioni. Con un'estrazione completa invece
di un flusso, una chiave mancante è un'eliminazione: chiudi la sua versione corrente.
WITH changes(seq, op, customer_id, city) AS (VALUES (1, 'I', 7, 'Bern'), (2, 'U', 7, 'Zurich'), (3, 'I', 8, 'Paris'), (4, 'D', 8, NULL), (5, 'U', 2, 'Lille')) SELECT customer_id, op, city FROM changes QUALIFY ROW_NUMBER() OVER (PARTITION BY customer_id ORDER BY seq DESC) = 1 ORDER BY customer_id;
| customer_id | op | city |
|---|---|---|
| 2 | U | Lille |
| 7 | U | Zurich |
| 8 | D | NULL |