php实现mysql数据库操作类分享

下面是详细讲解“PHP实现MySQL数据库操作类分享”的完整攻略。

一、前言

MySQL 是一种关系型数据库管理系统，而 PHP 是一种强大的服务器端编程语言，两者的结合可以帮助我们快速实现数据的持久化，常见的操作包括增删改查等。在PHP中，我们可以使用面向对象的方式封装MySQL数据库操作，在此基础上形成MySQL数据库操作类，并把操作结果封装成对象的形式返回，达到了更好的可读性和可维护性。

二、数据库连接类

在 PHP 中，我们可以使用 PDO 或 mysqli 扩展来实现和 MySQL 数据库的连接。这里我们以 mysqli 扩展为例，创建一个数据库连接类 DbConnect，其中包含数据库的连接和关闭方法。

class DbConnect {

    private $conn;

    public function __construct($dbhost, $dbuser, $dbpass, $dbname) {
        $this->conn = new mysqli($dbhost, $dbuser, $dbpass, $dbname);
        if ($this->conn->connect_error) {
            die("连接失败: " . $this->conn->connect_error);
        }
    }

    public function close() {
        $this->conn->close();
    }
}

以上代码中，我们通过 mysqli 尝试连接 MySQL 数据库，如果连接失败则输出错误信息。

三、数据库操作类

我们使用一个类来封装 MySQL 数据库的操作，包括常见的增、删、改、查，以及事务支持、防 SQL 注入等功能。以下是一个简化的数据库操作类 DbOperate 的实现。

3.1 插入数据

public function insert($table, $data) {
    $keys = [];
    $values = [];
    foreach ($data as $key => $value) {
        $keys[] = $this->escape($key);
        $values[] = $this->escape($value);
    }
    $keys = implode(', ', $keys);
    $values = implode("', '", $values);
    $sql = "INSERT INTO $table ($keys) VALUES ('$values')";
    if ($result = $this->query($sql)) {
        return $this->mysqli->insert_id;
    }
    return false;
}

以上代码中，我们接收表名 $table 以及要插入的数据 $data，提取 $data 中的键值对，防止 SQL 注入后通过 INSERT INTO 语句将数据插入到数据库中。如果插入成功，我们返回插入的数据的 ID，否则返回 false。

3.2 更新数据

public function update($table, $data, $where=null) {
    $set = [];
    foreach ($data as $key => $value) {
        $set[] = $this->escape($key) . " = '" . $this->escape($value) . "'";
    }
    $set = implode(', ', $set);
    $sql = "UPDATE $table SET $set";
    if (!empty($where)) {
        $sql .= " WHERE " . $where;
    }
    return $this->query($sql);
}

以上代码中，我们接收表名 $table、要更新的数据 $data，以及更新条件 $where（可选项）。我们使用 UPDATE 语句将数据更新到数据库中，返回是否更新成功的结果。

3.3 删除数据

public function delete($table, $where=null) {
    $sql = "DELETE FROM $table";
    if (!empty($where)) {
        $sql .= " WHERE " . $where;
    }
    return $this->query($sql);
}

以上代码接收表名 $table、删除条件 $where（可选项），使用 DELETE FROM 语句删除符合条件的数据，并返回是否删除成功的结果。

3.4 查询数据

public function select($table, $columns='*', $where=null, $order=null, $limit=null) {
    $sql = "SELECT $columns FROM $table";
    if (!empty($where)) {
        $sql .= " WHERE " . $where;
    }
    if (!empty($order)) {
        $sql .= " ORDER BY " . $order;
    }
    if (!empty($limit)) {
        $sql .= " LIMIT " . $limit;
    }
    $result = $this->query($sql);
    if (!$result) {
        return [];
    }
    $rows = [];
    while ($row = mysqli_fetch_assoc($result)) {
        $rows[] = $row;
    }
    return $rows;
}

以上代码接收表名 $table、要查询的列 $columns（默认为所有列）、查询条件 $where（可选项）、查询顺序 $order（可选项）、查询条数 $limit（可选项），使用 SELECT 语句从数据库中选中符合要求的数据，并将查询结果返回。

3.5 防 SQL 注入

上述代码中的 $this->escape() 方法用来防止 SQL 注入。以下是该方法的实现。

public function escape($value) {
    if ($value === null) {
        return 'NULL';
    }
    if (is_int($value)) {
        return (int)$value;
    }
    if (is_float($value)) {
        return (float)$value;
    }
    return $this->mysqli->real_escape_string($value);
}

以上代码使用 mysqli 的 real_escape_string() 方法来转义字符串，防止 SQL 注入。

四、示例说明

以下是一个简单的示例，用于测试以上代码的正确性。

$dbhost = 'localhost';
$dbuser = 'root';
$dbpass = 'password';
$dbname = 'test_db';
$db = new DbConnect($dbhost, $dbuser, $dbpass, $dbname);
$data = [
    'name' => '张三',
    'age' => 22,
    'email' => '[e-mail]'
];
$insert_id = $db->insert('user', $data); // 向 user 表插入一条记录
$conditions = "id = $insert_id";
$data['email'] = '[e-mail]';
$db->update('user', $data, $conditions); // 更新符合条件的记录
$user = $db->select('user', '*', $conditions); // 查询符合条件的记录
$db->delete('user', $conditions); // 删除符合条件的记录
$db->close(); // 关闭数据库连接

以上代码中，我们先通过 DbConnect 创建一个数据库连接实例 $db，接着向 user 表插入一条记录，然后更新符合条件的记录，查询符合条件的记录，最后删除符合条件的记录。最后，我们关闭 $db 的连接。

五、总结

以上实现的代码能够帮助我们快速实现MySQL数据库操作，提高了可扩展性和可维护性。在实际应用中，可以通过优化和扩展该类，实现各种更为复杂的业务需求。