Présentation de la manière de compléter une requête conjointe de table de deux bases de données de serveur différentes en PHP

Pour les développeurs utilisant PHP, un scénario courant est la nécessité d'interroger conjointement les données des bases de données de deux serveurs différents. Ce scénario peut être dû aux besoins de l'entreprise ou au fait que les données sont distribuées sur différents serveurs. Cet article expliquera comment réaliser cette opération de requête de fédération de données en PHP.

1. Déterminez les données requises pour la requête

Avant de commencer à écrire du code, nous devons déterminer les données que nous souhaitons interroger. Supposons que nous ayons deux services de base de données, nommés A et B. Nous devons interroger conjointement les informations client de ces deux bases de données, notamment l'identifiant client, le nom, l'âge et le sexe. Les deux bases de données A et B ont des tables clients, qui sont respectivement customers_a et customers_b. Ces tableaux incluent des informations de base sur les clients. 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

Notre objectif de requête est d'obtenir les informations de tous les clients dans customers_a et customers_b, nous devons donc effectuer des opérations JOIN sur les deux tables.

2. Connectez deux bases de données

Il est facile de connecter deux bases de données en utilisant PHP. Voici un exemple de code pour se connecter à la base de données A :

<?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>';
}

De même, nous pouvons nous connecter à la base de données B :

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

Maintenant, nous nous sommes connectés avec succès à deux bases de données différentes. 🎜🎜3. Effectuer une opération de requête conjointe🎜🎜Ensuite, nous devons effectuer une opération JOIN sur les deux bases de données pour obtenir les données dont nous avons besoin. Afin de garantir la lisibilité et la maintenabilité du code, nous encapsulons l'opération de requête dans une fonction. 🎜rrreee🎜Dans cette fonction, nous utilisons l'opération UNION pour fusionner les données dans customers_a et customers_b ensemble. Après avoir exécuté la requête, nous plaçons les enregistrements du jeu de résultats dans un tableau et renvoyons le tableau. 🎜🎜4. Appelez la fonction de requête🎜🎜Maintenant, nous avons terminé tout le travail de codage. Nous pouvons appeler la fonction get_customers dans le code pour obtenir les informations client interrogées conjointement dans les deux bases de données A et B. 🎜rrreee🎜5. Exemple de code complet🎜🎜Ce qui suit est l'exemple de code complet :🎜rrreee🎜Résumé🎜🎜En PHP, connecter deux bases de données différentes et effectuer des opérations de requête conjointes est un scénario très courant. Cet article décrit comment connecter deux services de base de données différents en PHP et utiliser l'opération UNION pour effectuer la tâche de requête conjointe. Grâce à cet article, nous espérons que les lecteurs pourront mieux comprendre comment utiliser plusieurs services de bases de données en PHP. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!