<?php

/*
FileArts
Copyright (C) 2007 Peter Goodman, Geoffrey Goodman

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
*/

define ('DBA_BASE_DIR', dirname(__FILE__) . '/database/');

class FADatabase {
    function &connect($info) {
        static $connections = array();
    
        $name = (isset($info['name'])) ? $info['name'] : 'default';
    
        if (isset($connections[$name]))
            return $connections[$name];
    
        if (!isset($info['driver']))
            return trigger_error("No database driver specified", E_USER_ERROR);
    
        $driver = DBA_BASE_DIR."/{$info['driver']}.php";
        $class = "{$info['driver']}Connection";
    
        if (!is_readable($driver))
            return trigger_error("Database driver does not exist: {$info['driver']}", E_USER_ERROR);
    
        require_once $driver;
    
        if (!class_exists($class))
            return trigger_error("Database driver does not exist: {$info['driver']}", E_USER_ERROR);
    
        $dba = &new $class();
    
        if (!is_a($dba, 'FADatabaseConnection'))
            return trigger_error("Database driver does not extends FADatabaseConnection: {$info['driver']}", E_USER_ERROR);
        
        // Error is thrown in the constructor (hopefully)
        $dba->open($info);
    
        $connections[$name] = &$dba;
    
        return $connections[$name];
    }
    
    function &open($name) {
        return FADatabase::connect(array('name' => $name));
    }
}

class FADatabaseConnection {
	var $_dbinfo;
	var $_dispatcher;
	
	function FADatabaseConnection() {
		$this->_dispatcher = &new FADispatcher;
	}
	
	function addObserver(&$observer) {
		$this->_dispatcher->addObserver($observer);
	}
	
    function close() {
        assert(FALSE);
    }

    function connect($dbinfo) {
		assert(FALSE);
    }
    
    function executeQuery($query) {
        assert(FALSE);
    }
    
    function &createStatement($query) {
        assert(FALSE);
    }
    
    function &createTransaction() {
        assert(FALSE);
    }
	
	function notifyAll(&$event) {
		$this->_dispatcher->notifyAll($event);
	}
	
	function getRow($stmt, $args = array()) {
		$result = $this->executeQuery($stmt, $args);
		$result->next();
		return $result->current();
	}
	
	function open($dbinfo) {
		if ($ret = $this->connect($dbinfo)) {
			$this->_dbinfo = $dbinfo;
		}
		
		return $ret;
	}
}

class FADatabaseResult extends FAIterator {
	function get($column) {
        $current = $this->current();
        
		if (isset($current[$column]))
			return $current[$column];
	}

	function getDate($column, $format = '%x') {
        $current = $this->current();
        
		if (isset($current[$column]))
			return strftime($format, $current[$column]);
	}

	function getFloat($column) {
        $current = $this->current();
        
		if (isset($current[$column]))
			return (float)$current[$column];
	}

	function getInt($column) {
        $current = $this->current();
        
		if (isset($current[$column]))
			return (int)$current[$column];
	}

	function getString($column) {
        $current = $this->current();
        
		if (isset($current[$column]))
			return (string)$current[$column];
	}

	function getTime($column, $format = '%X') {
        $current = $this->current();
        
		if (isset($current[$column]))
			return strftime($format, $current[$column]);
	}

	function getTimestamp($column, $format = 'Y-m-d H:i:s') {
        $current = $this->current();
        
		if (isset($current[$column]))
			return date($format, $current[$column]);
	}
}

class FADatabaseQueryEvent extends FAObservableEvent 
{
	var $_message;
	var $_rows;
	var $_time;

	function FADatabaseQueryEvent($message, $rows = 0, $time = 0) 
	{
		$this->_message = $message;
		$this->_rows = $rows;
		$this->_time = $time;
	}

	function getMessage() 
	{
		return $this->_message;
	}
	
	function getRows() 
	{
		return $this->_rows;
	}
	
	function getTime()
	{
		return $this->_time;
	}
}

class FADatabaseStatement {
	function &executeQuery($mode = DBA_ASSOC) {
        assert(FALSE);
	}

	function executeUpdate($mode = DBA_ASSOC) {
        assert(FALSE);
	}
	
	function set($n, $value) {
		if (is_int($value) || is_float($value) || is_numeric($value)) {
			if (ctype_digit($value)) {
				$this->setInt($n, $value);
			} else {
				$this->setFloat($n, $value);
			}
		} elseif ($value === NULL) {
			$this->setNull($n);
		} else {
			$this->setString($n, $value);
		}
	}

	function setFloat($n, $value) {
        assert(FALSE);
	}

	function setInt($n, $value) {
        assert(FALSE);
	}

	function setNull($n) {
        assert(FALSE);
	}

	function setString($n, $value) {
        assert(FALSE);
	}

	function getSql() {
        assert(FALSE);
	}
}

class FABasicDatabaseStatement extends FADatabaseStatement {
	var $_dba;
	var $_stmt;
	var $_vars = array();

	function FABasicDatabaseStatement($stmt, &$dba) {
		$count = substr_count($stmt, '?');
        
		if ($count) {
			$this->_vars = array_fill(1, $count, 'NULL');
		}
		
		$this->_stmt = str_replace(array('%', '?'), array('%%', '%s'), $stmt);
		$this->_dba = &$dba;
	}

	function &executeQuery($mode = DBA_ASSOC) {
		return $this->_dba->executeQuery($this->getSql(), $mode);
	}

	function executeUpdate($mode = DBA_ASSOC) {
		return $this->_dba->executeUpdate($this->getSql(), $mode);
	}

	function setFloat($n, $value) {
		$this->_vars[$n] = floatval($value);
	}

	function setInt($n, $value) {
		$this->_vars[$n] = intval($value);
	}

	function setNull($n) {
		$this->_vars[$n] = 'NULL';
	}

	function setString($n, $value) {
		$this->_vars[$n] = "'".$this->_dba->quote($value)."'";
	}

	function getSql() {
		$stmt = vsprintf($this->_stmt, $this->_vars);
		
		return str_replace('%%', '%', $stmt);
	}
}

?>