1 <?php 2 error_reporting(E_ALL ^ E_DEPRECATED); 3 4 //數據庫操作類 5 class MySQLDB{ 6 7 //屬性--必要的信息 8 private $_host; //主機 9 private $_port; //端口 10 private $_user; //用戶名 11 private $_pass; //密碼 12 private $_charset;//字符集 13 private $_dbname; //默認數據庫 14 15 //屬性--運行時生成 16 public $_link; //mysql link 資源 17 18 private static $_instance; 19 public static function getInstance($params=array()){ 20 if(!self::$_instance instanceof self){ 21 self::$_instance = new self($params); 22 } 23 return self::$_instance; 24 } 25 private function __clone(){} 26 27 /* 28 * 構造方法 29 * @param $param=array() array 關聯數組 需要六個屬性值 30 */ 31 private function __construct($params=array()){ 32 //初始化屬性 33 $this->_initParams($params); 34 //連接數據庫服務器 35 $this->_connect(); 36 //設定字符集 37 $this->_setCharset(); 38 //選擇默認數據 39 $this->_selectDB(); 40 } 41 42 /* 43 * 初始化數據庫服務器參數 44 */ 45 private function _initParams($params){ 46 $this->_host = isset($params['host'])?$params['host']:'127.0.0.1'; //本機 47 $this->_port = isset($params['port'])?$params['port']:'3306'; //3306 48 $this->_user = isset($params['user'])?$params['user']:''; //匿名用戶 49 $this->_pass = isset($params['pass'])?$params['pass']:''; //沒有密碼 50 $this->_charset = isset($params['charset'])?$params['charset']:'utf8'; //utf8 51 $this->_dbname = isset($params['dbname'])?$params['dbname']:''; //表示不用選擇默認數據庫 52 } 53 54 55 /* 56 * 連接數據庫服務器 57 */ 58 private function _connect(){ 59 //127.0.0.1:3306 60 if($link = mysql_connect("$this->_host:$this->_port",$this->_user,$this->_pass)){ 61 //成功 62 $this->_link = $link; 63 }else{ 64 //失敗,強制腳本結束,提示錯誤信息 65 die("-_-!,連接數據庫服務器失敗,請確定連接選項"); 66 } 67 } 68 69 /* 70 * 設定指定字符集 71 */ 72 private function _setCharset(){ 73 $sql = "set names $this->_charset"; 74 if(mysql_query($sql,$this->_link)){ 75 //成功 76 }else{ 77 //執行失敗給出錯誤信息 78 echo '-_-!SQL執行失敗<br/>'; 79 echo '錯誤的SQL為:',$sql,'<br/>'; 80 echo '錯誤代碼為:',mysql_errno($this->_link),'<br/>'; 81 echo '錯誤信息為:',mysql_error($this->_link); 82 die; 83 } 84 } 85 86 /* 87 * 選擇默認數據庫 88 * 如果沒有指定,則不選擇 89 */ 90 private function _selectDB(){ 91 //判斷是否需要選擇默認數據庫,表示不需要,防止為0 92 if($this->_dbname !== ''){ 93 //不為空,才選擇數據庫 94 $sql = "use `$this->_dbname`"; 95 if(mysql_query($sql,$this->_link)){ 96 //成功 97 }else{ 98 //執行失敗給出錯誤信息 99 echo '-_-!SQL執行失敗<br/>';100 echo '錯誤的SQL為:',$sql,'<br/>';101 echo '錯誤代碼為:',mysql_errno($this->_link),'<br/>';102 echo '錯誤信息為:',mysql_error($this->_link);103 die;104 }105 }106 }107 108 /**109 * 獲得全部記錄110 *111 * @param $sql string 查詢類的SQL(select,show,desc)112 *113 * @return array 二維數組,記錄的集合114 */115 public function fetchAll($sql){116 //先執行117 if(!$result = mysql_query($sql,$this->_link)){118 //執行失敗給出錯誤信息119 echo '-_-!SQL執行失敗<br/>';120 echo '錯誤的SQL為:',$sql,'<br/>';121 echo '錯誤代碼為:',mysql_errno($this->_link),'<br/>';122 echo '錯誤信息為:',mysql_error($this->_link);123 die;124 }125 //獲取數據126 $rows = array();127 while($row = mysql_fetch_assoc($result)){128 $rows[] = $row;129 }130 //釋放結果集131 mysql_free_result($result);132 //返回133 return $rows;134 }135 136 /**137 * 獲得一條記錄138 *139 * @param $sql string 查詢類的SQL(select,show,desc)140 *141 * @return array 一維數組,一條記錄142 */143 public function fetchRow($sql){144 //先執行145 if(!$result = mysql_query($sql,$this->_link)){146 //執行失敗給出錯誤信息147 echo '-_-!SQL執行失敗<br/>';148 echo '錯誤的SQL為:',$sql,'<br/>';149 echo '錯誤代碼為:',mysql_errno($this->_link),'<br/>';150 echo '錯誤信息為:',mysql_error($this->_link);151 die;152 }153 //獲取數據154 $row = mysql_fetch_assoc($result);155 //釋放結果集156 mysql_free_result($result);157 //返回158 return $row;159 }160 161 /**162 * 獲得一個數據163 *164 * @param $sql string 查詢類的SQL(select,show,desc)165 *166 * @return string 唯一的數據 第一條記錄的第一列167 */168 public function fetchColumn($sql){169 //先執行170 if(!$result = mysql_query($sql,$this->_link)){171 //執行失敗給出錯誤信息172 echo '-_-!SQL執行失敗<br/>';173 echo '錯誤的SQL為:',$sql,'<br/>';174 echo '錯誤代碼為:',mysql_errno($this->_link),'<br/>';175 echo '錯誤信息為:',mysql_error($this->_link);176 die;177 }178 //獲取數據179 $row = mysql_fetch_row($result);180 //釋放結果集181 mysql_free_result($result);182 //返回183 return $row[0];184 }185 186 187 /**188 * 序列化時執行的方法189 * @return array每個數組元素為一個需要被序列化的屬性名190 *191 */192 public function __sleep(){193 return array('_host','_post','_user','_pass','_charset','_dbname');194 }195 196 /*197 * 反序列化時被執行198 * 重新初始化工作199 */200 public function __wakeup(){201 //連接數據庫服務器202 $this->_connect();203 //設定連接字符集204 $this->_setCharset();205 //選擇默認數據庫206 $this->_selectDB();207 }208 }
新聞熱點
疑難解答