Джерело
Навчальний приклад форми з сервером db.example, портом 5432 та базою analytics_demo. З’єднання із зовнішньою базою не виконувалося.
Для SQL-підключення виберіть таблицю або режим запиту. Запит має бути лише для читання; записувальні команди не є способом налаштування джерела. Задайте потрібні поля та обмеження відбору й перевірте невелику вибірку перед повним запуском.
Отримувач
| Режим | Поведінка | Потрібно налаштувати |
|---|---|---|
| insert | Додати нові рядки. | Таблицю і відповідність полів. |
| update | Змінити наявні записи за ключем. | Ключові поля та значення для оновлення. |
| upsert | Оновити знайдені або додати відсутні записи. | Стабільний ключ, схему й правила запису. |
Отримувач завжди записує в таблицю, а не в довільний SQL-запит. Режими update/upsert потребують ключових полів. Для ClickHouse реалізоване тільки додавання.
Ключі та типи
- Ключ повинен однозначно знаходити запис.
- Перевірте дублікати ключа у вхідній таблиці до запису.
- Типи чисел, дат і порожніх значень мають бути сумісні зі схемою бази.
- Обов’язкові поля без типового значення потрібно передавати.
- Окремо оцініть поведінку повторного запуску: insert може додати дублікати.
Перевірка результату
Порівняйте очікувану кількість вставок/оновлень із журналом та вибіркою за конкретними ключами у цільовій таблиці. Якщо відповідь бази втрачена, спочатку звірте фактичні записи, потім вирішуйте, чи потрібен повтор.