Как ты используешь транзакцию?

Применение транзакций в PHP Backend-разработке

Работа с транзакциями — это фундаментальный аспект разработки надежных backend-систем, особенно в контексте целостности данных и согласованности ACID (Atomicity, Consistency, Isolation, Durability). Я использую транзакции для группировки нескольких операций в единую логическую единицу работы, которая либо выполняется полностью, либо не выполняется вовсе.

Основные сценарии применения

1. Финансовые операции (переводы между счетами)
2. Сложные регистрационные процессы (создание пользователя + профиль + настройки)
3. Инвентаризация и управление запасами
4. Пакетные обновления связанных данных
5. Обработка заказов в e-commerce

Практическая реализация

В PHP с использованием PDO (PHP Data Objects) или Doctrine ORM:

<?php
// Пример использования транзакций с PDO
class TransactionManager {
    private PDO $pdo;
    
    public function processOrder(Order $order): bool {
        try {
            // Начало транзакции
            $this->pdo->beginTransaction();
            
            // 1. Обновление информации о заказе
            $stmt = $this->pdo->prepare(
                "UPDATE orders SET status = ? WHERE id = ?"
            );
            $stmt->execute(['processing', $order->getId()]);
            
            // 2. Списание со склада
            foreach ($order->getItems() as $item) {
                $stmt = $this->pdo->prepare(
                    "UPDATE inventory SET quantity = quantity - ? 
                     WHERE product_id = ? AND quantity >= ?"
                );
                $stmt->execute([
                    $item->getQuantity(),
                    $item->getProductId(),
                    $item->getQuantity()
                ]);
                
                if ($stmt->rowCount() === 0) {
                    throw new Exception("Недостаточно товара на складе");
                }
            }
            
            // 3. Создание записи о транзакции
            $stmt = $this->pdo->prepare(
                "INSERT INTO transactions (order_id, amount, status) 
                 VALUES (?, ?, ?)"
            );
            $stmt->execute([
                $order->getId(),
                $order->getTotal(),
                'pending'
            ]);
            
            // Фиксация всех изменений
            $this->pdo->commit();
            return true;
            
        } catch (Exception $e) {
            // Откат при любой ошибке
            $this->pdo->rollBack();
            error_log("Transaction failed: " . $e->getMessage());
            return false;
        }
    }
}

Ключевые принципы работы с транзакциями

Atomicity (Атомарность):

• Все операции в транзакции выполняются как единое целое
• При ошибке любой операции откатываются ВСЕ изменения

Изоляция уровней (Transaction Isolation Levels):

-- Установка уровня изоляции в MySQL
SET TRANSACTION ISOLATION LEVEL READ COMMITTED;

• READ UNCOMMITTED — самый слабый уровень, возможны "грязные" чтения
• READ COMMITTED — стандартный уровень для большинства СУБД
• REPEATABLE READ (дефолт в MySQL) — гарантирует непротиворечивость чтений
• SERIALIZABLE — максимальная изоляция, но низкая производительность

Продвинутые техники

1. Вложенные транзакции через SAVEPOINT:

$this->pdo->beginTransaction();
// Основные операции...

$this->pdo->exec("SAVEPOINT point1");
try {
    // Операции, которые могут откатиться частично
    $this->pdo->exec("RELEASE SAVEPOINT point1");
} catch (Exception $e) {
    $this->pdo->exec("ROLLBACK TO SAVEPOINT point1");
}

1. Распределенные транзакции (XA Transactions):

// Для координации транзакций между разными БД
$this->pdo->exec("XA START 'transaction_id'");
// Операции в разных БД...
$this->pdo->exec("XA END 'transaction_id'");
$this->pdo->exec("XA PREPARE 'transaction_id'");
$this->pdo->exec("XA COMMIT 'transaction_id'");

1. Оптимистические и пессимистические блокировки:

-- Пессимистическая блокировка
SELECT * FROM accounts WHERE id = 1 FOR UPDATE;

-- Оптимистическая (через versioning)
UPDATE accounts SET balance = 100, version = version + 1 
WHERE id = 1 AND version = 2;

Лучшие практики

1. Держите транзакции максимально короткими — уменьшайте время блокировок
2. Всегда обрабатывайте исключения с гарантированным откатом
3. Избегайте бизнес-логики внутри транзакций — только операции с данными
4. Используйте соответствующий уровень изоляции для каждого сценария
5. Мониторьте блокировки и deadlocks в production-среде
6. Тестируйте отказы — симулируйте сбои во время транзакций

Отладка и мониторинг

// Логирование информации о транзакциях
class TransactionLogger {
    public function logTransaction(PDO $pdo, string $operation) {
        if ($pdo->inTransaction()) {
            error_log("Transaction active during: " . $operation);
        }
    }
}

// Отслеживание длительных транзакций
$startTime = microtime(true);
// ... операции транзакции
if (microtime(true) - $startTime > 5.0) {
    error_log("Long transaction detected: " . (microtime(true) - $startTime));
}

Транзакции — это мощный инструмент, но их нужно использовать осмысленно. Чрезмерное использование или слишком длинные транзакции могут привести к проблемам с производительностью, взаимным блокировкам (deadlocks) и снижению масштабируемости системы. В высоконагруженных системах часто применяются альтернативные подходы, такие как Event Sourcing, Компенсирующие транзакции (Saga Pattern) или идемпотентные операции, которые лучше масштабируются в распределенных средах.