PHP的數(shù)據(jù)庫操作類

字號(hào):


    $db = new mysql($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding);
    class mysql{
    private $db_host;
    private $db_user;
    private $db_password;
    private $db_table;
    private $db_conn; //數(shù)據(jù)庫連接標(biāo)識(shí);
    private $result; //執(zhí)行query命令的結(jié)果資源標(biāo)識(shí)
    private $sql; //sql執(zhí)行語句
    private $pre; //數(shù)據(jù)庫表前綴
    private $coding; //數(shù)據(jù)庫編碼,GBK,UTF8,gb2312
    function __construct($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding){
    $this->db_host = $db_host;
    $this->db_user = $db_user;
    $this->db_password = $db_password;
    $this->db_table = $db_table;
    $this->db_conn = $db_conn;
    $this->pre = $pre;
    $this->coding = $coding;
    $this->connect();
    }
    function connect(){
    $this->db_conn = @mysql_connect($this->db_host,$this->db_user,$this->db_password) or die($this->show_error("數(shù)據(jù)庫鏈接錯(cuò)誤,請(qǐng)檢查數(shù)據(jù)庫鏈接配置!"));
    if(!mysql_select_db($this->db_table,$this->db_conn)){
    echo "沒有找到數(shù)據(jù)表:".$this->db_table;
    }
    mysql_select_db($this->db_table,$this->db_conn);
    $this->query("SET NAMES $this->coding");
    }
    /*執(zhí)行SQL語句的函數(shù)*/
    function query($sql){
    if(emptyempty($sql)){
    $this->show_error("你的sql語句不能為空!");
    }else{
    $this->sql = $sql;
    }
    $result = mysql_query($this->sql,$this->db_conn);
    return $this->result = $result;
    }
    /*創(chuàng)建添加新的數(shù)據(jù)庫*/
    public function create_database($database_name){
    $database=$database_name;
    $sqlDatabase = 'create database '.$database;
    return $this->query($sqlDatabase);
    }
    // 根據(jù)select查詢結(jié)果計(jì)算結(jié)果集條數(shù)
    public function db_num_rows(){
    if($this->result==null){
    if($this->show_error){
    $this->show_error("sql語句錯(cuò)誤!");
    }
    }else{
    return mysql_num_rows($this->result);
    }
    }
    /*查詢服務(wù)器所有數(shù)據(jù)庫*/
    //將系統(tǒng)數(shù)據(jù)庫與用戶數(shù)據(jù)庫分開,更直觀的顯示?
    public function show_databases(){
    $this->query("show databases");
    echo "現(xiàn)有數(shù)據(jù)庫:".$amount =$this->db_num_rows($rs);
    echo "";
    $i=1;
    while($row = $this->fetch_array($rs)){
    echo "$i $row[Database]";
    echo "";
    $i++;
    }
    }
    //以數(shù)組形式返回主機(jī)中所有數(shù)據(jù)庫名
    public function databases()
    {
    $rsPtr=mysql_list_dbs($this->db_conn);
    $i=0;
    $cnt=mysql_num_rows($rsPtr);
    while($i<$cnt)
    {
    $rs[]=mysql_db_name($rsPtr,$i);
    $i++;
    }
    return print_r($rs);
    }
    /*查詢數(shù)據(jù)庫下所有的表*/
    function show_tables($database_name){
    $this->query("show tables");
    echo "現(xiàn)有數(shù)據(jù)庫:".$amount = $this->db_num_rows($rs);
    echo "";
    $i=1;
    while($row = $this->fetch_array($rs)){
    $columnName="Tables_in_".$database_name;
    echo "$i $row[$columnName]";
    echo "";
    $i++;
    }
    }
    /*
    mysql_fetch_row() array $row[0],$row[1],$row[2]
    mysql_fetch_array() array $row[0] 或 $row[id]
    mysql_fetch_assoc() array 用$row->content 字段大小寫敏感
    mysql_fetch_object() object 用$row[id],$row[content] 字段大小寫敏感
    */
    /*取得記錄集,獲取數(shù)組-索引和關(guān)聯(lián),使用$row['content'] */
    public function fetch_array()
    {
    return @mysql_fetch_array($this->result);
    }
    //獲取關(guān)聯(lián)數(shù)組,使用$row['字段名']
    public function fetch_ass()
    {
    return @mysql_fetch_assoc($this->result);
    }
    //獲取數(shù)字索引數(shù)組,使用$row[0],$row[1],$row[2]
    public function fetch_row()
    {
    return @mysql_fetch_row($this->result);
    }
    //獲取對(duì)象數(shù)組,使用$row->content
    public function fetch_Object()
    {
    return @mysql_fetch_object($this->result);
    }
    //簡(jiǎn)化查詢select
    public function findall($table){
    $table = $this->fulltablename($table);
    $this->query("select * from $table");
    }
    public function select($table,$columnName,$condition){
    $table = $this->fulltablename($table);
    if(emptyempty($columnName)){
    $columnName = "*";
    }
    $this->query("SELECT $columnName FROM $table $condition");
    }
    //簡(jiǎn)化的insert
    function insert($table,$arr){
    $table = $this->fulltablename($table);
    $sql = "INSERT INTO $table ";
    if(!is_array($arr)){
    $this->show_error("請(qǐng)輸入?yún)?shù)數(shù)組!");
    }else{
    $k = "";
    $v = "";
    foreach($arr as $key => $value){
    $k .= "`$key`,";
    $v .= "'".$value."',";
    }
    }
    $sql = $sql." (".substr($k,0,-1).") VALUES (".substr($v,0,-1).")";
    $this->query($sql);
    }
    //簡(jiǎn)化的update
    function update($table,$arr,$where){
    $table = $this->fulltablename($table);
    $sql = "UPDATE $table SET ";
    if(!is_array($arr)){
    $this->show_error("請(qǐng)輸入?yún)?shù)數(shù)組!");
    }else{
    foreach($arr as $key => $value){
    $sql .= " `".$key."` = '".$value."' ,";
    }
    }
    $sql = substr($sql,0,-1)." where ".$where;
    return $this->query($sql);
    }
    //簡(jiǎn)化的delete
    function delete($table,$where = ""){
    $table = $this->fulltablename($table);
    if(emptyempty($where)){
    $this->show_error("條件不能為空!");
    }else{
    $where = " where ".$where;
    }
    $sql = "DELETE FROM $table ".$where;
    //echo $sql;
    return $this->query($sql);
    }
    //取得上一步 INSERT 操作產(chǎn)生的 ID
    public function insert_id(){
    return mysql_insert_id();
    }
    //加上前綴的數(shù)據(jù)表
    public function fulltablename($table){
    return $table = $this->pre.$table;
    }
    //查詢字段數(shù)量
    public function num_fields($table){
    $table = $this->fulltablename($table);
    $this->query("select * from $table");
    echo "";
    echo "字段數(shù):".$total = mysql_num_fields($this->result);
    echo "
    ";
    for ($i=0; $i<$total; $i++){
    print_r(mysql_fetch_field($this->result,$i) );
    }
    echo "";
    echo "";
    }
    //取得 MySQL 服務(wù)器信息
    public function mysql_server($num=''){
    switch ($num){
    case 1 :
    return mysql_get_server_info(); //MySQL 服務(wù)器信息
    break;
    case 2 :
    return mysql_get_host_info(); //取得 MySQL 主機(jī)信息
    break;
    case 3 :
    return mysql_get_client_info(); //取得 MySQL 客戶端信息
    break;
    case 4 :
    return mysql_get_proto_info(); //取得 MySQL 協(xié)議信息
    break;
    default:
    return mysql_get_client_info(); //默認(rèn)取得mysql版本信息
    }
    }
    //析構(gòu)函數(shù),自動(dòng)關(guān)閉數(shù)據(jù)庫,垃圾回收機(jī)制
    /*public function __destruct()
    {
    if(!empty($this->result)){
    $this->free();
    }
    mysql_close($this->$db_conn);
    }*/
    /*獲得客戶端真實(shí)的IP地址*/
    function getip(){
    if(getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
    {
    $ip = getenv("HTTP_CLIENT_IP");
    }
    else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){
    $ip = getenv("HTTP_X_FORWARDED_FOR");
    }
    else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
    {
    $ip = getenv("REMOTE_ADDR");
    }
    else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")){
    $ip = $_SERVER['REMOTE_ADDR'];
    }
    else{
    $ip = "unknown";
    }
    return($ip);
    }
    function show_error($str){
    echo "Javascript'> alert('".$str."');history.back(-1);";
    }
    }
    ?>