mysql multi insert
Добрый день уважаемые форумчане!
Входные данные: Клиент передает на сервер json oбъект который содержит в себе массив вида (id, quantity, price) Моя функция для того чтоб сделать insert этого массива в db: static addSale(products){ //WHERE (SELECT stock FROM prais_informations WHERE code = ) > 20; let quer = 'INSERT INTO `sales` (`id`, `code`, `quantity`, `price`, `sum`, `idCheck`) VALUES ?;'; return new Promise((resolve, reject) => { pool.getConnection((err, connection) => { if (err)reject(err); connection.query(quer, [products.map(item => [null, item.id, item.quantity, item.price, item.sum, 3])], (err, rows) => { if (err) { reject(err); } resolve(rows); connection.release(); }); }); }); } Вопрос в следующем, прежде чем сделать инсерт всех строк, нужно проверить не превышает ли количество в запросе, остаток в бд, если хотя бы одна строка не удовлетворяет условию, запрос не должен быть сделан. Вариант я вижу один, создать дополнительную функцию, которая вернет в промисе AND нескольких селектов (true/false) и в части then уже делать insert запрос. |
Цитата:
|
Цитата:
|
Цитата:
|
andrew76,
что с чем сравнивать не знаю, но зачастую отдельного запрос не требуется. Пример простой, если я правильно понял, то нужно типа такого: "INSERT INTO table (count) SELECT N WHERE (SELECT balance FROM table LIMIT 1) > N" где N - это вставляемое количество в поле count, balance - это поле остатка в этой же таблице. Тут используется просто поле со значением по умолчанию, для всех, поэтому и LIMIT 1. Если вставка для конкретного ID, то нужно взять для этого ID, но сама вставка при этом, это уже будет обновление. То есть остаток по идее, это уже другая таблица, откуда он и извлекается для ID. Иначе это только ON DUPLICATE KEY UPDATE. |
Цитата:
|
Цитата:
https://www.mysqltutorial.org/mysql-nodejs/insert/ |
Цитата:
https://ibb.co/NntTBDr https://ibb.co/tm4z09n В функции, которую я представил выше, формируется запрос вида: INSERT INTO `sales` (`id`, `code`, `quantity`, `price`, `sum`, `idCheck`) VALUES (null, item.id, item.quantity, item.price, item.sum, 3), (null, item.id, item.quantity, item.price, item.sum, 3) , ... , (null, item.id, item.quantity, item.price, item.sum, 3); Но прежде чем сделать инсерты в `sales` нужно проверить, не превышает ли доступный остаток каждый элемент из VALUES. 1. Мне кажется одним запросом это не сделать, нужно написать новую функцию, которая примет массив, сравнит quantity c balance и вернет промис. Задача довольно типовая, поэтому я и задаюсь вопросом, как это реализовать правильно. |
Цитата:
Другое дело PDO, в нем есть и именованные псевдопеременные. Не проблема разместить в теле запроса в любом месте :a, :b ... и передать для записи массив [a=> 12, b=> 15] (объект, в случае Node) и проблем не будет никогда. Есть ли в Node поддержка абстракций для работы с БД не в курсе. А вообще такие запросы выгодно выполнять в случаях например множественной вставки или обновлений. В этом случае запрос подготавливается, проверяется, а затем в него вместо псевдопеременных просто подставляются новые данные. |
Цитата:
Можно предполагать, например, это заказ/продажа пишется в таблицу А, то есть информация о неком продукте. Сами продукты описаны в таблице В. Тогда в одном запросе можно обратиться к таблице В, сравнив его остаток со вставляемым значением в таблицу А. Делается это так как я показывал. Ваше же пояснение ни о чем не говорит, что с чем, откуда это все, не понять. |
Цитата:
|
Не придумал ничего умнее чем в цикле создать запрос вида
SELECT true WHERE (SELECT prais_informations.stock FROM prais_informations WHERE prais_informations.code = 1 LIMIT 1) > 7 UNION SELECT true WHERE (SELECT prais_informations.stock FROM prais_informations WHERE prais_informations.code = 2 LIMIT 1) > 3 вернуть промис и на основе ответа делать/не делать запрос insert. |
надо было триггер beforeInsert написать... и использовать транзацию)
|
Цитата:
П.С, сейчас попробую сделать процедуру. П.С, пошел смотреть продвинутый курс по mysql, бех этих знаний не обойтись. |
надо писать много букаф ).. по вашему получается: можно купить только половину, а можно и все, а можно и ничего, а если будет несколько пользователей, претендующих на одно и тоже... потом тень на плетень, сиди и думай ) кому и что показывать на какие запросы...
|
'INSERT INTO `sales` (`id`, `code`, `quantity`, `price`, `sum`, `idCheck`)
и при это для id указывать null не обязательно, проще убрать id из запроса. А проверить надо с параметрами таблицы prais_informations? Что с чем? |
SELECT prais_informations.stock <= количество для товара 0* FROM prais_informations WHERE prais_informations.code = код товара 0* ... SELECT prais_informations.stock <= количество для товара n* FROM prais_informations WHERE prais_informations.code = код товара n* * - приходит в запросе от клиентской части. где n количество товаров в текущем заказе, товары не дублируются, если хотя бы один из этих запросов возвращает false заказ дальше не идет, запись в БД не происходит. |
Что с чем сравнивать? Это не сравнение, это получение параметров из другой таблицы. С какими полями таблицы `sales` нужно сравнивать эти параметры?
|
sales: таблица в которую просто идет запись(тот самый мульти инсерт, c этой таблицей ничего сравнивать не нужно, в неё только запись)
sales prais_information AS pi: таблица в которой лежат остатки, от клиента приходит массив вида [id, quantity, price, sum] Соответственно pi.code === id and pi.stock >= quantity pi |
Да, не получится при многострочной вставке проверить, так как нельзя выбрать группы записей у несуществующего и сослаться не на что. Без временной таблицы не обойтись. Только в цикле:
var data = [ [code, quantity, ....], [code, quantity, ....], .... ]; data.forEach((d)=> { query('INSERT INTO sales (code, quantity, ...) SELECT ' + d.join(',') + ' WHERE (SELECT stock FROM pi WHERE code=' + d.code + ') >=' + d.quantity) }) |
Буду использовать временную таблицу.
Вам спасибо за подробное разъяснение. Начну просмотр курса sql на юдеми, после просмотра вернусь к задаче. |
Цитата:
'SELET 1 WHERE NOT EXISTS (SELECT * FROM pi WHERE code IN(sales.code, sales.code, ....) AND stock BETWEEN sales.quantity.min AND sales.quantity.max)' и если вернуло, значит можно вставлять, иначе нет. Если же разрешено вставлять товары, которые отвечают условию, то функция INSERT возвращает число вставленных записей. То есть, если записывать в цикле и проверять результат возвращаемый, то можно вернуть пользователю отчет, какие товары не добавлены, или наоборот обрадовать. |
Элегантное решение моих union select, сделать такой select и при правильном исходе в .then делать insert. Решение неплохое, но оно КМК не "энтерпрайз". В любом случае спасибо за помощь, я отпишусь в конце недели, как просмотрю и усвою курс. Спасибо.
|
Цитата:
|
Боюсь вы неверно поняли, я хотел сказать, что наговнокодил с UNION, вы же написали элегантное решение. Недопонимание вышло.
|
напиши хранимую процедуру )) https://www.mysqltutorial.org/mysql-if-statement/
|
Как сделаю, выложу.
|
Цитата:
|
Прикладываю процедуру, которую сделал на данный момент, из проблем insert в таблицу sales проходит, но пропускается один индекс (скрин).
Так же подскажите как правильно обновить остатки на складах, что то вроде(stackoverflow) You can use a CASE statement to handle multiple if/then scenarios: UPDATE table_to_update SET cod_user= CASE WHEN user_rol = 'student' THEN '622057' WHEN user_rol = 'assistant' THEN '2913659' WHEN user_rol = 'admin' THEN '6160230' END ,date = '12082014' WHERE user_rol IN ('student','assistant','admin') AND cod_office = '17389551'; Процедура: BEGIN DECLARE res INT; DECLARE last_index INT; SET @input := 'sales: [ { id: 2, quantity: 5, price: 123, sum: 615 }, { id: 1, quantity: 9, price: 97, sum: 873 } ]'; SET @input:=REPLACE(@input, ' ', ''); SET @input:=REPLACE(@input, 'sales:', ''); SET @input:=REGEXP_REPLACE(@input, '([{,])([a-z])', '$1"$2'); SET @input:=REGEXP_REPLACE(@input, '([a-z]):', '$1":'); CREATE TEMPORARY TABLE new_tbl SELECT jtin.id AS jtin_id, jtin.quantity AS jtin_qty, pi.stock AS pi_qty, pi.price AS pi_price FROM JSON_TABLE(@input, "$[*]" COLUMNS (id INT PATH "$.id" , quantity MEDIUMINT PATH "$.quantity", price DECIMAL(7,2) PATH "$.price", `sum` DECIMAL(8,2) PATH "$.sum" )) AS jtin LEFT JOIN prais_informations AS pi ON jtin.id = pi.code; SET res = (SELECT count(*) FROM new_tbl WHERE jtin_qty > pi_qty); IF res = 0 THEN /* Инсертим новую запись, получившийся id, будет являтся id чека */ INSERT INTO checks(`data`, `user`) VALUES ( UNIX_TIMESTAMP(), 0); SET last_index = (SELECT max(id) FROM checks); /* Инсертим содержимое массива заказа в таблицу регистрации */ INSERT INTO sales(`code`, `quantity`, `price`, `sum`, `idCheck`) SELECT nt.jtin_id, nt.jtin_qty, nt.pi_price, (nt.jtin_qty * nt.pi_price), last_index FROM new_tbl AS nt; /* Обновляем остатки на складе */ END IF END |
Как вариант можно сделать триггер на insert в sales и делать update в price_information.
|
Часовой пояс GMT +3, время: 15:09. |