MySQL Connection Class

<?

class MySQL {

    /**
     * The DB Host to connect to
     *
     * @var string
     */
    protected $host;

    /**
     * The DB Username to access the host
     *
     * @var string
     */
    protected $username;

    /**
     * The DB Password to access the host
     *
     * @var string
     */
    protected $password;

    /**
     * The DB Name to use once connected
     *
     * @var string
     */
    protected $database;

    /**
     * The connection string once the connection is made
     *
     * @var resource
     */
    protected $connection;

    protected $debug=0;

    /**
     * The constructor to create a MySQL Database object
     *
     * @param string $host
     * @param string $username
     * @param string $password
     * @param string $database
     */
    function __construct($host, $username, $password, $database){
        $this->host = $host;
        $this->username = $username;
        $this->password = $password;
        $this->database = $database;

        $this->connection = @mysql_connect($this->host, $this->username, $this->password);

        if(!$this->connection){
            print "There was an error while connecting to the database.  Please verify that your settings are correct and that your database allows connections from this server.";
            print "<br />" . mysql_error();
            exit;
        }

        $this->selectDatabase();

    }

    /**
     * Sets the debug flag
     *
     * @param int $debug
     */
    function setDebug($debug){
        $this->debug = $debug;
    }



    function execute($query) {

        if($this->debug){
            print "<b>QUERY: $query</b><br />\n";
        }

        $result = mysql_query($query);

        if(!$result) return(null);

        $rows = array();
        $fields = array();

        while (@$row = mysql_fetch_array($result, MYSQL_ASSOC)) {

            while($field = key($row)) {
                $fields[$field] = $row[$field];
                next($row);
            }
            $rows[] = $fields;

        }

        return($rows);

    }

    /**
     * Run a select query on the database
     *
     * @param string $query
     * @param string[] $columns An array of column names you want to name the multi-dimenstional array of selected values
     * @return string[][]
     */
    function select($query, $columns){

        if($this->debug){
            print "<b>QUERY: $query</b><br />\n";
        }

        $result = mysql_query($query);

        if(!$result){
            return(null);
        }

        $results = array();
        $i=0;
        while ($line = mysql_fetch_array($result, MYSQL_NUM)) {

            for($j=0; $j<sizeof($line); $j++){
                $results[$i][$columns[$j]] = $line[$j];
            }

            $i++;
        }

        return($results);
    }

    /**
     * Run a insert query on the database
     *
     * @param string $query
     * @return int the last inserted id from the query
     */
    function insert($query){

        if($this->debug){
            print "<b>QUERY: $query</b><br />\n";
        }

        $result = mysql_query($query);

        if(!$result){
            return(null);
        }

        $id = mysql_insert_id($this->connection);

        return($id);
    }

    /**
     * Run an update query on the database
     *
     * @param string $query
     * @return int the number of rows affected
     */
    function update($query){
        if($this->debug){
            print "<b>QUERY: $query</b><br />\n";
        }

        $result = mysql_query($query);

        if(!$result){
            return(null);
        }

        $id = mysql_affected_rows($this->connection);

        return($id);
    }

    /**
     * Run a delete query on the database
     *
     * @param string $query
     * @return int the number of rows affected
     */
    function delete($query){
        if($this->debug){
            print "<b>QUERY: $query</b><br />\n";
        }

        $result = mysql_query($query);

        if(!$result){
            return(null);
        }

        $id = mysql_affected_rows($this->connection);

        return($id);
    }

    /**
     * Select the database this connection is currently using
     *
     */
    function selectDatabase(){
        if(!@mysql_select_db($this->database)){
            print "There was an error while selecting the database.  Please verify that your settings are correct and that your database allows connections from this server.";
            exit;
        }
    }

    /**
     * The destructor used to close the connection on script exit
     *
     */
    function __destruct(){
        if($this->connection){
            mysql_close($this->connection);
        }
    }

    /**
     * Access the DB host
     *
     * @return string
     */
    function getHost(){
        return($this->host);
    }

    /**
     * Access the DB username
     *
     * @return string
     */
    function getUsername(){
        return($this->username);
    }

    /**
     * Access the DB password
     *
     * @return string
     */
    function getPassword(){
        return($this->password);
    }

    /**
     * Access the DB name
     *
     * @return unknown
     */
    function getDatabase(){
        return($this->database);
    }

    /**
     * Escape a string for mysql
     *
     * @return string
     */
    function escape($string) {
        if (get_magic_quotes_gpc()) {
            $string = stripslashes($string);
        }
        return mysql_real_escape_string($string);
    }
}


?>