Técnica
Aplicar un flujo de cambios
Reducir un lote de cambios al último por clave, borrados incluidos, y aplicarlo con un único MERGE.
Primero QUALIFY ROW_NUMBER() OVER (PARTITION BY key ORDER BY seq DESC) = 1: un MERGE con dos filas de origen para una clave
falla o se queda con una cualquiera. Después WHEN MATCHED AND op = 'D' THEN DELETE, WHEN MATCHED THEN UPDATE,
WHEN NOT MATCHED AND op <> 'D' THEN INSERT. Nunca descarte antes los borrados. Con una extracción completa en lugar de un flujo, una
clave ausente es un borrado: cierre su versión vigente.
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 |