0

0

PHP中安全高效地将JSON数据导入MySQL数据库

聖光之護

聖光之護

发布时间:2025-09-12 18:58:24

|

497人浏览过

|

来源于php中文网

原创

php中安全高效地将json数据导入mysql数据库

本文旨在解决PHP将JSON数据导入MySQL时遇到的不一致问题,尤其当JSON内容包含特殊字符时,数据插入失败的根本原因在于未正确处理SQL注入风险。教程将深入分析问题成因,并提供使用mysqli预处理语句的安全解决方案,确保数据导入的稳定性和安全性。

1. 问题描述与初步分析

在将JSON文件数据导入MySQL数据库时,开发者可能会遇到奇怪的现象:某些JSON文件能够顺利创建表并插入数据,而另一些结构看似相同的JSON文件却只能创建表,无法成功插入数据。尽管通过var_dump检查,发现所有JSON文件都能被PHP正确解析为数组,但数据插入的行为却截然不同。例如,一个包含简单字符串的test.json可以正常工作,而一个包含更复杂、带有撇号等特殊字符的newmainnews.json则会导入失败。

最初的PHP代码片段如下:

include("dbCon.php"); // 数据库连接文件

$fname = $_POST['fname']; // 表名/JSON文件名

if ($conn->connect_error) {
  die("Connection failed: " . $conn->connect_error);
}

// 创建表
$sql_create_table = "CREATE TABLE `".$fname."`(
  id bigint(20) NOT NULL AUTO_INCREMENT PRIMARY KEY,
  title VARCHAR(255) NOT NULL,
  imgurl VARCHAR(255) NOT NULL,
  content VARCHAR(20000) NOT NULL
)";

if ($conn->query($sql_create_table) === TRUE) {
   echo "Table ".$fname." created successfully";
} else {
   echo "Error creating table: " . $conn->error;
}

// 读取并解析JSON文件
$json_path = '../jsonFIle/'.$fname.'.json';
$json_content = file_get_contents($json_path);
$array_data = json_decode($json_content, true);

// 插入数据
foreach($array_data as $row) {
 $sql_insert_data = "INSERT INTO `".$fname."`(title, imgurl, content) VALUES('".$row["title"]."', '".$row["imgurl"]."', '".$row["content"]."')";
 mysqli_query($conn, $sql_insert_data);
}

$conn->close();

2. 根本原因:SQL注入漏洞与特殊字符

问题核心在于PHP代码在构建SQL INSERT 语句时,直接将从JSON解析出的字符串拼接到了SQL查询中,而没有对这些字符串进行任何转义处理。当JSON数据中包含SQL语句的特殊字符,如单引号(')时,就会导致生成的SQL语句语法错误。

以newmainnews.json中的一条数据为例:

立即学习PHP免费学习笔记(深入)”;

{
    "title":"NASA's record-breaking Lucy asteroid mission gearing up for October launch", 
    "imgurl":"record.jpg",
    "content":"Lucy is scheduled to launch atop a United Launch Alliance Atlas V rocket from Florida's Cape Canaveral Space Force Station on Oct."
}

当title字段的值NASA's record-breaking Lucy asteroid mission...被直接拼接到SQL语句中时,生成的SQL片段将是:

VALUES ('NASA's record-breaking Lucy asteroid mission...', ...)

这里的NASA's中的单引号会提前关闭字符串,导致s record-breaking Lucy asteroid mission...部分在SQL语法上成为无效的、未被引号包围的文本,从而使整个INSERT语句执行失败。由于mysqli_query在执行失败时默认不抛出错误,开发者可能难以察觉具体原因。

更严重的是,这种直接拼接字符串的方式会引入严重的安全漏洞——SQL注入。恶意用户可以构造包含SQL命令的JSON数据,例如:

{
   "title":"NASA','',''); DROP TABLE `newmainnews`; --",
   "imgurl": "",
   "content": ""
}

如果这样的数据被处理,生成的SQL语句可能变为:

MMM金融互助系统源码
MMM金融互助系统源码

MMM金融互助系统源码是以thinkphp为核心进行开发的3m金融互助平台。程序安装说明:1.恢复数据:将“数据备份”文件夹中的 urkeji.sql 文件请采用phpMyAdmin进行导入; 2.配置Sql数据库信息,文件路径:根目录下 config.php3.后台管理地址:http://域名/admin.php 用户名:100000 密码:admin1

下载

INSERT INTOnewmainnews(title, imgurl, content) VALUES ('NASA','',''); DROP TABLEnewmainnews; --', '', '')

这会导致在插入数据后,执行DROP TABLE newmainnews;命令,从而删除整个数据表,造成数据丢失

3. 解决方案:使用预处理语句(Prepared Statements)

为了解决SQL语法错误和防止SQL注入,我们必须使用预处理语句(Prepared Statements)。预处理语句将SQL查询的结构与数据分离,数据库服务器会预先解析SQL模板,然后将数据作为参数绑定到模板中,从而避免了特殊字符引发的语法问题,并有效阻止SQL注入攻击。

以下是使用mysqli预处理语句重构后的PHP代码示例:

connect_error) {
  die("数据库连接失败: " . $conn->connect_error);
}

// 1. 创建表 (这里可以直接拼接表名,因为表名通常是受控的,但如果表名也来自用户输入,则需更严格的验证或白名单)
// 注意:如果表名也可能包含特殊字符或来自不可信来源,需要进行额外验证或使用白名单机制。
// 对于本例,假设$fname是经过验证的文件名,可以直接用于表名。
$sql_create_table = "CREATE TABLE IF NOT EXISTS `".$fname."`(
  id bigint(20) NOT NULL AUTO_INCREMENT PRIMARY KEY,
  title VARCHAR(255) NOT NULL,
  imgurl VARCHAR(255) NOT NULL,
  content VARCHAR(20000) NOT NULL
)";

if ($conn->query($sql_create_table) === TRUE) {
   echo "表 `".$fname."` 创建成功或已存在。
"; } else { echo "创建表错误: " . $conn->error . "
"; $conn->close(); exit(); // 创建表失败,停止执行 } // 2. 读取并解析JSON文件 $json_path = '../jsonFIle/'.$fname.'.json'; if (!file_exists($json_path)) { die("错误: JSON文件不存在于 " . $json_path); } $json_content = file_get_contents($json_path); $array_data = json_decode($json_content, true); if (json_last_error() !== JSON_ERROR_NONE) { die("JSON解析错误: " . json_last_error_msg()); } if (!is_array($array_data) || empty($array_data)) { echo "警告: JSON文件为空或解析后不是有效数组。
"; $conn->close(); exit(); } // 3. 使用预处理语句插入数据 // 准备INSERT语句,使用问号(?)作为参数占位符 $sql_insert_template = "INSERT INTO `".$fname."`(title, imgurl, content) VALUES(?, ?, ?)"; // 创建预处理语句对象 if ($stmt = $conn->prepare($sql_insert_template)) { // 遍历JSON数据并绑定参数 foreach($array_data as $row) { // 绑定参数:'sss'表示三个参数都是字符串类型 // bind_param的参数顺序必须与占位符顺序一致 $stmt->bind_param("sss", $row["title"], $row["imgurl"], $row["content"]); // 执行预处理语句 if ($stmt->execute()) { // echo "数据插入成功。
"; } else { echo "数据插入失败: " . $stmt->error . "
"; } } // 关闭预处理语句 $stmt->close(); echo "所有数据处理完毕。
"; } else { echo "准备插入语句失败: " . $conn->error . "
"; } // 关闭数据库连接 $conn->close(); ?>

代码解释:

  1. $fname = $_POST['fname'] ?? 'default_table_name';: 使用PHP 7+ 的null合并运算符,为$_POST['fname']提供一个默认值,防止在fname未设置时引发警告。在实际应用中,应进行更严格的输入验证。
  2. CREATE TABLE IF NOT EXISTS: 在创建表时添加IF NOT EXISTS,可以避免重复运行脚本时因表已存在而报错。
  3. $sql_insert_template = "INSERT INTO".$fname."(title, imgurl, content) VALUES(?, ?, ?)";:
    • 这是预处理语句的核心。VALUES子句中的问号(?)是参数占位符。
    • 表名$fname仍然直接拼接,因为通常表名是程序内部控制或经过严格验证的,不直接暴露给用户任意输入。如果表名也来自用户输入,则需要更高级的动态SQL处理或白名单验证。
  4. if ($stmt = $conn->prepare($sql_insert_template)): prepare()方法用于准备SQL模板。如果成功,它会返回一个mysqli_stmt对象。
  5. $stmt->bind_param("sss", $row["title"], $row["imgurl"], $row["content"]);:
    • bind_param()方法用于将数据绑定到SQL模板中的占位符。
    • 第一个参数是一个字符串,指定了后续参数的类型:
      • s 代表字符串 (string)
      • i 代表整数 (integer)
      • d 代表双精度浮点数 (double)
      • b 代表BLOB (binary large object)
    • 后面的参数是与占位符一一对应的变量。mysqli会自动对这些变量的值进行适当的转义,无需手动处理。
  6. $stmt->execute(): 执行预处理语句。
  7. $stmt->close(): 在完成所有插入操作后,关闭预处理语句。
  8. 错误处理: 增加了json_last_error()和json_last_error_msg()来检查JSON解析是否成功,以及对文件是否存在和prepare()、execute()的错误检查,这对于调试和生产环境都至关重要。

4. 总结与最佳实践

通过使用预处理语句,我们不仅解决了因JSON数据中特殊字符导致的SQL语法错误问题,更重要的是,彻底杜绝了SQL注入这一严重的安全漏洞。

关键最佳实践:

  • 始终使用预处理语句:对于任何包含用户输入或外部数据的SQL查询(INSERT, UPDATE, DELETE, SELECT等),都应优先使用预处理语句(PDO或mysqli)。
  • 严格输入验证:尽管预处理语句能防止SQL注入,但对所有用户输入进行类型、格式、长度等方面的验证仍然是必要的。例如,确保$fname只包含合法的表名字符。
  • 完善错误处理:在数据库操作中,务必添加详细的错误检查和日志记录,以便及时发现并解决问题。
  • 了解数据类型:在bind_param中正确指定参数类型,有助于数据库进行更高效和准确的数据处理。
  • 避免直接拼接表名:虽然本教程中为简化直接拼接了表名,但在高度敏感或用户可控表名的场景中,应使用白名单机制或更复杂的动态SQL处理方式来确保表名的安全性。

遵循这些原则,可以显著提高PHP应用程序与数据库交互的安全性、稳定性和健壮性。

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

2015

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

1334

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

1241

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

948

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

1402

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

1231

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1440

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1303

2023.11.13

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

74

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
MySQL 教程
MySQL 教程

共48课时 | 1.6万人学习

MySQL 初学入门(mosh老师)
MySQL 初学入门(mosh老师)

共3课时 | 0.3万人学习

简单聊聊mysql8与网络通信
简单聊聊mysql8与网络通信

共1课时 | 779人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号