一个数据库操作PHP类

1. /*
2. * Author 墨龙
3. * Time 2010年12月2日 15:50:35
4. */
6. $db = new mysql($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding);
8. class mysql{
10. private $db_host;
11. private $db_user;
12. private $db_password;
13. private $db_table;
14. private $db_conn; //数据库连接标识;
15. private $result; //执行query命令的结果资源标识
16. private $sql; //sql执行语句
17. private $pre; //数据库表前缀
18. private $coding; //数据库编码，GBK,UTF8,gb2312
20. function __construct($db_host,$db_user,$db_password,$db_table,$db_conn,$pre,$coding){
22. $this->db_host = $db_host;
23. $this->db_user = $db_user;
24. $this->db_password = $db_password;
25. $this->db_table = $db_table;
26. $this->db_conn = $db_conn;
27. $this->pre = $pre;
28. $this->coding = $coding;
29. $this->connect();
31. }
33. function connect(){
35. $this->db_conn = @mysql_connect($this->db_host,$this->db_user,$this->db_password) or die($this->show_error("数据库链接错误,请检查数据库链接配置！"));
36. if(!mysql_select_db($this->db_table,$this->db_conn)){
38. echo "没有找到数据表：".$this->db_table;
39. }
40. mysql_select_db($this->db_table,$this->db_conn);
41. $this->query("SET NAMES $this->coding");
42. }
44. /*执行SQL语句的函数*/
45. function query($sql){
47. if(emptyempty($sql)){
48. $this->show_error("你的sql语句不能为空！");
49. }else{
50. $this->sql = $sql;
51. }
52. $result = mysql_query($this->sql,$this->db_conn);
54. return $this->result = $result;
55. }
57. /*创建添加新的数据库*/
58. public function create_database($database_name){
59. $database=$database_name;
60. $sqlDatabase = 'create database '.$database;
61. return $this->query($sqlDatabase);
62. }
64. // 根据select查询结果计算结果集条数
65. public function db_num_rows(){
66. if($this->result==null){
67. if($this->show_error){
68. $this->show_error("sql语句错误!");
69. }
70. }else{
71. return mysql_num_rows($this->result);
72. }
73. }
75. /*查询服务器所有数据库*/
76. //将系统数据库与用户数据库分开，更直观的显示？
77. public function show_databases(){
78. $this->query("show databases");
79. echo "现有数据库：".$amount =$this->db_num_rows($rs);
80. echo "
    ";
81. $i=1;
82. while($row = $this->fetch_array($rs)){
83. echo "$i $row[Database]";
84. echo "
    ";
85. $i++;
86. }
87. }
89. //以数组形式返回主机中所有数据库名
90. public function databases()
91. {
92. $rsPtr=mysql_list_dbs($this->db_conn);
93. $i=0;
94. $cnt=mysql_num_rows($rsPtr);
95. while($i {
96. $rs[]=mysql_db_name($rsPtr,$i);
97. $i++;
98. }
99. return print_r($rs);
100. }
102. /*查询数据库下所有的表*/
103. function show_tables($database_name){
104. $this->query("show tables");
105. echo "现有数据库：".$amount = $this->db_num_rows($rs);
106. echo "
     ";
107. $i=1;
108. while($row = $this->fetch_array($rs)){
109. $columnName="Tables_in_".$database_name;
110. echo "$i $row[$columnName]";
111. echo "
     ";
112. $i++;
113. }
114. }
116. /*
117. mysql_fetch_row() array $row[0],$row[1],$row[2]
118. mysql_fetch_array() array $row[0] 或 $row[id]
119. mysql_fetch_assoc() array 用$row->content 字段大小写敏感
120. mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感
121. */
122. /*取得记录集,获取数组-索引和关联,使用$row['content'] */
123. public function fetch_array()
124. {
125. return @mysql_fetch_array($this->result);
126. }
128. //获取关联数组,使用$row['字段名']
129. public function fetch_ass()
130. {
131. return @mysql_fetch_assoc($this->result);
132. }
134. //获取数字索引数组,使用$row[0],$row[1],$row[2]
135. public function fetch_row()
136. {
137. return @mysql_fetch_row($this->result);
138. }
140. //获取对象数组,使用$row->content
141. public function fetch_Object()
142. {
143. return @mysql_fetch_object($this->result);
144. }
146. //简化查询select
147. public function findall($table){
148. $table = $this->fulltablename($table);
149. $this->query("select * from $table");
150. }
152. public function select($table,$columnName,$condition){
153. $table = $this->fulltablename($table);
154. if(emptyempty($columnName)){
155. $columnName = "*";
156. }
157. $this->query("SELECT $columnName FROM $table $condition");
158. }
160. //简化的insert
161. function insert($table,$arr){
162. $table = $this->fulltablename($table);
163. $sql = "INSERT INTO $table ";
164. if(!is_array($arr)){
165. $this->show_error("请输入参数数组！");
166. }else{
167. $k = "";
168. $v = "";
169. foreach($arr as $key => $value){
170. $k .= "`$key`,";
171. $v .= "'".$value."',";
172. }
173. }
174. $sql = $sql." (".substr($k,0,-1).") VALUES (".substr($v,0,-1).")";
175. $this->query($sql);
176. }
177. //简化的update
178. function update($table,$arr,$where){
179. $table = $this->fulltablename($table);
180. $sql = "UPDATE $table SET ";
181. if(!is_array($arr)){
182. $this->show_error("请输入参数数组！");
183. }else{
184. foreach($arr as $key => $value){
185. $sql .= " `".$key."` = '".$value."' ,";
186. }
187. }
188. $sql = substr($sql,0,-1)." where ".$where;
189. return $this->query($sql);
190. }
191. //简化的delete
192. function delete($table,$where = ""){
193. $table = $this->fulltablename($table);
194. if(emptyempty($where)){
195. $this->show_error("条件不能为空!");
196. }else{
197. $where = " where ".$where;
198. }
199. $sql = "DELETE FROM $table ".$where;
200. //echo $sql;
201. return $this->query($sql);
202. }
204. //取得上一步 INSERT 操作产生的 ID
205. public function insert_id(){
206. return mysql_insert_id();
207. }
209. //加上前缀的数据表
210. public function fulltablename($table){
211. return $table = $this->pre.$table;
212. }
214. //查询字段数量
215. public function num_fields($table){
216. $table = $this->fulltablename($table);
217. $this->query("select * from $table");
218. echo "
     ";
219. echo "字段数：".$total = mysql_num_fields($this->result);
220. echo "

     ";  

221. for ($i=0; $i print_r(mysql_fetch_field($this->result,$i) );
222. }
223. echo "";
224. echo "
     ";
225. }
227. //取得 MySQL 服务器信息
228. public function mysql_server($num=''){
229. switch ($num){
230. case 1 :
231. return mysql_get_server_info(); //MySQL 服务器信息
232. break;
234. case 2 :
235. return mysql_get_host_info(); //取得 MySQL 主机信息
236. break;
238. case 3 :
239. return mysql_get_client_info(); //取得 MySQL 客户端信息
240. break;
242. case 4 :
243. return mysql_get_proto_info(); //取得 MySQL 协议信息
244. break;
246. default:
247. return mysql_get_client_info(); //默认取得mysql版本信息
248. }
249. }
251. //析构函数，自动关闭数据库,垃圾回收机制
252. /*public function __destruct()
253. {
254. if(!empty($this->result)){
255. $this->free();
256. }
257. mysql_close($this->$db_conn);
258. }*/
260. /*获得客户端真实的IP地址*/
261. function getip(){
262. if(getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
263. {
264. $ip = getenv("HTTP_CLIENT_IP");
265. }
266. else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown")){
267. $ip = getenv("HTTP_X_FORWARDED_FOR");
268. }
269. else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
270. {
271. $ip = getenv("REMOTE_ADDR");
272. }
273. else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown")){
274. $ip = $_SERVER['REMOTE_ADDR'];
275. }
276. else{
277. $ip = "unknown";
278. }
279. return($ip);
280. }
282. function show_error($str){
283. echo "";
284. }
286. }
287. ?>

复制代码

PHP