绍如何在PHP中完成两个不同服务器数据库的表联合查询

PHPzhong原创: 2023-04-06 11:58:0141浏览

对于使用PHP的开发者来说，一个常见的场景是需要从两个不同的服务器的数据库中联合查询数据。这种场景可能是因为业务需要，或者因为数据分布在不同的服务器上。本文将介绍如何在PHP中完成这种数据联合查询操作。

1. 确定查询需要的数据

在开始编写代码之前，我们需要确定要查询的数据。假设我们有两个数据库服务，分别为A和B。我们需要从这两个数据库中联合查询客户信息，包括客户ID、姓名、年龄和性别。A和B两个数据库都有客户表，分别为customers_a和customers_b。这些表都包括客户的基本信息。

我们的查询目标是获取customers_a和customers_b中所有客户的信息，因此我们需要在两个表上执行JOIN操作。

2. 连接两个数据库

使用PHP连接两个数据库很容易。下面是连接A数据库的代码示例：

<?php
$host = 'localhost';
$username = 'db_user';
$password = 'db_password';
$dbname = 'database_a';

$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 = 'localhost';
$username = 'db_user';
$password = 'db_password';
$dbname = 'database_b';

$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['id'] . ' ' . $row['name'] . ' ' . $row['age'] . ' ' . $row['gender'] . '<br>';
}

5. 完整的代码示例

以下是完整的代码示例：

<?php
$host_a = 'localhost';
$username_a = 'db_user';
$password_a = 'db_password';
$dbname_a = 'database_a';

$host_b = 'localhost';
$username_b = 'db_user';
$password_b = 'db_password';
$dbname_b = 'database_b';

$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();
?>