migrations/Version20220411225956.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 Version20220411225956 extends AbstractMigration
  14. {
  15.     public function getDescription(): string
  16.     {
  17.         return 'TeamInfo';
  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 equipe_information ADD team_id INT NOT NULL, ADD league_id INT NOT NULL');
  25.         // Id Team
  26.         $lastId = 0;
  27.         while (true) {
  28.             $infos = $this->connection->fetchAllAssociative("SELECT idinformation, idequipe_equipe_information, idligue_equipe_information FROM equipe_information WHERE idinformation > {$lastId} LIMIT 1000");
  29.             if (empty($infos)) {
  30.                 break;
  31.             }
  33.             foreach ($infos as $info) {
  34.                 $infoId = $lastId = $info['idinformation'];
  35.                 $teamServiceId = $info['idequipe_equipe_information'];
  36.                 $leagueServiceId = $info['idligue_equipe_information'];
  37.                 $team = $this->connection->fetchAssociative("SELECT idequipe FROM equipe WHERE idequipeservice_equipe = {$teamServiceId}");
  38.                 $league = $this->connection->fetchAssociative("SELECT idligue FROM ligue WHERE idligueservice_ligue = {$leagueServiceId} AND (lang_ligue IS NULL OR lang_ligue = '')");
  39.                 if ($team && $league) {
  40.                     $teamId = $team['idequipe'];
  41.                     $leagueId = $league['idligue'];
  42.                     $this->connection->executeQuery("UPDATE equipe_information SET team_id = {$teamId}, league_id = {$leagueId} WHERE idinformation = {$infoId}");
  43.                 } else {
  44.                     echo "DELETE Info.id {$infoId} : Team.serviceId {$teamServiceId} or League.serviceId {$leagueServiceId} not found\n";
  45.                     $this->connection->executeQuery("DELETE FROM equipe_information WHERE idinformation = {$infoId}");
  46.                 }
  47.             }
  48.         }
  50.         $this->addSql('ALTER TABLE equipe_information ADD CONSTRAINT FK_E3E9E953296CD8AE FOREIGN KEY (team_id) REFERENCES equipe (idequipe)');
  51.         $this->addSql('ALTER TABLE equipe_information ADD CONSTRAINT FK_E3E9E95358AFC4DE FOREIGN KEY (league_id) REFERENCES ligue (idligue)');
  52.         $this->addSql('ALTER TABLE equipe_information ADD CONSTRAINT FK_E3E9E953382FD7AB FOREIGN KEY (idsaison_equipe_information) REFERENCES saison (idsaison)');
  53.         $this->addSql('CREATE INDEX IDX_E3E9E953296CD8AE ON equipe_information (team_id)');
  54.         $this->addSql('CREATE INDEX IDX_E3E9E95358AFC4DE ON equipe_information (league_id)');
  55.     }
  57.     public function down(Schema $schema): void
  58.     {
  59.         // this down() migration is auto-generated, please modify it to your needs
  60.         $this->addSql('ALTER TABLE equipe_information DROP FOREIGN KEY FK_E3E9E953296CD8AE');
  61.         $this->addSql('ALTER TABLE equipe_information DROP FOREIGN KEY FK_E3E9E95358AFC4DE');
  62.         $this->addSql('ALTER TABLE equipe_information DROP FOREIGN KEY FK_E3E9E953382FD7AB');
  63.         $this->addSql('DROP INDEX IDX_E3E9E953296CD8AE ON equipe_information');
  64.         $this->addSql('DROP INDEX IDX_E3E9E95358AFC4DE ON equipe_information');
  65.         $this->addSql('ALTER TABLE equipe_information DROP team_id, DROP league_id');
  66.     }
  67. }