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

<?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,$database);
    }
  
    function database($host,$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,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;
    }
}
?>