本教程详细介绍了如何使用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数据库的连接。良好的实践包括错误处理，以确保在连接失败时能够提供有用的信息。
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数组中。
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字符串。
$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字符不被转义（例如，"中国"不会变成"\u4e2d\u56fd"），这在处理多语言数据时非常有用。
完整示例代码
将上述所有部分整合，得到一个完整的PHP脚本：
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端点会更合适，而不是一次性返回所有数据。本教程的方法适用于需要一次性获取所有相关数据的场景。
