php mysql完整数据库连接类

1. class mysql { 
2.  private $db_host; //数据库主机 
3.  private $db_user; //数据库用户名 
4.  private $db_pwd; //数据库用户名密码 
5.  private $db_database; //数据库名 
6.  private $conn; //数据库连接标识; 
7.  private $result; //执行query命令的结果资源标识 
8.  private $sql; //sql执行语句 
9.  private $row; //返回的条目数 
10.  private $coding; //数据库编码，gbk,utf8,gb2312 
11.  private $bulletin = true; //是否开启错误记录 
12.  private $show_error = false; //测试阶段，显示所有错误,具有安全隐患,默认关闭 
13.  private $is_error = false; //发现错误是否立即终止,默认true,建议不启用，因为当有问题时用户什么也看不到是很苦恼的 
14.  
15.  /*构造函数*/ 
16.  public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) { 
17.   $this->db_host = $db_host; 
18.   $this->db_user = $db_user; 
19.   $this->db_pwd = $db_pwd; 
20.   $this->db_database = $db_database; 
21.   $this->conn = $conn; 
22.   $this->coding = $coding; 
23.   $this->connect(); 
24.  } 
25.  
26.  /*数据库连接*/ 
27.  public function connect() { 
28.   if ($this->conn == "pconn") { 
29.    //永久链接 
30.    $this->conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd); 
31.   } else { 
32.    //即使链接 
33.    $this->conn = mysql_connect($this->db_host, $this->db_user, $this->db_pwd); 
34.   } 
35.  
36.   if (!mysql_select_db($this->db_database, $this->conn)) { 
37.    if ($this->show_error) { 
38.     $this->show_error("数据库不可用：", $this->db_database); 
39.    } 
40.   } 
41.   mysql_query("set names $this->coding"); 
42.  } 
43.  
44.  /*数据库执行语句，可执行查询添加修改删除等任何sql语句*/ 
45.  public function query($sql) { 
46.   if ($sql == "") { 
47.    $this->show_error("sql语句错误：", "sql查询语句为空"); 
48.   } 
49.   $this->sql = $sql; 
50.  
51.   $result = mysql_query($this->sql, $this->conn); 
52.  
53.   if (!$result) { 
54.    //调试中使用，sql语句出错时会自动打印出来 
55.    if ($this->show_error) { 
56.     $this->show_error("错误sql语句：", $this->sql); 
57.    } 
58.   } else { 
59.    $this->result = $result; 
60.   } 
61.   return $this->result; 
62.  } 
63.  
64.  /*创建添加新的数据库*/ 
65.  public function create_database($database_name) { 
66.   $database = $database_name; 
67.   $sqldatabase = 'create database ' . $database; 
68.   $this->query($sqldatabase); 
69.  } 
70.  
71.  /*查询服务器所有数据库*/ 
72.  //将系统数据库与用户数据库分开，更直观的显示？ 
73.  public function show_databases() { 
74.   $this->query("show databases"); 
75.   echo "现有数据库：" . $amount = $this->db_num_rows($rs); 
76.   echo "<br />"; 
77.   $i = 1; 
78.   while ($row = $this->fetch_array($rs)) { 
79.    echo "$i $row[database]"; 
80.    echo "<br />"; 
81.    $i++; 
82.   } 
83.  } 
84.  
85.  //以数组形式返回主机中所有数据库名 
86.  public function databases() { 
87.   $rsptr = mysql_list_dbs($this->conn); 
88.   $i = 0; 
89.   $cnt = mysql_num_rows($rsptr); 
90.   while ($i < $cnt) { 
91.    $rs[] = mysql_db_name($rsptr, $i); 
92.    $i++; 
93.   } 
94.   return $rs; 
95.  } 
96.  
97.  /*查询数据库下所有的表*/ 
98.  public function show_tables($database_name) { 
99.   $this->query("show tables"); 
100.   echo "现有数据库：" . $amount = $this->db_num_rows($rs); 
101.   echo "<br />"; 
102.   $i = 1; 
103.   while ($row = $this->fetch_array($rs)) { 
104.    $columnname = "tables_in_" . $database_name; 
105.    echo "$i $row[$columnname]"; 
106.    echo "<br />"; 
107.    $i++; 
108.   } 
109.  } 
110.  
111.  /* 
112.  mysql_fetch_row()    array  $row[0],$row[1],$row[2] 
113.  mysql_fetch_array()  array  $row[0] 或 $row[id] 
114.  mysql_fetch_assoc()  array  用$row->content 字段大小写敏感 
115.  mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感 
116.  */ 
117.  
118.  /*取得结果数据*/ 
119.  public function mysql_result_li() { 
120.   return mysql_result($str); 
121.  } 
122.  
123.  /*取得记录集,获取数组-索引和关联,使用$row['content'] */ 
124.  public function fetch_array($resultt="") { 
125.   if($resultt<>""){ 
126.    return mysql_fetch_array($resultt); 
127.   }else{ 
128.   return mysql_fetch_array($this->result); 
129.   } 
130.  } 
131.  
132.  //获取关联数组,使用$row['字段名'] 
133.  public function fetch_assoc() { 
134.   return mysql_fetch_assoc($this->result); 
135.  } 
136.  
137.  //获取数字索引数组,使用$row[0],$row[1],$row[2] 
138.  public function fetch_row() { 
139.   return mysql_fetch_row($this->result); 
140.  } 
141.  
142.  //获取对象数组,使用$row->content 
143.  public function fetch_object() { 
144.   return mysql_fetch_object($this->result); 
145.  } 
146.  
147.  //简化查询select 
148.  public function findall($table) { 
149.   $this->query("select * from $table"); 
150.  } 
151.  
152.  //简化查询select 
153.  public function select($table, $columnname = "*", $condition = '', $debug = '') { 
154.   $condition = $condition ? ' where ' . $condition : null; 
155.   if ($debug) { 
156.    echo "select $columnname from $table $condition"; 
157.   } else { 
158.    $this->query("select $columnname from $table $condition"); 
159.   } 
160.  } 
161.  
162.  //简化删除del 
163.  public function delete($table, $condition, $url = '') { 
164.   if ($this->query("delete from $table where $condition")) { 
165.    if (!emptyempty ($url)) 
166.     $this->get_admin_msg($url, '删除成功！'); 
167.   } 
168.  } 
169.  
170.  //简化插入insert 
171.  public function insert($table, $columnname, $value, $url = '') { 
172.   if ($this->query("insert into $table ($columnname) values ($value)")) { 
173.    if (!emptyempty ($url)) 
174.     $this->get_admin_msg($url, '添加成功！'); 
175.   } 
176.  } 
177.  
178.  //简化修改update 
179.  public function update($table, $mod_content, $condition, $url = '') { 
180.   //echo "update $table set $mod_content where $condition"; exit(); 
181.   if ($this->query("update $table set $mod_content where $condition")) { 
182.    if (!emptyempty ($url)) 
183.     $this->get_admin_msg($url); 
184.   } 
185.  } 
186.  
187.  /*取得上一步 insert 操作产生的 id*/ 
188.  public function insert_id() { 
189.   return mysql_insert_id(); 
190.  } 
191.  
192.  //指向确定的一条数据记录 
193.  public function db_data_seek($id) { 
194.   if ($id > 0) { 
195.    $id = $id -1; 
196.   } 
197.   if (!@ mysql_data_seek($this->result, $id)) { 
198.    $this->show_error("sql语句有误：", "指定的数据为空"); 
199.   } 
200.   return $this->result; 
201.  } 
202.  
203.  // 根据select查询结果计算结果集条数 
204.  public function db_num_rows() { 
205.   if ($this->result == null) { 
206.    if ($this->show_error) { 
207.     $this->show_error("sql语句错误", "暂时为空，没有任何内容！"); 
208.    } 
209.   } else { 
210.    return mysql_num_rows($this->result); 
211.   } 
212.  } 
213.  
214.  // 根据insert,update,delete执行结果取得影响行数 
215.  public function db_affected_rows() { 
216.   return mysql_affected_rows(); 
217.  } 
218.  
219.  //输出显示sql语句 
220.  public function show_error($message = "", $sql = "") { 
221.   if (!$sql) { 
222.    echo "<font color='red'>" . $message . "</font>"; 
223.    echo "<br />"; 
224.   } else { 
225.    echo "<fieldset>"; 
226.    echo "<legend>错误信息提示:</legend><br />"; 
227.    echo "<div style='font-size:14px; clear:both; font-family:verdana, arial, helvetica, sans-serif;'>"; 
228.    echo "<div style='height:20px; background:#000000; border:1px #000000 solid'>"; 
229.    echo "<font color='white'>错误号：12142</font>"; 
230.    echo "</div><br />"; 
231.    echo "错误原因：" . mysql_error() . "<br /><br />"; 
232.    echo "<div style='height:20px; background:#ff0000; border:1px #ff0000 solid'>"; 
233.    echo "<font color='white'>" . $message . "</font>"; 
234.    echo "</div>"; 
235.    echo "<font color='red'><pre>" . $sql . "</pre></font>"; 
236.    $ip = $this->getip(); 
237.    if ($this->bulletin) { 
238.     $time = date("y-m-d h:i:s"); 
239.     $message = $message . "rn$this->sql" . "rn客户ip:$ip" . "rn时间 :$time" . "rnrn"; 
240.  
241.     $server_date = date("y-m-d"); 
242.     $filename = $server_date . ".txt"; 
243.     $file_path = "error/" . $filename; 
244.     $error_content = $message; 
245.     //$error_content="错误的数据库，不可以链接"; 
246.     $file = "error"; //设置文件保存目录 
247.  
248.     //建立文件夹 
249.     if (!file_exists($file)) { 
250.      if (!mkdir($file, 0777)) { 
251.       //默认的 mode 是 0777，意味着最大可能的访问权 
252.       die("upload files directory does not exist and creation failed"); 
253.      } 
254.     } 
255.  
256.     //建立txt日期文件 
257.     if (!file_exists($file_path)) { 
258.  
259.      //echo "建立日期文件"; 
260.      fopen($file_path, "w+"); 
261.  
262.      //首先要确定文件存在并且可写 
263.      if (is_writable($file_path)) { 
264.       //使用添加模式打开$filename，文件指针将会在文件的开头 
265.       if (!$handle = fopen($file_path, 'a')) { 
266.        echo "不能打开文件 $filename"; 
267.        exit; 
268.       } 
269.  
270.       //将$somecontent写入到我们打开的文件中。 
271.       if (!fwrite($handle, $error_content)) { 
272.        echo "不能写入到文件 $filename"; 
273.        exit; 
274.       } 
275.  
276.       //echo "文件 $filename 写入成功"; 
277.  
278.       echo "——错误记录被保存!"; 
279.  
280.       //关闭文件 
281.       fclose($handle); 
282.      } else { 
283.       echo "文件 $filename 不可写"; 
284.      } 
285.  
286.     } else { 
287.      //首先要确定文件存在并且可写 
288.      if (is_writable($file_path)) { 
289.       //使用添加模式打开$filename，文件指针将会在文件的开头 
290.       if (!$handle = fopen($file_path, 'a')) { 
291.        echo "不能打开文件 $filename"; 
292.        exit; 
293.       } 
294.  
295.       //将$somecontent写入到我们打开的文件中。 
296.       if (!fwrite($handle, $error_content)) { 
297.        echo "不能写入到文件 $filename"; 
298.        exit; 
299.       } 
300.  
301.       //echo "文件 $filename 写入成功"; 
302.       echo "——错误记录被保存!"; 
303.  
304.       //关闭文件 
305.       fclose($handle); 
306.      } else { 
307.       echo "文件 $filename 不可写"; 
308.      } 
309.     } 
310.  
311.    } 
312.    echo "<br />"; 
313.    if ($this->is_error) { 
314.     exit; 
315.    } 
316.   } 
317.   echo "</div>"; 
318.   echo "</fieldset>"; 
319.  
320.   echo "<br />"; 
321.  } 
322.  
323.  //释放结果集 
324.  public function free() { 
325.   @ mysql_free_result($this->result); 
326.  } 
327.  
328.  //数据库选择 
329.  public function select_db($db_database) { 
330.   return mysql_select_db($db_database); 
331.  } 
332.  
333.  //查询字段数量 
334.  public function num_fields($table_name) { 
335.   //return mysql_num_fields($this->result); 
336.   $this->query("select * from $table_name"); 
337.   echo "<br />"; 
338.   echo "字段数：" . $total = mysql_num_fields($this->result); 
339.   echo "<pre>"; 
340.   for ($i = 0; $i < $total; $i++) { 
341.    print_r(mysql_fetch_field($this->result, $i)); 
342.   } 
343.   echo "</pre>"; 
344.   echo "<br />"; 
345.  } 
346.  
347.  //取得 mysql 服务器信息 
348.  public function mysql_server($num = '') { 
349.   switch ($num) { 
350.    case 1 : 
351.     return mysql_get_server_info(); //mysql 服务器信息 
352.     break; 
353.  
354.    case 2 : 
355.     return mysql_get_host_info(); //取得 mysql 主机信息 
356.     break; 
357.  
358.    case 3 : 
359.     return mysql_get_client_info(); //取得 mysql 客户端信息 
360.     break; 
361.  
362.    case 4 : 
363.     return mysql_get_proto_info(); //取得 mysql 协议信息 
364.     break; 
365.  
366.    default : 
367.     return mysql_get_client_info(); //默认取得mysql版本信息 
368.   }//开源代码phpfensi.com 
369.  } 
370.  
371.  //析构函数，自动关闭数据库,垃圾回收机制 
372.  public function __destruct() { 
373.   if (!emptyempty ($this->result)) { 
374.    $this->free(); 
375.   } 
376.   mysql_close($this->conn); 
377.  } //function __destruct(); 
378.  
379.  /*获得客户端真实的ip地址*/ 
380.  function getip() { 
381.   if (getenv("http_client_ip") && strcasecmp(getenv("http_client_ip"), "unknown")) { 
382.    $ip = getenv("http_client_ip"); 
383.   } else 
384.    if (getenv("http_x_forwarded_for") && strcasecmp(getenv("http_x_forwarded_for"), "unknown")) { 
385.     $ip = getenv("http_x_forwarded_for"); 
386.    } else 
387.     if (getenv("remote_addr") && strcasecmp(getenv("remote_addr"), "unknown")) { 
388.      $ip = getenv("remote_addr"); 
389.     } else 
390.      if (isset ($_server['remote_addr']) && $_server['remote_addr'] && strcasecmp($_server['remote_addr'], "unknown")) { 
391.       $ip = $_server['remote_addr']; 
392.      } else { 
393.       $ip = "unknown"; 
394.      } 
395.   return ($ip); 
396.  } 
397.  function inject_check($sql_str) { //防止注入 
398.   $check = eregi('select|insert|update|delete|'|/*|*|../|./|union|into|load_file|outfile', $sql_str); 
399.   if ($check) { 
400.    echo "输入非法注入内容！"; 
401.    exit (); 
402.   } else { 
403.    return $sql_str; 
404.   } 
405.  } 
406.  function checkurl() { //检查来路 
407.   if (preg_replace("/https?://([^:/]+).*/i", "1", $_server['http_referer']) !== preg_replace("/([^:]+).*/", "1", $_server['http_host'])) { 
408.    header("location: http://www.phpfensi.com"); 
409.    exit(); 
410.   } 
411.  } 
412.  
413. }