src/Core/Framework/DataAbstractionLayer/Doctrine/RetryableTransaction.php line 21

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\DataAbstractionLayer\Doctrine;
  5. use Doctrine\DBAL\Connection;
  6. use Doctrine\DBAL\Exception\RetryableException;
  7. use Shopware\Core\Framework\Log\Package;
  9. #[Package('core')]
  10. class RetryableTransaction
  11. {
  12.     /**
  13.      * Executes the given closure inside a DBAL transaction. In case of a deadlock (RetryableException) the transaction
  14.      * is rolled back and the closure will be retried. Because it may run multiple times the closure should not cause
  15.      * any side effects outside of its own scope.
  16.      *
  17.      * @return mixed
  18.      */
  19.     public static function retryable(Connection $connection, \Closure $closure)
  20.     {
  21.         return self::retry($connection, $closure, 0);
  22.     }
  24.     /**
  25.      * @param \Closure(Connection):mixed $closure The function to execute transactionally.
  26.      *
  27.      * @return mixed
  28.      */
  29.     private static function retry(Connection $connection, \Closure $closure, int $counter)
  30.     {
  31.         ++$counter;
  33.         try {
  34.             return $connection->transactional($closure);
  35.         } catch (RetryableException $retryableException) {
  36.             if ($connection->getTransactionNestingLevel() > 0) {
  37.                 // If this RetryableTransaction was executed inside another transaction, do not retry this nested
  38.                 // transaction. Remember that the whole (outermost) transaction was already rolled back by the database
  39.                 // when any RetryableException is thrown.
  40.                 // Rethrow the exception here so only the outermost transaction is retried which in turn includes this
  41.                 // nested transaction.
  42.                 throw $retryableException;
  43.             }
  45.             if ($counter > 10) {
  46.                 throw $retryableException;
  47.             }
  49.             // Randomize sleep to prevent same execution delay for multiple statements
  50.             usleep(random_int(10, 20));
  52.             return self::retry($connection, $closure, $counter);
  53.         }
  54.     }
  55. }