本教程详细介绍了如何使用php和mysqli从多个数据库表中独立查询数据，并将这些数据集合到一个单一的、结构化的json对象中。文章涵盖了数据库连接、执行多条select语句、处理结果集以及最终通过`json_encode`函数生成符合api输出要求的json格式数据，为前端应用或api接口提供统一的数据源。
在现代Web开发中，后端API经常需要从关系型数据库的多个表中获取数据，并将其整合成一个易于前端应用消费的json格式。本文将指导您如何使用php和mysqli扩展实现这一目标，以地理位置数据（国家、城市、社区）为例，演示如何从多个独立表中查询数据，并将其组织成一个统一的JSON结构。
数据库结构概述
假设我们有以下三个MySQL表，它们之间存在逻辑上的父子关系：
- Countries (国家表)
- countryId (主键)
- countryName
- Cities (城市表)
- cityId (主键)
- cityName
- countryId (外键，关联Countries表)
- Neighborhoods (社区表)
- neighborhoodId (主键)
- neighborhoodName
- cityId (外键，关联Cities表)
我们的目标是获取这三个表的所有数据，并将其输出为以下JSON格式：
{ "Countries": [ { "countryId": "...", "countryName": "..." } ], "Cities": [ { "cityId": "...", "cityName": "...", "countryId": "..." } ], "Neighborhoods": [ { "neighborhoodId": "...", "neighborhoodName": "...", "cityId": "..." } ] }实现步骤
要实现上述目标，我们需要执行以下几个核心步骤：
立即学习“PHP免费学习笔记（深入）”；
- 建立数据库连接：使用PHP的mysqli扩展连接到MySQL数据库。
- 执行多条查询：针对每个需要获取数据的表，执行独立的SELECT查询。
- 处理结果集：遍历每个查询的结果集，将行数据逐一存入独立的PHP数组中。
- 构建最终数据结构：将这些独立的数组组合成一个大的关联数组，其键名对应最终JSON的顶级键。
- 编码为JSON：使用json_encode()函数将PHP数组转换为JSON字符串并输出。
1. 建立数据库连接
首先，我们需要一个函数或代码块来建立与MySQL数据库的连接。良好的实践包括错误处理，以确保在连接失败时能够提供有用的信息。
<?php // 数据库连接参数 $dbHost = "your_db_host"; // 例如: localhost $dbUser = "your_db_username"; // 您的数据库用户名 $dbPass = "your_db_password"; // 您的数据库密码 $dbName = "your_db_name"; // 您的数据库名称 // 建立MySQLi连接 $connection = new mysqli($dbHost, $dbUser, $dbPass, $dbName); // 检查连接是否成功 if ($connection->connect_errno) { // 连接失败，输出错误信息并终止脚本 http_response_code(500); // 设置HTTP状态码为500 Internal Server Error echo json_encode(["error" => "Failed to connect to MySQL: " . $connection->connect_error]); exit(); } // 设置字符集，防止中文乱码 $connection->set_charset("utf8mb4"); // 声明用于存储各个表数据的数组 $countriesData = []; $citiesData = []; $neighborhoodsData = []; // ... 后续代码 ... ?>2. 执行多条查询并处理结果集
接下来，我们将对每个表执行SELECT *查询，并使用fetch_assoc()方法逐行获取数据，然后将其添加到各自的PHP数组中。
<?php // ... (数据库连接代码) ... // 查询 Countries 表 $resultCountries = $connection->query("SELECT * FROM Countries"); if ($resultCountries) { while ($row = $resultCountries->fetch_assoc()) { $countriesData[] = $row; } $resultCountries->free(); // 释放结果集内存 } else { // 查询失败，记录错误或返回错误信息 error_log("Error querying Countries table: " . $connection->error); // 可以选择在此处返回错误或继续执行，取决于业务逻辑 } // 查询 Cities 表 $resultCities = $connection->query("SELECT * FROM Cities"); if ($resultCities) { while ($row = $resultCities->fetch_assoc()) { $citiesData[] = $row; } $resultCities->free(); // 释放结果集内存 } else { error_log("Error querying Cities table: " . $connection->error); } // 查询 Neighborhoods 表 $resultNeighborhoods = $connection->query("SELECT * FROM Neighborhoods"); if ($resultNeighborhoods) { while ($row = $resultNeighborhoods->fetch_assoc()) { $neighborhoodsData[] = $row; } $resultNeighborhoods->free(); // 释放结果集内存 } else { error_log("Error querying Neighborhoods table: " . $connection->error); } // ... (构建最终数据结构和JSON编码代码) ... // 关闭数据库连接 $connection->close(); ?>注意事项：
- 每次查询后都应检查query()方法的返回值。如果返回false，表示查询失败，可以通过$connection->error获取详细错误信息。
- 在处理完结果集后，调用$result->free()可以释放与结果集相关的内存，这是一个良好的资源管理习惯。
3. 构建最终数据结构并编码为JSON
最后一步是将收集到的所有数据数组组合成一个顶级关联数组，然后使用json_encode()将其转换为JSON字符串。
<?php // ... (数据库连接和查询代码) ... // 构建最终的PHP关联数组，键名与期望的JSON键名一致 $finalOutput = [ "Countries" => $countriesData, "Cities" => $citiesData, "Neighborhoods" => $neighborhoodsData ]; // 设置HTTP响应头为JSON格式 header('Content-Type: application/json'); // 将PHP数组编码为JSON字符串并输出 echo json_encode($finalOutput, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE); // 关闭数据库连接 (确保在所有操作完成后执行) $connection->close(); ?>json_encode()选项：
- JSON_PRETTY_PRINT: 使输出的JSON格式化，带有缩进和换行，更易于阅读和调试。在生产环境中通常省略此选项以减少传输大小。
- JSON_UNESCAPED_UNICODE: 确保中文字符或其他Unicode字符不被转义（例如，”中国”不会变成”u4e2du56fd”），这在处理多语言数据时非常有用。
完整示例代码
将上述所有部分整合，得到一个完整的PHP脚本：
<?php // 1. 数据库连接参数 $dbHost = "localhost"; $dbUser = "root"; $dbPass = "your_password"; // 请替换为您的数据库密码 $dbName = "your_database"; // 请替换为您的数据库名称 // 2. 建立MySQLi连接 $connection = new mysqli($dbHost, $dbUser, $dbPass, $dbName); // 检查连接是否成功 if ($connection->connect_errno) { http_response_code(500); echo json_encode(["error" => "Failed to connect to MySQL: " . $connection->connect_error]); exit(); } // 设置字符集 $connection->set_charset("utf8mb4"); // 3. 声明用于存储各个表数据的数组 $countriesData = []; $citiesData = []; $neighborhoodsData = []; $errors = []; // 用于收集查询过程中的错误 // 4. 执行多条查询并处理结果集 // 查询 Countries 表 $resultCountries = $connection->query("SELECT * FROM Countries"); if ($resultCountries) { while ($row = $resultCountries->fetch_assoc()) { $countriesData[] = $row; } $resultCountries->free(); } else { $errors[] = "Error querying Countries table: " . $connection->error; error_log("Error querying Countries table: " . $connection->error); } // 查询 Cities 表 $resultCities = $connection->query("SELECT * FROM Cities"); if ($resultCities) { while ($row = $resultCities->fetch_assoc()) { $citiesData[] = $row; } $resultCities->free(); } else { $errors[] = "Error querying Cities table: " . $connection->error; error_log("Error querying Cities table: " . $connection->error); } // 查询 Neighborhoods 表 $resultNeighborhoods = $connection->query("SELECT * FROM Neighborhoods"); if ($resultNeighborhoods) { while ($row = $resultNeighborhoods->fetch_assoc()) { $neighborhoodsData[] = $row; } $resultNeighborhoods->free(); } else { $errors[] = "Error querying Neighborhoods table: " . $connection->error; error_log("Error querying Neighborhoods table: " . $connection->error); } // 5. 关闭数据库连接 $connection->close(); // 6. 构建最终的PHP关联数组 $finalOutput = [ "Countries" => $countriesData, "Cities" => $citiesData, "Neighborhoods" => $neighborhoodsData ]; // 如果有错误，可以考虑将错误信息也包含在JSON输出中，或者直接返回错误状态 if (!empty($errors)) { // 示例：将错误信息添加到输出中，或者直接返回HTTP 500 // http_response_code(500); // echo json_encode(["error" => "Data retrieval issues", "details" => $errors]); // exit(); // 对于本教程，我们暂时忽略错误，继续输出已获取的数据 } // 7. 设置HTTP响应头为JSON格式 header('Content-Type: application/json'); // 8. 将PHP数组编码为JSON字符串并输出 echo json_encode($finalOutput, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE); ?>总结与注意事项
通过上述步骤，您已经学会了如何从MySQL的多个表中获取数据并将其组织成一个结构化的JSON对象。这种方法对于构建restful API或为前端应用提供数据非常实用。
重要注意事项：
- 错误处理： 务必在数据库连接和每次查询后检查错误。在生产环境中，不应直接将数据库错误信息暴露给用户，而应记录到日志文件中，并向用户返回友好的错误提示。
- 性能优化： 对于数据量非常大的表，SELECT *可能会导致不必要的性能开销。建议只选择需要的列，例如 SELECT countryId, countryName FROM Countries。
- 数据量： 如果单个表的数据量非常庞大，一次性获取所有数据可能会消耗大量内存和时间。在这种情况下，应考虑实现分页、按需加载或使用更高级的数据库查询（如JOIN操作结合JSON函数，如果数据库支持）。
- 安全性： 虽然本例中的SELECT *查询不涉及用户输入，因此sql注入风险较低，但任何涉及用户输入的查询都应使用预处理语句（Prepared Statements）来防止SQL注入攻击。
- API设计： 考虑API的使用场景。如果前端需要独立访问某个表的数据，可能为每个表提供单独的API端点会更合适，而不是一次性返回所有数据。本教程的方法适用于需要一次性获取所有相关数据的场景。