class Database { private $host; private $username; private $password; private $database; private $connection; private $result; public function __construct($host, $username, $password, $database) { $this->host = $host; $this->username = $username; $this->password = $password; $this->database = $database; // 建立数据库连接 $this->connection = mysqli_connect($host, $username, $password, $database); if (!$this->connection) { die('Could not connect: ' . mysqli_error()); } } public function query($sql) { // 实行 SQL 查询 $this->result = mysqli_query($this->connection, $sql); if (!$this->result) { die('Query failed: ' . mysqli_error($this->connection)); } return $this->result; } public function fetchArray($result) { // 获取查询结果的数组形式 return mysqli_fetch_array($result); } public function numRows($result) { // 获取查询结果的行数 return mysqli_num_rows($result); } public function escapeString($str) { // 转义字符串中的分外字符 return mysqli_real_escape_string($this->connection, $str); } public function __destruct() { // 关闭数据库连接 mysqli_close($this->connection); }}
上述代码定义了一个 Database 类,用于连接数据库、实行 SQL 查询等操作。详细来说,该类包含了以下几个方法:
__construct($host, $username, $password, $database):布局方法,用于建立数据库连接。query($sql):实行 SQL 查询语句,返回查询结果。fetchArray($result):获取查询结果的数组形式。numRows($result):获取查询结果的行数。escapeString($str):转义字符串中的分外字符。__destruct():析构方法,用于关闭数据库连接。利用该类进行数据库操作时,只需实例化该类,并调用相应的方法即可,例如:
$db = new Database('localhost', 'root', 'password', 'mydatabase');$result = $db->query('SELECT FROM mytable');while ($row = $db->fetchArray($result)) { // 处理查询结果}$db->__destruct();
通过这种办法,可以将数据库操作封装在一个类中,使得代码更加易于掩护和复用。同时,也可以在类中添加更多的方法,用于处理其他数据库操作,例如插入、更新和删除数据等操作。

当封装数据库操作类时,须要考虑到常见的数据库操作,包括插入、更新、删除、查询等。下面是一个大略的示例,展示如何在数据库操作类中添加更多方法来处理这些操作:
class Database { private $host; private $username; private $password; private $database; private $conn; // 布局函数 function __construct($host, $username, $password, $database) { $this->host = $host; $this->username = $username; $this->password = $password; $this->database = $database; $this->conn = new mysqli($this->host, $this->username, $this->password, $this->database); if ($this->conn->connect_error) { die("Connection failed: " . $this->conn->connect_error); } } // 插入数据 function insert($table, $data) { $columns = implode(',', array_keys($data)); $values = "'" . implode("','", array_values($data)) . "'"; $sql = "INSERT INTO $table ($columns) VALUES ($values)"; if ($this->conn->query($sql) === TRUE) { return true; } else { echo "Error: " . $sql . "<br>" . $this->conn->error; return false; } } // 更新数据 function update($table, $data, $where) { $set = array(); foreach ($data as $column => $value) { $set[] = "$column = '$value'"; } $set = implode(',', $set); $sql = "UPDATE $table SET $set WHERE $where"; if ($this->conn->query($sql) === TRUE) { return true; } else { echo "Error: " . $sql . "<br>" . $this->conn->error; return false; } } // 删除数据 function delete($table, $where) { $sql = "DELETE FROM $table WHERE $where"; if ($this->conn->query($sql) === TRUE) { return true; } else { echo "Error: " . $sql . "<br>" . $this->conn->error; return false; } } // 查询数据 function select($table, $columns = '', $where = '') { $sql = "SELECT $columns FROM $table"; if ($where != '') { $sql .= " WHERE $where"; } $result = $this->conn->query($sql); if ($result->num_rows > 0) { $rows = array(); while ($row = $result->fetch_assoc()) { $rows[] = $row; } return $rows; } else { return false; } }}
在上面的示例中,我们添加了四个常见的数据库操作方法:insert()、update()、delete()和select()。这些方法接管不同的参数,并利用mysqli实现对数据库的操作。利用这些方法时,我们只需实例化数据库操作类并调用相应的方法即可。例如:
$db = new Database('localhost', 'username', 'password', 'database');$data = array('name' => 'John Doe', 'age' => 30, 'email' => 'john.doe@example.com');$insert_id = $db->insert('users', $data);if ($insert_id) { echo "Data inserted successfully with ID: " . $insert_id;} else { echo "Error inserting data";}
这段代码创建Database类的一个新实例,创建一个要插入的数据数组,然后调用insert()方法将数据插入到“用户”表中。该方法返回插入的记录的ID,如果插入成功,则将其打印到屏幕上。