14. SQL: upsert довідника товарів

Завдання та передумови

Оновити наявний товар за ключем sku і додати відсутній товар до навчальної SQL-таблиці.

Приклад містить навчальні дані та налаштування. Виберіть власні тестові джерела й підключення замість ідентифікаторів demo_*, відтворіть очікуваний результат і лише потім використовуйте робочі об’єкти.

Потрібне підключення до навчальної SQL-БД із підтримуваним конектором і правами читання/запису demo_products. Сам приклад не виконує SQL-запис.

Навчальні вхідні дані

Початковий стан таблиці demo_products:

products.csv

sku;name;price
T01;Tea premium;12.5
J01;Juice;8

Блоки, зв’язки й точні налаштування

Пояснювальна схемаЗбільшити ↗

{
  "version": 3,
  "nodes": [
    {
      "id": "src",
      "type": "file",
      "label": "src",
      "config": {
        "role": "source",
        "source_id": "demo_products_upsert",
        "options": {
          "sheet": "CSV",
          "range": "A1:C3",
          "header": true,
          "delimiter": ";"
        }
      }
    },
    {
      "id": "cast",
      "type": "number_format",
      "label": "cast",
      "config": {
        "rules": [
          {
            "kind": "number",
            "field": "price",
            "decimal_in": ".",
            "thousands_in": "",
            "extract": false,
            "invalid": "error",
            "output": "number"
          }
        ]
      }
    },
    {
      "id": "sql",
      "type": "connection",
      "label": "sql",
      "config": {
        "role": "target",
        "connection_id": "demo_sql",
        "external": {
          "object": "demo_products",
          "write_mode": "upsert",
          "key_fields": [
            "sku"
          ]
        }
      }
    }
  ],
  "edges": [
    {
      "source": "src",
      "target": "cast",
      "source_port": "out",
      "target_port": "in"
    },
    {
      "source": "cast",
      "target": "sql",
      "source_port": "out",
      "target_port": "in"
    }
  ]
}

Очікуваний результат

T01 оновлено, J01 додано, C01 залишається. Ключ sku має бути унікальним у навчальній таблиці.

Запуск і перевірка

1. Підготуйте навчальну таблицю demo_products і перевірте початковий стан із 2 рядків.
2. Звірте типи стовпців: sku/name — текст, price — число; блок cast перетворює текст CSV на число.
3. Виконайте попередню перевірку, потім запуск; прочитайте таблицю та звірте 3 наведені рядки.
4. Повторіть той самий запуск: upsert за sku має оновити ті самі товари без створення дублікатів.

Типові помилки

• insert замість upsert не оновить T01 і може порушити унікальний ключ.
• Порожній або повторний sku у вхідному файлі треба виправити до запису.
• Не підміняйте навчальну таблицю робочою без перевірки схеми та прав запису.