PHP命令行导出导入CSV技巧

#!/usr/bin/env php
\n";
    exit(1);
}

$filePath = $argv[1];

if (!file_exists($filePath)) {
    echo "错误：文件不存在。\n";
    exit(1);
}

$file = fopen($filePath, 'r');
if (!$file) {
    echo "无法打开文件。\n";
    exit(1);
}

// 跳过标题行（如果有）
$header = fgetcsv($file);

while (($row = fgetcsv($file)) !== false) {
    // 示例：打印每行数据
    echo "姓名: {$row[0]}, 邮箱: {$row[1]}, 年龄: {$row[2]}\n";

    // 这里可插入数据库操作，如PDO插入
    // $pdo->prepare("INSERT INTO users ...")->execute($row);
}

fclose($file);
echo "导入完成。\n";
?>

php import.php data.csv

#!/usr/bin/env php
\n";
    exit(1);
}

$outputFile = $argv[1];

$file = fopen($outputFile, 'w');
if (!$file) {
    echo "无法创建文件。\n";
    exit(1);
}

// 写入标题行
fputcsv($file, ['姓名', '邮箱', '年龄']);

// 模拟数据（实际可从数据库查询）
$data = [
    ['张三', 'zhangsan@example.com', 25],
    ['李四', 'lisi@example.com', 30],
    ['王五', 'wangwu@example.com', 28]
];

foreach ($data as $row) {
    fputcsv($file, $row);
}

fclose($file);
echo "数据已导出到 $outputFile\n";
?>

php export.php users.csv

$pdo = new PDO('mysql:host=localhost;dbname=test', 'user', 'pass');
$stmt = $pdo->prepare("INSERT INTO users (name, email, age) VALUES (?, ?, ?)");

while (($row = fgetcsv($file)) !== false) {
    $stmt->execute($row);
}

$stmt = $pdo->query("SELECT name, email, age FROM users");
while ($row = $stmt->fetch(PDO::FETCH_NUM)) {
    fputcsv($file, $row);
}