1 <?php 

     2 /*

     3  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

     4  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

     5  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

     6  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

     7  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

     8  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

     9  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

    10  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

    11  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

    12  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

    13  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

    14  *

    15  * This software consists of voluntary contributions made by many individuals

    16  * and is licensed under the LGPL. For more information, see

    17  * <http://www.doctrine-project.org>.

    18  */

    19 

    20 namespace Doctrine\ORM;

    21 

    22 /**

    23  * Represents a native SQL query.

    24  *

    25  * @author Roman Borschel <roman@code-factory.org>

    26  * @since 2.0

    27  */

    28 final class NativeQuery extends AbstractQuery

    29 {

    30     private $_sql;

    31 

    32     /**

    33      * Sets the SQL of the query.

    34      *

    35      * @param string $sql

    36      * @return NativeQuery This query instance.

    37      */

    38     public function setSQL($sql)

    39     {

    40         $this->_sql = $sql;

    41         return $this;

    42     }

    43 

    44     /**

    45      * Gets the SQL query.

    46      *

    47      * @return mixed The built SQL query or an array of all SQL queries.

    48      * @override

    49      */

    50     public function getSQL()

    51     {

    52         return $this->_sql;

    53     }

    54 

    55     /**

    56      * {@inheritdoc}

    57      */

    58     protected function _doExecute()

    59     {

    60         $stmt = $this->_em->getConnection()->prepare($this->_sql);

    61         $params = $this->_params;

    62         foreach ($params as $key => $value) {

    63             if (isset($this->_paramTypes[$key])) {

    64                 $stmt->bindValue($key, $value, $this->_paramTypes[$key]);

    65             } else {

    66                 $stmt->bindValue($key, $value);

    67             }

    68         }

    69         $stmt->execute();

    70 

    71         return $stmt;

    72     }

    73 }