| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
ebey2291
8年前发布

php操作mysql的类

[PHP]代码

<?php  class mysql {      private $db_host; //数据库主机      private $db_user; //数据库用户名      private $db_pwd; //数据库用户名密码      private $db_database; //数据库名      private $conn; //数据库连接标识;      private $result; //执行query命令的结果资源标识      private $sql; //sql执行语句      private $row; //返回的条目数      private $coding; //数据库编码,GBK,UTF8,gb2312      private $bulletin = true; //是否开启错误记录      private $show_error = false; //测试阶段,显示所有错误,具有安全隐患,默认关闭      private $is_error = false; //发现错误是否立即终止,默认true,建议不启用,因为当有问题时用户什么也看不到是很苦恼的        /*构造函数*/      public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) {          $this->db_host = $db_host;          $this->db_user = $db_user;          $this->db_pwd = $db_pwd;          $this->db_database = $db_database;          $this->conn = $conn;          $this->coding = $coding;          $this->connect();      }        /*数据库连接*/      public function connect() {          if ($this->conn == "pconn") {              //永久链接              $this->conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd);          } else {              //即使链接              $this->conn = mysql_connect($this->db_host, $this->db_user, $this->db_pwd);          }            if (!mysql_select_db($this->db_database, $this->conn)) {              if ($this->show_error) {                  $this->show_error("数据库不可用:", $this->db_database);              }          }          mysql_query("SET NAMES $this->coding");      }        /*数据库执行语句,可执行查询添加修改删除等任何sql语句*/      public function query($sql) {          if ($sql == "") {              $this->show_error("SQL语句错误:", "SQL查询语句为空");          }          $this->sql = $sql;            $result = mysql_query($this->sql, $this->conn);            if (!$result) {              //调试中使用,sql语句出错时会自动打印出来              if ($this->show_error) {                  $this->show_error("错误SQL语句:", $this->sql);              }          } else {              $this->result = $result;          }          return $this->result;      }        /*创建添加新的数据库*/      public function create_database($database_name) {          $database = $database_name;          $sqlDatabase = 'create database ' . $database;          $this->query($sqlDatabase);      }        /*查询服务器所有数据库*/      //将系统数据库与用户数据库分开,更直观的显示?      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->conn);          $i = 0;          $cnt = mysql_num_rows($rsPtr);          while ($i < $cnt) {              $rs[] = mysql_db_name($rsPtr, $i);              $i++;          }          return $rs;      }        /*查询数据库下所有的表*/      public 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] 字段大小写敏感      */        /*取得结果数据*/      public function mysql_result_li() {          return mysql_result($str);      }        /*取得记录集,获取数组-索引和关联,使用$row['content'] */      public function fetch_array($resultt="") {          if($resultt<>""){              return mysql_fetch_array($resultt);          }else{          return mysql_fetch_array($this->result);          }      }        //获取关联数组,使用$row['字段名']      public function fetch_assoc() {          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) {          $this->query("SELECT * FROM $table");      }        //简化查询select      public function select($table, $columnName = "*", $condition = '', $debug = '') {          $condition = $condition ? ' Where ' . $condition : NULL;          if ($debug) {              echo "SELECT $columnName FROM $table $condition";          } else {              $this->query("SELECT $columnName FROM $table $condition");          }      }        //简化删除del      public function delete($table, $condition, $url = '') {          if ($this->query("DELETE FROM $table WHERE $condition")) {              if (!empty ($url))                  $this->Get_admin_msg($url, '删除成功!');          }      }        //简化插入insert      public function insert($table, $columnName, $value, $url = '') {          if ($this->query("INSERT INTO $table ($columnName) VALUES ($value)")) {              if (!empty ($url))                  $this->Get_admin_msg($url, '添加成功!');          }      }        //简化修改update      public function update($table, $mod_content, $condition, $url = '') {          //echo "UPDATE $table SET $mod_content WHERE $condition"; exit();          if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {              if (!empty ($url))                  $this->Get_admin_msg($url);          }      }        /*取得上一步 INSERT 操作产生的 ID*/      public function insert_id() {          return mysql_insert_id();      }        //指向确定的一条数据记录      public function db_data_seek($id) {          if ($id > 0) {              $id = $id -1;          }          if (!@ mysql_data_seek($this->result, $id)) {              $this->show_error("SQL语句有误:", "指定的数据为空");          }          return $this->result;      }        // 根据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);          }      }        // 根据insert,update,delete执行结果取得影响行数      public function db_affected_rows() {          return mysql_affected_rows();      }        //输出显示sql语句      public function show_error($message = "", $sql = "") {          if (!$sql) {              echo "<font color='red'>" . $message . "</font>";              echo "<br />";          } else {              echo "<fieldset>";              echo "<legend>错误信息提示:</legend><br />";              echo "<div style='font-size:14px; clear:both; font-family:Verdana, Arial, Helvetica, sans-serif;'>";              echo "<div style='height:20px; background:#000000; border:1px #000000 solid'>";              echo "<font color='white'>错误号:12142</font>";              echo "</div><br />";              echo "错误原因:" . mysql_error() . "<br /><br />";              echo "<div style='height:20px; background:#FF0000; border:1px #FF0000 solid'>";              echo "<font color='white'>" . $message . "</font>";              echo "</div>";              echo "<font color='red'><pre>" . $sql . "</pre></font>";              $ip = $this->getip();              if ($this->bulletin) {                  $time = date("Y-m-d H:i:s");                  $message = $message . "\r\n$this->sql" . "\r\n客户IP:$ip" . "\r\n时间 :$time" . "\r\n\r\n";                    $server_date = date("Y-m-d");                  $filename = $server_date . ".txt";                  $file_path = "error/" . $filename;                  $error_content = $message;                  //$error_content="错误的数据库,不可以链接";                  $file = "error"; //设置文件保存目录                    //建立文件夹                  if (!file_exists($file)) {                      if (!mkdir($file, 0777)) {                          //默认的 mode 是 0777,意味着最大可能的访问权                          die("upload files directory does not exist and creation failed");                      }                  }                    //建立txt日期文件                  if (!file_exists($file_path)) {                        //echo "建立日期文件";                      fopen($file_path, "w+");                        //首先要确定文件存在并且可写                      if (is_writable($file_path)) {                          //使用添加模式打开$filename,文件指针将会在文件的开头                          if (!$handle = fopen($file_path, 'a')) {                              echo "不能打开文件 $filename";                              exit;                          }                            //将$somecontent写入到我们打开的文件中。                          if (!fwrite($handle, $error_content)) {                              echo "不能写入到文件 $filename";                              exit;                          }                            //echo "文件 $filename 写入成功";                            echo "——错误记录被保存!";                            //关闭文件                          fclose($handle);                      } else {                          echo "文件 $filename 不可写";                      }                    } else {                      //首先要确定文件存在并且可写                      if (is_writable($file_path)) {                          //使用添加模式打开$filename,文件指针将会在文件的开头                          if (!$handle = fopen($file_path, 'a')) {                              echo "不能打开文件 $filename";                              exit;                          }                            //将$somecontent写入到我们打开的文件中。                          if (!fwrite($handle, $error_content)) {                              echo "不能写入到文件 $filename";                              exit;                          }                            //echo "文件 $filename 写入成功";                          echo "——错误记录被保存!";                            //关闭文件                          fclose($handle);                      } else {                          echo "文件 $filename 不可写";                      }                  }                }              echo "<br />";              if ($this->is_error) {                  exit;              }          }          echo "</div>";          echo "</fieldset>";            echo "<br />";      }        //释放结果集      public function free() {          @ mysql_free_result($this->result);      }        //数据库选择      public function select_db($db_database) {          return mysql_select_db($db_database);      }        //查询字段数量      public function num_fields($table_name) {          //return mysql_num_fields($this->result);          $this->query("select * from $table_name");          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->conn);      } //function __destruct();        /*获得客户端真实的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 inject_check($sql_str) { //防止注入          $check =eregi('select|insert|update|delete|\'|\/\*|\*|\.\.\/|\.\/|union|into|load_file|outfile',$sql_str);          if ($check) {              echo "输入非法注入内容!";              exit ();          } else {              return $sql_str;          }      }      function checkurl() { //检查来路          if (preg_replace("/https?:\/\/([^\:\/]+).*/i", "\\1", $_SERVER['HTTP_REFERER']) !== preg_replace("/([^\:]+).*/", "\\1", $_SERVER['HTTP_HOST'])) {              header("Location: http://www.dareng.com");              exit();          }      }    }  ?>