migrations/Version20220413125627.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 Version20220413125627 extends AbstractMigration
  14. {
  15.     public function getDescription(): string
  16.     {
  17.         return 'TeamAka';
  18.     }
  20.     public function up(Schema $schema): void
  21.     {
  22.         // this up() migration is auto-generated, please modify it to your needs
  23.         $this->connection->executeQuery('ALTER TABLE aka ADD team_id INT DEFAULT NULL');
  25.         $lastId = 0;
  26.         while (true) {
  27.             $akas = $this->connection->fetchAllAssociative("SELECT idaka, idelement_aka FROM aka WHERE typeelement_aka = 2 AND idaka > {$lastId} LIMIT 1000");
  28.             if (empty($akas)) {
  29.                 break;
  30.             }
  32.             foreach ($akas as $aka) {
  33.                 $akaId = $lastId = $aka['idaka'];
  34.                 $akaElementId = $aka['idelement_aka'];
  36.                 $teamId = $this->connection->fetchOne("SELECT idequipe FROM equipe WHERE idequipeservice_equipe = {$akaElementId}");
  37.                 if (!$teamId) {
  38.                     continue;
  39.                 }
  41.                 $this->connection->executeQuery("UPDATE aka SET team_id = {$teamId} WHERE idaka = {$akaId}");
  42.             }
  43.         }
  45.         $this->addSql('ALTER TABLE aka ADD CONSTRAINT FK_AE89BA7296CD8AE FOREIGN KEY (team_id) REFERENCES equipe (idequipe)');
  46.         $this->addSql('CREATE INDEX IDX_AE89BA7296CD8AE ON aka (team_id)');
  47.     }
  49.     public function down(Schema $schema): void
  50.     {
  51.         // this down() migration is auto-generated, please modify it to your needs
  52.         $this->addSql('ALTER TABLE aka DROP FOREIGN KEY FK_AE89BA7296CD8AE');
  53.         $this->addSql('DROP INDEX IDX_AE89BA7296CD8AE ON aka');
  54.         $this->addSql('ALTER TABLE aka DROP team_id');
  55.     }
  56. }