php怎么封装数据库增删改的类
随着WEB应用程序的发展，对于数据库管理的需求也越来越高。作为一名PHP程序员，如何优化执行增删改查的操作，是必须要解决的问题。而这个问题的解决，可以通过php封装数据库增删改的类来解决。
1.为什么需要封装数据库类？
通常情况下，在进行数据库操作时，我们会在应用程序的主要逻辑中进行操作，比如在控制器中操作数据库。但实际上，这种方式存在几个明显的问题：
代码冗余：在我们的应用程序中，很可能多个控制器需要对数据库进行操作。如果每个控制器都单独编写数据库操作的代码，那么就会出现大量的冗余代码。
代码可读性差：这种情况下，代码的可读性也就差了。很可能我们同一段代码就出现在多个控制器中，这样一来，就会给其他开发人员带来困扰。
安全问题：将数据库操作代码直接写在应用程序中，存在一定的安全风险。比如sql注入等问题。
综上所述，我们有必要将我们的数据库操作代码封装起来，让它们成为一个独立的模块。这个模块需要具有以下几个特点：
具有良好的可读性
能够方便的进行代码复用
具有良好的扩展性
能够有效的解决安全问题
2.封装数据库增删改类的基本思路
针对上面提到的问题，我们可以把类写成php库的形式，以便实现类的复用。封装数据库增删改类的基本思路如下：
将所有的数据库操作都封装在一个类中，比如叫做db类。
编写通用的方法来实现数据库增删改查操作。
在方法中实现参数化查询，从而有效的避免sql注入等安全问题。
将所有的错误信息都捕获，并且封装成一个统一的异常抛出给上层代码。
下面是一个简单的db类的实现：
class db {
private $db_host;
private $db_user;
private $db_pass;
private $db_name;
private $conn;
function __construct($db_host, $db_user, $db_pass, $db_name) {
$this->db_host = $db_host;
$this->db_user = $db_user;
$this->db_pass = $db_pass;
$this->db_name = $db_name;
}
// 数据库连接方法
function connect() {
$this->conn = Mysqli_connect($this->db_host, $this->db_user, $this->db_pass, $this->db_name);
if (!$this->conn) {
throw new Exception('数据库连接失败');
}
mysqli_query($this->conn, "SET NAMES 'utf8'");
}
// 数据库关闭方法
function close() {
mysqli_close($this->conn);
}
// 查询方法，参数化查询
function query($sql, $params) {
$stmt = mysqli_prepare($this->conn, $sql);
if (!$stmt) {
throw new Exception('query error: '.mysqli_error($this->conn));
}
if (count($params) > 0) {
call_user_func_array('mysqli_stmt_bind_param', array_merge(array($stmt, str_repeat('s', count($params))), $params));
}
$result = mysqli_stmt_execute($stmt);
if (!$result) {
throw new Exception('query error: '.mysqli_stmt_error($stmt));
}
$rows = array();
$meta = mysqli_stmt_result_metadata($stmt);
if ($meta) {
while ($field = mysqli_fetch_field($meta)) {
$params[] = &$row[$field->name];
}
call_user_func_array(array($stmt, 'bind_result'), $params);
while (mysqli_stmt_fetch($stmt)) {
$rows[] = $row;
}
}
mysqli_stmt_close($stmt);
return $rows;
}
// 增加方法，参数化查询
function insert($table, $data) {
$sql = 'INSERT INTO '.$table.' ('.implode(',', array_keys($data)).') VALUES ('.implode(',', array_fill(0, count($data), '?')).')';
$result = $this->query($sql, array_values($data));
return mysqli_affected_rows($this->conn);
}
// 更新方法
function update() {
// 实现更新方法
}
// 删除方法
function delete() {
// 实现删除方法
}
}
