PHP 中安全读取并更新 CSV 文件的完整教程-php教程-PHP中文网

PHP 中安全读取并更新 CSV 文件的完整教程

csv 文件本质上是字节流而非行结构，无法直接原地修改某一行；必须通过“读取全部 → 内存中修改 → 写入新文件（或覆盖原文件）”的方式实现安全更新。

csv 文件本质上是字节流而非行结构，无法直接原地修改某一行；必须通过“读取全部 → 内存中修改 → 写入新文件（或覆盖原文件）”的方式实现安全更新。

在 PHP 中处理 CSV 文件时，一个常见误区是试图用 fopen(..., 'a')（追加模式）来“更新”某一行——但正如底层文件系统所决定的：文件没有逻辑上的“行”概念，只有连续的字节序列；fseek() 只能覆写、不能插入，'a' 模式只能写入末尾。因此，原问题中 savetoCSV() 每次追加新记录，实际导致重复数据堆积，而非更新原有行。

✅ 正确做法是采用「读-改-写」三步法：

完整读取 CSV 到内存数组（使用 file() + str_getcsv() 或 fgetcsv() 循环）；
遍历并按条件修改目标行（例如匹配 $line[1] 非空且 $username 不含 'Login'）；
一次性写入新内容到临时文件，再原子化替换原文件（避免中断导致数据丢失）。

以下是推荐的健壮实现：

Knowledge Graph - Csv Graph Loader Generator

从 CSV 数据集生成图数据库加载器和三元组映射。将表格 CSV 数据转换为图数据库可直接使用的节点、边和三元组。

下载

<?php function updateCsvRows($filename, $updateCallback) {
    // 1. 安全读取全部行（自动处理 BOM）
    $lines = [];
    $handle = fopen($filename, 'r');
    if (!$handle) {
        throw new RuntimeException("无法打开文件: $filename");
    }

    while (($row = fgetcsv($handle)) !== false) {
        $lines[] = $row;
    }
    fclose($handle);

    // 2. 遍历并更新符合条件的行（传入回调函数定义更新逻辑）
    foreach ($lines as &$line) {
        if (count($line) < 4) continue; // 跳过格式异常行

        $client_name = trim(str_replace(' ', '', $line[0]));
        $account_id  = trim(str_replace(' ', '', $line[1]));
        $username    = trim(str_replace(' ', '', $line[2]));
        $pass        = trim(str_replace(' ', '', $line[3]));

        // 跳过标题行或含 "Login" 的用户名（示例条件）
        if (empty($account_id) || strpos($username, 'Login') !== false) {
            continue;
        }

        // 执行更新：追加两个新字段（空值 + 原密码），等同原逻辑
        $line = [$client_name, $account_id, $username, $pass, '', $pass];
    }
    unset($line); // 解除引用

    // 3. 原子化写入：先写入临时文件，再重命名覆盖
    $tempFile = $filename . '.tmp';
    $fp = fopen($tempFile, 'w');
    if (!$fp) {
        throw new RuntimeException("无法创建临时文件: $tempFile");
    }

    foreach ($lines as $row) {
        fputcsv($fp, $row);
    }
    fclose($fp);

    // 原子替换（Linux/macOS 安全；Windows 下 rename() 也保证原子性）
    if (!rename($tempFile, $filename)) {
        unlink($tempFile);
        throw new RuntimeException("更新文件失败: $filename");
    }

    echo "✅ CSV 更新完成，共处理 " . count($lines) . " 行。\n";
}

// 调用示例
try {
    updateCsvRows('de_login.csv', null); // 第二个参数可扩展为自定义回调
} catch (Exception $e) {
    echo "❌ 错误: " . $e->getMessage() . "\n";
}
?>

? 关键注意事项：

永远不要边读边写同一文件：'r+' 模式下 fseek() + fwrite() 仅能覆写等长内容，CSV 字段长度变化会导致数据错位或截断；
BOM 处理：若 CSV 含 UTF-8 BOM（EF BB BF），建议读取时用 file() + mb_convert_encoding() 清洗，或使用 stream_filter_append()；
大文件优化：当 CSV 超过 10MB 时，应改用流式处理（逐块读取+临时索引），但需自行维护行号映射，复杂度显著上升；
并发安全：生产环境需加文件锁（flock($fp, LOCK_EX)），防止多进程同时写入冲突；
备份习惯：关键操作前建议 copy($filename, $filename . '.backup.' . date('Ymd_His'))。