Chargement incrémental (upsert)

Chaque nuit, le pipeline reçoit dans stg_produits les produits nouveaux ou modifiés depuis le dernier chargement. La table cible dw_produits doit être mise à jour sans tout recharger. Terminez chaque requête par « ; » (.tables, .schema <table>).

1. Appliquez un upsert : INSERT INTO dw_produits … SELECT … FROM stg_produits WHERE true ON CONFLICT(code) DO UPDATE SET nom = excluded.nom, prix = excluded.prix, maj_le = excluded.maj_le
2. Mettez à jour le filigrane (watermark) : etat_chargement.dernier_maj = plus grande maj_le chargée
3. Nombre de lignes de dw_produits après chargement → answer lignes <n>