Home | Classes | Modules | Annotated | Functions | Files

Query.php

Go to the documentation of this file.

<?php

/*
 *  $Id: Query.php,v 1.1 2004/05/21 11:21:25 micha 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 
{
  var $conn;
  
  var $sql;
      
  var $max = 0;
  
  var $start = 0;
  
  function Query(/*Connection*/ &$conn, $sql = null)
  {
    if (! is_a($conn, 'Connection')) {
      trigger_error (
        "Query::Query(): parameter 1 not of type 'Connection' !",
        E_USER_ERROR
      );
    }

    $this->conn =& $conn;
    $this->sql = $sql;
  }
  
  function setSql($sql)
  {
    $this->sql = $sql;
  }
  
  function setStart($v)
  {
    $this->start = $v;
  }
  
  function setMax($v)
  {
    $this->max = $v;
  }
  
  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);
    $e = null; 

    if (Creole::isError($rs)) {
      return $rs;
    }

    $results = array();
    while(($e = $rs->next()) === true) {
      $results[] =& $rs->getRow();
    }

    if (Creole::isError($e)) {
      return $e;
    }

    $rs->close();
    $stmt->close();
    return $results;
  }

  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);
   
    if (Creole::isError($rs)) {
      return $rs;
    }

    $e = $rs->next();

    if (Creole::isError($e)) {
      return $e;
    }

    $results = $rs->getRow();        
    $rs->close();
    $stmt->close();
    return $results;
  }
  
  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);
    $e = null;

    if (Creole::isError($rs)) {
      return $rs;
    }

    $results = array();
    while(($e = $rs->next()) === true) {
      $results[] =& array_shift($rs->getRow());
    }

    if (Creole::isError($e)) {
      return $e;
    }

    $rs->close();
    $stmt->close();
    return $results;
  }
  
  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);

    if (Creole::isError($rs)) {
      return $rs;
    }

    $e = $rs->next();

    if (Creole::isError($e)) {
      return $e;
    }

    $res =& array_shift($rs->getRow());
    $rs->close();
    $stmt->close();
    return $res;
  }
  
  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);
    $e = null;

    if (Creole::isError($rs)) {
      return $rs;
    }

    $numcols = null;
    $results = array();

    while(($e = $rs->next()) === true) {
      $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);
      }
    }
    
    if (Creole::isError($e)) {
      return $e;
    }

    $rs->close();
    $stmt->close();
    
    return $results;
  }
  
  function &getDataSet()
  {
    include_once 'jargon/QueryDataSet.php';
    $qds =& new QueryDataSet($this->conn, $this->sql);
    $e =& $qds->fetchRecords($this->start, $this->max);

    if (Creole::isError($e)) {
      return $e;
    }

    return $qds;
  }
} 

---

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