使用 PHP 将 JSON 数组保存到 MySQL 数据库
在实际开发中,我们经常需要处理前端传递过来的 JSON 格式数据,其中 JSON 数组是很常见的数据类型。本文将介绍如何通过 PHP 将 JSON 数组解析后,存储到 MySQL 数据库中,涵盖完整的流程从数据接收、解析到数据库操作。
前置准备
在操作之前,需要先准备好以下环境:
- 已安装 PHP 运行环境(建议 PHP 7.0 及以上版本)
- 已安装 MySQL 数据库服务
- 创建好用于存储数据的数据库和数据表
首先我们先创建测试用的数据库和数据表,示例 SQL 语句如下:
-- 创建测试数据库
CREATE DATABASE IF NOT EXISTS test_db DEFAULT CHARSET utf8mb4;
USE test_db;
-- 创建存储 JSON 数组数据的表
CREATE TABLE IF NOT EXISTS user_info (
id INT PRIMARY KEY AUTO_INCREMENT,
name VARCHAR(50) NOT NULL COMMENT '用户姓名',
age INT NOT NULL COMMENT '用户年龄',
email VARCHAR(100) COMMENT '用户邮箱',
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;这个表我们将用来存储解析后的 JSON 数组中的用户信息,每个数组元素对应一条数据库记录。
JSON 数组数据示例
假设前端传递过来的 JSON 数组数据格式如下,包含多个用户的基本信息:
[
{"name": "张三", "age": 25, "email": "zhangsan@ipipp.com"},
{"name": "李四", "age": 28, "email": "lisi@ipipp.com"},
{"name": "王五", "age": 22, "email": "wangwu@ipipp.com"}
]我们的目标就是将这三个用户的信息分别插入到 user_info 表中。
PHP 实现数据保存的完整流程
整个流程分为四个步骤:接收 JSON 数据、解析 JSON 数组、连接 MySQL 数据库、循环插入数据。下面是完整的 PHP 代码示例:
<?php
// 1. 模拟接收前端传递的 JSON 数组数据,实际开发中可以从 $_POST 或输入流中获取
$jsonStr = '[
{"name": "张三", "age": 25, "email": "zhangsan@ipipp.com"},
{"name": "李四", "age": 28, "email": "lisi@ipipp.com"},
{"name": "王五", "age": 22, "email": "wangwu@ipipp.com"}
]';
// 2. 解析 JSON 数组为 PHP 数组
$userList = json_decode($jsonStr, true);
// 判断 JSON 解析是否成功
if (json_last_error() !== JSON_ERROR_NONE) {
die("JSON 数据解析失败:" . json_last_error_msg());
}
// 3. 连接 MySQL 数据库
$dbHost = '127.0.0.1';
$dbUser = 'root';
$dbPass = 'root123'; // 替换为你的数据库密码
$dbName = 'test_db';
$conn = new mysqli($dbHost, $dbUser, $dbPass, $dbName);
// 检查数据库连接是否成功
if ($conn->connect_error) {
die("数据库连接失败:" . $conn->connect_error);
}
// 设置字符集为 utf8mb4,避免中文乱码
$conn->set_charset('utf8mb4');
// 4. 准备插入 SQL 语句,使用预处理防止 SQL 注入
$insertSql = "INSERT INTO user_info (name, age, email) VALUES (?, ?, ?)";
$stmt = $conn->prepare($insertSql);
if (!$stmt) {
die("SQL 语句准备失败:" . $conn->error);
}
// 绑定参数,s 代表字符串类型,i 代表整数类型
$stmt->bind_param('sis', $name, $age, $email);
// 循环遍历解析后的数组,插入每一条数据
$successCount = 0;
$errorCount = 0;
foreach ($userList as $user) {
// 提取每个用户的字段,做简单的非空校验
$name = $user['name'] ?? '';
$age = $user['age'] ?? 0;
$email = $user['email'] ?? '';
if (empty($name) || $age <= 0) {
$errorCount++;
continue;
}
// 执行插入操作
if ($stmt->execute()) {
$successCount++;
} else {
$errorCount++;
echo "插入数据失败,用户姓名:{$name},错误信息:" . $stmt->error . "<br/>";
}
}
// 输出操作结果
echo "数据插入完成,成功 {$successCount} 条,失败 {$errorCount} 条<br/>";
// 5. 释放资源,关闭连接
$stmt->close();
$conn->close();
?>代码关键逻辑说明
下面对代码中的核心部分做详细说明:
- JSON 解析:使用
json_decode函数将 JSON 字符串转为 PHP 数组,第二个参数传 true 表示转为关联数组,方便后续取值。同时通过json_last_error判断解析是否出错,避免无效数据进入后续流程。 - 数据库连接:使用 mysqli 扩展连接 MySQL,连接成功后再设置字符集为 utf8mb4,支持存储中文和特殊表情字符,避免乱码问题。
- 预处理语句:使用
prepare预处理 SQL 语句,通过bind_param绑定参数,这种方式可以有效防止 SQL 注入攻击,比直接拼接 SQL 字符串更安全。 - 数据校验与插入:循环遍历解析后的数组,对必填字段做非空校验,符合要求的再执行插入操作,同时统计成功和失败的记录数,方便后续排查问题。
实际开发注意事项
在实际项目中使用时,还需要注意以下几点:
- 如果是接收前端传递的 JSON 数据,需要从输入流中获取,比如通过
file_get_contents('php://input')获取原始数据,再解析,而不是直接模拟字符串。 - 正式环境中不要将数据库密码等敏感信息硬编码在代码中,建议放在配置文件或者环境变量中。
- 如果 JSON 数组数据量很大,建议分批次插入,避免一次性插入过多数据导致数据库压力过大,也可以使用事务来保证批量插入的原子性,要么全部成功,要么全部回滚。
- 对于邮箱这类字段,可以在插入前做格式校验,确保数据符合业务要求。
总结
通过上面的示例,我们可以清晰地看到 PHP 处理 JSON 数组并保存到 MySQL 的完整流程。核心是正确解析 JSON 数据,使用安全的数据库操作方式,同时做好数据校验,保证存储到数据库的数据符合预期。这个流程可以适配大多数需要存储 JSON 数组数据的场景,开发者可以根据自身业务需求调整字段和校验逻辑。