app/DoctrineMigrations/Version20230928014611.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.  * Auto-generated Migration: Please modify to your needs!
  12.  */
  13. final class Version20230928014611 extends AbstractMigration
  14. {
  15.     public function getDescription(): string
  16.     {
  17.         return '';
  18.     }
  20.     public function up(Schema $schema): void
  21.     {
  22.         // 重複した在庫がdtb_product_stockにあるのか確認する。
  23.         $exists = $this->connection->fetchAllKeyValue(" 
  24. SELECT product_class_id, product_class_id_count
  25. FROM (
  26.          SELECT
  27.              product_class_id,
  28.              COUNT(product_class_id) AS product_class_id_count
  29.          FROM
  30.              dtb_product_stock
  31.          GROUP BY
  32.              product_class_id
  33.      ) AS subquery
  34. WHERE product_class_id_count > 1;
  35. ");
  37.         // 重複在庫がある場合、dtb_product_class.stockを正として、それ以外の在庫情報は削除する
  38.         if (count($exists) != 0) {
  39.             foreach ($exists as $pc_id => $value) {
  40.                 $stock = $this->connection->fetchOne("SELECT stock FROM dtb_product_class WHERE id = :id", ["id" => $pc_id]);
  41.                 $this->addSql("DELETE FROM dtb_product_stock WHERE product_class_id = :pc_id", ["pc_id" => $pc_id]);
  42.                 $this->addSql("INSERT INTO dtb_product_stock (product_class_id, creator_id, stock, create_date, update_date, discriminator_type) VALUES (:pc_id, NULL, :stock, CURRENT_TIMESTAMP, CURRENT_TIMESTAMP, 'productstock')", ["pc_id" => $pc_id, "stock" => $stock]);
  43.             }
  44.         }
  45.     }
  47.     public function down(Schema $schema): void
  48.     {
  49.     }
  50. }