紹如何在PHP中完成兩個不同伺服器資料庫的表聯合查詢-PHP問題-PHP中文網

首頁

後端開發

PHP問題

紹如何在PHP中完成兩個不同伺服器資料庫的表聯合查詢

PHPz

Apr 06, 2023 am 09:14 AM

對於使用PHP的開發者來說，一個常見的場景是需要從兩個不同的伺服器的資料庫中聯合查詢資料。這種場景可能是因為業務需要，或是因為資料分佈在不同的伺服器上。本文將介紹如何在PHP中完成此資料聯合查詢操作。

1. 確定查詢所需的資料

在開始編寫程式碼之前，我們需要確定要查詢的資料。假設我們有兩個資料庫服務，分別為A和B。我們需要從這兩個資料庫中聯合查詢客戶信息，包括客戶ID、姓名、年齡和性別。 A和B兩個資料庫都有客戶表，分別為customers_a和customers_b。這些表都包括客戶的基本資訊。

我們的查詢目標是獲取customers_a和customers_b中所有客戶的信息，因此我們需要在兩個表上執行JOIN操作。

2. 連接兩個資料庫

使用PHP連接兩個資料庫很容易。以下是連接A資料庫的程式碼範例：

<?php $host = &#39;localhost&#39;;
$username = &#39;db_user&#39;;
$password = &#39;db_password&#39;;
$dbname = &#39;database_a&#39;;

$db_a = new mysqli($host, $username, $password, $dbname);
if ($db_a->connect_error) {
    die('Connect Error (' . $db_a->connect_errno . ') '
            . $db_a->connect_error);
}

同樣地，我們可以連接B資料庫：

<?php $host = &#39;localhost&#39;;
$username = &#39;db_user&#39;;
$password = &#39;db_password&#39;;
$dbname = &#39;database_b&#39;;

$db_b = new mysqli($host, $username, $password, $dbname);
if ($db_b->connect_error) {
    die('Connect Error (' . $db_b->connect_errno . ') '
            . $db_b->connect_error);
}

現在我們已經成功連接到了兩個不同的資料庫。

3. 執行聯合查詢操作

接下來，我們需要在兩個資料庫上執行JOIN操作，並取得我們需要的資料。為了確保程式碼的可讀性和易維護性，我們將查詢操作封裝成一個函數。

<?php function get_customers($db_a, $db_b) {
    $sql = "SELECT id, name, age, gender FROM customers_a
            UNION
            SELECT id, name, age, gender FROM customers_b";
    $result = $db_a->query($sql);
    if (!$result) {
        die('Query Error: ' . $db_a->error);
    }
    $rows = array();
    while ($row = $result->fetch_assoc()) {
        $rows[] = $row;
    }
    $result->free();

    return $rows;
}

在這個函數中，我們使用了UNION操作，將customers_a和customers_b中的資料合併在一起。執行完查詢之後，我們將結果集中的記錄放到一個陣列中，並傳回該陣列。

4. 呼叫查詢函數

現在我們已經完成了所有的程式碼編寫工作。我們可以在程式碼中呼叫get_customers函數，取得從A和B兩個資料庫中聯合查詢的客戶資訊。

<?php $rows = get_customers($db_a, $db_b);
foreach ($rows as $row) {
    echo $row[&#39;id&#39;] . &#39; &#39; . $row[&#39;name&#39;] . &#39; &#39; . $row[&#39;age&#39;] . &#39; &#39; . $row[&#39;gender&#39;] . &#39;<br>';
}

5. 完整的程式碼範例

以下是完整的程式碼範例：

<?php $host_a = &#39;localhost&#39;;
$username_a = &#39;db_user&#39;;
$password_a = &#39;db_password&#39;;
$dbname_a = &#39;database_a&#39;;

$host_b = &#39;localhost&#39;;
$username_b = &#39;db_user&#39;;
$password_b = &#39;db_password&#39;;
$dbname_b = &#39;database_b&#39;;

$db_a = new mysqli($host_a, $username_a, $password_a, $dbname_a);
if ($db_a->connect_error) {
    die('Connect Error (' . $db_a->connect_errno . ') '
            . $db_a->connect_error);
}

$db_b = new mysqli($host_b, $username_b, $password_b, $dbname_b);
if ($db_b->connect_error) {
    die('Connect Error (' . $db_b->connect_errno . ') '
            . $db_b->connect_error);
}

function get_customers($db_a, $db_b) {
    $sql = "SELECT id, name, age, gender FROM customers_a
            UNION
            SELECT id, name, age, gender FROM customers_b";
    $result = $db_a->query($sql);
    if (!$result) {
        die('Query Error: ' . $db_a->error);
    }
    $rows = array();
    while ($row = $result->fetch_assoc()) {
        $rows[] = $row;
    }
    $result->free();

    return $rows;
}

$rows = get_customers($db_a, $db_b);
foreach ($rows as $row) {
    echo $row['id'] . ' ' . $row['name'] . ' ' . $row['age'] . ' ' . $row['gender'] . '<br>';
}

$db_a->close();
$db_b->close();
?>