root/website/lib/db/DBManager.class.php @ 2165

<?
/******************************************************************************
* DBManager - Abstract class to manage databases                                                            *
* To do inheritance in this class, override the class vars (in constructor),    *
* and the 'open' method                                                                                                             *
******************************************************************************/
class DBManager{
    
    #'True' database's value
    var $_TRUE = true;
    
    #'False' databse's value
    var $_FALSE = false;
    
    #connection's link resource
    var $connection = null;

    #last query done
    var $lastQuery = null;

    #result's link resource
    var $result = null;
        
    #References to execute queries: the funcion, and params
    #query
    var $queryF = array('func'=>"", 'params'=>array());
    #rows affected
    var $rowsAF = array('func'=>"", 'params'=>array());
    #close connection
    var $closeF = array('func'=>"", 'params'=>array());
    #fetch object
    var $fetchObjectF = array('func'=>"", 'params'=>array());
    
    #get last insert id
    var $getLastInsertF = array('func'=>"", 'params'=>array());
    
    #open the database connection
    function open($host, $db, $user, $password){}
    
    #closes the database connection
    function close(){
        $this->execCommand($this->closeF);
    }
    
    #executes a generic query
    function executeGenericQuery($query=null){
        if($query !== null){
            $this->lastQuery = $query;
        }
        echo "\"".$this->lastQuery . "\"";
        $this->result = $this->execCommand($this->queryF);
    }
    
    function setQuery($query){
        $this->lastQuery = $query;
    }
    
    #executes a 'select' statement
    function executeSelect($table, $fields="*", $where=null){
        $this->lastQuery = "SELECT " . $fields . " FROM " . $table .
            " WHERE " . $this->checkTrue($where);
        $this->executeGenericQuery();
    }
    
    #executes an 'update' statement
    function executeUpdate($table, $fields, $where=null){
        $this->lastQuery = "UPDATE " . $table . " SET " . $fields .
            " WHERE " . $this->checkTrue($where);
        $this->executeGenericQuery();
    }
    
    #executes an 'insert' statement
    function executeInsert($table, $values, $fields=null){
        $query = "INSERT INTO ".$table;
        $query .= ($fields === null) ? "" : " (" . $fields . ") ";
        $query .= "VALUES (" . $values . ") ";
        
        $this->lastQuery = $query;
        $this->executeGenericQuery();
    }
    
    #executes a 'delete' statement
    function executeDelete($table, $where=null){
        $this->lastQuery = "DELETE FROM " . $table . " WHERE " .
            $this->checkTrue($where);
        $this->executeGenericQuery();
    }
    
    #checks if $var is null (for a database)
    function checkTrue($var, $check=null){
        return ($var === $check) ? $this->_TRUE : $var;
    }
    
    #execute a command
    function execCommand($functionArr){
        if(count($functionArr['params']) > 0){
            $ret = call_user_func_array($functionArr['func'],
                                    $functionArr['params']);
        }else{
            $ret = call_user_func($functionArr['func']);
        }
        return $ret;
    }
    
    #get the number of affected rows
    function getAffectedRows(){
        return $this->execCommand($this->rowsAF);
    }
    
    #fetch an object
    function get(){
        return $this->execCommand($this->fetchObjectF);
    }
    
    #get the last insertion ID
    function getLastInsertID(){
        return $this->execCommand($this->lastInsertF);
    }
    
    #fetch all rows in the database as an array of objects
    function getArray(){
        $ret = array();
        while($obj = $this->get()){
            $ret[] = $obj;
        }
        return $ret;
    }
    
}
?>