[Summary view] [Print] [Text view]

   1  <?php
   2  /*
   3   * Limb PHP Framework
   4   *
   5   * @link http://limb-project.com 
   6   * @copyright  Copyright &copy; 2004-2007 BIT(http://bit-creative.com)
   7   * @license    LGPL http://www.gnu.org/copyleft/lesser.html 
   8   */
   9  
  10  lmb_require('limb/dbal/src/drivers/lmbDbQueryStatement.interface.php');
  11  lmb_require(dirname(__FILE__) . '/lmbPgsqlStatement.class.php');
  12  lmb_require(dirname(__FILE__) . '/lmbPgsqlRecord.class.php');
  13  lmb_require(dirname(__FILE__) . '/lmbPgsqlRecordSet.class.php');
  14  lmb_require(dirname(__FILE__) . '/lmbPgsqlArraySet.class.php');
  15  
  16  /**

  17   * class lmbPgsqlQueryStatement.

  18   *

  19   * @package dbal

  20   * @version $Id: lmbPgsqlQueryStatement.class.php 5945 2007-06-06 08:31:43Z pachanga $

  21   */
  22  class lmbPgsqlQueryStatement extends lmbPgsqlStatement implements lmbDbQueryStatement
  23  {
  24    function getOneRecord()
  25    {
  26      $record = new lmbPgsqlRecord();
  27      $queryId = $this->connection->execute($this->getSQL());
  28      $values = pg_fetch_assoc($queryId);
  29      $record->import($values);
  30      pg_free_result($queryId);
  31      if(is_array($values))
  32        return $record;
  33    }
  34  
  35    function getOneValue()
  36    {
  37      $queryId = $this->connection->execute($this->getSQL());
  38      $row = pg_fetch_row($queryId);
  39      pg_free_result($queryId);
  40      if(is_array($row))
  41        return $row[0];
  42    }
  43  
  44    function getOneColumnAsArray()
  45    {
  46      $column = array();
  47      $queryId = $this->connection->execute($this->getSQL());
  48      while(is_array($row = pg_fetch_row($queryId)))
  49        $column[] = $row[0];
  50      pg_free_result($queryId);
  51      return $column;
  52    }
  53  
  54    function getRecordSet()
  55    {
  56      return new lmbPgsqlRecordSet($this->connection, $this->getSQL());
  57    }
  58  }
  59  
  60  ?>