PHP結合MySQL實現數據遷移

在PHP中結合MySQL實現數據遷移，通常涉及以下幾個步驟：

1. 連接到MySQL數據庫：使用PHP的MySQLi或PDO擴展來連接到目標數據庫。

2. 查詢源數據庫數據：編寫SQL查詢語句從源數據庫中提取數據。

3. 處理數據：根據需要對數據進行清洗、轉換或格式化。

4. 連接到目標數據庫：同樣使用PHP的MySQLi或PDO擴展來連接到目標數據庫。

5. 插入或更新數據：將處理后的數據插入到目標數據庫中，或者更新現有記錄。

6. 錯誤處理：確保在數據遷移過程中能夠妥善處理可能出現的錯誤。

7. 日志記錄：記錄數據遷移的進度和結果，便于后續跟蹤和審計。

下面是一個簡單的示例，展示了如何使用PHP和MySQLi實現數據遷移：

<?php
// 數據庫配置
$source_host = 'localhost';
$source_user = 'source_username';
$source_pass = 'source_password';
$source_db = 'source_database';

$target_host = 'localhost';
$target_user = 'target_username';
$target_pass = 'target_password';
$target_db = 'target_database';

// 創建連接
$source_conn = new mysqli($source_host, $source_user, $source_pass, $source_db);
$target_conn = new mysqli($target_host, $target_user, $target_pass, $target_db);

// 檢查連接
if ($source_conn->connect_error || $target_conn->connect_error) {
    die('連接失敗: ' . $source_conn->connect_error . ' -> ' . $target_conn->connect_error);
}

// 查詢源數據庫數據
$sql = "SELECT id, name, email FROM users";
$result = $source_conn->query($sql);

if ($result->num_rows > 0) {
    // 插入或更新數據到目標數據庫
    while($row = $result->fetch_assoc()) {
        $id = $row['id'];
        $name = $row['name'];
        $email = $row['email'];

        // 插入新記錄
        $target_sql = "INSERT INTO users (id, name, email) VALUES ($id, '$name', '$email')";
        if (!$target_conn->query($target_sql)) {
            echo "Error: " . $target_sql . "<br>" . $target_conn->error;
        }
    }
} else {
    echo "0 結果";
}

// 關閉連接
$source_conn->close();
$target_conn->close();
?>

在這個示例中，我們首先定義了源數據庫和目標數據庫的配置信息，然后創建了兩個MySQLi連接對象。接著，我們執行了一個查詢來獲取源數據庫中的users表數據。對于查詢結果中的每一行數據，我們構建了一個插入語句，并將其發送到目標數據庫中。如果在插入過程中發生錯誤，我們會輸出錯誤信息。最后，我們關閉了數據庫連接。

請注意，這只是一個簡單的示例，實際的數據遷移可能需要更復雜的邏輯，例如處理大量數據的分批遷移、數據轉換、事務管理等。此外，對于生產環境中的數據遷移，建議先在測試環境中進行充分的測試。