vendor/shopware/core/Framework/DataAbstractionLayer/Doctrine/RetryableQuery.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 Doctrine\DBAL\Statement;
  8. use Shopware\Core\Framework\Log\Package;
  10. #[Package('core')]
  11. class RetryableQuery
  12. {
  13.     public function __construct(
  14.         private readonly ?Connection $connection,
  15.         private readonly Statement $query
  16.     ) {
  17.     }
  19.     public function execute(array $params = []): int
  20.     {
  21.         return self::retry($this->connection, fn () => $this->query->executeStatement($params), 0);
  22.     }
  24.     public static function retryable(Connection $connection, \Closure $closure)
  25.     {
  26.         return self::retry($connection, $closure, 0);
  27.     }
  29.     public function getQuery(): Statement
  30.     {
  31.         return $this->query;
  32.     }
  34.     private static function retry(?Connection $connection, \Closure $closure, int $counter)
  35.     {
  36.         ++$counter;
  38.         try {
  39.             return $closure();
  40.         } catch (RetryableException $e) {
  41.             if ($connection && $connection->getTransactionNestingLevel() > 0) {
  42.                 // If this closure was executed inside a transaction, do not retry. Remember that the whole (outermost)
  43.                 // transaction was already rolled back by the database when any RetryableException is thrown. Rethrow
  44.                 // the exception here so only the outermost transaction is retried which in turn includes this closure.
  45.                 throw $e;
  46.             }
  48.             if ($counter > 10) {
  49.                 throw $e;
  50.             }
  52.             // randomize sleep to prevent same execution delay for multiple statements
  53.             usleep(20 * $counter);
  55.             return self::retry($connection, $closure, $counter);
  56.         }
  57.     }
  58. }