PHP實現數據庫讀寫分離

在PHP中實現數據庫讀寫分離，通常涉及以下幾個步驟：配置主從數據庫服務器、編寫代碼來分離讀寫操作、處理異常和錯誤等。以下是一個基本的實現示例：

1. 配置主從數據庫服務器

首先，你需要配置主數據庫（Master）和從數據庫（Slave）。假設你已經有了這兩個數據庫服務器，并且它們已經正確配置并運行。

2. 編寫代碼來分離讀寫操作

你可以使用PHP的數據庫擴展（如PDO或mysqli）來連接數據庫，并根據SQL操作的類型（讀或寫）來選擇連接到主庫還是從庫。

使用PDO示例：

<?php
$masterConfig = [
    'host' => 'master_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

$slaveConfig = [
    'host' => 'slave_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

function getConnection($isWrite) {
    if ($isWrite) {
        return new PDO($masterConfig['dsn'], $masterConfig['user'], $masterConfig['password']);
    } else {
        return new PDO($slaveConfig['dsn'], $slaveConfig['user'], $slaveConfig['password']);
    }
}

// 示例：讀取操作
$query = "SELECT * FROM table_name";
$conn = getConnection(false); // false 表示讀取操作
$stmt = $conn->prepare($query);
$stmt->execute();
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
print_r($result);

// 示例：寫入操作
$query = "INSERT INTO table_name (column1, column2) VALUES (?, ?)";
$conn = getConnection(true); // true 表示寫入操作
$stmt = $conn->prepare($query);
$stmt->execute(['value1', 'value2']);
?>

使用mysqli示例：

<?php
$masterConfig = [
    'host' => 'master_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

$slaveConfig = [
    'host' => 'slave_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

function getConnection($isWrite) {
    if ($isWrite) {
        $mysqli = new mysqli($masterConfig['host'], $masterConfig['user'], $masterConfig['password'], $masterConfig['dbname']);
        if ($mysqli->connect_error) {
            die('Connect Error (' . $mysqli->connect_errno . ') ' . $mysqli->connect_error);
        }
        return $mysqli;
    } else {
        $mysqli = new mysqli($slaveConfig['host'], $slaveConfig['user'], $slaveConfig['password'], $slaveConfig['dbname']);
        if ($mysqli->connect_error) {
            die('Connect Error (' . $mysqli->connect_errno . ') ' . $mysqli->connect_error);
        }
        return $mysqli;
    }
}

// 示例：讀取操作
$query = "SELECT * FROM table_name";
$conn = getConnection(false); // false 表示讀取操作
$result = $conn->query($query);
while ($row = $result->fetch_assoc()) {
    print_r($row);
}

// 示例：寫入操作
$query = "INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')";
$conn = getConnection(true); // true 表示寫入操作
if ($conn->query($query) === TRUE) {
    echo "New record created successfully";
} else {
    echo "Error: " . $query . "<br>" . $conn->error;
}
$conn->close();
?>

3. 處理異常和錯誤

在實際應用中，你需要處理可能出現的異常和錯誤，確保程序的健壯性。

4. 考慮連接池和性能優化

對于高并發應用，可以考慮使用連接池來管理數據庫連接，以提高性能。

5. 監控和維護

定期監控主從數據庫的狀態，確保數據同步正常，及時處理可能出現的故障。

通過以上步驟，你可以在PHP中實現基本的數據庫讀寫分離。根據具體需求，你可能需要進一步優化和擴展這個實現。