classes/db/DAOResultFactory.inc.php

<?php

// $Id: DAOResultFactory.inc.php,v 1.14 2008/07/01 01:16:09 asmecher Exp $


import('core.ItemIterator');

class DAOResultFactory extends ItemIterator {
   var $dao;

   var $functionName;

   var $records;

   var $wasEmpty;

   var $isFirst;
   var $isLast;
   var $page;
   var $count;
   var $pageCount;

   function DAOResultFactory(&$records, &$dao, $functionName) {
      $this->functionName = $functionName;
      $this->dao = &$dao;

      if (!$records || $records->EOF) {
         if ($records) $records->Close();
         $this->records = null;
         $this->wasEmpty = true;
         $this->page = 1;
         $this->isFirst = true;
         $this->isLast = true;
         $this->count = 0;
         $this->pageCount = 1;
      }
      else {
         $this->records = &$records;
         $this->wasEmpty = false;
         $this->page = $records->AbsolutePage();
         $this->isFirst = $records->atFirstPage();
         $this->isLast = $records->atLastPage();
         $this->count = $records->MaxRecordCount();
         $this->pageCount = $records->LastPageNo();
      }
   }

   function &next() {
      if ($this->records == null) return $this->records;
      if (!$this->records->EOF) {
         $functionName = &$this->functionName;
         $dao = &$this->dao;
         $row = &$this->records->getRowAssoc(false);
         $result = &$dao->$functionName($row);
         if (!$this->records->MoveNext()) $this->_cleanup();
         return $result;
      } else {
         $this->_cleanup();
         $nullVar = null;
         return $nullVar;
      }
   }

   function &nextWithKey() {
      // We don't have keys with rows. (Row numbers might become
      // valuable at some point.)
      return array(null, $this->next());
   }

   function atFirstPage() {
      return $this->isFirst;
   }

   function atLastPage() {
      return $this->isLast;
   }

   function getPage() {
      return $this->page;
   }

   function getCount() {
      return $this->count;
   }

   function getPageCount() {
      return $this->pageCount;
   }

   function eof() {
      if ($this->records == null) return true;
      if ($this->records->EOF) {
         $this->_cleanup();
         return true;
      }
      return false;
   }

   function wasEmpty() {
      return $this->wasEmpty;
   }

   function _cleanup() {
      $this->records->close();
      unset($this->records);
      $this->records = null;
   }

   function &toArray() {
      $returner = array();
      while (!$this->eof()) {
         $returner[] = $this->next();
      }
      return $returner;
   }

   function isInBounds() {
      return ($this->pageCount >= $this->page);
   }

   function &getLastPageRangeInfo() {
      import('db.DBResultRange');
      $returner =& new DBResultRange($this->count, $this->pageCount);
      return $returner;
   }
}

?>

---