1. 引言
在web应用开发中，将外部数据（如csv格式）导入到数据库是一个常见的需求。php结合pdo（php data objects）为与mysql数据库交互提供了强大且安全的方式。本教程将引导您完成一个完整的csv文件导入mysql数据库的流程，并指出常见的错误及如何避免它们。
2. 前置准备
在开始之前，请确保您已具备以下环境和基础知识：
- Web服务器环境： 如Apache或Nginx，并安装了PHP。
- MySQL数据库： 确保MySQL服务正在运行。
- PHP基础： 了解PHP语法、文件操作及表单处理。
- PDO基础： 了解PDO的基本概念，如连接数据库、预处理语句等。
数据库表结构示例： 为了演示，我们假设有一个名为 users 的数据库表，包含以下字段：
CREATE TABLE `users` (
`id` INT AUTO_INCREMENT PRIMARY KEY,
`szam` VARCHAR(255) NOT NULL,
`forras_szam` VARCHAR(255) NOT NULL
);CSV文件格式示例： 假设您的CSV文件数据以分号（;）分隔，例如：
BGYR002217;FK-066 BGYR002218;FK-140
3. PHP脚本实现
整个导入过程可以分为几个主要步骤：数据库连接、文件上传处理、读取CSV数据并插入数据库。
3.1 数据库连接
首先，我们需要使用PDO建立与MySQL数据库的连接。为了提高安全性，建议将数据库凭据保存在配置文件中，但这里为了演示方便直接写入代码。
PDO::ERRMODE_EXCEPTION, // 启用异常模式
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认关联数组获取结果
PDO::ATTR_EMULATE_PREPARES => false // 禁用模拟预处理，使用原生预处理
]
);
} catch (Exception $ex) {
// 捕获数据库连接异常
exit("数据库连接失败: " . $ex->getMessage());
}
?>注意事项：
立即学习“PHP免费学习笔记（深入）”；
- PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION：这是非常重要的设置，它会使PDO在遇到错误时抛出异常，方便我们进行错误捕获和处理。
- PDO::ATTR_EMULATE_PREPARES => false：禁用模拟预处理，确保使用数据库服务器的原生预处理功能，提高安全性和性能。
- utf8mb4：推荐使用 utf8mb4 字符集，以支持更广泛的Unicode字符，包括表情符号等。
3.2 处理文件上传
CSV文件通常通过HTML表单上传到服务器。PHP通过 $_FILES 全局变量来处理上传的文件。
首先，您需要一个HTML表单来上传CSV文件：
ECTouch是上海商创网络科技有限公司推出的一套基于 PHP 和 MySQL 数据库构建的开源且易于使用的移动商城网店系统！应用于各种服务器平台的高效、快速和易于管理的网店解决方案，采用稳定的MVC框架开发，完美对接ecshop系统与模板堂众多模板，为中小企业提供最佳的移动电商解决方案。ECTouch程序源代码完全无加密。安装时只需将已集成的文件夹放进指定位置，通过浏览器访问一键安装，无需对已有
CSV文件导入
在 import.php 中，我们需要检查文件是否成功上传：
// ... (数据库连接代码) ...
if (!isset($_FILES["upcsv"]) || $_FILES["upcsv"]["error"] !== UPLOAD_ERR_OK) {
exit("文件上传失败或未选择文件.");
}
$csvFilePath = $_FILES["upcsv"]["tmp_name"];
$fh = fopen($csvFilePath, "r");
if ($fh === false) {
exit("无法打开上传的CSV文件.");
}3.3 读取CSV数据并插入数据库
这是核心部分，我们将逐行读取CSV文件，并使用PDO预处理语句将数据插入到数据库中。
关键点：CSV分隔符fgetcsv() 函数默认使用逗号（,）作为分隔符。如果您的CSV文件使用其他分隔符（如本例中的分号 ;），您必须将其作为第二个参数（或第三个参数，如果指定了长度）传递给 fgetcsv()。
关键点：PDO预处理语句占位符 在PDO预处理语句中，参数占位符是问号 ? 或命名占位符 :name。原始代码中使用了 VALUES (?;?)，这是不正确的语法。正确的占位符应该是 VALUES (?,?)。
// ... (数据库连接和文件处理代码) ...
$rowCount = 0;
$errorCount = 0;
// 开始事务，确保数据一致性，如果导入过程中出现错误，可以回滚
$pdo->beginTransaction();
try {
// 准备SQL插入语句
// 注意：VALUES (?,?) 是正确的占位符语法
$stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?,?)");
// 循环读取CSV文件中的每一行
// fgetcsv的第三个参数是分隔符，这里指定为分号 ';'
while (($row = fgetcsv($fh, 0, ';')) !== false) {
// 检查行数据是否符合预期，避免 Undefined array key 错误
if (count($row) < 2) {
echo "警告: 跳过无效行 (数据不足): " . implode(';', $row) . "
";
$errorCount++;
continue;
}
try {
// 执行预处理语句，绑定CSV行中的数据
$stmt->execute([$row[0], $row[1]]);
$rowCount++;
} catch (Exception $ex) {
// 捕获每行插入时的数据库错误
echo "插入数据失败 (行: " . implode(';', $row) . "): " . $ex->getMessage() . "
";
$errorCount++;
// 可以选择在这里中断导入或继续
}
}
// 提交事务
$pdo->commit();
echo "数据导入完成。
";
echo "成功导入 " . $rowCount . " 行。
";
if ($errorCount > 0) {
echo "有 " . $errorCount . " 行导入失败或被跳过。
";
}
} catch (Exception $ex) {
// 捕获整个导入过程中的异常，并回滚事务
$pdo->rollBack();
echo "导入过程中发生致命错误: " . $ex->getMessage() . "
";
echo "所有更改已回滚。
";
} finally {
// 确保文件句柄被关闭
fclose($fh);
}
echo "DONE.";
?>4. 完整代码示例
将上述所有部分组合起来，形成一个完整的 import.php 文件：
PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES => false
]
);
} catch (Exception $ex) {
exit("数据库连接失败: " . $ex->getMessage());
}
// 2. 处理文件上传
if (!isset($_FILES["upcsv"]) || $_FILES["upcsv"]["error"] !== UPLOAD_ERR_OK) {
exit("文件上传失败或未选择文件.");
}
$csvFilePath = $_FILES["upcsv"]["tmp_name"];
$fh = fopen($csvFilePath, "r");
if ($fh === false) {
exit("无法打开上传的CSV文件.");
}
// 3. 读取CSV数据并插入数据库
$rowCount = 0;
$errorCount = 0;
// 开始事务
$pdo->beginTransaction();
try {
// 准备SQL插入语句，使用正确的占位符 '?'
$stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?,?)");
// 循环读取CSV文件中的每一行
// fgetcsv的第三个参数是分隔符，这里指定为分号 ';'
while (($row = fgetcsv($fh, 0, ';')) !== false) {
// 简单的数据完整性检查
if (count($row) < 2) {
echo "警告: 跳过无效行 (数据不足): " . htmlspecialchars(implode(';', $row)) . "
";
$errorCount++;
continue;
}
try {
// 执行预处理语句
$stmt->execute([$row[0], $row[1]]);
$rowCount++;
} catch (Exception $ex) {
// 捕获每行插入时的数据库错误
echo "插入数据失败 (行: " . htmlspecialchars(implode(';', $row)) . "): " . $ex->getMessage() . "
";
$errorCount++;
}
}
// 提交事务
$pdo->commit();
echo "数据导入完成。
";
echo "成功导入 " . $rowCount . " 行。
";
if ($errorCount > 0) {
echo "有 " . $errorCount . " 行导入失败或被跳过。
";
}
} catch (Exception $ex) {
// 捕获整个导入过程中的异常，并回滚事务
$pdo->rollBack();
echo "导入过程中发生致命错误: " . $ex->getMessage() . "
";
echo "所有更改已回滚。
";
} finally {
// 确保文件句柄被关闭
if ($fh) {
fclose($fh);
}
}
echo "DONE.";
?>5. 注意事项与最佳实践
- 错误处理： 使用 try-catch 块捕获所有可能的异常，包括数据库连接、文件操作和SQL执行错误。
- 事务： 对于批量数据导入，强烈建议使用事务（beginTransaction(), commit(), rollBack()）。这样可以确保数据的一致性，如果导入过程中发生任何错误，可以回滚所有已执行的操作，避免部分数据导入成功而导致的数据不完整。
- CSV分隔符： 务必根据您的CSV文件实际使用的分隔符，正确设置 fgetcsv() 的第三个参数。
- 数据验证： 在 $stmt->execute() 之前，对从CSV读取的数据进行严格的验证（如数据类型、长度、格式等），以防止无效数据插入数据库或SQL注入风险。
-
安全性：
- 永远不要直接将用户输入拼接到SQL查询中。使用PDO预处理语句是防止SQL注入的最佳实践。
- 限制上传文件的大小和类型，防止恶意文件上传。
- 上传的文件应存储在Web服务器不可直接访问的目录中，处理完成后及时删除。
-
性能优化：
- 对于非常大的CSV文件，可以考虑分批次导入（例如，每1000行提交一次事务），以减少内存消耗和提高效率。
- 如果数据量巨大，LOAD DATA INFILE 是MySQL原生提供的一种更高效的导入方式，但它需要文件在数据库服务器上可访问。
- 用户反馈： 在导入完成后，向用户提供清晰的反馈，说明导入结果、成功行数、失败行数及原因。
6. 总结
通过本文的详细教程，您应该已经掌握了如何使用PHP和PDO安全高效地将CSV文件导入MySQL数据库。核心要点在于正确使用PDO预处理语句的占位符 ?，以及根据CSV文件的实际分隔符配置 fgetcsv() 函数。遵循上述最佳实践，可以帮助您构建一个健壮、安全且高效的数据导入功能。
