PHP PDO与CSV数据导入概述
在web开发中，将数据从csv（逗号分隔值）文件导入到关系型数据库（如mysql）是一个常见的需求。php的pdo（php data objects）扩展提供了一个轻量级、一致性的接口，用于连接多种数据库，并支持预处理语句，这对于防止sql注入攻击至关重要。结合php的文件处理函数（如fgetcsv），我们可以高效地实现csv数据的批量导入。
常见错误：SQL预处理语句占位符语法
在使用PDO的预处理语句时，一个常见的语法错误发生在指定参数占位符时。例如，当尝试将数据插入到users表的szam和forras_szam字段时，错误的写法可能如下：
INSERT INTO users (szam, forras_szam) VALUES (?;?)
这里的错误在于占位符?之间使用了分号;作为分隔符。在SQL预处理语句中，问号?是用于表示参数的占位符，它们之间不应有任何分隔符（如逗号、分号或其他字符），除非这些字符本身是SQL语法的一部分。数据库解析器在遇到VALUES (?;?)时，会将其视为非法的SQL语法，从而抛出“SQLSTATE[42000]: Syntax error or access violation: 1064”错误。
正确的占位符语法应该是使用逗号,来分隔不同的值，就像在普通INSERT语句中一样：
INSERT INTO users (szam, forras_szam) VALUES (?,?)
完整的PHP导入脚本示例
以下是一个修正后的PHP脚本示例，它展示了如何正确地使用PDO预处理语句将CSV数据导入MySQL数据库。此示例假定CSV文件使用分号;作为字段分隔符。
立即学习“PHP免费学习笔记（深入）”；
PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 可选：设置默认的获取模式
]
);
echo "数据库连接成功。
";
} catch (PDOException $ex) {
// 捕获数据库连接异常
exit("数据库连接失败: " . $ex->getMessage());
}
// 假设CSV文件通过表单上传，文件名为 'upcsv'
// 在实际应用中，需要确保 $_FILES["upcsv"]["tmp_name"] 存在且有效
if (!isset($_FILES["upcsv"]["tmp_name"]) || empty($_FILES["upcsv"]["tmp_name"])) {
exit("未找到上传的CSV文件。");
}
// 打开上传的CSV文件
// 注意：fgetcsv 默认分隔符是逗号，如果CSV使用分号，需要明确指定
$fh = fopen($_FILES["upcsv"]["tmp_name"], "r");
if ($fh === false) {
exit("无法打开上传的CSV文件。");
}
$importedCount = 0;
$errorCount = 0;
// 开启事务，确保数据一致性，如果中途出错可以回滚
$pdo->beginTransaction();
try {
// 准备SQL插入语句，使用正确的占位符语法
$stmt = $pdo->prepare("INSERT INTO users (szam, forras_szam) VALUES (?,?)");
// 逐行读取CSV文件
while (($row = fgetcsv($fh, 0, ';')) !== false) { // 指定分号为分隔符
// 检查行数据是否符合预期，避免 Undefined array key 错误
if (count($row) < 2) {
echo "警告: CSV行数据格式不正确，跳过。行内容: " . implode(';', $row) . "
";
$errorCount++;
continue;
}
try {
// 执行预处理语句，绑定CSV行数据到占位符
$stmt->execute([$row[0], $row[1]]);
$importedCount++;
} catch (PDOException $ex) {
// 捕获SQL执行异常
echo "插入数据失败: " . $ex->getMessage() . " (数据: " . implode(';', $row) . ")
";
$errorCount++;
}
}
// 提交事务
$pdo->commit();
echo "CSV数据导入完成。成功导入 " . $importedCount . " 条记录，" . $errorCount . " 条记录处理失败。
";
} catch (Exception $e) {
// 捕获事务或其他操作的异常，回滚事务
$pdo->rollBack();
echo "导入过程中发生错误，事务已回滚: " . $e->getMessage() . "
";
} finally {
// 关闭文件句柄
fclose($fh);
}
echo "DONE.";
?>对应的HTML表单（upload.html）示例：
为了使上述PHP脚本能够接收文件上传，你需要一个HTML表单：
上传CSV文件
导入过程中的关键注意事项
CSV文件分隔符： fgetcsv()函数默认使用逗号,作为字段分隔符。如果你的CSV文件使用分号;、制表符\t或其他字符作为分隔符，你必须在fgetcsv()的第三个参数中明确指定，例如：fgetcsv($fh, 0, ';')。否则，文件内容可能无法正确解析，导致数据错位或Undefined array key错误。
-
错误处理机制：
- PDO错误模式： 始终将PDO的错误模式设置为PDO::ERRMODE_EXCEPTION。这会使PDO在遇到SQL错误时抛出PDOException，允许你使用try-catch块来优雅地捕获和处理错误，而不是默默失败或只发出警告。
- 文件操作错误： 对fopen()和fgetcsv()的返回值进行检查，确保文件被成功打开和读取。
- 数据完整性检查： 在$stmt->execute()之前，检查$row数组的元素数量，确保它包含所有预期的字段，以避免Undefined array key错误。
-
文件上传处理：
- 在生产环境中，需要对$_FILES数组进行更严格的验证，包括文件类型、大小、以及是否是合法的上传文件（使用is_uploaded_file()）。
- 将上传的文件移动到安全的位置，而不是直接在tmp_name上操作，尽管对于一次性导入可能不是强制的，但这是良好的安全实践。
-
事务处理：
- 对于批量数据插入，使用事务（$pdo->beginTransaction()、$pdo->commit()、$pdo->rollBack()）至关重要。如果导入过程中发生任何错误，你可以回滚所有已插入的记录，确保数据库的数据一致性。
-
数据验证与类型转换：
- 在将CSV数据插入数据库之前，强烈建议对数据进行验证和必要的类型转换。例如，如果数据库字段是整数类型，而CSV中可能包含非数字字符，你需要进行intval()转换或更复杂的验证。这有助于防止数据类型不匹配导致的错误。
-
性能优化：
- 对于非常大的CSV文件（例如，几十万或上百万行），逐行插入可能会很慢。可以考虑批量插入（一次INSERT多条记录）或使用MySQL的LOAD DATA INFILE命令，后者通常是处理大量CSV数据的最快方式。
总结
正确理解和使用SQL预处理语句的占位符语法是避免常见数据库错误的基石。通过本文的示例和注意事项，我们不仅解决了VALUES (?;?)这一特定语法错误，还提供了一套健壮的CSV数据导入方案，涵盖了错误处理、事务管理和文件解析等关键方面。遵循这些最佳实践，将有助于你构建更稳定、更安全的PHP应用程序。
