根據$errno 自動進行數據庫重連機制

M66 2025-06-11

在開發PHP 應用時，數據庫連接的穩定性是一個非常重要的部分。尤其是在高並發或網絡波動較大的環境下，數據庫連接可能會中斷或者失效。為了解決這個問題，我們可以根據$errno錯誤碼來自動實現數據庫的重連機制。本文將介紹如何在PHP 中通過$errno錯誤碼來自動進行數據庫重連。

1. 了解$errno錯誤碼

在PHP 中，當你進行數據庫操作時，如果發生連接錯誤，數據庫會返回一個錯誤碼$errno ，我們可以根據該錯誤碼判斷是否需要進行數據庫重連。通常，常見的錯誤碼如下：

2002 : 無法連接到MySQL 服務器。
2006 : MySQL 服務器斷開了連接。
2013 : MySQL 查詢超時。

如果我們捕獲到這些錯誤碼，就可以判斷出是因為數據庫連接問題導致的錯誤，從而進行重連。

2. 創建一個數據庫連接函數

首先，我們需要一個函數來建立數據庫連接。如果連接失敗，我們需要根據錯誤碼判斷是否需要重試連接。

 <?php
function connectToDatabase() {
    $host = 'localhost';   // 數據庫服務器
    $dbname = 'test_db';   // 數據庫名
    $username = 'root';    // 數據庫用戶名
    $password = '';        // 數據庫密碼

    try {
        // 嘗試建立數據庫連接
        $pdo = new PDO("mysql:host=$host;dbname=$dbname", $username, $password);
        // 設定PDO錯誤模式為異常
        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        return $pdo;
    } catch (PDOException $e) {
        // 捕獲異常，返回錯誤信息
        echo "連接失敗: " . $e->getMessage();
        return null;
    }
}
?>

這段代碼提供了一個簡單的數據庫連接函數connectToDatabase ，它會返回一個PDO 對象，用於執行數據庫操作。如果連接失敗，函數將返回null 。

3. 實現自動重連機制

接下來，我們需要在進行數據庫操作時，判斷$errno錯誤碼並自動重連。

 <?php
function reconnectIfNeeded($pdo) {
    // 如果 PDO 對象為空，表示数据库連接失敗
    if ($pdo === null) {
        // 嘗試重新連接
        echo "正在嘗試重新連接数据库...";
        $pdo = connectToDatabase();
    }

    // 判斷連接是否成功
    if ($pdo !== null) {
        echo "數據庫連接成功!";
    } else {
        echo "数据库連接失敗，請稍後再試。";
    }

    return $pdo;
}

// 模擬數據庫操作
function queryDatabase($pdo) {
    try {
        // 執行一個簡單的查詢操作
        $stmt = $pdo->query("SELECT * FROM users");
        while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
            print_r($row);
        }
    } catch (PDOException $e) {
        // 捕獲 PDO 異常，並根據錯誤碼判斷是否重連
        if ($e->getCode() == 2002 || $e->getCode() == 2006 || $e->getCode() == 2013) {
            echo "數據庫連接中斷，嘗試重新連接...\n";
            // 調用重連函數
            $pdo = reconnectIfNeeded($pdo);
            // 重新嘗試查詢數據庫
            queryDatabase($pdo);
        } else {
            // 其他錯誤，输出異常信息
            echo "查詢失敗: " . $e->getMessage();
        }
    }
}

// 初始化數據庫連接
$pdo = connectToDatabase();

// 執行查詢操作
queryDatabase($pdo);
?>

代碼解釋：

connectToDatabase() : 用於建立數據庫連接。
reconnectIfNeeded() : 該函數會在檢測到數據庫連接為空時嘗試重新連接。
queryDatabase() : 該函數執行數據庫查詢，如果發生連接錯誤（錯誤碼2002、2006 或2013），會調用reconnectIfNeeded()自動重連數據庫並重新執行查詢。

在執行數據庫操作時，我們通過try-catch捕獲異常並檢查$errno錯誤碼。遇到連接中斷錯誤時，自動重連並重新執行查詢。

4. 小結

使用$errno錯誤碼可以有效地捕捉數據庫連接中斷的情況，並通過自動重連機制恢復數據庫連接，確保應用的穩定性。上述代碼示例展示瞭如何在PHP 中處理數據庫連接錯誤並實現重連功能。通過合理的錯誤處理，我們能夠保證應用在面對數據庫故障時依然能夠正常運行。

mysqli::$errno