laravel_db_savepoints

<?php

use Illuminate\Database\PostgresConnection as Connection;

class DBTransaction
{
    /**
     * Выполнение функкции в транзакции с возможностью указывать точки сохранения.
     * - Если функция выполнится без ошибки (Exception), произойдёт полный коммит
     * - Если функция выбросит исключение, то произойдёт коммит от начала до последнего вызовы `savepoint()`
     */
    public static function run(Connection $connection, Callable $fn)
    {
        $startLevel = $connection->transactionLevel();
        $connection->beginTransaction();

        $transaction = new self($connection);

        try {
            return $fn($transaction);
        }
        catch(\Exception $e) {
            $connection->rollBack($startLevel + $transaction->savepoints);
            throw $e;
        }
        finally {
            $endLevel = $connection->transactionLevel();

            for ($n = $startLevel; $n <= $endLevel; $n++) {
                $connection->commit();
            }
        }
    }

    /** @var Connection */
    protected $connection;
    protected $savepoints = 0;

    protected function __construct(Connection $connection)
    {
        $this->connection = $connection;
    }

    public function savepoint()
    {
        $this->savepoints++;
        $this->connection->beginTransaction();
    }
}