app/DoctrineMigrations/Version20241213100000.php line 1

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace DoctrineMigrations;
  6. use Doctrine\DBAL\Schema\Schema;
  7. use Doctrine\Migrations\AbstractMigration;
  9. final class Version202412131100000 extends AbstractMigration
  10. {
  11.     public function getDescription(): string
  12.     {
  13.         return 'Truncate maker table and import initial data from CSV';
  14.     }
  16.     private function loadCsvData(): array
  17.     {
  18.         $csvPath = __DIR__ . '/Data/makers.csv';
  19.         
  20.         if (!file_exists($csvPath)) {
  21.             throw new \RuntimeException('CSV file not found: ' . $csvPath);
  22.         }
  24.         $data = [];
  25.         if (($handle = fopen($csvPath, 'r')) !== false) {
  26.             // ヘッダー行をスキップ
  27.             fgetcsv($handle);
  28.             
  29.             while (($row = fgetcsv($handle)) !== false) {
  30.                 $data[] = [
  31.                     'id' => $row[0],
  32.                     'name_en' => $row[1],
  33.                     'name_jp' => $row[2],
  34.                 ];
  35.             }
  36.             fclose($handle);
  37.         }
  38.         
  39.         return $data;
  40.     }
  42.     public function up(Schema $schema): void
  43.     {
  44.         // 外部キー制約を一時的に無効化（必要な場合）
  45.         $this->addSql('SET FOREIGN_KEY_CHECKS = 0');
  46.         
  47.         // テーブルをクリア
  48.         $this->addSql('TRUNCATE TABLE dtb_maker');
  49.         
  50.         try {
  51.             $makers = $this->loadCsvData();
  52.             
  53.             foreach ($makers as $maker) {
  54.                 $this->addSql(
  55.                     'INSERT INTO dtb_maker (id, name_en, name_jp, create_date, update_date, discriminator_type) 
  56.                     VALUES (?, ?, ?, NOW(), NOW(), \'maker\')',
  57.                     [$maker['id'], $maker['name_en'], $maker['name_jp']]
  58.                 );
  59.             }
  60.         } catch (\Exception $e) {
  61.             $this->write('Migration failed: ' . $e->getMessage());
  62.             throw $e;
  63.         } finally {
  64.             // 外部キー制約を再有効化
  65.             $this->addSql('SET FOREIGN_KEY_CHECKS = 1');
  66.         }
  67.     }
  69.     public function down(Schema $schema): void
  70.     {
  71.         // ロールバック時の処理
  72.         $this->addSql('TRUNCATE TABLE dtb_maker');
  73.     }
  74. }