```php <?php /** * 專業操作數據 */ class DB { private $host; //主機 private $user;//用戶名 private $password;//密碼 private $dbname;//數據庫名字 private $port;//端口 private $charset; private $link;//數據庫鏈接資源 private static $instance;//保證只有一個 /** * DB constructor. * @param $params DB類中需要的數據 */ private function __construct($params) { $this->host = isset($params['host'])?$params['host']:"127.0.0.1"; $this->user = isset($params['user'])?$params['user']:"root"; $this->password = $params['password']; $this->dbname = $params['dbname']; $this->port = isset($params['port'])?$params['port']:3306; $this->charset = isset($params['charset'])?$params['charset']:"utf8"; $this->connect(); //必須優先調用connect() $this->setCharset(); } /** * 創建DB類的對象，并且返回 * @return DB */ public static function getInstance($params){ if(!self::$instance instanceof self){ self::$instance= new self($params); } return self::$instance; } private function __clone(){ } /** * 連接數據庫 */ private function connect() { $this->link = mysqli_connect($this->host, $this->user, $this->password, $this->dbname, $this->port); //鏈接錯誤時返回false if ($this->link === false) { //鏈接失敗. 就退出 exit("連接失敗!錯誤信息:" . mysqli_connect_error()); } } /** * 設置編碼 */ private function setCharset() { $sql = "set names " . $this->charset; $result = mysqli_query($this->link, $sql); if ($result === false) { //鏈接失敗. 就退出 exit("執行SQL失敗!錯誤信息:" . mysqli_connect_error()); } } /** * 執行sql語句 * @param $sql */ public function query($sql) { $result = mysqli_query($this->link, $sql); if ($result === false) { //鏈接失敗. 就退出 echo "執行SQL失敗!<br/>"; echo "SQL:{$sql}!<br/>"; exit("執行SQL失敗!錯誤信息:" . mysqli_connect_error()); } return $result; } /** * 執行sql語句,返回所有的數據,該數據以二維數組的形式存在 * @param $sql * @return 二維數組 */ public function fetchAll($sql){ $result = $this->query($sql); //一次性從結果中取出所有的數據,并且以索引數組返回. $rows = mysqli_fetch_all($result,MYSQLI_ASSOC); //>>3. 返回二維數組 return $rows; } /** * 根據sql查詢出一行數據 * @param $sql * @return 一維數組 */ public function fetchRow($sql){ //>>1. 執行sql語句,得到多行數據 $rows = $this->fetchAll($sql); //>>2. 從多行數據中解析出一行 return empty($rows)?null:$rows[0]; } //執行sql語句,得到唯一結果值. public function fetchColumn($sql){ $row = $this->fetchRow($sql); // 從第一行中得到第一列的值 return empty($row)?null:array_values($row)[0]; //因為row是一個關聯數組,需要先從關聯數組中取出所有的值. 再從所有的值中取出第一個值. } //得到插入記錄的id public function insertId(){ return mysqli_insert_id($this->link); } public function __destruct() { //mysqli_close($this->link); } /** * 該方法在對象序列化時被調用. * @return array */ public function __sleep() { //該數組中指定的屬性才能夠被序列化 return ["host",'user','password','dbname','port','charset']; } //該方法在對象被反序列化時調用 public function __wakeup() { //用來重新初始化屬性 $this->connect(); $this->setCharset(); } } ```