如何解决数据导入导出难题？ddeboer/data-import助你轻松搞定！

composer require ddeboer/data-import:@stable

require_once 'vendor/autoload.php';

name,email,created_at
Alice,alice@example.com,2023-01-15 10:00:00
Bob,bob@example.com,2023-02-20 11:30:00
Charlie,charlie@example.com,2023-03-01 09:15:00

<?php

require_once 'vendor/autoload.php';

use Ddeboer\DataImport\Workflow;
use Ddeboer\DataImport\Reader\CsvReader;
use Ddeboer\DataImport\Writer\DoctrineWriter;
use Ddeboer\DataImport\ValueConverter\DateTimeValueConverter;
use Doctrine\ORM\Tools\Setup;
use Doctrine\ORM\EntityManager;

// 1. 准备 Doctrine EntityManager (此处仅为示例，实际项目中请根据您的配置调整)
$isDevMode = true;
$config = Setup::createAnnotationMetadataConfiguration(array(__DIR__."/src"), $isDevMode);

$conn = array(
    'driver'   => 'pdo_mysql',
    'host'     => 'localhost',
    'dbname'   => 'your_database',
    'user'     => 'your_user',
    'password' => 'your_password',
);

// 假设您已经定义了 User 实体
// namespace App\Entity;
// use Doctrine\ORM\Mapping as ORM;
// /** @ORM\Entity */
// class User {
//     /** @ORM\Id @ORM\Column(type="integer") @ORM\GeneratedValue */
//     private $id;
//     /** @ORM\Column(type="string") */
//     private $name;
//     /** @ORM\Column(type="string", unique=true) */
//     private $email;
//     /** @ORM\Column(type="datetime") */
//     private $createdAt;
//     // ... getters and setters
// }
$entityManager = EntityManager::create($conn, $config);

// 2. 创建 CSV 阅读器
$file = new \SplFileObject('users.csv');
$reader = new CsvReader($file);
// 告诉阅读器第一行是表头，这样数据会以关联数组的形式提供 (e.g., ['name' => 'Alice'])
$reader->setHeaderRowNumber(0);

// 3. 创建数据导入工作流
$workflow = new Workflow($reader);

// 4. 添加 Doctrine 写入器
// 'App\Entity\User' 是你的 Doctrine 实体类名
$writer = new DoctrineWriter($entityManager, 'App\Entity\User');
// 默认情况下，DoctrineWriter 会在导入前清空表，如果你不希望清空，可以调用 disableTruncate()
// $writer->disableTruncate();
$workflow->addWriter($writer);

// 5. 添加值转换器：将 'created_at' 字段的字符串转换为 DateTime 对象
// 'Y-m-d H:i:s' 是 CSV 中日期字符串的格式
$dateTimeConverter = new DateTimeValueConverter('Y-m-d H:i:s');
$workflow->addValueConverter('created_at', $dateTimeConverter);

// 6. （可选）添加过滤器，例如跳过 email 为空的行
// $workflow->addFilter(new CallbackFilter(function ($item) {
//     return !empty($item['email']);
// }));

// 7. （可选）设置遇到错误时跳过当前行，而不是中断整个流程
$workflow->setSkipItemOnFailure(true);

// 8. 处理工作流
try {
    $result = $workflow->process();

    echo "数据导入完成！\n";
    echo "总处理行数: " . $result->getTotalProcessedCount() . "\n";
    echo "成功导入行数: " . $result->getSuccessCount() . "\n";
    echo "错误行数: " . $result->getErrorCount() . "\n";

    if ($result->hasErrors()) {
        echo "错误详情:\n";
        foreach ($result->getExceptions() as $exception) {
            echo " - " . $exception->getMessage() . "\n";
        }
    }

} catch (\Exception $e) {
    echo "导入过程中发生严重错误: " . $e->getMessage() . "\n";
}