migrations/Version20230220121817.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use Doctrine\DBAL\Exception;
  8. use Doctrine\DBAL\Schema\Schema;
  9. use Doctrine\Migrations\AbstractMigration;
  11. final class Version20230220121817 extends AbstractMigration
  12. {
  13.     public function up(Schema $schema): void
  14.     {
  15.         $this->addSql('CREATE TABLE service_campaign_message (id INT AUTO_INCREMENT NOT NULL, message_id INT NOT NULL, service_campaign_id INT NOT NULL, created_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', updated_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', deleted_at DATETIME DEFAULT NULL COMMENT \'(DC2Type:datetime_immutable)\', UNIQUE INDEX UNIQ_B9428B42537A1329 (message_id), INDEX IDX_B9428B423AA3D1D8 (service_campaign_id), PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
  16.         $this->addSql('ALTER TABLE service_campaign_message ADD CONSTRAINT FK_B9428B42537A1329 FOREIGN KEY (message_id) REFERENCES message (id)');
  17.         $this->addSql('ALTER TABLE service_campaign_message ADD CONSTRAINT FK_B9428B423AA3D1D8 FOREIGN KEY (service_campaign_id) REFERENCES service_campaign (id)');
  19.         $serviceCampaigns = $this->getData('SELECT id, message_id FROM service_campaign');
  21.         foreach ($serviceCampaigns as $serviceCampaign) {
  22.             $now = new \DateTimeImmutable();
  23.             $this->addSql('INSERT INTO service_campaign_message (message_id, service_campaign_id, created_at, updated_at) VALUES (?,?,?,?)', [
  24.                 $serviceCampaign['message_id'],
  25.                 $serviceCampaign['id'],
  26.                 $now->format('Y-m-d H:i:s'),
  27.                 $now->format('Y-m-d H:i:s'),
  28.             ]);
  29.         }
  31.         $this->addSql('ALTER TABLE service_campaign DROP FOREIGN KEY FK_B176F1DD537A1329');
  32.         $this->addSql('ALTER TABLE service_campaign DROP message_id');
  33.     }
  35.     public function down(Schema $schema): void
  36.     {
  37.         $serviceCampaignMessages = $this->getData('SELECT message_id, service_campaign_id FROM service_campaign_message');
  39.         $this->addSql('ALTER TABLE service_campaign_message DROP FOREIGN KEY FK_B9428B42537A1329');
  40.         $this->addSql('ALTER TABLE service_campaign_message DROP FOREIGN KEY FK_B9428B423AA3D1D8');
  41.         $this->addSql('DROP TABLE service_campaign_message');
  42.         $this->addSql('ALTER TABLE service_campaign ADD message_id INT NOT NULL');
  45.         foreach ($serviceCampaignMessages as $serviceCampaignMessage) {
  46.             $this->addSql(
  47.                 'UPDATE service_campaign SET message_id = :messageId WHERE id = :serviceCampaignId',
  48.                 [
  49.                     'messageId' => $serviceCampaignMessage['message_id'],
  50.                     'serviceCampaignId' => $serviceCampaignMessage['service_campaign_id'],
  51.                 ]
  52.             );
  53.         }
  54.     }
  56.     /**
  57.      * @throws Exception
  58.      */
  59.     private function getData(string $sql): \Traversable
  60.     {
  61.         return $this->connection->executeQuery($sql)->iterateAssociative();
  62.     }
  63. }