面向对象的mysql数据库操作php类

class database {

    var $host = NULL;
    var $username = NULL;
    var $password = NULL;
    var $databaseName = NULL;
    var $link = NULL;
    var $queries = NULL;
    var $errors = NULL;

    var $databaseExtras = NULL;

    function __construct($host, $username, $password, $database) {
        $this->database($host, $username, $password, $database);
    }

    function database($host, $username, $password, $database) {
        /*$this->database = array (
                "host" => $host,
                "username" => $username,
                "password" => $password,
                "database" => $database,
                "link" => "",
                "queries" => array (),
                "errors" => array ()
            );*/

        $this->host = $host;
        $this->username = $username;
        $this->password = $password;
        $this->databaseName = $database;
        $this->link = "";
        $this->queries = array ();
        $this->errors = array ();

        $this->databaseExtras = new stdClass;

        $this->link = mysql_connect($this->host, $this->username, $this->password) or die("Could not connect to Database");
        mysql_select_db($this->databaseName);
    }

    function justquery($sql) {
        $this->queries[] = $sql;
        return mysql_query($sql, $this->link);
    }

    function loadResult($sql) {
        if (!($cur = $this->justquery($sql))) {
            return null;
        }
        $ret = null;
        if ($row = mysql_fetch_row( $cur )) {
            $ret = $row[0];
        }
        mysql_free_result( $cur );
        return $ret;
    }

    function loadFirstRow($sql) {
        if (!($cur = $this->justquery($sql))) {
            return null;
        }
        $ret = null;
        if ($row = mysql_fetch_object( $cur )) {
            $ret = $row;
        }
        mysql_free_result( $cur );
        return $ret;
    }

    function insertid() {
        return mysql_insert_id( $this->link );
    }

    function query($sql, $key = "", $returns = true, $batch = false) {
        $result = array ();

        switch ($batch) {
            default:
            case true:
                foreach ($sql as $index => $query) {
                    $this->queries[] = $query;
                    $answer = mysql_query($query, $this->link);

                    if (!$answer) {
                        $this->errors[] = mysql_error($this->link);
                    }
                    else {
                        if ($returns != false) {
                            if (mysql_num_rows($answer) > 0){
                                while ($row = mysql_fetch_object($answer)) {
                                    if ($key != ""){
                                        $result[$index][$row->$key] = $row;
                                    }
                                    else {
                                        $result[$index][] = $row;
                                    }
                                }
                            } else {}
                        } else {}
                    }
                }
                break;

            case false:
                $this->queries[] = $sql;
                $answer = mysql_query($sql, $this->link);

                if (!$answer) {
                    $this->errors[] = mysql_error($this->link);
                    $result = false;
                }
                else {
                    if ($returns != false) {
                        if (mysql_num_rows($answer) > 0){
                            while ($row = mysql_fetch_object($answer)) {
                                if ($key != ""){
                                    $result[$row->$key] = $row;
                                }
                                else {
                                    $result[] = $row;
                                }
                            }
                        } else {}
                    }
                    else {
                        $result = true;
                    }
                }
                break;
        }

        return $result;
    }

    function loadObject( $sql, &$object ) {
        if ($object != null) {
            if (!($cur = $this->justquery($sql))) {
                return false;
            } else {}
            if ($array = mysql_fetch_assoc( $cur )) {
                mysql_free_result( $cur );
                $this->bindArrayToObject( $array, $object);
                return true;
            }
            else {
                return false;
            }
        }
        else {
            if ($cur = $this->justquery($sql)) {
                if ($object = mysql_fetch_object( $cur )) {
                    mysql_free_result( $cur );
                    return true;
                }
                else {
                    $object = null;
                    return false;
                }
            }
            else {
                return false;
            }
        }
    }

    function bindArrayToObject( $array, &$obj) {
        if (!is_array( $array ) || !is_object( $obj )) {
            return (false);
        }

        foreach (get_object_vars($obj) as $k => $v) {
            if( substr( $k, 0, 1 ) != '_' ) {
                $ak = $k;
                if (isset($array[$ak])) {
                    $obj->$k = $array[$ak];
                }
            }
        }

        return true;
    }

    function formatCSVCell($data) {
        $useQuotes = false;

        $quotable = array (
                "\"" => "\"\"",
                "," => ",",
                "\n" => "\n"
            );

        foreach ($quotable as $char => $repl) {
            if (eregi($char, $data)) {
                $useQuotes = true;
            } else {}
        }

        if ($useQuotes == true) {
            foreach ($quotable as $char => $repl) {
                $data = str_replace($char, $repl, $data);
            }

            $data = "\"" . $data . "\"";
        }
        else {

        }

        return $data;
    }
}
?>

面向对象, mysql, php