Как это превратить в один запрос?

Question

[perchikooko]

Передо мной стоит задача оптимизации запросов:
этим запросом я проверяю количество записей удовлетворяющих условию

select * from Products where product_id=$p_id and region=$key

этот запрос если количество записей не равно нулю

update Products set prices_purchase=$p_purchase, prices_selling=$p_selling, prices_discount=$p_discount where product_id=$p_id and region=$key;

а это уже если равно

INSERT INTO Products (product_id, region, prices_purchase, prices_selling, prices_discount)
VALUES ('$p_id', '$key', '$p_purchase', '$p_selling', '$p_discount')

Вопрос заключается в том как это соединить в один запрос (у меня получается только два), не получилось с if exists, а также insert into ... on duplicate key update. Желательно чтобы был готовый вариант (если не затруднит поясните).

Comments

[Slava Rozhnev]

https://sqlize.online/sql/mysql57/a74e975e2772380f...

[Akina]

Вы обязаны начать с выкладывания результата выполнения SHOW CREATE TABLE Products;
Сейчас в принципе непонятно, есть ли у ODKU вообще материал для работы...

Answer 1

[stavfz]

Скажите а "select * from Products where product_id=$p_id and region=$key" Может вернуть больше одной записи за один проход?
Не пойму просто логическую суть условия if ($smth->num_rows!=0)
если задача найти именно дублирующиеся записи то по идеи должно быть if ($smth->num_rows>1) т.к. 1 строка это не дубликат. Получается что в Select как таковом отпадает всякая нужна просто update и всё (есть что обновить обновит нету нет) и если в самой таблице настроить уникальность по двум полям то можно следом и insert делать, он все равно не задвоит данные.

по вашему примеру получается что update можно делать и если больше одной записи в базе соответсвует выборке ваше условие !=0 предполагает что нужно обновить все записи которые соответсвуют выборке сколько бы их в базе не было
Есть ещё такая штука как replace, работает также как инсерт если в базе найдется запись которая совпадет по значению первичных ключей (если product_id и region у вас являются таковыми) со вставляемой строкой то произойдет Update
Опять возвращаемся к тому что сложно посоветовать что то конкретное не видя структуру таблицы её ключей и индексов
Вполне вероятно что в вашем случае просто вместо конструкций из if можно написать:

$sql = "REPLACE INTO Products (product_id, region, prices_purchase, prices_selling, prices_discount)
        VALUES ('$p_id', '$key', '$p_purchase', '$p_selling', '$p_discount')";

p.s.
то что пишу ниже это офтоп но не совсем, вы спрашивали "Можете посоветовать что можно изменить в коде"
Могу.
Строить запросы так как это делаете Вы неправильно с точки зрения безопасности, правильно было бы сделать так:
для INSERT

$sql = "INSERT INTO Products
SET
product_id= :product_id, 
region= :region, 
prices_purchase= :prices_purchase, 
prices_selling= :prices_selling, 
prices_discount= :prices_discount
";
// подготовка запроса
$stmt = $this->bd_connect->prepare($sql);

// привязываем значения
$stmt->bindParam(':product_id',$p_id);
$stmt->bindParam(':region',$key);
$stmt->bindParam(':prices_purchase',$p_purchase);
$stmt->bindParam(':prices_selling',$p_selling);
$stmt->bindParam(':prices_discount',$p_discount);

//Выполняем запрос
$stmt->execute()

Для SELECT

$sql = "SELECT * FROM Products 
WHERE product_id= :p_id AND region= :key";

// подготовка запроса
$stmt = $this->bd_connect->prepare($sql);

// привязываем значения
$stmt->bindParam(':p_id',$p_id);
$stmt->bindParam(':key',$key);

// выполняем запрос
$stmt->execute();
 
 // получаем количество строк
$num = $stmt->rowCount();

// одним из распространенных вариантов получаем значения (смотри php PDO)
$row = $stmt->fetch(PDO::FETCH_ASSOC);

Перед привязкой значений можно а часто даже нужно дополнительно обработать ( слеши там всякие и т.п. :) ), то, что собираешься биндить

Comments

[perchikooko]

В том то и подвох что ни одно из полей таблицы нельзя сделать уникальным, поэтому replace бесполезен (просто создает записи без замены). По поводу select и num_rows, в $smth->num_rows может быть и 0, 1 и 5, короче много чего там может быть. Мне нужно именно проверять по product_id и region если они равны значениям которые перебираются в цикле то надо просто перезаписать поля: prices_purchase, prices_selling, prices_discount.

[perchikooko]

Благодарю насчёт последних примеров с insert и select, возьму на заметку (хоть это и тестовое задание).

[stavfz]

perchikooko, Темболее если тестовое, это то на что обязательно обратят внимание 100%

[stavfz]

perchikooko, Значит 100% update можно делать сразу, если есть что обновлять то оно обновиться и тут же можно сделать проверку если обновилось 0 строк то делаем insert но тут есть ещё нюанс если данные небыли новыми то ничего не обновиться и при проверке на кол-во строк которые были затронуты запросом UPDATE мы получим 0 ну то-есть если для записи которая соответствует WHERE product_id= :p_id AND region= :key данные которые ты кидаешь для UPDATE такие же как уже в базе данных то такой подход может не сработать.

В коде то о чем я говорю будет выглядеть примерно так:

$sql = "UPDATE Products
SET
prices_purchase= :prices_purchase, 
prices_selling= :prices_selling, 
prices_discount= :prices_discount
WHERE product_id= :product_id
AND region= :region
";
// подготовка запроса
$update = $this->bd_connect->prepare($sql);

// привязываем значения
$update->bindParam(':product_id',$p_id);
$update->bindParam(':region',$key);
$update->bindParam(':prices_purchase',$p_purchase);
$update->bindParam(':prices_selling',$p_selling);
$update->bindParam(':prices_discount',$p_discount);

//Выполняем запрос
$update->execute()

//Узнаем сколько строк затронул запрос
$count = $update->rowCount();

if ($count==0){
$sql = "INSERT INTO Products
SET
product_id= :product_id, 
region= :region, 
prices_purchase= :prices_purchase, 
prices_selling= :prices_selling, 
prices_discount= :prices_discount
";
// подготовка запроса
$stmt = $this->bd_connect->prepare($sql);

// привязываем значения
$stmt->bindParam(':product_id',$p_id);
$stmt->bindParam(':region',$key);
$stmt->bindParam(':prices_purchase',$p_purchase);
$stmt->bindParam(':prices_selling',$p_selling);
$stmt->bindParam(':prices_discount',$p_discount);

//Выполняем запрос
$stmt->execute()
}

[Kek145]

stavfz, Очень сильно помогли.