Как правильно обновлять данные в MySQL с помощью PHP

Пример 1. Обновление с использованием подзапроса и агрегации

Задача: обновить рейтинг товаров на основе среднего отзыва.

$sql = "UPDATE products p
        SET p.rating = (
            SELECT COALESCE(AVG(r.score), 0) FROM reviews r
            WHERE r.product_id = p.id
        )
        WHERE p.category_id = 5";
$count = $pdo->exec($sql);
echo "Обновлено товаров: $count";
  

Обновлено товаров: 12
  

Пример 2. Массовое обновление с помощью CASE (множественные условия)

Задача: установить разные скидки в зависимости от группы товаров.

$sql = "UPDATE products
        SET discount = CASE
            WHEN price > 5000 THEN 10
            WHEN price BETWEEN 2000 AND 5000 THEN 5
            ELSE 0
        END";
$pdo->exec($sql);
 echo 'Скидки обновлены';
  

Скидки обновлены
  

Пример 3. Обновление с лимитом (LIMIT) для пошаговой обработки

Задача: постепенно обработать большие объемы данных, обновляя по 100 записей.

$limit = 100;
$offset = 0;
$total = $pdo->query("SELECT COUNT(*) FROM logs WHERE processed = 0")->fetchColumn();
while ($offset < $total) {
    $pdo->exec("UPDATE logs SET processed = 1 WHERE processed = 0 LIMIT $limit");
    $offset += $limit;
}
  

(выполнение без вывода, но количество затронутых строк можно проверить через rowCount)
  

Пример 4. Обновление с использованием временных переменных (MySQL)

Задача: пронумеровать записи в порядке возрастания id.

$sql = "SET @row_number = 0;
        UPDATE articles
        SET sort_order = (@row_number := @row_number + 1)
        ORDER BY id ASC";
$pdo->exec($sql);
  

(после выполнения поле sort_order получит последовательные числа 1, 2, 3...)
  

Пример 5. Обновление с проверкой условий через IF

Задача: обновить поле status в зависимости от даты последнего входа.

$sql = "UPDATE users
        SET status = IF(last_login < DATE_SUB(NOW(), INTERVAL 30 DAY), 'inactive', 'active')";
$pdo->exec($sql);
  

(все пользователи получат соответствующий статус)
  

Пример 6. Обновление с присоединением вложенной таблицы (UPDATE с JOIN)

Задача: обновить поле manager_name в таблице orders на основе id менеджера.

$sql = "UPDATE orders o
        JOIN managers m ON o.manager_id = m.id
        SET o.manager_name = CONCAT(m.first_name, ' ', m.last_name)
        WHERE o.status = 'pending'";
$pdo->exec($sql);
  

(все заказы в статусе pending получат полное имя менеджера)
  

Пример 7. Использование транзакций для согласованного обновления

Задача: перевести сумму между счетами с гарантией атомарности.

$pdo->beginTransaction();
try {
    $pdo->exec("UPDATE bank_accounts SET balance = balance - 500 WHERE account_id = 10");
    $pdo->exec("UPDATE bank_accounts SET balance = balance + 500 WHERE account_id = 20");
    $pdo->commit();
    echo 'Перевод выполнен';
} catch (Exception $e) {
    $pdo->rollBack();
    echo 'Ошибка: ' . $e->getMessage();
}
  

Перевод выполнен
  

Пример 8. Обновление с обработкой потенциальных блокировок (SELECT ... FOR UPDATE)

Задача: заблокировать строку при чтении для последующего обновления (пессимистическая блокировка).

$pdo->beginTransaction();
$stmt = $pdo->prepare("SELECT balance FROM bank_accounts WHERE account_id = ? FOR UPDATE");
$stmt->execute([10]);
$row = $stmt->fetch();
$newBalance = $row['balance'] - 500;
$pdo->prepare("UPDATE bank_accounts SET balance = ? WHERE account_id = ?")->execute([$newBalance, 10]);
$pdo->commit();
  

(другие транзакции не смогут прочитать или изменить эту строку до завершения текущей)
  

Пример 9. Обновление с использованием многотабличного UPDATE (без JOIN)

Задача: обновить поле в одной таблице на основе значения из другой без JOIN, через подзапрос.

$sql = "UPDATE products p
        SET p.stock = (SELECT SUM(quantity) FROM inventory WHERE product_id = p.id)
        WHERE EXISTS (SELECT 1 FROM inventory WHERE product_id = p.id)";
$pdo->exec($sql);
  

(количество товара на складе обновлено для всех продуктов, имеющих записи в inventory)
  

Пример 10. Обновление с нумерацией строк по группам (ROW_NUMBER эмуляция)

Задача: присвоить порядковые номера в каждой категории.

$sql = "UPDATE products p
        JOIN (
            SELECT id,
                   ROW_NUMBER() OVER (PARTITION BY category_id ORDER BY price DESC) as rn
            FROM products
        ) ranked ON p.id = ranked.id
        SET p.position = ranked.rn";
$pdo->exec($sql);
  

(в каждой категории товары получат номер от 1 до N по убыванию цены)