Транзакции

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

Когда использовать транзакцииКогда использовать транзакции

• При сложных изменениях данных, которые состоят из нескольких операций.

• Когда важно, чтобы другие процессы не видели промежуточные результаты.

Как работать с транзакциямиКак работать с транзакциями

Используйте объект Bitrix\Main\DB\Connection. Внутри транзакции можно выполнять SQL-запросы или работать с ORM:

$db = \Bitrix\Main\Application::getConnection();
        
        try {
            $db->startTransaction();
        
            // Пример SQL-запроса
            $db->queryExecute(
        		"UPDATE my_table SET active = '".\$db->getSqlHelper()->forSql('N')."' WHERE age > ".(int)0
        	);
        
            // Пример изменения через ORM
            \Bitrix\Main\SiteTable::update('s1', ['ACTIVE' => 'N']);
        
            $db->commitTransaction();
        } catch (Throwable $e) {
            $db->rollbackTransaction();
            throw $e;
        }
        

• startTransaction() — начинает новую транзакцию. Все последующие операции будут частью этой транзакции до ее завершения.

• commitTransaction() — подтверждает транзакцию, применяя все изменения в базе данных. Если транзакция успешна, данные сохраняются.

• rollbackTransaction() — отменяет транзакцию, отменяя все изменения, сделанные в ее рамках. Используется при ошибках для возврата в исходное состояние.

Особенности вложенных транзакцийОсобенности вложенных транзакций

Можно вызывать транзакции внутри других транзакций. В этом случае:

• startTransaction() внутри другой транзакции создает точку сохранения — SAVEPOINT,

• commitTransaction() во вложенной транзакции ничего не сохраняет в БД — сохранение происходит при коммите внешней транзакции,

• rollbackTransaction() делает частичный откат до точки сохранения и выбрасывает исключение TransactionException.

Что может произойти дальше:

• если исключение не поймано — скрипт упадет, MySQL откатит все изменения,

• если вы поймали исключение и решили продолжить — изменения из внешней транзакции могут быть сохранены,

• если вы решили откатить и сами находитесь во вложенной транзакции — процесс повторится на уровень выше.

Как обрабатывать ошибки во вложенных транзакцияхКак обрабатывать ошибки во вложенных транзакциях

Если вложенная транзакция завершилась с ошибкой:

1. откатите основную транзакцию полностью — rollbackTransaction,

2. решите, как следует обработать ошибку — залогировать, повторить операцию или выполнить другие действия.

use Bitrix\Main\Application;
        use Bitrix\Main\DB\Connection;
        use Bitrix\Main\DB\SqlExpression;
        use Bitrix\Main\DB\TransactionException;
        
        // Функция обновления счетов
        function updateAccounts(int $userId, Connection $db) {
            try {
                $db->startTransaction();
                // Ваш код изменения данных
                $db->commitTransaction();
            } catch (Throwable $e) {
                $db->rollbackTransaction();
                throw $e;
            }
        }
        
        // Функция обновления заказов
        function updateOrders(int $userId, Connection $db) {
            try {
                $db->startTransaction();
                // Ваш SQL-запрос
                $db->commitTransaction();
            } catch (Throwable $e) {
                $db->rollbackTransaction();
                throw $e;
            }
        }
        
        // Основная транзакция
        $db = Application::getConnection();
        
        try {
            $db->startTransaction();
            
            updateOrders($userId, $db);    // Вложенная транзакция
            updateAccounts($userId, $db);  // Вложенная транзакция
            
            $db->commitTransaction();
        } catch (TransactionException $e) {
            // Если ошибка во вложенной транзакции
            $db->rollbackTransaction();  // Откатываем все
        } catch (Throwable $e) {
            $db->rollbackTransaction();
            throw $e;
        }