app/DoctrineMigrations/Version20251022000000.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use Doctrine\DBAL\Schema\Schema;
  8. use Doctrine\Migrations\AbstractMigration;
  10. /**
  11.  * データ移行履歴テーブルの作成
  12.  * dtb_data_migrationテーブルを追加
  13.  */
  14. final class Version20251022000000 extends AbstractMigration
  15. {
  16.     public function getDescription(): string
  17.     {
  18.         return 'データ移行履歴を記録するdtb_data_migrationテーブルを作成';
  19.     }
  21.     public function up(Schema $schema): void
  22.     {
  23.         // dtb_data_migrationテーブルが存在するかチェック
  24.         $schemaManager = $this->connection->createSchemaManager();
  25.         $tables = $schemaManager->listTableNames();
  26.         
  27.         if (!in_array('dtb_data_migration', $tables)) {
  28.             $this->addSql('
  29.                 CREATE TABLE dtb_data_migration (
  30.                     id INT UNSIGNED AUTO_INCREMENT NOT NULL,
  31.                     update_type SMALLINT UNSIGNED NOT NULL,
  32.                     update_date DATETIME NOT NULL,
  33.                     discriminator_type VARCHAR(255) DEFAULT NULL,
  34.                     PRIMARY KEY(id)
  35.                 ) DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci ENGINE = InnoDB
  36.             ');
  37.         } else {
  38.             // テーブルが存在する場合、discriminator_typeカラムを追加
  39.             $columns = $schemaManager->listTableColumns('dtb_data_migration');
  40.             $hasDiscriminator = false;
  41.             foreach ($columns as $column) {
  42.                 if ($column->getName() === 'discriminator_type') {
  43.                     $hasDiscriminator = true;
  44.                     break;
  45.                 }
  46.             }
  47.             if (!$hasDiscriminator) {
  48.                 $this->addSql('ALTER TABLE dtb_data_migration ADD discriminator_type VARCHAR(255) DEFAULT NULL');
  49.             }
  50.         }
  51.     }
  53.     public function down(Schema $schema): void
  54.     {
  55.         // rollback処理 - テーブルが存在する場合のみ削除
  56.         $schemaManager = $this->connection->createSchemaManager();
  57.         $tables = $schemaManager->listTableNames();
  58.         
  59.         if (in_array('dtb_data_migration', $tables)) {
  60.             $this->addSql('DROP TABLE dtb_data_migration');
  61.         }
  62.     }
  63. }