mysql数据库连接操作类

分享一篇可以记录错误日志的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. ?>