如何结合 mysqli::get_warnings 和异常机制统一错误处理

gitbox 2025-05-27

在使用 PHP 进行 MySQL 数据库操作时，常常会遇到各种警告和错误。为了保证程序的健壮性，我们需要统一地捕获和处理这些异常信息。本文将结合 PHP 的面向对象 mysqli 扩展中的 mysqli::get_warnings() 方法和异常机制，讲解如何实现统一的错误处理。

一、背景说明

mysqli::get_warnings() 方法用于获取最近执行的 MySQL 语句中产生的警告信息。通常情况下，MySQL 查询可能成功执行但伴随一些警告（比如字段截断、数据溢出等），这些警告往往容易被忽视。如果只依赖于传统的错误检测，程序很难捕捉到这些潜在的问题。

另一方面，PHP 的异常机制可以帮助我们捕获和处理错误，特别是可以借助 try...catch 结构统一管理错误流程。

二、结合使用的思路

捕获 mysqli 报错
当出现严重错误时，mysqli 通常会报错或者返回 false，我们可以通过异常捕获机制获取错误信息。
检查并处理警告
通过 mysqli::get_warnings() 获取警告链，如果存在警告，抛出自定义异常或者进行相应的日志记录和处理。
统一错误处理
通过捕获异常，在一个地方集中处理所有错误和警告，保证代码简洁且易于维护。

三、示例代码

下面示范一个简单的 PHP 脚本，演示如何结合 mysqli::get_warnings() 和异常机制来实现统一的错误处理。

<?php
class DatabaseException extends Exception {}

function executeQuery(mysqli $mysqli, string $sql) {
    // 执行查询
    if (!$result = $mysqli->query($sql)) {
        // 查询错误，抛出异常
        throw new DatabaseException("Query Error: " . $mysqli->error);
    }

    // 检查警告
    $warning = $mysqli->get_warnings();
    if ($warning) {
        $warnings = [];
        do {
            $warnings[] = sprintf("Warning Code %d: %s", $warning->errno, $warning->message);
        } while ($warning = $warning->next());

        // 抛出警告异常（也可以记录日志或做其他处理）
        throw new DatabaseException("Query Warnings: " . implode("; ", $warnings));
    }

    return $result;
}

// 使用示例
$mysqli = new mysqli("gitbox.net", "username", "password", "database");

try {
    $sql = "INSERT INTO users (id, name) VALUES (1, 'test')";
    $result = executeQuery($mysqli, $sql);
    echo "Query executed successfully.";
} catch (DatabaseException $ex) {
    // 统一错误处理
    echo "Database Exception: " . $ex->getMessage();
}

四、代码说明

自定义了 DatabaseException 继承自 Exception，用于统一抛出数据库相关的错误和警告。
executeQuery 函数负责执行 SQL 查询，并检测错误和警告。
当查询执行失败时，立即抛出异常。
当查询成功但存在警告时，遍历警告链并抛出异常。
在调用处用 try...catch 统一捕获并处理异常。

五、总结

通过结合 mysqli::get_warnings() 和 PHP 异常机制，我们可以更细致地捕获数据库操作中的异常情况，尤其是那些通常被忽视的警告信息。这样不仅增强了程序的健壮性，也便于集中管理和日志记录错误，提升代码的可维护性。

如果你的项目中对数据库错误和警告有较高要求，建议采用上述方案来统一处理。