PHP使用PDO实现MySQL数据库操作封装类

目标与优势

PDO（PHP Data Objects）是 PHP 官方推荐的统一数据库访问层。相较于旧版扩展，它能提供一致的操作接口，且原生支持参数化预处理，能有效防止 SQL 注入攻击。本方案参考 Java 生态中 Spring 框架的 JdbcTemplate 模式，将高频的 CRUD（增删改查）操作封装为静态或实例方法，降低样板代码量。

准备条件

1. 环境版本：PHP 5 及以上（PDO 已内置）。当前主流开发建议直接使用 PHP 8 并引入现代 ORM 框架，但对于轻量级脚本或遗留维护，此类封装仍具有参考价值。
2. 配置参数：需提前获取 MySQL 服务器的 IP地址（Host）、端口（Port）、库名（Database Name）、用户名及密码。

操作步骤与原理

第1步：定义连接配置类 (DbConfig)

此步骤目的是将易变的数据库连接信息集中存放，方便统一管理。采用 static 属性存储参数，便于在无需实例化的情况下直接调用。

• 核心逻辑：getdsn() 方法根据配置项拼接标准的 DSN（Data Source Name）字符串。DSN 格式固定为：mysql:host=IP;port=3306;dbname=DBNAME;charset=UTF8。
• 关键细节：必须设置 charset=utf8mb4 以支持完整的 Unicode 字符集。

class dbconfig {

    private static $dbms = 'mysql';

    private static $host = '127.0.0.1';

    private static $port = '3306';

    private static $username = '';

    private static $password = '';

    private static $dbname = '';

    private static $charset = 'utf-8';

    private static $dsn;


    public static function getdsn() {

        if (!isset(self::$dsn)) {

            self::$dsn = self::$dbms . ':host=' . self::$host . ';port=' . self::$port . ';dbname=' . self::$dbname;

            if (strlen(self::$charset) > 0) {

                self::$dsn = self::$dsn . ';charset=' . self::$charset;

            }

        }

        return self::$dsn;

    }

    // 后续省略 setter...
}

第2步：构建通用操作基类 (DbTemplate)

此步骤旨在创建核心操作引擎。内部封装了获取连接、准备语句和清理资源的私有方法，对外暴露只读结果的方法。

• 获取连接：getConnection() 实例化 Pdo 对象，并强制启用 PDO::ATTR_CASE 使得列名全部大写，保持风格一致。
• 更新执行：exeUpdate() 处理 INSERT/UPDATE/DELETE 语句，返回受影响行数。

private function getConnection() {

    $conn = new Pdo(DbConfig::getDsn(), DbConfig::getUsername(), DbConfig::getPassword());

    $conn->setAttribute(Pdo::ATTR_CASE, Pdo::CASE_UPPER);

    return $conn;
}

private function exeUpdate($sql, $parameters = null) {

    $conn = $this->getConnection();

    $stmt = $conn->prepare($sql);

    $stmt->execute($parameters);

    $affectedRows = $stmt->rowCount();

    $stmt = null;

    $conn = null;

    return $affectedRows;
}

第3步：实现查询快捷方法

为满足业务对不同数据类型的需求，对 execute() 的结果进行了包装：

1. 多行记录：queryRows() 直接返回二维数组列表，用于渲染表格等场景。
2. 单条记录：queryRow() 提取二维数组的第一项。若为空则返回 null，避免空指针异常。
3. 标量类型转换：提供 queryForInt()、queryForFloat() 等方法，自动将查询出的第一个字段转换为对应数值型，适合统计总数或聚合计算。

第4步：实际调用示例

配置好参数后，即可调用如下方式执行 SQL。注意始终使用预编译占位符 ? 或命名占位符 :id 传递参数。

// 实例化模板

$template = new DbTemplate();

// 1. 查询多条记录

$sql = "SELECT * FROM users WHERE status = ?";

$rows = $template->queryRows($sql, [$status]);

// 2. 查询数量

$countSql = "SELECT COUNT(*) FROM users";

$count = $template->queryForInt($countSql);

// 3. 新增用户

$insertSql = "INSERT INTO users SET name=?, age=?";

$affected = $template->update($insertSql, [$name, $age]);

注意事项与维护

• 资源释放：上述示例代码在执行完毕后显式置为 null。在大多数现代 PHP 请求生命周期中，脚本结束时会自动断开连接。但若存在长期运行的守护进程，请务必手动释放连接。
• 安全性升级：生产环境建议增加 PDO::ATTR_ERRMODE => Pdo::ERRMODE_EXCEPTION 异常模式，以便快速捕捉 SQL 语法错误。
• 编码问题：如果使用的是较新版本的 MySQL/MariaDB，建议将 charset 修改为 utf8mb4 以完整支持 Emoji 等特殊符号。

总结

该 DbTemplate 封装类通过标准化 DSN 管理与类型安全的返回机制，大幅缩减了原始 PDO 编写时所需的样板代码。它保留了底层操作的灵活性，同时保证了基础交互的安全性。以上就是利用PHP PDO封装MySQL数据库操作类的详细内容，更多关于PHP高级编程的资料请关注本站其它相关文章！