File Source for Database.php

<?php
/**
* CNZ Framework
*
* A Framework for Creating and Using Complex Web Elements
*
* The purpose of this framework is to provide a library of high-level objects
* to facilitate common HTML coding tasks, such as menus, tables, and forms.
* The intent is to reduce repetitive HTML coding as much as possible, replacing
* it with a combination of configuration files and style sheets with
* standardized naming conventions.
*
* This framework is built on and requires the
* {@link http://framework.zend.com/ Zend Framework}.
*
* @category Cnz
* @package Cnz_Html
* @subpackage Table
*
* @author Lyle Frost <lfrost@cnz.com>
* @copyright Copyright (c) 2006-2007 Citadel Network <{@link http://www.citadelnetwork.com/}>
* @filesource
* @license http://www.citadelnetwork.com/license/cnzframework New BSD License
* @version $Id: Database.php 27 2007-07-19 18:47:54Z lfrost $
*/
/**
* Required classes.
*
* @ignore
*/
Zend_Loader::loadClass('Cnz_Html_Table');
Zend_Loader::loadClass('Zend_Filter');
Zend_Loader::loadClass('Zend_Filter_Alnum');
Zend_Loader::loadClass('Zend_Db_Select');
/**
* HTML Table Database class
*
* @category Cnz
* @package Cnz_Html
* @subpackage Table
*
* @see Cnz_Html_Table
*/
class Cnz_Html_Table_Database extends Cnz_Html_Table
{
/**#@+ @var array */
private $filterArray = array();
private $joinArray = array();
/**#@-*/
/**#@+ @var string */
private $columns = '*';
private $from = NULL;
private $query = NULL;
/**#@-*/
/* Getters/Setters ===================================================*/
/** @return string Query */
public function getQuery()
{
return $this->query;
}
/**
* @param string $query New query
* @return void
*/
public function setQuery($query)
{
$this->query = $query;
return;
}
/* Methods ===========================================================*/
/**
* Option fields:
* none
*
* Configuration fields:
* cols
* from SQL from clause
* filters
* join
*
* @param array $options Options
* @param Zend_Config $config Configuration
*/
public function __construct(array $options = array())
{
parent::__construct($options);
// Process configuration.
if (isset($this->config->cols)) $this->columns = $this->config->cols;
if (isset($this->config->from)) $this->from = $this->config->from;
if (isset($this->config->filters)) $this->filterArray = Cnz_Html::listToArray($this->config->filters);
// Process joins.
if (isset($this->config->join))
{
for ($this->config->join->rewind(); $this->config->join->valid(); $this->config->join->next())
{
$joinConfig = $this->config->join->current();
$join = array();
$join['name'] = $this->config->join->key();
if (isset($joinConfig->type)) $join['type'] = $joinConfig->type;
// HACK: Zend_Config_Ini does not allow " in values.
if (isset($joinConfig->on)) $join['on'] = str_replace('`', '"', $joinConfig->on);
if (isset($joinConfig->columns)) $join['columns'] = explode(',', $joinConfig->columns);
$this->joinArray[] = $join;
}
}
return;
}
/**
* @return boolean Success
*/
protected function readData()
{
$offset = $this->offset;
$limit = $this->limit;
$db = Cnz_Html::getDb();
$order = array();
foreach ($this->orderArray as $name => $dir)
{
if (!empty($dir))
{
$dir = strtoupper($dir);
$name .= ' ' . $dir;
}
$order[] = $name;
}
$columns = array();
foreach ($this->columnArray as $column)
{
if (strlen($column->getExpression()) < 1)
{
$columns[] = $column->getName();
}
else
{
$columns[] = new Zend_Db_Expr($column->getExpression() . ' AS ' . $column->getName());
}
}
// Primary key (change to be configurable)
$columns[] = 'id';
// Count rows.
$select = $db->select();
$select->from($this->from, $columns)
->limit($this->limit, $this->offset)
->order($order);
foreach ($this->joinArray as $join)
{
$select->join($join['name'], $join['on'], $join['columns']);
}
// Filter.
foreach ($this->filterArray as $key => $value)
{
$select->where($key . ' = ?', $_POST[$key]);
}
$this->query = $select->__toString();
// FIX count for joins
$result = $db->query('SELECT count(*) FROM ' . $db->quoteIdentifier($this->from));
$rowSet = $result->fetchAll();
$this->rowCount = (int)$rowSet[0]['count'];
$this->pageCount = (int)ceil($this->rowCount / $limit);
if ($this->pageCount < 1) $this->pageCount = 1;
$this->pageNumber = $offset / $limit + 1;
// Get rows.
$result = $db->query($this->query);
$result->setFetchMode(Zend_Db::FETCH_ASSOC);
$this->rowArray = $result->fetchAll();
return true;
}
}

Source for file Database.php