当前位置：首页 > PHP教程 > php类库 > 列表

mysql数据库连接操作类

发布:smiling　来源: PHP粉丝网 　添加日期：2014-09-11 10:02:37　浏览: 评论：0　

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

  1. <?php 
  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 "<br />"; 
  78.   $i = 1; 
  79.   while ($row = $this->fetch_array($rs)) { 
  80.    echo "$i $row[Database]"; 
  81.    echo "<br />"; 
  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 "<br />"; 
  103.   $i = 1; 
  104.   while ($row = $this->fetch_array($rs)) { 
  105.    $columnName = "Tables_in_" . $database_name; 
  106.    echo "$i $row[$columnName]"; 
  107.    echo "<br />"; 
  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 "<font color='red'>" . $message . "</font>"; 
  234.    echo "<br />"; 
  235.   } else { 
  236.    echo "<fieldset>"; 
  237.    echo "<legend>错误信息提示:</legend><br />"; 
  238.    echo "<div style='font-size:14px; clear:both; font-family:Verdana, Arial, Helvetica, sans-serif;'>"; 
  239.    echo "<div style='height:20px; background:#000000; border:1px #000000 solid'>"; 
  240.    echo "<font color='white'>错误号：12142</font>"; 
  241.    echo "</div><br />"; 
  242.    echo "错误原因：" . mysql_error() . "<br /><br />"; 
  243.    echo "<div style='height:20px; background:#FF0000; border:1px #FF0000 solid'>"; 
  244.    echo "<font color='white'>" . $message . "</font>"; 
  245.    echo "</div>"; 
  246.    echo "<font color='red'><pre>" . $sql . "</pre></font>"; 
  247.    $ip = $this->getip(); 
  248.    if ($this->bulletin) { 
  249.     $time = date("Y-m-d H:i:s"); 
  250.     $message = $message . "rn$this->sql" . "rn客户IP:$ip" . "rn时间 :$time" . "rnrn"; 
  251.  
  252.     $server_date = date("Y-m-d"); 
  253.     $filename = $server_date . ".txt"; 
  254.     $file_path = "error/" . $filename; 
  255.     $error_content = $message; 
  256.     //$error_content="错误的数据库，不可以链接"; 
  257.     $file = "error"; //设置文件保存目录 
  258.  
  259.     //建立文件夹 
  260.     if (!file_exists($file)) { 
  261.      if (!mkdir($file, 0777)) { 
  262.       //默认的 mode 是 0777，意味着最大可能的访问权 
  263.       die("upload files directory does not exist and creation failed"); 
  264.      } 
  265.     } 
  266.  
  267.     //建立txt日期文件 
  268.     if (!file_exists($file_path)) { 
  269.  
  270.      //echo "建立日期文件"; 
  271.      fopen($file_path, "w+"); 
  272.  
  273.      //首先要确定文件存在并且可写 
  274.      if (is_writable($file_path)) { 
  275.       //使用添加模式打开$filename，文件指针将会在文件的开头 
  276.       if (!$handle = fopen($file_path, 'a')) { 
  277.        echo "不能打开文件 $filename"; 
  278.        exit; 
  279.       } 
  280.  
  281.       //将$somecontent写入到我们打开的文件中。 
  282.       if (!fwrite($handle, $error_content)) { 
  283.        echo "不能写入到文件 $filename"; 
  284.        exit; 
  285.       } 
  286.  
  287.       //echo "文件 $filename 写入成功"; 
  288.  
  289.       echo "——错误记录被保存!"; 
  290.  
  291.       //关闭文件 
  292.       fclose($handle); 
  293.      } else { 
  294.       echo "文件 $filename 不可写"; 
  295.      } 
  296.  
  297.     } else { 
  298.      //首先要确定文件存在并且可写 
  299.      if (is_writable($file_path)) { 
  300.       //使用添加模式打开$filename，文件指针将会在文件的开头 
  301.       if (!$handle = fopen($file_path, 'a')) { 
  302.        echo "不能打开文件 $filename"; 
  303.        exit; 
  304.       } 
  305.  
  306.       //将$somecontent写入到我们打开的文件中。 
  307.       if (!fwrite($handle, $error_content)) { 
  308.        echo "不能写入到文件 $filename"; 
  309.        exit; 
  310.       } 
  311.  
  312.       //echo "文件 $filename 写入成功"; 
  313.       echo "——错误记录被保存!"; 
  314.  
  315.       //关闭文件 
  316.       fclose($handle); 
  317.      } else { 
  318.       echo "文件 $filename 不可写"; 
  319.      } 
  320.     } 
  321.  
  322.    } 
  323.    echo "<br />"; 
  324.    if ($this->is_error) { 
  325.     exit; 
  326.    } 
  327.   } 
  328.   echo "</div>"; 
  329.   echo "</fieldset>"; 
  330.  
  331.   echo "<br />"; 
  332.  } 
  333.  
  334.  //释放结果集 
  335.  public function free() { 
  336.   @ mysql_free_result($this->result); 
  337.  } 
  338.  
  339.  //数据库选择 
  340.  public function select_db($db_database) { 
  341.   return mysql_select_db($db_database); 
  342.  } 
  343.  
  344.  //查询字段数量 
  345.  public function num_fields($table_name) { 
  346.   //return mysql_num_fields($this->result); 
  347.   $this->query("select * from $table_name"); 
  348.   echo "<br />"; 
  349.   echo "字段数：" . $total = mysql_num_fields($this->result); 
  350.   echo "<pre>"; 
  351.   for ($i = 0; $i < $total; $i++) { 
  352.    print_r(mysql_fetch_field($this->result, $i)); 
  353.   } 
  354.   echo "</pre>"; 
  355.   echo "<br />"; 
  356.  } 
  357.  
  358.  //取得 MySQL 服务器信息 
  359.  public function mysql_server($num = '') { 
  360.   switch ($num) { 
  361.    case 1 : 
  362.     return mysql_get_server_info(); //MySQL 服务器信息 
  363.     break; 
  364.  
  365.    case 2 : 
  366.     return mysql_get_host_info(); //取得 MySQL 主机信息 
  367.     break; 
  368.  
  369.    case 3 : 
  370.     return mysql_get_client_info(); //取得 MySQL 客户端信息 
  371.     break; 
  372.  
  373.    case 4 : 
  374.     return mysql_get_proto_info(); //取得 MySQL 协议信息 
  375.     break; 
  376.  
  377.    default : 
  378.     return mysql_get_client_info(); //默认取得mysql版本信息 
  379.   } 
  380.  } 
  381.  
  382.  //析构函数，自动关闭数据库,垃圾回收机制 
  383.  public function __destruct() { 
  384.   if (!emptyempty ($this->result)) { 
  385.    $this->free(); 
  386.   } 
  387.   mysql_close($this->conn); 
  388.  } //function __destruct(); 
  389.  
  390.  /*获得客户端真实的IP地址*/ 
  391.  function getip() { 
  392.   if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown")) { 
  393.    $ip = getenv("HTTP_CLIENT_IP"); 
  394.   } else 
  395.    if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")) { 
  396.     $ip = getenv("HTTP_X_FORWARDED_FOR"); 
  397.    } else 
  398.     if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown")) { 
  399.      $ip = getenv("REMOTE_ADDR"); 
  400.     } else 
  401.      if (isset ($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")) { 
  402.       $ip = $_SERVER['REMOTE_ADDR']; 
  403.      } else { 
  404.       $ip = "unknown"; 
  405.      } 
  406.   return ($ip); 
  407.  } 
  408.  function inject_check($sql_str) { //防止注入 
  409.   $check = eregi('select|insert|update|delete|'|/*|*|../|./|union|into|load_file|outfile', $sql_str); 
  410.   if ($check) { 
  411.    echo "输入非法注入内容！"; 
  412.    exit (); 
  413.   } else { 
  414.    return $sql_str; 
  415.   } 
  416.  } 
  417.  function checkurl() { //检查来路 
  418.   if (preg_replace("/https?://([^:/]+).*/i", "\1", $_SERVER['HTTP_REFERER']) !== preg_replace("/([^:]+).*/", "\1", $_SERVER['HTTP_HOST'])) { 
  419.    header("Location: http://www.phpfensi.com"); 
  420.    exit();//开源代码phpfensi.com 
  421.   } 
  422.  } 
  423.  function htmtocode($content) { 
  424.  $content = str_replace("n", "<br>", str_replace(" ", "&nbsp;", $content)); 
  425.  return $content; 
  426. } 
  427.  
  428. } 
  429. $db=new mysql("localhost","root","","Messages","","gbk"); 
  430. ?>

Tags: mysql数据库类 php连接操作类

分享到：

相关文章

推荐文章

热门文章

最新评论文章