Форум

class DB
{
   protected static $transactions = 0;

   public static function transaction(Closure $callback)
   {
      self::beginTransaction();

      try {
         $result = $callback();
      } catch (Throwable $e) {
         self::rollbackTransaction();

         throw $e;
      }

      try {
         if (self::$transactions == 1) {
            Application::getConnection()->commitTransaction();
         }

         self::$transactions = max(0, self::$transactions - 1);
      } catch (Throwable $e) {
         self::$transactions = 0;
      }

      return $result;
   }

   public static function beginTransaction()
   {
      if (self::$transactions == 0) {
         Application::getConnection()->startTransaction();
      } elseif (self::$transactions >= 1) {
         self::createSavepoint();
      }

      self::$transactions++;
   }

   public static function rollbackTransaction()
   {
      $toLevel = min(0, self::$transactions - 1);

      if ($toLevel == 0) {
         Application::getConnection()->rollbackTransaction();
      } else {
         self::removeSavepoint($toLevel + 1);
      }

      self::$transactions = $toLevel;
   }

   protected static function createSavepoint()
   {
      Application::getConnection()->query('SAVEPOINT trans' . (self::$transactions + 1));
   }

   protected static function removeSavepoint(int $level)
   {
      Application::getConnection()->query('ROLLBACK TO SAVEPOINT trans' . $level);
   }
}

DB::transaction(function () {
    // update
    DB::transaction(function () {    
        // update
    });
    DB::transaction(function () { 
        // update
        throw new Exception()
    });
    // insert
});

// sql
START TRANSACTION
UPDATE ...
SAVEPOINT trans1
UPDATE ...
SAVEPOINT trans2
UPDATE ...
ROLLBACK TO SAVEPOINT trans2
INSERT ...
COMMIT