vendor/doctrine/orm/lib/Doctrine/ORM/NativeQuery.php line 65

Open in your IDE?
  1. <?php
  3. /*
  4.  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  5.  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  6.  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  7.  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  8.  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  9.  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  10.  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  11.  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  12.  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  13.  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  14.  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  15.  *
  16.  * This software consists of voluntary contributions made by many individuals
  17.  * and is licensed under the MIT license. For more information, see
  18.  * <http://www.doctrine-project.org>.
  19.  */
  21. namespace Doctrine\ORM;
  23. use function array_values;
  24. use function is_int;
  25. use function key;
  26. use function ksort;
  28. /**
  29.  * Represents a native SQL query.
  30.  */
  31. final class NativeQuery extends AbstractQuery
  32. {
  33.     /** @var string */
  34.     private $sql;
  36.     /**
  37.      * Sets the SQL of the query.
  38.      *
  39.      * @param string $sql
  40.      *
  41.      * @return self This query instance.
  42.      */
  43.     public function setSQL($sql): self
  44.     {
  45.         $this->sql = $sql;
  47.         return $this;
  48.     }
  50.     /**
  51.      * Gets the SQL query.
  52.      *
  53.      * @return mixed The built SQL query or an array of all SQL queries.
  54.      *
  55.      * @override
  56.      */
  57.     public function getSQL()
  58.     {
  59.         return $this->sql;
  60.     }
  62.     /**
  63.      * {@inheritdoc}
  64.      */
  65.     protected function _doExecute()
  66.     {
  67.         $parameters = [];
  68.         $types      = [];
  70.         foreach ($this->getParameters() as $parameter) {
  71.             $name  = $parameter->getName();
  72.             $value = $this->processParameterValue($parameter->getValue());
  73.             $type  = $parameter->getValue() === $value
  74.                 ? $parameter->getType()
  75.                 : Query\ParameterTypeInferer::inferType($value);
  77.             $parameters[$name] = $value;
  78.             $types[$name]      = $type;
  79.         }
  81.         if ($parameters && is_int(key($parameters))) {
  82.             ksort($parameters);
  83.             ksort($types);
  85.             $parameters = array_values($parameters);
  86.             $types      = array_values($types);
  87.         }
  89.         return $this->_em->getConnection()->executeQuery(
  90.             $this->sql,
  91.             $parameters,
  92.             $types,
  93.             $this->_queryCacheProfile
  94.         );
  95.     }
  96. }