PHP编程：一个功效还算完全的数据库操作类 - 仓酷云

<?php /* * Author  墨龙 * Time 2010年12月2日 15:50:35 */       $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;          //数据库毗连
标识;       private $result;       //履行
query号令
的了局
资本
标识       private $sql;    //sql履行
语句       private $pre;    //数据库表前缀       private $coding;  //数据库编码，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("数据库链接毛病
,请反省
数据库链接设置装备摆设
！"));          if(!mysql_select_db($this->db_table,$this->db_conn)){                               echo "没有找到数据表：".$this->db_table;          }          mysql_select_db($this->db_table,$this->db_conn);          $this->query("SET NAMES $this->coding");       }             /*履行
SQL语句的函数*/       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;       }             /*创立
添加新的数据库*/       public function create_database($database_name){          $database=$database_name;          $sqlDatabase = 'create database '.$database;          return $this->query($sqlDatabase);       }                   // 依据
select查询了局
盘算
了局
集条数       public function db_num_rows(){             if($this->result==null){             if($this->show_error){                   $this->show_error("sql语句毛病
!");             }                      }else{             return  mysql_num_rows($this->result);             }       }             /*查询办事
器一切
数据库*/       //将体系
数据库与用户数据库分隔
，更直不雅
的显示？       public function show_databases(){          $this->query("show databases");          echo "现无数
据库：".$amount =$this->db_num_rows($rs);          echo "<br />";          $i=1;          while($row = $this->fetch_array($rs)){                         echo "$i $row[Database]";                         echo "<br />";             $i++;          }       }             //以数组模式
前往
主机中一切
数据库名       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);       }                      /*查询数据库下一切
的表*/       function show_tables($database_name){          $this->query("show tables");          echo "现无数
据库：".$amount = $this->db_num_rows($rs);          echo "<br />";          $i=1;          while($row = $this->fetch_array($rs)){             $columnName="Tables_in_".$database_name;             echo "$i $row[$columnName]";             echo "<br />";             $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] 字段巨细
写敏感    */       /*获得
纪录
集,获得
数组-索引和联系关系
,利用
$row['content'] */       public function fetch_array()       {                return @mysql_fetch_array($this->result);       }                //获得
联系关系
数组,利用
$row['字段名']       public function fetch_ass()       {          return @mysql_fetch_assoc($this->result);       }                   //获得
数字索引数组,利用
$row[0],$row[1],$row[2]       public function fetch_row()       {          return @mysql_fetch_row($this->result);       }             //获得
对象数组,利用
$row->content       public function fetch_Object()       {          return @mysql_fetch_object($this->result);       }             //简化查询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");       }             //简化的insert       function insert($table,$arr){          $table = $this->fulltablename($table);          $sql = "INSERT INTO $table ";          if(!is_array($arr)){             $this->show_error("请输出
参数数组！");          }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);       }       //简化的update       function update($table,$arr,$where){          $table = $this->fulltablename($table);          $sql = "UPDATE $table SET ";          if(!is_array($arr)){             $this->show_error("请输出
参数数组！");          }else{          foreach($arr as $key => $value){             $sql .= " `".$key."` = '".$value."' ,";          }          }          $sql = substr($sql,0,-1)." where ".$where;          return $this->query($sql);       }       //简化的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 操作发生
的 ID       public function insert_id(){          return mysql_insert_id();       }             //加上前缀的数据表       public function fulltablename($table){          return $table = $this->pre.$table;       }             //查询字段数目
      public function num_fields($table){          $table = $this->fulltablename($table);             $this->query("select * from $table");          echo "<br />";          echo "字段数：".$total = mysql_num_fields($this->result);          echo "<pre>";          for ($i=0; $i<$total; $i++){             print_r(mysql_fetch_field($this->result,$i) );          }          echo "</pre>";          echo "<br />";       }             //获得
MySQL 办事
器信息       public function mysql_server($num=''){          switch ($num){             case 1 :             return mysql_get_server_info(); //MySQL 办事
器信息                break;                               case 2 :             return mysql_get_host_info(); //获得
MySQL 主机信息             break;                               case 3 :             return mysql_get_client_info(); //获得
MySQL 客户端信息             break;                               case 4 :             return mysql_get_proto_info();  //获得
MySQL 协定
信息             break;                               default:             return mysql_get_client_info(); //默许
获得
mysql版本信息          }       }             //析构函数，主动
封闭
数据库,渣滓
收受接管
机制       /*public function __destruct()    {          if(!empty($this->result)){             $this->free();          }          mysql_close($this->$db_conn);    }*/             /*取得
客户端真实的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 "<script language='Javascript'> alert('".$str."');history.back(-1);</script>";       }          } ?>

复制代码