Home | Classes | Modules | Annotated | Hierarchy | Functions | Files

Query.php

Go to the documentation of this file.

<?php

/*
 *  $Id: Query.php,v 1.7 2004/04/24 14:45:39 hlellelid Exp $
 *
 * 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 please see
 * <http://creole.phpdb.org>.
 */

class Query {
    
    protected $conn;
    
    protected $sql;
        
    protected $max = 0;
    
    protected $start = 0;
    
    public function __construct(Connection $conn, $sql = null)
    {
        $this->conn = $conn;
        $this->sql = $sql;
    }
    
    public function setSql($sql)
    {
        $this->sql = $sql;
    }
    
    public function setStart($v)
    {
        $this->start = $v;
    }
    
    public function setMax($v)
    {
        $this->max = $v;
    }
    
    public function getRows() 
    {
        $stmt = $this->conn->createStatement();
        if ($this->max) $stmt->setLimit($this->max);
        if ($this->start) $stmt->setOffset($this->start);
        $rs = $stmt->executeQuery($this->sql);
        $results = array();
        while($rs->next()) {
            $results[] = $rs->getRow();
        }
        $rs->close();
        $stmt->close();
        return $results;
    }

    public function getRow() 
    {
        $stmt = $this->conn->createStatement();
        if ($this->max) $stmt->setLimit($this->max);
        if ($this->start) $stmt->setOffset($this->start);
        $rs = $stmt->executeQuery($this->sql);
        $rs->next();
        $results = $rs->getRow();        
        $rs->close();
        $stmt->close();
        return $results;
    }
    
    public function getCol() 
    {
        $stmt = $this->conn->createStatement();
        if ($this->max) $stmt->setLimit($this->max);
        if ($this->start) $stmt->setOffset($this->start);
        $rs = $stmt->executeQuery($this->sql);
        $results = array();
        while($rs->next()) {
            $results[] = array_shift($rs->getRow());
        }
        $rs->close();
        $stmt->close();
        return $results;
    }
    
    public function getOne() 
    {
        $stmt = $this->conn->createStatement();
        if ($this->max) $stmt->setLimit($this->max);
        if ($this->start) $stmt->setOffset($this->start);
        $rs = $stmt->executeQuery($this->sql);
        $rs->next();
        $res = array_shift($rs->getRow());
        $rs->close();
        $stmt->close();
        return $res;
    }
    
    public function getAssoc($scalar = false)
    {
        $stmt = $this->conn->createStatement();
        if ($this->max) $stmt->setLimit($this->max);
        if ($this->start) $stmt->setOffset($this->start);
        $rs = $stmt->executeQuery($this->sql);
        
        $numcols = null;
        $results = array();
        while($rs->next()) {
            $fields = $rs->getRow();
            if ($numcols === null) {
                $numcols = count($fields);
            }
            if (!$scalar || ($numcols > 2)) {
                $results[ array_shift($fields) ] = array_values($fields);
            } else {
                $results[ array_shift($fields) ] = array_shift($fields);
            }
        }
        
        $rs->close();
        $stmt->close();
        
        return $results;
    }
    
    public function getDataSet()
    {
        include_once 'jargon/QueryDataSet.php';
        $qds = new QueryDataSet($this->conn, $this->sql);
        $qds->fetchRecords($this->start, $this->max);
        return $qds;
    }
} 

---

This file is part of the Creole[php5] library.