vendor/doctrine/orm/src/Query/Exec/SingleTableDeleteUpdateExecutor.php line 43

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Doctrine\ORM\Query\Exec;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Connections\PrimaryReadReplicaConnection;
  9. use Doctrine\ORM\Query\AST;
  10. use Doctrine\ORM\Query\SqlWalker;
  12. /**
  13.  * Executor that executes the SQL statements for DQL DELETE/UPDATE statements on classes
  14.  * that are mapped to a single table.
  15.  *
  16.  * @link        www.doctrine-project.org
  17.  */
  18. class SingleTableDeleteUpdateExecutor extends AbstractSqlExecutor
  19. {
  20.     /** @param SqlWalker $sqlWalker */
  21.     public function __construct(AST\Node $AST, $sqlWalker)
  22.     {
  23.         parent::__construct();
  25.         if ($AST instanceof AST\UpdateStatement) {
  26.             $this->sqlStatements = $sqlWalker->walkUpdateStatement($AST);
  27.         } elseif ($AST instanceof AST\DeleteStatement) {
  28.             $this->sqlStatements = $sqlWalker->walkDeleteStatement($AST);
  29.         }
  30.     }
  32.     /**
  33.      * {@inheritDoc}
  34.      *
  35.      * @return int
  36.      */
  37.     public function execute(Connection $conn, array $params, array $types)
  38.     {
  39.         if ($conn instanceof PrimaryReadReplicaConnection) {
  40.             $conn->ensureConnectedToPrimary();
  41.         }
  43.         return $conn->executeStatement($this->sqlStatements, $params, $types);
  44.     }
  45. }