Statement.php

Ir para a documentação deste ficheiro.

<?php
/*
 *  $Id$
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the LGPL. For more information, see
 * <http://www.doctrine-project.org>.
 */
 
namespace Doctrine\DBAL;
 
use PDO,
    Doctrine\DBAL\Types\Type,
    Doctrine\DBAL\Driver\Statement as DriverStatement;
 
class Statement implements DriverStatement
{
    private $_sql;
    private $_params = array();
    private $_stmt;
    private $_platform;
    private $_conn;
 
    public function __construct($sql, Connection $conn)
    {
        $this->_sql = $sql;
        $this->_stmt = $conn->getWrappedConnection()->prepare($sql);
        $this->_conn = $conn;
        $this->_platform = $conn->getDatabasePlatform();
    }
 
    public function bindValue($name, $value, $type = null)
    {
        $this->_params[$name] = $value;
        if ($type !== null) {
            if (is_string($type)) {
                $type = Type::getType($type);
            }
            if ($type instanceof Type) {
                $value = $type->convertToDatabaseValue($value, $this->_platform);
                $bindingType = $type->getBindingType();
            } else {
                $bindingType = $type; // PDO::PARAM_* constants
            }
            return $this->_stmt->bindValue($name, $value, $bindingType);
        } else {
            return $this->_stmt->bindValue($name, $value);
        }
    }
 
    public function bindParam($name, &$var, $type = PDO::PARAM_STR)
    {
        return $this->_stmt->bindParam($name, $var, $type);
    }
 
    public function execute($params = null)
    {
        $hasLogger = $this->_conn->getConfiguration()->getSQLLogger();
        if ($hasLogger) {
            $this->_conn->getConfiguration()->getSQLLogger()->startQuery($this->_sql, $this->_params);
        }
 
        $stmt = $this->_stmt->execute($params);
 
        if ($hasLogger) {
            $this->_conn->getConfiguration()->getSQLLogger()->stopQuery();
        }
        $this->_params = array();
        return $stmt;
    }
 
    public function closeCursor()
    {
        return $this->_stmt->closeCursor();
    }
 
    public function columnCount()
    {
        return $this->_stmt->columnCount();
    }
 
    public function errorCode()
    {
        return $this->_stmt->errorCode();
    }
 
    public function errorInfo()
    {
        return $this->_stmt->errorInfo();
    }
 
    public function fetch($fetchStyle = PDO::FETCH_BOTH)
    {
        return $this->_stmt->fetch($fetchStyle);
    }
 
    public function fetchAll($fetchStyle = PDO::FETCH_BOTH, $columnIndex = 0)
    {
        if ($columnIndex != 0) {
            return $this->_stmt->fetchAll($fetchStyle, $columnIndex);
        }
        return $this->_stmt->fetchAll($fetchStyle);
    }
 
    public function fetchColumn($columnIndex = 0)
    {
        return $this->_stmt->fetchColumn($columnIndex);
    }
 
    public function rowCount()
    {
        return $this->_stmt->rowCount();
    }
 
    public function getWrappedStatement()
    {
        return $this->_stmt;
    }
}