Организация транзакции через PDO с корректным откатом требует строгого соблюдения порядка операций и использования механизма `PDO::beginTransaction()`, `commit()` или `rollback()`. Корректный откат возможен только в рамках одной транзакции, если она не завершена успешно. При работе с несколькими базами данных или распределенными системами полная атомарность невозможна без внешних механизмов координации.

Архитектура транзакции: уровни изоляции и блокировки

Перед началом работы необходимо определить уровень изоляции. По умолчанию в MySQL используется `READ COMMITTED`, но для финансовых операций часто требуется `REPEATABLE READ` или `SERIALIZABLE`. Уровень изоляции влияет на видимость данных других транзакций и вероятность возникновения проблем с блокировками.

Блокировки возникают, когда одна транзакция пытается изменить данные, занятые другой. Если первая транзакция не завершилась за разумное время (таймаут), вторая может зависнуть или получить ошибку `Lock wait timeout exceeded`. Необходимо настроить `innodb_lock_wait_timeout` в конфигурации базы данных.

Важно понимать разницу между ошибкой SQL (например, синтаксическая ошибка) и логической ошибкой бизнес-логики. PDO откатывает транзакцию только при возникновении исключения (`PDOException`). Логические ошибки требуют ручной проверки условий и вызова `rollback()`.

Пошаговая реализация: код и логика

Шаг 1. Инициализация соединения и создание транзакции.

Создайте объект PDO с флагом `PDO::ATTR_ERRMODE` установленным в `PDO::ERRMODE_EXCEPTION`. Это позволит перехватывать ошибки как исключения PHP. Вызовите `$pdo->beginTransaction()` перед любыми изменениями данных.

Шаг 2. Выполнение операций.

Выполняйте все необходимые запросы (`INSERT`, `UPDATE`, `DELETE`) внутри цикла или последовательно. Используйте параметризированные запросы для защиты от SQL-инъекций.

Шаг 3. Обработка ошибок и принятие решения.

После каждого критического запроса проверяйте результат. Если возникло исключение, немедленно вызывайте `$pdo->rollback()`. Если все операции прошли успешно, вызовите `$pdo->commit()`.

Шаг 4. Завершение транзакции.

Транзакция должна быть закрыта после завершения работы или при ошибке. Не оставляйте соединение в состоянии активной транзакции надолго, так как это блокирует ресурсы базы данных.

Как оценить результат и проверить корректность

Проверка целостности: после завершения транзакции выполните SELECT-запрос для подтверждения изменений. Если данные не изменились, значит, произошла ошибка или откат.

Мониторинг блокировок: используйте системные таблицы MySQL (`information_schema.innodb_trx`, `innodb_locks`) для анализа активных транзакций и времени их выполнения.

Логирование: записывайте в лог файл статус каждой транзакции (успех, откат, причина ошибки). Это поможет быстро найти проблему при повторном возникновении.

Ограничения и частые ошибки

Ограничение по одной базе данных: стандартный PDO не поддерживает распределенные транзакции (2PC) напрямую. Для работы с несколькими базами данных используйте внешние механизмы, например, очереди сообщений или специализированные драйверы.

Ошибка «забытый откат»: если код завершается аварийно после `commit()`, изменения сохраняются. Всегда проверяйте флаг `$pdo->inTransaction()` перед началом работы и не забывайте закрывать транзакцию явно.

Проблема с большими объемами данных: при работе с миллионами строк транзакция может занять много времени, что приведет к блокировкам. В таких случаях разбивайте работу на несколько мелких транзакций или используйте пакетные операции.

Практический пример кода

Пример структуры функции для обработки транзакции:

«`php
function processTransaction(PDO $pdo, array $data): bool {
try {
$pdo->beginTransaction();

// Операция 1: создание записи
$stmt = $pdo->prepare('INSERT INTO users (name, email) VALUES (:name, :email)');
$stmt->execute([':name' => $data['name'], ':email' => $data['email']]);

// Операция 2: начисление баланса
$stmt = $pdo->prepare('UPDATE accounts SET balance = balance + :amount WHERE user_id = :id');
$stmt->execute([':amount' => $data['amount'], ':id' => $data['user_id']]);

// Операция 3: создание транзакции в журнале
$stmt = $pdo->prepare('INSERT INTO transactions (user_id, amount, type) VALUES (:id, :amount, :type)');
$stmt->execute([':id' => $data['user_id'], ':amount' => $data['amount'], ':type' => 'credit']);

// Успех
$pdo->commit();
return true;

} catch (PDOException $e) {
// Откат при ошибке
$pdo->rollback();
error_log('Transaction failed: ' . $e->getMessage());
return false;
}
}
«`

В этом примере все три операции выполняются в рамках одной транзакции. Если любая из них вызовет исключение, изменения отменятся.

FAQ: дополнительные вопросы

Вопрос: Что делать, если нужно откатить только часть операций?

Ответ: Стандартный PDO не поддерживает частичные откаты внутри одной транзакции. Необходимо завершить текущую транзакцию (`commit()` или `rollback()`) и начать новую.

Вопрос: Как избежать блокировок при высокой нагрузке?

Ответ: Используйте уровни изоляции с меньшим количеством блокировок (например, `READ COMMITTED`), оптимизируйте индексы и разбивайте большие транзакции на мелкие.

Вопросы и ответы

Можно ли откатить только одну операцию внутри транзакции?

Нет, механизм транзакций в PDO работает атомарно: либо все операции выполняются, либо ни одна. Частичный откат невозможен без завершения текущей транзакции и начала новой.

Как определить, что транзакция успешно завершена?

Успешное завершение подтверждается вызовом метода `commit()` без ошибок и отсутствием исключений. Рекомендуется выполнить контрольный SELECT-запрос для проверки данных.

Что делать, если транзакция зависла на длительное время?

Если транзакция выполняется дольше таймаута блокировок (`innodb_lock_wait_timeout`), она может быть принудительно завершена администратором базы данных или через утилиту `mysqladmin kill`. В коде следует учитывать возможность таймаута и обрабатывать соответствующие исключения.

function processTransaction(PDO $pdo, array $data): bool {
    try {
        $pdo->beginTransaction();
        
        // Операция 1: создание записи
        $stmt = $pdo->prepare('INSERT INTO users (name, email) VALUES (:name, :email)');
        $stmt->execute([':name' => $data['name'], ':email' => $data['email']]);
        
        // Операция 2: начисление баланса
        $stmt = $pdo->prepare('UPDATE accounts SET balance = balance + :amount WHERE user_id = :id');
        $stmt->execute([':amount' => $data['amount'], ':id' => $data['user_id']]);
        
        // Операция 3: создание транзакции в журнале
        $stmt = $pdo->prepare('INSERT INTO transactions (user_id, amount, type) VALUES (:id, :amount, :type)');
        $stmt->execute([':id' => $data['user_id'], ':amount' => $data['amount'], ':type' => 'credit']);
        
        // Успех
        $pdo->commit();
        return true;
        
    } catch (PDOException $e) {
        // Откат при ошибке
        $pdo->rollback();
        error_log('Transaction failed: ' . $e->getMessage());
        return false;
    }
}