Чтобы вставить запись или обновить её, если она уже существует (по order_id, например), в SQLite можно использовать конструкцию INSERT OR REPLACE, INSERT OR IGNORE, или UPSERT с ON CONFLICT.
Вот как можно переписать ваш запрос, чтобы он обновлял запись, если она уже существует по order_id:
Для UPSERT нужно, чтобы order_id был уникальным:
sqlCREATE UNIQUE INDEX IF NOT EXISTS idx_order_id ON deal_current(order_id);
INSERT INTO ... ON CONFLICT ... DO UPDATEphp$stmt = $SQLite3->prepare("
INSERT INTO deal_current (order_id, notifies_text, date_create)
VALUES (:order_id, :notifies_text, :date_create)
ON CONFLICT(order_id) DO UPDATE SET
notifies_text = excluded.notifies_text,
date_create = excluded.date_create
");
$stmt->bindValue(':order_id', $val['order_id'], SQLITE3_INTEGER);
$stmt->bindValue(':notifies_text', $notifies_textSQL, SQLITE3_TEXT);
$stmt->bindValue(':date_create', $val['deal_update'], SQLITE3_TEXT);
$stmt->execute();
ON CONFLICT(order_id) — говорит SQLite, что делать в случае конфликта по полю order_id.
DO UPDATE SET ... — обновляет поля, если такая запись уже есть.
excluded.column_name — это значения, которые вы пытались вставить.
Если что-то нужно уточнить — покажите структуру таблицы deal_current, и я помогу подстроить под неё.
Спасибо за уточнение. У вас возникла ошибка при выполнении запроса prepare() — ошибка синтаксиса возле ), что часто указывает на проблему с SQL-синтаксисом.
Вы используете:
sqlINSERT INTO deal_current (order_id, notifies_text, date_create)
VALUES (:order_id, :notifies_text, :date_create)
ON CONFLICT(order_id) DO UPDATE SET
notifies_text = excluded.notifies_text,
date_create = excluded.date_create
SQLite до версии 3.24.0 (выпущена в 2018) не поддерживает excluded. и ON CONFLICT DO UPDATE. Возможно, ваша версия SQLite устарела.
Также, вы используете order_id INT UNIQUE ON CONFLICT REPLACE, что может конфликтовать с ON CONFLICT DO UPDATE.
INSERT OR REPLACE (поддерживается в старых SQLite)php$stmt = $SQLite3->prepare("
INSERT OR REPLACE INTO deal_current (order_id, notifies_text, date_create)
VALUES (:order_id, :notifies_text, :date_create)
");
$stmt->bindValue(':order_id', $val['order_id'], SQLITE3_INTEGER);
$stmt->bindValue(':notifies_text', $notifies_textSQL, SQLITE3_TEXT);
$stmt->bindValue(':date_create', $val['deal_update'], SQLITE3_TEXT);
$stmt->execute();
📌 Важно: OR REPLACE удаляет старую строку (если есть конфликт по order_id) и вставляет новую, сбрасывая автоинкрементный id.
Если вы не хотите терять id, можно сделать это в два шага:
php// 1. Попробовать UPDATE
$update = $SQLite3->prepare("
UPDATE deal_current
SET notifies_text = :notifies_text,
date_create = :date_create
WHERE order_id = :order_id
");
$update->bindValue(':order_id', $val['order_id'], SQLITE3_INTEGER);
$update->bindValue(':notifies_text', $notifies_textSQL, SQLITE3_TEXT);
$update->bindValue(':date_create', $val['deal_update'], SQLITE3_TEXT);
$update->execute();
// 2. Если обновление не затронуло строк — вставить
if ($SQLite3->changes() === 0) {
$insert = $SQLite3->prepare("
INSERT INTO deal_current (order_id, notifies_text, date_create)
VALUES (:order_id, :notifies_text, :date_create)
");
$insert->bindValue(':order_id', $val['order_id'], SQLITE3_INTEGER);
$insert->bindValue(':notifies_text', $notifies_textSQL, SQLITE3_TEXT);
$insert->bindValue(':date_create', $val['deal_update'], SQLITE3_TEXT);
$insert->execute();
}
Проверьте версию SQLite:
phpecho SQLite3::version()['versionString'];
Для поддержки ON CONFLICT ... DO UPDATE нужна версия 3.24.0+.
Нужен совет, какой вариант лучше — зависит от того, хотите ли вы сохранять id или готовы его сбрасывать при обновлении.
Чтобы очистить таблицу deal_current и затем вставить новые записи, нужно сделать это в два шага:
Вариант 1 — полностью удалить все записи (с сохранением структуры и автоинкремента):
php$SQLite3->exec("DELETE FROM deal_current");
Вариант 2 — полностью сбросить таблицу, включая AUTOINCREMENT счётчик:
php$SQLite3->exec("DELETE FROM deal_current");
$SQLite3->exec("DELETE FROM sqlite_sequence WHERE name='deal_current'");
Пример:
php$stmt = $SQLite3->prepare("
INSERT INTO deal_current (order_id, notifies_text, date_create)
VALUES (:order_id, :notifies_text, :date_create)
");
$stmt->bindValue(':order_id', $val['order_id'], SQLITE3_INTEGER);
$stmt->bindValue(':notifies_text', $notifies_textSQL, SQLITE3_TEXT);
$stmt->bindValue(':date_create', $val['deal_update'], SQLITE3_TEXT);
$stmt->execute();
php// Очистка таблицы
$SQLite3->exec("DELETE FROM deal_current");
$SQLite3->exec("DELETE FROM sqlite_sequence WHERE name='deal_current'"); // Сброс автоинкремента (необязательно)
// Вставка новой записи
$stmt = $SQLite3->prepare("
INSERT INTO deal_current (order_id, notifies_text, date_create)
VALUES (:order_id, :notifies_text, :date_create)
");
$stmt->bindValue(':order_id', $val['order_id'], SQLITE3_INTEGER);
$stmt->bindValue(':notifies_text', $notifies_textSQL, SQLITE3_TEXT);
$stmt->bindValue(':date_create', $val['deal_update'], SQLITE3_TEXT);
$stmt->execute();
Если нужно вставить сразу несколько записей после очистки — можешь использовать цикл foreach после очистки и выполнять INSERT в каждой итерации. Хочешь пример такого варианта?