本文介绍如何通过 php 将两个分别连接不同 mysql 服务器的查询结果按用户名（username）高效合并，并动态计算如 totalbalance 等衍生列，适用于跨库关联场景。

在实际开发中，常因架构限制（如数据分库、微服务拆分或安全隔离）导致关键关联表分布在不同 MySQL 实例上，无法直接使用 JOIN 或 FEDERATED 引擎。此时，需在应用层完成数据合并与计算。以下提供一套健壮、可读性强且性能可控的 PHP 合并方案。

✅ 核心思路：哈希映射 + 一次遍历合并

避免嵌套循环（O(n×m)），改用 username 为键构建哈希表（$hashMapRes2），实现 O(1) 查找，再遍历主结果集进行左关联式填充：

PaperAiBye

支持近30多种语言降ai降重，并且支持多种语言免费测句子的ai率，支持英文aigc报告等

下载

// 执行两个独立查询
$result1 = mysqli_query($conn, $sql1);  // 来自 project1（本地）
$result2 = mysqli_query($conn2, $sql2); // 来自 project2（远程）

// 转为关联数组便于处理
$res1 = mysqli_fetch_all($result1, MYSQLI_ASSOC);
$res2 = mysqli_fetch_all($result2, MYSQLI_ASSOC);

// 构建 username → TotalExpenses 的哈希映射（自动去重，取首个匹配）
$hashMapRes2 = array_reduce($res2, function ($carry, $item) {
    $carry[$item['Username']] = $item['sum(TotalExpenses)']; // 注意字段别名
    return $carry;
}, []);

// 合并并计算 TotalBalance
$output = array_map(function ($row) use ($hashMapRes2) {
    $username = $row['Username'];
    $totalExpenses = $hashMapRes2[$username] ?? 0; // 不存在则补 0
    $totalBalance = (int)$row['TotalAmount'] + (int)$row['Totalnvested'] - (int)$totalExpenses;

    return [
        'UserId' => $row['UserID'],
        'Username' => $username,
        'TotalAmountResetDate' => $row['TotalAmountResetDate'],
        'TotalAmount' => $row['TotalAmount'],
        'Totalnvested' => $row['Totalnvested'],
        'TotalExpenses' => $totalExpenses,
        'TotalBalance' => $totalBalance
    ];
}, $res1);

mysqli_close($conn);
mysqli_close($conn2);

⚠️ 关键注意事项

• 字段别名一致性：$sql2 中 SELECT Username, sum(TotalExpenses) 应显式使用 AS TotalExpenses，否则 PHP 中需用 ‘sum(TotalExpenses)’ 访问（易出错）。推荐修正为：

  SELECT Username, SUM(TotalExpenses) AS TotalExpenses 
  FROM TotalExpensesTable 
  WHERE date_of_expense_date BETWEEN '2022-01-31' AND '2022-02-12' 
  GROUP BY Username

• 数据类型安全：对 TotalAmount、Totalnvested、TotalExpenses 使用 (int) 强制转换，防止字符串拼接导致计算错误。
• 空值处理：COALESCE() 已用于 SQL 层，PHP 层仍需 ?? 0 防御性编程。
• 内存考量：若数据量极大（>10 万行），建议改用流式处理或分页合并，避免 mysqli_fetch_all() 内存溢出。

? 最终输出示例（可用于 HTML 表格渲染）

echo '';
foreach ($output as $row) {
    echo "";
}
echo '
UserId
Username
TotalBalance
{$row['UserId']}
{$row['Username']}
{$row['TotalBalance']}
';

该方案解耦了数据库依赖，逻辑清晰，易于扩展（如增加更多数据源或计算字段），是跨库聚合场景下的推荐实践。

https://www.php.cn/faq/1993147.html