5154

PHP 查询 MySQL 数据库并返回 JSON 数据

在 Web 开发中，经常需要使用 PHP 从 MySQL 数据库中获取数据并以 JSON 格式返回给前端，以下是详细的步骤和示例代码，展示如何实现这一功能。

一、环境搭建

1、安装 MySQL：确保已安装 MySQL 数据库服务器，并创建好相应的数据库和表结构，创建一个名为test_db 的数据库和一个名为users 的表，表结构如下：

2、安装 PHP：确保已安装 PHP，并且配置好与 MySQL 的连接，可以通过在命令行中运行php m 来检查是否安装了所需的扩展，如mysqli 或pdo_mysql。

二、PHP 连接 MySQL 数据库

使用mysqli 扩展连接到 MySQL 数据库的示例代码如下：

<?php
$servername = "localhost";
$username = "root";
$password = "your_password";
$dbname = "test_db";
// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);
// 检查连接
if ($conn>connect_error) {
    die("连接失败: " . $conn>connect_error);
}
echo "连接成功";
?>

上述代码中，首先定义了数据库连接所需的参数，包括服务器地址、用户名、密码和数据库名称，然后使用new mysqli() 方法创建连接对象，并通过connect_error 属性检查连接是否成功，如果连接失败，则输出错误信息并终止脚本执行；如果连接成功，则输出“连接成功”。

三、执行查询语句获取数据

编写 SQL 查询语句从users 表中获取所有用户数据，并将结果存储在一个变量中：

<?php
$sql = "SELECT id, name, age FROM users";
$result = $conn>query($sql);
?>

这里使用了query() 方法执行 SQL 查询语句，该方法返回一个结果集对象$result。

四、处理查询结果并转换为 JSON 格式

为了将查询结果转换为 JSON 格式，需要遍历结果集，并将每一行数据存储到一个数组中，然后将整个数组编码为 JSON 字符串，可以使用fetch_assoc() 方法逐行获取结果，并将其存储到数组中：

<?php
$data = array();
if ($result>num_rows > 0) {
    while($row = $result>fetch_assoc()) {
        $data[] = $row;
    }
}
$json_data = json_encode($data, JSON_PRETTY_PRINT);
echo $json_data;
?>

上述代码中，首先初始化一个空数组$data，然后检查查询结果是否有数据（即num_rows 属性是否大于 0），如果有数据，则使用while 循环和fetch_assoc() 方法逐行获取结果，并将每一行数据作为一个关联数组添加到$data 数组中，使用json_encode() 函数将$data 数组编码为 JSON 字符串，并设置JSON_PRETTY_PRINT 选项使输出的 JSON 数据格式化，便于阅读，最后输出 JSON 数据。

五、关闭数据库连接

在完成数据处理后，应该关闭数据库连接以释放资源：

<?php
$conn>close();
?>

这行代码调用close() 方法关闭与 MySQL 数据库的连接。

相关问题与解答

问题 1：如果查询结果为空，输出的 JSON 数据会是什么样子？

解答：如果查询结果为空，即$result>num_rows 等于 0，那么$data 数组将为空，经过json_encode() 函数编码后，输出的 JSON 数据将是[]，表示一个空数组。

问题 2：如何处理数据库连接错误和查询错误？

解答：在实际应用中，应该对数据库连接错误和查询错误进行更完善的处理，对于数据库连接错误，已经在前面的代码中进行了检查，如果连接失败则输出错误信息并终止脚本执行，对于查询错误，可以在执行查询语句后检查$conn>error 属性，如果存在错误则进行相应的处理，例如记录错误日志、向用户显示友好的错误提示等，以下是一个简单的示例：

<?php
$sql = "SELECT id, name, age FROM users";
$result = $conn>query($sql);
if ($conn>error) {
    echo "查询错误: " . $conn>error;
} else {
    $data = array();
    if ($result>num_rows > 0) {
        while($row = $result>fetch_assoc()) {
            $data[] = $row;
        }
    }
    $json_data = json_encode($data, JSON_PRETTY_PRINT);
    echo $json_data;
}
?>

这样，当查询出现错误时，会输出错误信息，而不是直接输出 JSON 数据。