电话
400 9058 355
PHP导入班级通信录支持断点续传需流式读取CSV、持久化记录最后处理的行号或主键(如student_id)、入库前校验幂等性、事务提交后更新断点,并统一编码、避免并发冲突。
断点续传不是 PHP 自带功能,必须靠开发者自己记录导入进度。核心思路是:每次成功写入一批数据后,把最后处理的行号或唯一标识(如学号)存到数据库或文件中;下次导入时先读这个位置,跳过已处理的数据。
$_FILES 上传后直接全量解析 CSV —— 大文件会超内存、超时,且无法中断恢复fgetcsv() 流式读取,配合 ftell() 记录文件指针位置,或用行号($lineNumber)做断点标记task_id、last_line、status、updated_at
fgetcsv() 行号错乱,务必用 str_getcsv() + 手动按 \r\n 切分并校验引号配对,或改用 League\Csv 库处理复杂格式关键不是重跑整个文件,而是从上次中断处继续。这要求导入流程可拆解为原子操作,并能明确判断某条记录是否已入库。
SELECT 1 FROM students WHERE student_id = ?,存在则跳过 —— 这是“幂等性”基础,防止重复插入student_id 或 class_id + name 联合唯一)校验,避免因文件内容变动(删行/插行)导致跳过错误数据INSERT ... ON DUPLICATE KEY UPDATE 比手动查+插更高效,但需确保表有合适唯一索引(如 UNIQUE(student_id))task_id 而非文件名,后端据此查出 last_line 和文件存储路径(如 /upload/task_abc123.csv),再 fopen() 定位到对应行断点续传真正难的不是代码,而是状态一致性。很多“续传失败”其实是中间态没清理干净造成的。
max_execution_time)或内存溢出时,last_line 可能已更新但数据没写完 → 必须在事务提交成功后才更新断点值INSERT IGNORE 或加 FOR UPDATE 锁住断点记录行,避免覆盖student_id 匹配失败,看起来像“重复导入” → 统一转为 UTF-8 再处理,可用 mb_convert_encoding($line, 'UTF-8', 'GBK')
file_get_contents() 一次性读全文件再 explode("\n"),看似简单,但大文件直接崩 —— 必须流式处理,哪怕多花 20 行代码以下仅示意核心控制流,不封装、不异常处理,方便你快速对齐逻辑:
// 假设已知 task_id = 123,查出 last_line = 45
$fp = fopen('/upload/task_123.csv', 'r');
for ($i = 0; $i < 45; $i++) {
fgetcsv($fp); // 跳过已处理行
}
while (($row = fgetcsv($fp)) !== false) {
$studentId = $row[0];
// 先查是否存在
$exists = $pdo->prepare("SELECT 1 FROM students WHERE student_id = ?")->execute([$studentId])->fetch();
if ($exists) continue;
// 插入
$pdo->prepare("INSERT INTO students (student_id, name, phone) VALUES (?, ?, ?)")->execute([$studentId, $row[1], $row[2]]);
// 更新断点(放在循环末尾,保证至少处理完当前行)
$pdo->prepare("UPDATE import_tasks SET last_line = ? WHERE id = ?")->execute
([$i + 46, 123]);
$i++;
}
fclose($fp);
实际项目里,行号容易漂移,更稳妥的是用最后一行的 student_id 作为断点标记,再配合 WHERE student_id > ? ORDER BY student_id LIMIT 100 分页导入 —— 这种方式对文件顺序无依赖,但要求数据本身有序或可排序。
邮箱:8955556@qq.com
Q Q:8955556
本文详解如何将Go官方present工具(用于生成HTML5...
PySNMP在不同版本中对SNMP错误状态(errorSta...
time.Sleep仅阻塞当前goroutine,其他gor...
PHPfopen()创建含特殊符号的文件名失败主因是操作系统...
WooCommerce中通过代码为分组产品动态聚合子商品的属...
io.ReadFull返回io.ErrUnexpectedE...
本文详解Yii2中控制器向视图传递ActiveRecord数...
本文详解为何通过wp_set_object_terms()为...
Pytest中使用@mock.patch类装饰器会导致补丁泄...
带缓冲的channel是并发安全的FIFO队列;make(c...