PHP如何处理CSV文件_CSV文件读写操作教程

fgetcsv()

fputcsv()

fgetcsv()

<?php

function readCsvFile(string $filePath, string $delimiter = ',', string $enclosure = '"'): array
{
    $data = [];
    if (!file_exists($filePath) || !is_readable($filePath)) {
        // 实际项目中这里可能抛出异常或返回错误码
        error_log("Error: CSV file not found or not readable at " . $filePath);
        return $data;
    }

    // 尝试以只读模式打开文件
    if (($handle = fopen($filePath, 'r')) !== FALSE) {
        // 跳过UTF-8 BOM头，如果存在的话。这是处理中文CSV时常遇到的一个坑。
        // 我通常会在读取第一行之前检查并跳过。
        $bom = fread($handle, 3);
        if ($bom !== "\xEF\xBB\xBF") {
            rewind($handle); // 如果没有BOM，则重置文件指针
        }

        while (($row = fgetcsv($handle, 0, $delimiter, $enclosure)) !== FALSE) {
            // fgetcsv会返回一个数组，或者在文件末尾返回false
            if ($row === null) { // 遇到空行或者解析错误时，fgetcsv可能返回null
                continue;
            }
            $data[] = $row;
        }
        fclose($handle); // 记得关闭文件句柄
    } else {
        error_log("Error: Could not open CSV file for reading at " . $filePath);
    }
    return $data;
}

// 示例用法：
// 假设有一个名为 'example.csv' 的文件
// header1,header2,header3
// value1,value2,"value with, comma"
// "another value",value4,value5

// $csvData = readCsvFile('example.csv');
// print_r($csvData);

/*
输出可能类似：
Array
(
    [0] => Array
        (
            [0] => header1
            [1] => header2
            [2] => header3
        )

    [1] => Array
        (
            [0] => value1
            [1] => value2
            [2] => value with, comma
        )

    [2] => Array
        (
            [0] => another value
            [1] => value4
            [2] => value5
        )

)
*/

?>

fgetcsv()

length

0

fputcsv()

<?php

function writeCsvFile(string $filePath, array $data, string $delimiter = ',', string $enclosure = '"'): bool
{
    // 确保目录存在且可写
    $dir = dirname($filePath);
    if (!is_dir($dir) && !mkdir($dir, 0777, true)) {
        error_log("Error: Could not create directory for CSV file at " . $dir);
        return false;
    }

    // 尝试以写入模式打开文件。'w'会清空文件，'a'会追加。
    // 我这里用'w'作为默认，如果你需要追加，可以修改。
    if (($handle = fopen($filePath, 'w')) !== FALSE) {
        // 写入UTF-8 BOM头，这对于确保Excel正确识别UTF-8编码的中文CSV很有帮助
        fwrite($handle, "\xEF\xBB\xBF");

        foreach ($data as $row) {
            // fputcsv期望一个数组作为行数据
            if (!is_array($row)) {
                error_log("Warning: Skipping non-array row data during CSV writing.");
                continue;
            }
            fputcsv($handle, $row, $delimiter, $enclosure);
        }
        fclose($handle);
        return true;
    } else {
        error_log("Error: Could not open CSV file for writing at " . $filePath);
        return false;
    }
}

// 示例用法：
// $dataToWrite = [
//     ['Name', 'Age', 'City'],
//     ['Alice', 30, 'New York'],
//     ['Bob', 24, 'London'],
//     ['Charlie', 35, 'Paris, France'] // 注意带逗号的字段会被正确引用
// ];

// $success = writeCsvFile('output.csv', $dataToWrite);
// if ($success) {
//     echo "CSV file 'output.csv' written successfully.";
// } else {
//     echo "Failed to write CSV file.";
// }

?>

fputcsv()

fgetcsv

fgetcsv()

readCsvFile

fgetcsv()

fgetcsv()

// 再次强调 fgetcsv 的用法，它本身就是高效的
if (($handle = fopen($filePath, 'r')) !== FALSE) {
    // ... BOM处理 ...
    while (($row = fgetcsv($handle, 0, $delimiter, $enclosure)) !== FALSE) {
        // 在这里直接处理 $row，而不是将所有行都存入一个大数组
        // 例如：将数据写入数据库、进行计算、筛选等
        // processRow($row);
        // 如果你需要收集部分数据，也要注意控制收集量，比如每1000行批量处理一次
    }
    fclose($handle);
}

fputcsv()

// 假设 $largeDataSource 是一个可以迭代的大型数据源，比如数据库结果集
function writeLargeCsv(string $filePath, iterable $largeDataSource, string $delimiter = ',', string $enclosure = '"'): bool
{
    if (($handle = fopen($filePath, 'w')) !== FALSE) {
        fwrite($handle, "\xEF\xBB\xBF"); // 写入BOM

        foreach ($largeDataSource as $row) {
            // 确保 $row 是一个数组
            if (is_array($row)) {
                fputcsv($handle, $row, $delimiter, $enclosure);
            } else {
                error_log("Warning: Skipping non-array item from large data source.");
            }
        }
        fclose($handle);
        return true;
    }
    return false;
}

// 示例：从数据库中获取数据并写入CSV
// $stmt = $pdo->query("SELECT name, email, address FROM users WHERE status = 'active'");
// writeLargeCsv('active_users.csv', $stmt); // PDOStatement是可迭代的

yield

<?php
function csvRowsGenerator(string $filePath, string $delimiter = ',', string $enclosure = '"'): Generator
{
    if (!file_exists($filePath) || !is_readable($filePath)) {
        throw new \RuntimeException("CSV file not found or not readable at " . $filePath);
    }

    if (($handle = fopen($filePath, 'r')) !== FALSE) {
        // 尝试跳过BOM
        $bom = fread($handle, 3);
        if ($bom !== "\xEF\xBB\xBF") {
            rewind($handle);
        }

        while (($row = fgetcsv($handle, 0, $delimiter, $enclosure)) !== FALSE) {
            if ($row === null) {
                continue;
            }
            yield $row; // 每次迭代时返回一行数据
        }
        fclose($handle);
    } else {
        throw new \RuntimeException("Could not open CSV file for reading at " . $filePath);
    }
}

// 示例用法：
// try {
//     foreach (csvRowsGenerator('large_data.csv') as $rowIndex => $row) {
//         // 处理每一行数据，内存占用极低
//         // echo "Row " . $rowIndex . ": " . implode(', ', $row) . "\n";
//         // insertIntoDatabase($row);
//     }
// } catch (\RuntimeException $e) {
//     error_log("Error processing CSV: " . $e->getMessage());
// }
?>

foreach