app/DoctrineMigrations/Version20251121120000.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.  */
  13. final class Version20251121120000 extends AbstractMigration
  14. {
  15.     public function getDescription(): string
  16.     {
  17.         return '商品テーブル(dtb_product)に購入点数制限(purchase_limit)カラムを追加';
  18.     }
  20.     public function up(Schema $schema): void
  21.     {
  22.         // MySQL
  23.         if ($this->connection->getDatabasePlatform()->getName() === 'mysql') {
  24.             // テーブルが存在するか確認
  25.             $tableExists = $this->connection->fetchOne("
  26.                 SELECT COUNT(*) 
  27.                 FROM information_schema.TABLES 
  28.                 WHERE TABLE_SCHEMA = DATABASE() 
  29.                 AND TABLE_NAME = 'dtb_product'
  30.             ");
  31.             
  32.             if ($tableExists) {
  33.                 // カラムが存在しない場合のみ追加
  34.                 $columnExists = $this->connection->fetchOne("
  35.                     SELECT COUNT(*) 
  36.                     FROM information_schema.COLUMNS 
  37.                     WHERE TABLE_SCHEMA = DATABASE() 
  38.                     AND TABLE_NAME = 'dtb_product' 
  39.                     AND COLUMN_NAME = 'purchase_limit'
  40.                 ");
  41.                 
  42.                 if (!$columnExists) {
  43.                     $this->addSql('ALTER TABLE dtb_product ADD purchase_limit INT UNSIGNED DEFAULT NULL COMMENT \'購入点数制限（NULL or 0 = 制限なし）\'');
  44.                 }
  45.             }
  46.         }
  47.         // PostgreSQL
  48.         else if ($this->connection->getDatabasePlatform()->getName() === 'postgresql') {
  49.             // テーブルが存在するか確認
  50.             $tableExists = $this->connection->fetchOne("
  51.                 SELECT COUNT(*) 
  52.                 FROM information_schema.tables 
  53.                 WHERE table_schema = 'public' 
  54.                 AND table_name = 'dtb_product'
  55.             ");
  56.             
  57.             if ($tableExists) {
  58.                 // カラムが存在しない場合のみ追加
  59.                 $columnExists = $this->connection->fetchOne("
  60.                     SELECT COUNT(*) 
  61.                     FROM information_schema.columns 
  62.                     WHERE table_schema = 'public' 
  63.                     AND table_name = 'dtb_product' 
  64.                     AND column_name = 'purchase_limit'
  65.                 ");
  66.                 
  67.                 if (!$columnExists) {
  68.                     $this->addSql('ALTER TABLE dtb_product ADD purchase_limit INT DEFAULT NULL');
  69.                     $this->addSql('COMMENT ON COLUMN dtb_product.purchase_limit IS \'購入点数制限（NULL or 0 = 制限なし）\'');
  70.                 }
  71.             }
  72.         }
  73.     }
  75.     public function down(Schema $schema): void
  76.     {
  77.         // MySQL
  78.         if ($this->connection->getDatabasePlatform()->getName() === 'mysql') {
  79.             $columnExists = $this->connection->fetchOne("
  80.                 SELECT COUNT(*) 
  81.                 FROM information_schema.COLUMNS 
  82.                 WHERE TABLE_SCHEMA = DATABASE() 
  83.                 AND TABLE_NAME = 'dtb_product' 
  84.                 AND COLUMN_NAME = 'purchase_limit'
  85.             ");
  86.             
  87.             if ($columnExists) {
  88.                 $this->addSql('ALTER TABLE dtb_product DROP COLUMN purchase_limit');
  89.             }
  90.         }
  91.         // PostgreSQL
  92.         else if ($this->connection->getDatabasePlatform()->getName() === 'postgresql') {
  93.             $columnExists = $this->connection->fetchOne("
  94.                 SELECT COUNT(*) 
  95.                 FROM information_schema.columns 
  96.                 WHERE table_schema = 'public' 
  97.                 AND table_name = 'dtb_product' 
  98.                 AND column_name = 'purchase_limit'
  99.             ");
  100.             
  101.             if ($columnExists) {
  102.                 $this->addSql('ALTER TABLE dtb_product DROP COLUMN purchase_limit');
  103.             }
  104.         }
  105.     }
  106. }