面向对象编程的过程中，经常要用到动态数据来填充静态网页，而动态数据往往来自于数据库，为了不用每此创建一个脚本都要重新打一遍连接数据库以及其它的获取资源结果集的代码，因此封装一个数据库的工具类文件就显得尤为重要了。
数据库工具类的封装，要实现的基本功能要有初始化数据库连接的信息，例如端口、主机号、字符集和数据库名等，然后就是一些常用的功能，例如查询表后获取一个多行多列，单行多列和单行单列的结果集，还有就是一个能用于查询的方法，能够完成查询并返回结果集的功能，并且人为地提示错误信息等，因为数据库采用静默模式，因此默认情况下并不会报错。
1 <?php
2
3 header("content-type:text/html;charset=utf-8");
4 //MySQLDB类
5 class MySQLDB{
6 private $host; //主机地址
7 private $port; //端口号
8 private $user; //用户名
9 private $pass; //密码
10 private $charset;//字符集
11 private $dbname; //数据库名
12 private $link; //连接资源
13 private static $instance; //保存对象
14
15 private function __construct($arr){
16 $this->host=isset($arr[‘host‘]) ? $arr[‘host‘] : "localhost";
17 $this->port=isset($arr[‘port‘]) ? $arr[‘port‘] : "3306";
18 $this->user=isset($arr[‘user‘]) ? $arr[‘user‘] : "root";
19 $this->pass=isset($arr[‘pass‘]) ? $arr[‘pass‘] : "";
20 $this->charset=isset($arr[‘charset‘]) ? $arr[‘charset‘] : "utf8";
21 $this->dbname=isset($arr[‘dbname‘]) ? $arr[‘dbname‘] : "";
22
23 $this->my_connect();
24
25 $this->my_charset();
26
27 $this->my_dbname();
28 }
29
30 public static function getInstance($arr){
31 if(!self::$instance instanceof self){
32 self::$instance = new self($arr);
33 }
34 return self::$instance;
35 }
36
37 //连接数据的方法
38 private function my_connect(){
39 if($link = @ mysql_connect("$this->host:$this->port",$this->user,$this->pass)){
40 //连接成功
41 $this->link = $link;
42 }else{
43 //连接失败
44 echo "连接数据库失败<br/>";
45 echo "错误代码 ",mysql_errno(), "<br/>";
46 echo "错误信息 ",mysql_error(), "<br/>";
47 die;
48 }
49 }
50
51 //sql语句执行方法
52 public function my_query($sql){
53 $result=mysql_query($sql);
54 if(!$result){
55 //执行失败
56 echo "执行SQL语句失败<br/>";
57 echo "错误代码 ",mysql_errno(), "<br/>";
58 echo "错误信息 ",mysql_error(), "<br/>";
59 echo "错误语句 ",$sql, "<br/>";
60 die;
61 }else{
62 //执行成功
63 return $result;
64 }
65 }
66
67 public function fetchAll($sql){
68 if($result = $this->my_query($sql)){
69 //执行成功，遍历结果集
70 $rows = array();
71 while($row = mysql_fetch_assoc($result)){
72 $rows[] = $row;
73 }
74 //结果资源集用完之后最好手动释放
75 mysql_free_result($result);
76 //提取成功后返回一个二维数组或空数组
77 return $rows;
78 }else{
79 return false;
80 }
81 }
82
83 public function fetchRow($sql){
84 if($result = $this->my_query($sql)){
85 //执行成功就返回一个一维数组
86 $row = mysql_fetch_assoc($result);
87 //提取结果集后手动释放
88 mysql_free_result($result);
89 //返回所有数据或空数组
90 return $row;
91 }else{
92 return flase;
93 }
94 }
95
96 public function fetchColumn($sql){
97 if($result = $this->my_query($sql)){
98 //执行语句成功，提取结果集
99 $row = mysql_fetch_row($result);
100 //提取完后主动释放结果集
101 mysql_free_result($result);
102 //返回结果
103 return isset($row[0]) ? $row[0] : flase;
104 }else{
105 return flase;
106 }
107 }
108
109 //选择默认字符集
110 private function my_charset(){
111 $sql = "set names $this->charset";
112 $this->my_query($sql);
113 }
114
115 //选择默认数据库
116 private function my_dbname(){
117 $sql = "use $this->dbname";
118 $this->my_query($sql);
119 }
120
121 public function __destruct(){
122 @ mysql_close($this->link);
123 }
124
125 public function __sleep(){
126 //序列化数据之前，系统自动调用的方法，可以确定哪些数据需要序列化
127 return array(‘host‘,‘port‘,‘user‘,‘pass‘,‘charset‘,‘dbname‘);
128 }
129
130 public function __wakeup(){
131 //反序列化的时候，系统自动调用的方法
132 //连接数据库三部曲
133 //连接数据库
134 $this->my_connect();
135 //选择默认字符集
136 $this->my_charset();
137 //选择默认数据库
138 $this->my_dbname();
139 }
140
141 public function __set($name,$value){
142 $allow_set = array(‘host‘,‘port‘,‘user‘,‘pass‘,‘charset‘,‘dbname‘);
143 if(in_array($name, $allow_set)){
144 $this->$name = $value;
145 }
146 }
147
148 public function __get($name){
149 $allow_get = array(‘host‘,‘port‘,‘charset‘,‘dbname‘);
150 if(in_array($name, $allow_get)){
151 return $this->$name;
152 }else{
153 return flase;
154 }
155 }
156
157 public function __isset($name){
158 $allow_isset = array(‘host‘,‘port‘,‘user‘,‘pass‘,‘charset‘,‘dbname‘);
159 if(in_array($name, $allow_isset)){
160 return true;
161 }else{
162 return flase;
163 }
164 }
165
166 public function __unset($name){
167 //unset什么功能都不用实现
168 }
169
170 private function __clone(){
171
172 }
173 }
时间： 2024-11-10 07:26:34