mysql数据库连接类

这是一款比较常用的mysql+php的数据库连接类文件代码,这款连接类支持pconnect与mysql_connect来连接,用户可以根据自己的WEB应用类型来处理作选择,mysql数据库连接类代码如下:

1. $dbhost = 'localhost';    // 数据库服务器 
2.  $dbuser = 'root';     // 数据库用户名 
3.  $dbpw = 'qwaszx';             // 数据库密码 
4.  $dbname = 'movie';  // 数据库名 
5.  $adminemail = 'haha@163.com'; // 系统管理员 Email 
6.  
7.  $database = 'mysql';  // 不能修改此处 
8.  $tplrefresh = 1;  // 模板自动刷新开关 0=关闭, 1=打开 
9.  $pconnect = 0;   // 数据库连接方式 0=connect, 1=pconnect 
10.  
11. class db_class { 
12.  var $querynum = 0; 
13.  //function dbstuff() { global $fp; $fp = fopen("./tempdata/dblog.txt", "w"); } 
14.  
15.  function connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect = 0) { 
16.   if($pconnect) { 
17.    if(!@mysql_pconnect($dbhost, $dbuser, $dbpw)) { 
18.     $this->halt('Can not connect to MySQL server'); 
19.    } 
20.   } else { 
21.    if(!@mysql_connect($dbhost, $dbuser, $dbpw)) { 
22.     $this->halt('Can not connect to MySQL server'); 
23.    } 
24.   } 
25.   mysql_query("SET NAMES 'GB2312'");//www.111cn.net 
26.  } 
27.  
28.  function select_db($dbname) { 
29.   return mysql_select_db($dbname); 
30.  } 
31.  
32.  function fetch_array($query, $result_type = MYSQL_ASSOC){ 
33.  
34.  
35.   $query = mysql_fetch_array($query, $result_type); 
36.  
37.   return $query; 
38.  } 
39.  
40.  function query($sql, $silence = 0) { 
41.   //echo "|$sql|<br>"; //debug 
42.   //@fwrite($GLOBALS[fp], $sql." "); //debug 
43.   $query = mysql_query($sql); 
44.         //echo 'query:'.$query.'<br>'; 
45.      if(!$query && !$silence) 
46.         { 
47.          $this->halt('MySQL Query Error', $sql); 
48.   } 
49.         $this->querynum++; 
50.   return $query; 
51.  } 
52.  
53.  function unbuffered_query($sql, $silence = 0) { 
54.   $func_unbuffered_query = @function_exists('mysql_unbuffered_query') ? 'mysql_unbuffered_query' : 'mysql_query'; 
55.   $query = $func_unbuffered_query($sql); 
56.   if(!$query && !$silence) { 
57.    $this->halt('MySQL Query Error', $sql); 
58.   } 
59.   $this->querynum++; 
60.   return $query;//www.111cn.net 
61.  } 
62.  function get_one($sql){ 
63.         $SQL=$sql; 
64.   if(function_exists('mysql_unbuffered_query')){ 
65.    $query = mysql_unbuffered_query($SQL); 
66.   }else{ 
67.    $query = mysql_query($SQL); 
68.   } 
69.   $this->querynum++; 
70.   if (!$query)  $this->halt('Query Error: ' . $SQL); 
71.    
72.   $rs =& mysql_fetch_array($query, MYSQL_ASSOC); 
73.   mysql_free_result($query); 
74.   return $rs; 
75.  } 
76.  
77.  function affected_rows() { 
78.   return mysql_affected_rows(); 
79.  } 
80.  
81.  function error() { 
82.   return mysql_error(); 
83.  } 
84.  
85.  function errno() { 
86.   return mysql_errno(); 
87.  } 
88.  
89.  function result($query, $row) { 
90.   $query = @mysql_result($query, $row); 
91.   return $query;www.111cn.net 
92.  } 
93.  
94.  function num_rows($query) { 
95.   $query = mysql_num_rows($query); 
96.   return $query; 
97.  } 
98.  
99.  function num_fields($query) { 
100.   return mysql_num_fields($query); 
101.  } 
102.  
103.  function free_result($query) { 
104.   return mysql_free_result($query); 
105.  } 
106.  
107.  function insert_id() { 
108.   $id = mysql_insert_id(); 
109.   return $id; 
110.  } 
111.  
112.  function fetch_row($query) { 
113.   $query = mysql_fetch_row($query); 
114.   return $query; 
115.  } 
116.  
117.  function close() { 
118.   return mysql_close(); 
119.  } 
120.  function halt($message = '', $sql = '') { 
121.           echo $message; 
122.               } 
123.  
124. } 
125.  
126. // ========= 连接数据库 
127.  
128. $db = new db_class; 
129. $db->connect($dbhost, $dbuser, $dbpw, $pconnect); 
130. //开源代码phpfensi.com 
131. $db->select_db($dbname); 
132. unset($dbhost, $dbuser, $dbpw, $dbname, $pconnect);