script Database Class

<?php

/***********************************************************
| Saven.nl Class v1.0
+-----------------------------------------------------------
| =============================================
| Author:    Saven
| Copyright: (c) 2006 Saven.nl
| =============================================
|
| Usage:
| =============================================
| $db = new Database;
| $query = $db->query("SELECT [pre]foo FROM bar"); # [pre] will automatically be replaced by the database prefix
| 
| $num = $db->num();      #if the first parameter is empty, it wil fetch the last query
| discription: counts the number of rows of a query
|
| $fetch = $db->fetch();  #if the first parameter is empty, it wil fetch the last query
| discription: fetches a query
| 
| $db->upd($table, $set, $where);
| discription: updates a table, short function
| example: $db->upd("table", "level='3', status='admin', foo='bar'", "username='Saven'");
|
| $db->del($table, $where);
| discription: deletes data from a table, a short function
| example: $db->del("table", "id='$some_id'");
|
| $db->set_prefix();
| discription: sets the database prefix
|
| $db->error('string');
| discription: returns a error and dies
|
| $db->close();
| discription: closes the connection with the database
| ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| The $obj array needs to contain the following keys:
| 'host' # the database host, usually 'localhost'
| 'user' # the database username
| 'pass' # the database password
| 'db'   # the database name
| 'pre'  # the database prefix, if you do not use a database prefix, leave the value empty
|
| example: $obj = array('host'=>'localhost', 'user'=>'me', 'pass'=>'blabla', 'db'=>'forum', 'pre'=>'saven_');
| ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
|
| $conn checks if there's a connection
| $query_id is the last used query
| =============================================
+-----------------------------------------------------------
| Saven.nl Database Class v1.0
***********************************************************/

class Database
{
    
    # array met database info
    var $obj        = array( 'host'        => 'localhost'    ,
                             'user'        => 'username'    ,
                             'pass'        => 'password'    ,
                             'db'        => 'database'    ,
                             'pre'        => 'saven_'        );
                 
    var $conn        = FALSE;
    
    var $query_id    = NULL;
    
    
    /*---------------------------------------------------------*/
    // Constructor
    /*---------------------------------------------------------*/
    
    function Database()
    {
        //-----------------------------------------
        // SQL Prefix al geset?
        //-----------------------------------------
         
         $this->set_prefix();
        
        //-----------------------------------------
        // Connecten
        //-----------------------------------------
        
        $this->conn = @mysql_connect( $this->obj['host'] ,
                                      $this->obj['user'] ,
                                      $this->obj['pass']    );
                
        if( !$this->conn )
        {
            $this->error('Kan geen verbinding maken met de database<br /><small>'.mysql_error().'<small>');
            
            return FALSE;
        }
        
        if( !@mysql_select_db($this->obj['db'], $this->conn) )
        {
            $this->error('De opgegeven database bestaat niet<br /><small>'.mysql_error().'<small>');
            
            return FALSE;
        }
        
        return TRUE;        
    }
    
    /*---------------------------------------------------------*/
    // Prefix voor tabellen vastzetten
    /*---------------------------------------------------------*/
    
    function set_prefix()
    {
        if( !defined('prefix') )
        {
            $this->obj['pre'] = isset($this->obj['pre']) ? $this->obj['pre'] : '';
            
            define('prefix', $this->obj['pre']);
        }
    }
        
    /*---------------------------------------------------------*/
    // MySQL errors weergeven (bij connecten of query)
    /*---------------------------------------------------------*/
    
    function error($msg, $die=TRUE)
    {
        $out = '<center><h1>MySQL Error</h1><hr />'.$msg.'</center>';
        
        die($out);
    }
    
    /*---------------------------------------------------------*/
    // Een query gaan uitvoeren
    /*---------------------------------------------------------*/
    
    function query($the_query)
    {
        $the_query      = str_replace('[pre]', prefix, $the_query);
                
        $this->query_id = mysql_query($the_query, $this->conn);
                
        if( !$this->query_id )
        {            
            $this->error('Fout in query: <em>('.$the_query.')</em><br />'.mysql_error());
        }
        else
        {
            return $this->query_id;
        }
    }
    
    /*---------------------------------------------------------*/
    // MySQL querys fetchen gebaseerd op laastste query
    /*---------------------------------------------------------*/
    
    function fetch($query='', $how='assoc')
    {
        if( empty($query) )
        {
            return mysql_fetch_assoc( $this->query_id );
        }        
        elseif( $how == 'assoc' || empty($how) )
        {
            return mysql_fetch_assoc($query);
        }
        elseif( $how = 'array' )
        {
            return mysql_fetch_array($query);
        }
        elseif( $fetch == 'object' )
        {
            return mysql_fetch_object($query);
        }
        else
        {
            $this->error('Onbekende methode om te fetchen ('.$how.')');
        }
        
    }
    
    /*-------------------------------------------------------------------------*/
    // Aantal resultaten van query tellen gebaseerd op laastste query
    /*-------------------------------------------------------------------------*/
    
    function num($query='')
    {
        if( empty($query) )
        {
            $num = $this->query_id;
        }
        else
        {
            $num = $query;
        }
        
        return mysql_num_rows($num);
    }
    
    /*-------------------------------------------------------------------------*/
    // Snel een tabel updaten
    /*-------------------------------------------------------------------------*/
    
    function upd($tbl, $set, $where='')
    {
        $query = "UPDATE ".prefix.$tbl." SET ".$set;
        
        if( !empty($where) )
        {
            $query .= " WHERE ".$where;
        }
        
        $do = mysql_query($query);
        
        if( !$do )
        {
            $this->error('Fout tijdens quick-update ('.$query.')');
            
            $do = FALSE;
        }
        
        return $do;
    }
    
    /*-------------------------------------------------------------------------*/
    // Snel een record verwijderen uit een tabel
    /*-------------------------------------------------------------------------*/
    
    function del($tbl, $where)
    {
        $query = "DELETE FROM ".prefix.$tbl;
        
        if( !empty($where) )
        {
            $query .= " WHERE ".$where;
        }
        
        $do = mysql_query($query);
        
        if( !$do )
        {
            $this->error('Fout tijdens quick-delete ('.$query.')');
            
            $do = FALSE;
        }
        
        return $do;
    }
    
    /*-------------------------------------------------------------------------*/
    // En toen gingen we de verbinding sluiten
    /*-------------------------------------------------------------------------*/
    
    function close()
    {
        if( $this->conn )
        {
            @mysql_close($this->conn);
        }
    }
    
}

?>

if( !$do )
        {
            $this->error('Fout tijdens quick-delete ('.$query.')');
            
            $do = FALSE;
        }