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 }