app/DoctrineMigrations/Version20241213000000.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 Version2024121300000000 extends AbstractMigration
  10. {
  11.     public function getDescription(): string
  12.     {
  13.         return 'Import maker data from CSV';
  14.     }
  16.     private function loadCsvData(): array
  17.     {
  18.         // CSVファイルのパスを指定（src/Migrations/Data/makers.csvなど）
  19.         $csvPath = __DIR__ . '/Data/makers.csv';
  20.         
  21.         if (!file_exists($csvPath)) {
  22.             throw new \RuntimeException('CSV file not found: ' . $csvPath);
  23.         }
  25.         $data = [];
  26.         if (($handle = fopen($csvPath, 'r')) !== false) {
  27.             // ヘッダー行をスキップ
  28.             fgetcsv($handle);
  29.             
  30.             while (($row = fgetcsv($handle)) !== false) {
  31.                 // CSVの列順序に合わせて配列にマッピング
  32.                 $data[] = [
  33.                     'id' => $row[0],
  34.                     'name_en' => $row[1],
  35.                     'name_jp' => $row[2],
  36.                 ];
  37.             }
  38.             fclose($handle);
  39.         }
  40.         
  41.         return $data;
  42.     }
  44.     public function up(Schema $schema): void
  45.     {
  46.         try {
  47.             $makers = $this->loadCsvData();
  48.             
  49.             foreach ($makers as $maker) {
  50.                 $this->addSql(
  51.                     'INSERT INTO dtb_maker (id, name_en, name_jp, create_date, update_date, discriminator_type) 
  52.                     VALUES (?, ?, ?, NOW(), NOW(), \'maker\')',
  53.                     [$maker['id'], $maker['name_en'], $maker['name_jp']]
  54.                 );
  55.             }
  56.         } catch (\Exception $e) {
  57.             $this->write('Migration failed: ' . $e->getMessage());
  58.             throw $e;
  59.         }
  60.     }
  62.     public function down(Schema $schema): void
  63.     {
  64.         // 追加したすべてのメーカーデータを削除
  65.         $this->addSql('DELETE FROM dtb_maker WHERE id IN (SELECT id FROM dtb_maker)');
  66.     }
  67. }