databaselist.php

<?php
if(!defined('INITIALIZED'))
exit;

class DatabaseList extends DatabaseHandler implements Iterator, Countable
{
    public $data;
    public $iterator = 0;
    public $class;
    public $table;
    public $tables = array();
    public $fields = array();
    public $extraFields = array();
    public $filter;
    public $orders = array();
    public $limit;
    public $offset = 0;

    public function __construct($class = null)
    {
        if($class !== null)
        $this->setClass($class);
    }

    public function load()
    {
        $fieldsArray = array();

        if(count($this->fields) > 0)
        foreach($this->fields as $fieldName)
            $fieldsArray[$fieldName] = $this->getDatabaseHandler()->tableName($this->table) . '.' . $this->getDatabaseHandler()->fieldName($fieldName);

        if(count($this->extraFields) > 0)
        foreach($this->extraFields as $field)
            if(!$field->hasAlias())
                $fieldsArray[] = $this->getDatabaseHandler()->tableName($field->getTable()) . '.' . $this->getDatabaseHandler()->fieldName($field->getName());
            else
                $fieldsArray[] = $this->getDatabaseHandler()->tableName($field->getTable()) . '.' . $this->getDatabaseHandler()->fieldName($field->getName()) . ' AS ' . $this->getDatabaseHandler()->fieldName($field->getAlias());

        $tables = array();
        foreach($this->tables as $table)
            $tables[] = $this->getDatabaseHandler()->tableName($table);

        $filter = '';
        if($this->filter !== null)
            $filter = ' WHERE ' .$this->filter->__toString();

        $order = '';
        $orders = array();
        if(count($this->orders) > 0)
        {
            foreach($this->orders as $_tmp_order)
                $orders[] = $_tmp_order->__toString();
            if(count($orders) > 0)
                $order = ' ORDER BY ' . implode(', ', $orders);
        }

        $limit = '';
        if($this->limit !== null)
            $limit = ' LIMIT ' . (int) $this->limit;

        $offset = '';
        if($this->offset > 0)
            $offset = ' OFFSET ' . (int) $this->offset;

        $query = 'SELECT ' . implode(', ', $fieldsArray) . ' FROM ' . implode(', ', $tables) . $filter . $order . $limit . $offset;

        $this->data = $this->getDatabaseHandler()->query($query)->fetchAll();
    }

    public function getResult($id)
    {
    if(!isset($this->data))
    $this->load();
    if(isset($this->data[$id]))
    {
    if(!is_object($this->data[$id]))
    {
    $_tmp = new $this->class();
    $_tmp->loadData($this->data[$id]);
    return $_tmp;
    }
    else
    return $this->data[$id];
    }
    else
    return false;
    }

    public function addExtraField($field)
    {
    $this->extraFields[] = $field;
    $this->addTables($field->getTable());
    }

    public function addOrder($order)
    {
    $this->orders[] = $order;
    }

    public function setClass($class)
    {
    $this->class = $class;
    $instance = new $this->class();
    $this->fields = $instance::$fields;
    if(isset($instance::$extraFields))
    foreach($instance::$extraFields as $extraField)
    {
    if(!isset($extraField[2]))
    $this->extraFields[] = new SQL_Field($extraField[0], $extraField[1]);
    else
    $this->extraFields[] = new SQL_Field($extraField[0], $extraField[1], $extraField[2]);
    $this->tables[$extraField[1]] = $extraField[1];
    }
    $this->table = $instance::$table;
    $this->tables[$instance::$table] = $instance::$table;
    }

    public function setFilter($filter)
    {
    $this->addTables($filter->getTables());
    $this->filter = $filter;
    }

    public function setLimit($limit)
    {
    $this->limit = $limit;
    }

    public function setOffset($offset)
    {
    $this->offset = $offset;
    }

    public function addTables($tables)
    {
    if(is_array($tables))
    {
    foreach($tables as $table)
    if($table != '' && !in_array($table, $this->tables))
    $this->tables[$table] = $table;
    }
    elseif($tables != '' && !in_array($tables, $this->tables))
    $this->tables[$tables] = $tables;
    }

    public function current()
    {
        return $this->getResult($this->iterator);
    }

    public function rewind()
    {
    if(!isset($this->data))
    $this->load();
        $this->iterator = 0;
    }

    public function next()
    {
        ++$this->iterator;
    }

    public function key()
    {
        return $this->iterator;
    }

    public function valid()
    {
        return isset($this->data[$this->iterator]);
    }

    public function count()
    {
    if(!isset($this->data))
        $this->load();
        return count($this->data);
    }
}