migrations/Version20220411103436.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 Version20220411103436 extends AbstractMigration
  14. {
  15.     public function getDescription(): string
  16.     {
  17.         return 'Aka';
  18.     }
  20.     public function up(Schema $schema): void
  21.     {
  22.         // this up() migration is auto-generated, please modify it to your needs
  24.         $totalPlayerRemoved = $totalTeamRemoved = $totalRemoved = 0;
  26.         $lastId = 0;
  27.         while (true) {
  28.             $akas = $this->connection->fetchAllAssociative("SELECT idaka, idelement_aka, typeelement_aka, aka_aka FROM aka WHERE idaka > {$lastId} LIMIT 1000");
  29.             if (empty($akas)) {
  30.                 break;
  31.             }
  33.             foreach ($akas as $aka) {
  34.                 $akaId = $lastId = $aka['idaka'];
  35.                 $akaElementType = $aka['typeelement_aka'];
  36.                 $akaElementId = $aka['idelement_aka'];
  37.                 $akaName = $aka['aka_aka'];
  38.                 $akaIdToDelete = null;
  40.                 if (null === $akaElementType) {
  41.                     echo "DELETE Aka {$akaId} : {$akaName} : pas de relation\n";
  42.                     $akaIdToDelete = $akaId;
  43.                 } elseif ('1' == $akaElementType) {
  44.                     $player = $this->connection->fetchAssociative("SELECT idjoueur FROM joueur WHERE idjoueurservice_joueur = {$akaElementId}");
  45.                     if (!$player) {
  46.                         echo "DELETE Aka {$akaId} : {$akaName} : Player.idjoueurservice_joueur {$akaElementId} not found\n";
  47.                         $akaIdToDelete = $akaId;
  48.                         ++$totalPlayerRemoved;
  49.                     }
  50.                 } elseif ('2' == $akaElementType) {
  51.                     $team = $this->connection->fetchAssociative("SELECT idequipe FROM equipe WHERE idequipeservice_equipe = {$akaElementId}");
  52.                     if (!$team) {
  53.                         echo "DELETE Aka {$akaId} : {$akaName} : Team.idequipeservice_equipe {$akaElementId} not found\n";
  54.                         $akaIdToDelete = $akaId;
  55.                         ++$totalTeamRemoved;
  56.                     }
  57.                 } else {
  58.                     echo "ERROR : Aka {$akaId} : {$akaName}";
  59.                 }
  61.                 if ($akaIdToDelete) {
  62.                     ++$totalRemoved;
  63.                     $this->connection->executeQuery("DELETE FROM aka WHERE idaka = {$akaIdToDelete}");
  64.                 }
  65.             }
  66.         }
  68.         echo "END | Players removed : {$totalPlayerRemoved} | Teams removed : {$totalTeamRemoved} | Total removed : {$totalRemoved}\n";
  70.         $this->addSql('ALTER TABLE aka CHANGE typeelement_aka typeelement_aka VARCHAR(2) NOT NULL');
  71.     }
  73.     public function down(Schema $schema): void
  74.     {
  75.         // this down() migration is auto-generated, please modify it to your needs
  76.         $this->addSql('ALTER TABLE aka CHANGE typeelement_aka typeelement_aka VARCHAR(2) DEFAULT NULL');
  77.     }
  78. }