content/DBI.php5

<?php
class DBI {

    private $username = "";
    private $password = "";
    private $database = "";
    private $dbServer   = "";
    private $previousQuery = "";
    protected $dbObject = null;
    private $resultSet = null;
    private $errors = array();
    private $lastID = "";
    private $totalQueryTime = 0;

    public function __construct ($user = "", $pass = "", $db = "", $server = "", $port = "3306") {
        // store the input parameters
        $this->username = $user;
        $this->password = $pass;
        $this->database = $db;
        $this->dbServer = "$server:$port";

        // establish a db connection
        $this->dbObject = @mysql_pconnect($this->dbServer, $this->username, $this->password);

        // check to see if the db server connection was successful
        if ($this->dbObject) {
            // select the db we want to use
            $db = @mysql_select_db($this->database, $this->dbObject);
            if ($db) {
                return (true);
            // if db was not found, report and return false
            } else {
                $this->setError("Undefined database " . $this->database . " selected.  Technical: " . @mysql_error());
                return (false);
            }
        // if db server connection was unsuccessful, report and return false
        } else {
            $this->setError("Undefined database server " . $this->dbServer . " selected.  Technical: " . @mysql_error());
            return (false);
        }
    }

    public function __destruct() {
        if(SConfig::getOption('common.debugQueries'))
            print "Total DBI time: " . ($this->totalTime * 1000) . "<br />\n";
    }

    private $oldQueries = array();
    private $qcount = 0;
    private $totalTime = 0;


    /*----------------------------------------------*/
    /* Run A Query                                  */
    /*----------------------------------------------*/

    public function query($query, $queryInfo = false) {

            // make sure we are querying the correct database!
            $db = mysql_select_db($this->database, $this->dbObject);

            // Are we debugging?
            $dbg = SConfig::getOption('common.debugQueries');

            // DEBUG: Report if we've already run this query before
            if($dbg) {
                $start = array_sum(explode(' ', microtime()));
                if(isset($oldQueries[$query])) {
                    SErrorManager::setWarning("Already ran query '$query' (debug message id $oldQueries[$query])");
                }
            }

            // Create a new SQL object
            $sqlObj = new SQL($this, $query, $queryInfo);

            // Execute the SQL Statement
            $sqlObj->doSQL();

            // Save the SQL Object
            $this->previousQuery = $sqlObj;

            // Get the last inserted ID value from the database (for passing back to a newly committed object)
            $this->lastID = $sqlObj->mysql_insert_id();

            // Get the result of the query
            $res = $this->getResult($query);

            // DEBUG: Print the time it took to run this query
            if($dbg) {
                $end = array_sum(explode(' ', microtime()));
                $this->totalTime += ($end - $start);
                SErrorManager::sobj_setDebug("<i>DBI Query [$this->qcount]</i> <b>(TIME: " . substr((($end - $start) * 1000), 0, 6) . " ms)</b><br />$query", 2);
                $this->oldQueries[$query] = $this->qcount;
                $this->qcount++;
            }

            // Return the result array
            return $res;
    }


    /*----------------------------------------------*/
    /* Error Reporting                              */
    /*----------------------------------------------*/

    public function setError($errorMessage) {
        array_push($this->errors, $errorMessage);
    }

    public function getError($pos = "") {
        if ($pos == "") {
            return($this->errors);
        } else {
            if (isset($this->errors) && $this->errors[$pos] != "") {
                return $this->errors[$pos];
            }
        }
    }

    public function hasError() {
        return (count($this->errors) > 0);
    }

    public function clearErrors() {
        $this->errors = array();
    }


    /*----------------------------------------------*/
    /* Results Caching                              */
    /*----------------------------------------------*/

    public function setResult($resultIndex, $resultIn) {
        $this->resultSet[$resultIndex] = null;
        $this->resultSet[$resultIndex] = $resultIn;
    }

    public function getResult($index = "") {
        if ($index != "") {
            if ($this->resultSet[$index] != "") {
                return ($this->resultSet[$index]);
            } else {
                return (array("0"));
            }
        } else {
            return($this->resultSet);
        }
    }

    /*----------------------------------------------*/
    /* Get/Set                                      */
    /*----------------------------------------------*/

    public function getDB() {
        return ($this->dbObject);
    }

    public function getDBName() {
        return $this->database;
    }

    public function getQuery() {
        if ($this->previousQuery != null) {
            return ($this->previousQuery->getQuery());
        } else {
            return ("");
        }
    }

    public function mysql_insert_id() {
        return ($this->lastID);
    }

    public function fieldName() {

        $sqlObj = new SQL($this, $this->previousQuery, false);

        if ($this->previousQuery != null) {
            return ($this->previousQuery->getFieldName());
        }
    }
}


/*----------------------------------------------*/
/* SQL Class                                    */
/*----------------------------------------------*/

class SQL {

    private $dbObject = null;
    private $query = "";
    private $dbAccess;
    private $additionalQueryInfo;
    private $lastID = "";
    private $fieldName = array();

    public function __construct($dbO = null, $queryIn = "", $queryInfo) {
        $this->dbObject = $dbO;
        $this->query = $queryIn;
        $this->dbAccess = $this->dbObject->getDB();
        $this->additionalQueryInfo = $queryInfo;
    }

    public function doSQL() {

        $results = array();
        $counter = 0;

        // Make sure we are querying the right database
        if(!mysql_select_db($this->dbObject->getDBName(), $this->dbAccess))
            $this->dbObject->setWarning("Could not select DB: " . mysql_error($this->dbAccess));

        if (!($dbResult = mysql_query($this->query, $this->dbAccess))) {
            // An error occurred, error handler
            $this->dbObject->setError("MySQL Error: " . mysql_error($this->dbAccess) . ". Associated query: " . $this->query);
        }


        if($dbResult) {
            if(SConfig::getOption('common.debugQueries') == true)
                SErrorManager::setDebug("Number of results: " . mysql_num_rows($dbResult));
            if ($dbResult != 1 && mysql_num_rows($dbResult) > 0 && $this->additionalQueryInfo) {
                $results["__count"] = @mysql_num_rows($dbResult);
            }

            $dontCheckNumFields = false;
            if (eregi("^INSERT", $this->query) !== FALSE) {
                $dontCheckNumFields = true;
                $this->lastID = @mysql_insert_id($this->dbAccess);
            }
            if (eregi("^UPDATE", $this->query) !== FALSE) {
                $dontCheckNumFields = true;
            }
            if (eregi("^DELETE", $this->query) !== FALSE) {
                $dontCheckNumFields = true;
            }

            if(!$dontCheckNumFields) {
                for ($i = 0; $i < @mysql_num_fields($dbResult); $i++) {
                    @array_push($this->fieldName, @mysql_field_name($dbResult, $i));
                }
                while ($dbRow = @mysql_fetch_assoc($dbResult)) {
                    $results[$counter] = $dbRow;
                    $counter++;
                }
            }

            if(SConfig::getOption('common.debugQueries') == true)
                SErrorManager::setDebug("Number of rows affected: " . mysql_affected_rows($this->dbAccess));

            if (@mysql_affected_rows($this->dbAccess) > 0 && $this->additionalQueryInfo) {
                $results["__affected"] = @mysql_affected_rows($this->dbAccess);
            }
        }
        $this->dbObject->setResult($this->query, $results);
    }

    public function getFieldName() {
        return($this->fieldName);
    }

    public function getQuery() {
        if ($this->query != "") {
            return ($this->query);
        } else {
            return ("");
        }
    }

    public function mysql_insert_id() {
        if ($this->query != "") {
            return ($this->lastID);
        } else {
            return ("");
        }
    }
}

?>

---