php专区

 首页 > php专区 > PHP应用 > php类库 > mysql数据库连接操作类 - php类库

mysql数据库连接操作类 - php类库

分享到：
【字体：大 中 小】
导读：
         [导读] 分享一篇可以记录错误日志的mysql数据库连接类文件,实例代码如下:?phpclassmysql{private$db_host;//数据库主机private$db_user;//数据库......

mysql数据库连接操作类

分享一篇可以记录错误日志的mysql数据库连接类文件,实例代码如下:

  2. class mysql { 
  3.  private $db_host; //数据库主机 
  4.  private $db_user; //数据库用户名 
  5.  private $db_pwd; //数据库用户名密码 
  6.  private $db_database; //数据库名 
  7.  private $conn; //数据库连接标识; 
  8.  private $result; //执行query命令的结果资源标识 
  9.  private $sql; //sql执行语句 
  10.  private $row; //返回的条目数 
  11.  private $coding; //数据库编码，GBK,UTF8,gb2312 
  12.  private $bulletin = true; //是否开启错误记录 
  13.  private $show_error = true; //测试阶段，显示所有错误,具有安全隐患,默认关闭 
  14.  private $is_error = false; //发现错误是否立即终止,默认true,建议不启用，因为当有问题时用户什么也看不到是很苦恼的 
  15.  
  16.  /*构造函数*/ 
  17.  public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) { 
  18.   $this->db_host = $db_host; 
  19.   $this->db_user = $db_user; 
  20.   $this->db_pwd = $db_pwd; 
  21.   $this->db_database = $db_database; 
  22.   $this->conn = $conn; 
  23.   $this->coding = $coding; 
  24.   $this->connect(); 
  25.  } 
  26.  
  27.  /*数据库连接*/ 
  28.  public function connect() { 
  29.   if ($this->conn == "pconn") { 
  30.    //永久链接 
  31.    $this->conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd); 
  32.   } else { 
  33.    //即使链接 
  34.    $this->conn = mysql_connect($this->db_host, $this->db_user, $this->db_pwd); 
  35.   } 
  36.  
  37.   if (!mysql_select_db($this->db_database, $this->conn)) { 
  38.    if ($this->show_error) { 
  39.     $this->show_error("数据库不可用：", $this->db_database); 
  40.    } 
  41.   } 
  42.   mysql_query("SET NAMES $this->coding"); 
  43.  } 
  44.  
  45.  /*数据库执行语句，可执行查询添加修改删除等任何sql语句*/ 
  46.  public function query($sql) { 
  47.   if ($sql == "") { 
  48.    $this->show_error("SQL语句错误：", "SQL查询语句为空"); 
  49.   } 
  50.   $this->sql = $sql; 
  51.  
  52.   $result = mysql_query($this->sql, $this->conn); 
  53.  
  54.   if (!$result) { 
  55.    //调试中使用，sql语句出错时会自动打印出来 
  56.    if ($this->show_error) { 
  57.     $this->show_error("错误SQL语句：", $this->sql); 
  58.    } 
  59.   } else { 
  60.    $this->result = $result; 
  61.   } 
  62.   return $this->result; 
  63.  } 
  64.  
  65.  /*创建添加新的数据库*/ 
  66.  public function create_database($database_name) { 
  67.   $database = $database_name; 
  68.   $sqlDatabase = 'create database ' . $database; 
  69.   $this->query($sqlDatabase); 
  70.  } 
  71.  
  72.  /*查询服务器所有数据库*/ 
  73.  //将系统数据库与用户数据库分开，更直观的显示？ 
  74.  public function show_databases() { 
  75.   $this->query("show databases"); 
  76.   echo "现有数据库：" . $amount = $this->db_num_rows($rs); 
  77.   echo ""; 
  78.   $i = 1; 
  79.   while ($row = $this->fetch_array($rs)) { 
  80.    echo "$i $row[Database]"; 
  81.    echo ""; 
  82.    $i++; 
  83.   } 
  84.  } 
  85.  
  86.  //以数组形式返回主机中所有数据库名 
  87.  public function databases() { 
  88.   $rsPtr = mysql_list_dbs($this->conn); 
  89.   $i = 0; 
  90.   $cnt = mysql_num_rows($rsPtr); 
  91.   while ($i < $cnt) { 
  92.    $rs[] = mysql_db_name($rsPtr, $i); 
  93.    $i++; 
  94.   } 
  95.   return $rs; 
  96.  } 
  97.  
  98.  /*查询数据库下所有的表*/ 
  99.  public function show_tables($database_name) { 
  100.   $this->query("show tables"); 
  101.   echo "现有数据库：" . $amount = $this->db_num_rows($rs); 
  102.   echo ""; 
  103.   $i = 1; 
  104.   while ($row = $this->fetch_array($rs)) { 
  105.    $columnName = "Tables_in_" . $database_name; 
  106.    echo "$i $row[$columnName]"; 
  107.    echo ""; 
  108.    $i++; 
  109.   } 
  110.  } 
  111.  
  112.  /* 
  113.  mysql_fetch_row()    array  $row[0],$row[1],$row[2] 
  114.  mysql_fetch_array()  array  $row[0] 或 $row[id] 
  115.  mysql_fetch_assoc()  array  用$row->content 字段大小写敏感 
  116.  mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感 
  117.  */ 
  118.  
  119.  /*取得结果数据*/ 
  120.  public function mysql_result_li() { 
  121.   return mysql_result($str); 
  122.  } 
  123.  
  124.  /*取得记录集,获取数组-索引和关联,使用$row['content'] */ 
  125.  
  126.  public function fetch_array() { 
  127.   return mysql_fetch_array($this->result); 
  128.  } 
  129.  
  130. // public function fetch_array($query) { 
  131. //  return mysql_fetch_array($query); 
  132. // } 
  133.  
  134.  //获取关联数组,使用$row['字段名'] 
  135.  public function fetch_assoc() { 
  136.   return mysql_fetch_assoc($this->result); 
  137.  } 
  138.  
  139.  //获取数字索引数组,使用$row[0],$row[1],$row[2] 
  140.  public function fetch_row() { 
  141.   return mysql_fetch_row($this->result); 
  142.  } 
  143.  
  144.  //获取对象数组,使用$row->content 
  145.  public function fetch_Object() { 
  146.   return mysql_fetch_object($this->result); 
  147.  } 
  148.  
  149.  //简化查询select 
  150.  public function findall($table) { 
  151.   $this->query("SELECT * FROM $table"); 
  152.  } 
  153.  
  154.  //简化查询select 
  155.  public function select($table, $columnName = "*", $condition = '', $debug = '') { 
  156.   $condition = $condition ? ' Where ' . $condition : NULL; 
  157.   if ($debug) { 
  158.    echo "SELECT $columnName FROM $table $condition"; 
  159.   } else { 
  160.    $this->query("SELECT $columnName FROM $table $condition"); 
  161.   } 
  162.  } 
  163.  
  164.  //简化删除del 
  165.  public function delete($table, $condition, $url = '') { 
  166.   if ($this->query("DELETE FROM $table WHERE $condition")) { 
  167.    if (!emptyempty ($url)) 
  168.     $this->Get_admin_msg($url, '删除成功！'); 
  169.   } 
  170.  } 
  171.  
  172.  //简化插入insert 
  173.  public function insert($table, $columnName, $value, $url = '') { 
  174.   if ($this->query("INSERT INTO $table ($columnName) VALUES ($value)")) { 
  175.    if (!emptyempty ($url)) 
  176.     $this->Get_admin_msg($url, '添加成功！'); 
  177.   } 
  178.  } 
  179.  
  180.  //简化修改update 
  181.  public function update($table, $mod_content, $condition, $url = '') { 
  182.   //echo "UPDATE $table SET $mod_content WHERE $condition"; exit(); 
  183.   if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) { 
  184.    if (!emptyempty ($url)) 
  185.     $this->Get_admin_msg($url); 
  186.   } 
  187.  } 
  188.  
  189.  /*取得上一步 INSERT 操作产生的 ID*/ 
  190.  public function insert_id() { 
  191.   return mysql_insert_id(); 
  192.  } 
  193.  
  194.  //指向确定的一条数据记录 
  195.  public function db_data_seek($id) { 
  196.   if ($id > 0) { 
  197.    $id = $id -1; 
  198.   } 
  199.   if (!@ mysql_data_seek($this->result, $id)) { 
  200.    $this->show_error("SQL语句有误：", "指定的数据为空"); 
  201.   } 
  202.   return $this->result; 
  203.  } 
  204.  
  205.  // 根据select查询结果计算结果集条数 
  206. /* public function db_num_rows() { 
  207.   if ($this->result == null) { 
  208.    if ($this->show_error) { 
  209.     $this->show_error("SQL语句错误", "暂时为空，没有任何内容！"); 
  210.    } 
  211.   } else { 
  212.    return mysql_num_rows($this->result); 
  213.   } 
  214.  }*/ 
  215.  public function db_num_rows($result){ 
  216.   if($result==null){ 
  217.   if ($this->show_error) { 
  218.     $this->show_error("SQL语句错误", "暂时为空，没有任何内容！"); 
  219.    } 
  220.   }else{ 
  221.    return mysql_num_rows($result); 
  222.   } 
  223.  } 
  224.  
  225.  // 根据insert,update,delete执行结果取得影响行数 
  226.  public function db_affected_rows() { 
  227.   return mysql_affected_rows(); 
  228.  } 
  229.  
  230.  //输出显示sql语句 
  231.  public function show_error($message = "", $sql = "") { 
  232.   if (!$sql) { 
  233.    echo "" . $message . ""; 
  234.    echo ""; 
  235.   } else { 
  236.    echo "
    "; 
  237.    echo "错误信息提示:"; 
  238.    echo ""; 
  239.    echo ""; 
  240.    echo "错误号：12142"; 
  241.    echo "
"; 
  •    echo "错误原因：" . mysql_error() . ""; 
  •    echo ""; 
  •    echo "" . $message . ""; 
  •    echo "
    • "; 
  •    echo "
    " . $sql . "
    "    ; 
  •    $ip = $this->getip(); 
  •    if ($this->bulletin) { 
  •     $time = date("Y-m-d H:i:s"); 
  •     $message = $message . "rn$this->sql" . "rn客户IP:$ip" . "rn时间 :$time" . "rnrn"; 
  •  
  •     $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 ""; 
  •    if ($this->is_error) { 
  •     exit; 
  •    } 
  •   } 
  •   echo "
    • "; 
  •   echo ""; 
  •  
  •   echo ""; 
  •  } 
  •  
  •  //释放结果集 
  •  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 ""; 
  •   echo "字段数：" . $total = mysql_num_fields($this->result); 
  •   echo "
    "; 
  •   for ($i = 0; $i < $total; $i++) { 
  •    print_r(mysql_fetch_field($this->result, $i)); 
  •   } 
  •   echo ""; 
  •   echo ""; 
  •  } 
  •  
  •  //取得 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 (!emptyempty ($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.phpfensi.com"); 
  •    exit();//开源代码phpfensi.com 
  •   } 
  •  } 
  •  function htmtocode($content) { 
  •  $content = str_replace("n", "
    "    , str_replace(" ", " ", $content)); 
  •  return $content; 
  • } 
  •  
  • } 
  • $db=new mysql("localhost","root","","Messages","","gbk"); 
  • ?>
    • 分享到：
    Memcached 超时时间解决方案说明参数返回...
    Memcached 超时时间解决方案 Memcached 存储命令 expire 过期时间设置 问题： 拿set命令为例 bool Memcache::set ( string $key , mixed $var [, int $flag [, int $expire ]] ) 一个同事将 $expire 设置为100天，发现设置的key总是获取不到值…     因： 一些存储命令在发送时会包含一个失效值（与一个元素或...
    php-汉字拼音首字母工具类
    •         php迷，一个php技术的分享社区，专属您自己的技术摘抄本、收藏夹。
    • 在这里……

    Tags

    网站声明：本站所有视频，教程都由网友上传，站长收集和分享给大家学习使用，如由牵扯版权问题请联系站长邮箱  冀ICP备18013926号-2