值得一看
双11 12
广告
广告

使用PHP和PDO将CSV文件导入MySQL数据库的教程

使用PHP和PDO将CSV文件导入MySQL数据库的教程

本教程详细介绍了如何使用PHP的PDO扩展将CSV文件高效、安全地导入MySQL数据库。文章着重解决了在导入过程中常见的SQL语法错误和CSV文件解析问题,特别是PDO预处理语句中参数占位符的正确使用,以及fgetcsv函数处理不同CSV分隔符的方法。通过提供完整代码示例和最佳实践,旨在帮助开发者避免常见陷阱,确保数据导入的准确性和系统稳定性。

1. 理解CSV文件导入需求

在web应用开发中,从csv文件导入数据到数据库是常见的需求。csv(comma separated values)文件以纯文本形式存储表格数据,每行记录由逗号或其他特定字符分隔。本教程将以一个包含两列数据的csv文件为例,演示如何将其导入到mysql数据库的users表中。

示例CSV数据格式:

BGYR002217;FK-066
BGYR002218;FK-140

注意,此示例中数据字段的分隔符是分号(;),而非默认的逗号(,)。

2. 核心技术栈

  • PHP: 服务器端脚本语言,用于处理文件上传和数据库交互。
  • PDO (PHP Data Objects): PHP的数据库抽象层,提供统一的API访问多种数据库,支持预处理语句,增强安全性和性能。
  • MySQL/MariaDB: 关系型数据库管理系统,用于存储数据。

3. 构建数据库表结构

首先,我们需要在MySQL数据库中创建一个用于存储CSV数据的表。假设表名为users,包含szam和forras_szam两列。

CREATE TABLE `users` (
`id` INT AUTO_INCREMENT PRIMARY KEY,
`szam` VARCHAR(255) NOT NULL,
`forras_szam` VARCHAR(255) NOT NULL
);

4. PHP文件上传与解析

为了导入CSV文件,通常需要一个HTML表单供用户上传文件,然后PHP脚本接收并处理该文件。

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

4.1 HTML文件上传表单

创建一个简单的HTML文件(例如 index.html)来提供文件上传功能:

<!DOCTYPE html>
<html lang="zh">
<head>
<meta charset="UTF-8">
<title>CSV文件导入</title>
</head>
<body>
<h1>上传CSV文件到MySQL</h1>
<form action="import.php" method="post" enctype="multipart/form-data">
<label for="upcsv">选择CSV文件:</label>
<input type="file" name="upcsv" id="upcsv" accept=".csv">
<button type="submit">上传并导入</button>
</form>
</body>
</html>

4.2 PHP处理脚本 (import.php)

这是核心的PHP脚本,负责数据库连接、CSV文件读取、解析和数据插入。

<?php
// 1. 数据库配置
$dbHost = 'localhost';
$dbName = 'test'; // 替换为你的数据库名
$dbChar = 'utf8mb4'; // 推荐使用 utf8mb4 以支持更广泛的字符集
$dbUser = 'root';    // 替换为你的数据库用户名
$dbPass = '';        // 替换为你的数据库密码
// 2. 建立PDO数据库连接
try {
$pdo = new PDO(
"mysql:host=" . $dbHost . ";dbname=" . $dbName . ";charset=" . $dbChar,
$dbUser,
$dbPass,
[
PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION, // 错误报告模式:抛出异常
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,       // 默认获取模式:关联数组
PDO::ATTR_EMULATE_PREPARES   => false                   // 禁用模拟预处理,使用原生预处理
]
);
} catch (PDOException $ex) {
exit("数据库连接失败: " . $ex->getMessage());
}
// 3. 检查文件上传
if (!isset($_FILES["upcsv"]) || $_FILES["upcsv"]["error"] !== UPLOAD_ERR_OK) {
exit("文件上传失败或未选择文件。错误码: " . ($_FILES["upcsv"]["error"] ?? 'N/A'));
}
$tmpFilePath = $_FILES["upcsv"]["tmp_name"];
if (!is_uploaded_file($tmpFilePath)) {
exit("无效的文件上传。");
}
// 4. 打开并读取CSV文件
// 注意:fgetcsv 默认分隔符是逗号(,), 如果CSV文件使用分号(;)作为分隔符,需要明确指定
$fh = fopen($tmpFilePath, "r");
if ($fh === false) {
exit("无法打开上传的CSV文件。");
}
// 准备SQL插入语句,使用正确的PDO占位符 `?`
// 错误示例:VALUES (?;?)
// 正确示例:VALUES (?,?)
$stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?, ?)");
$importedRows = 0;
while (($row = fgetcsv($fh, 0, ';')) !== false) { // 明确指定分号作为分隔符
// 检查行数据是否有效,防止空行或格式不符的行导致错误
if (count($row) < 2) {
echo "跳过无效行: " . implode(';', $row) . "<br>";
continue;
}
try {
// 执行预处理语句,绑定CSV行数据到占位符
$stmt->execute([$row[0], $row[1]]);
$importedRows++;
} catch (PDOException $ex) {
// 捕获并输出每行导入的错误信息,而不是中断整个过程
echo "导入行错误: " . implode(';', $row) . " - " . $ex->getMessage() . "<br>";
}
}
// 5. 关闭文件句柄
fclose($fh);
echo "导入完成!成功导入 " . $importedRows . " 行数据。";
?>

5. 关键点解析与常见问题解决

5.1 PDO占位符的正确使用

原始问题中出现的错误 SQLSTATE[42000]: Syntax error or access violation: 1064 You have an error in your SQL syntax;… VALUES (?;?) 明确指出SQL语法错误。

问题根源:
PDO预处理语句中,参数占位符只能是问号(?)或具名参数(例如:param_name)。将分号(;)用作占位符是错误的语法。分号在SQL中通常用作语句的终止符,而不是参数绑定符号。

解决方案:
将SQL语句中的 VALUES (?;?) 改为 VALUES (?,?)。

// 错误示例:
// $stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?;?)");
// 正确示例:
$stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?, ?)");

5.2 fgetcsv函数与CSV分隔符

原始CSV数据 BGYR002217;FK-066 使用分号作为字段分隔符。fgetcsv函数默认使用逗号(,)作为分隔符。如果CSV文件使用其他字符作为分隔符,必须在fgetcsv函数的第三个参数中明确指定。

问题根源:
如果未指定分隔符,fgetcsv会将 BGYR002217;FK-066 视为单个字段读取到 $row[0] 中,导致 $row[1] 未定义,从而引发 Undefined array key 1 警告,并最终导致 execute 方法参数不足或不正确。

解决方案:
在调用 fgetcsv 时,将分隔符参数设置为分号(;):

// 错误示例(如果CSV使用分号分隔):
// while (($row = fgetcsv($fh)) !== false) { ... }
// 正确示例:
while (($row = fgetcsv($fh, 0, ';')) !== false) { // 0表示最大行长度不限制,';'是分隔符
// ...
}

5.3 错误处理与健壮性

在实际应用中,对文件操作和数据库操作进行适当的错误处理至关重要。

  • 文件上传错误: 使用 $_FILES[“upcsv”][“error”] 检查上传状态,并使用 is_uploaded_file() 确保文件是通过HTTP POST上传的。
  • 文件打开错误: 检查 fopen() 的返回值是否为 false。
  • PDO连接错误: 使用 try-catch 块捕获 PDOException。
  • PDO执行错误: 在循环内部,为每次 execute() 调用添加 try-catch 块,这样即使某一行数据导入失败,也不会中断整个导入过程,可以记录错误并继续处理下一行。
  • 数据有效性检查: 在处理 $row 数组之前,检查 count($row) 以确保行数据包含预期的列数,避免 Undefined array key 错误。

6. 最佳实践与注意事项

  • 使用预处理语句: 始终使用PDO预处理语句来插入或更新数据,这可以有效防止SQL注入攻击,并提高重复执行相同SQL语句的性能。
  • 明确字符集: 在PDO连接字符串中指定charset(例如utf8mb4),并确保数据库、表和列的字符集也一致,以避免乱码问题。
  • 错误报告: 在开发环境中,将PDO::ATTR_ERRMODE设置为PDO::ERRMODE_EXCEPTION,以便在出现数据库错误时抛出异常,方便调试。在生产环境中,可以考虑将错误记录到日志文件而非直接输出给用户。
  • 处理大文件: 对于非常大的CSV文件,逐行读取并插入可能会导致性能问题或内存耗尽。可以考虑以下优化:

    • 事务处理: 每隔N行提交一次事务,减少数据库操作的开销。
    • LOAD DATA INFILE: 如果PHP脚本和MySQL服务器在同一台机器上,并且有文件系统权限,LOAD DATA INFILE是导入大量数据最快的方法。
    • 分块读取: 如果内存是瓶颈,可以分块读取CSV文件。
  • 用户体验: 对于长时间运行的导入任务,考虑在前端显示进度条,或使用AJAX异步处理,避免页面超时。

7. 总结

通过本教程,我们学习了如何使用PHP和PDO将CSV文件导入MySQL数据库。核心要点包括:正确使用PDO预处理语句的占位符(?),以及根据CSV文件的实际分隔符配置fgetcsv函数。同时,强调了错误处理、健壮性设计和性能优化在数据导入过程中的重要性。遵循这些指导原则,将能够构建出高效、安全且稳定的CSV数据导入功能。

温馨提示: 本文最后更新于2025-07-15 22:27:40,某些文章具有时效性,若有错误或已失效,请在下方留言或联系易赚网
文章版权声明 1 本网站名称: 创客网
2 本站永久网址:https://new.ie310.com
1 本文采用非商业性使用-相同方式共享 4.0 国际许可协议[CC BY-NC-SA]进行授权
2 本站所有内容仅供参考,分享出来是为了可以给大家提供新的思路。
3 互联网转载资源会有一些其他联系方式,请大家不要盲目相信,被骗本站概不负责!
4 本网站只做项目揭秘,无法一对一教学指导,每篇文章内都含项目全套的教程讲解,请仔细阅读。
5 本站分享的所有平台仅供展示,本站不对平台真实性负责,站长建议大家自己根据项目关键词自己选择平台。
6 因为文章发布时间和您阅读文章时间存在时间差,所以有些项目红利期可能已经过了,能不能赚钱需要自己判断。
7 本网站仅做资源分享,不做任何收益保障,创业公司上收费几百上千的项目我免费分享出来的,希望大家可以认真学习。
8 本站所有资料均来自互联网公开分享,并不代表本站立场,如不慎侵犯到您的版权利益,请联系79283999@qq.com删除。

本站资料仅供学习交流使用请勿商业运营,严禁从事违法,侵权等任何非法活动,否则后果自负!
THE END
喜欢就支持一下吧
点赞8赞赏 分享
评论 抢沙发

请登录后发表评论

    暂无评论内容