migrations/Version20220404175436.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use App\Domain\Core\Entity\Player;
  8. use Doctrine\DBAL\Schema\Schema;
  9. use Doctrine\Migrations\AbstractMigration;
  11. /**
  12.  * Auto-generated Migration: Please modify to your needs!
  13.  */
  14. final class Version20220404175436 extends AbstractMigration
  15. {
  16.     public function getDescription(): string
  17.     {
  18.         return 'Fill Player.positions from LiaisonJoueurPosition';
  19.     }
  21.     public function up(Schema $schema): void
  22.     {
  23.         // this up() migration is auto-generated, please modify it to your needs
  24.         $lastId = 0;
  25.         while (true) {
  26.             $positions = $this->connection->fetchAllAssociative("SELECT * FROM liaison_joueur_position WHERE idliaison > {$lastId} ORDER BY idliaison ASC LIMIT 100");
  27.             if (empty($positions)) {
  28.                 break;
  29.             }
  31.             $playersIds = array_column($positions, 'idjoueur');
  32.             $players = $this->connection->fetchAllAssociative('SELECT idjoueurservice_joueur, positions FROM joueur WHERE idjoueurservice_joueur in (' . implode(',', $playersIds) . ')');
  33.             $playersByPlayerId = array_combine(array_column($players, 'idjoueurservice_joueur'), $players);
  35.             $updateStmt = '';
  36.             foreach ($positions as $position) {
  37.                 $lastId = (int) $position['idliaison'];
  38.                 $playerId = $position['idjoueur'];
  39.                 $positionId = (int) $position['idposition'];
  40.                 if (!($player = $playersByPlayerId[$playerId] ?? null)) {
  41.                     continue;
  42.                 }
  43.                 $positions = json_decode($player['positions'], true);
  44.                 $newPosition = match ($positionId) {
  45.                     1 => Player::POSITION_POINT_GUARD,
  46.                     2 => Player::POSITION_SHOOTING_GUARD,
  47.                     4 => Player::POSITION_SMALL_FORWARD,
  48.                     8 => Player::POSITION_POWER_FORWARD,
  49.                     16 => Player::POSITION_CENTER,
  50.                     default => null,
  51.                 };
  52.                 if (!$newPosition) {
  53.                     throw new \Exception(sprintf('Error : Player # %s | Position # %s', $playerId, $positionId));
  54.                 }
  55.                 $positions[] = $newPosition;
  56.                 $positions = array_unique($positions);
  57.                 $positionsJson = json_encode($positions);
  58.                 $updateStmt .= "UPDATE joueur SET positions = '{$positionsJson}' WHERE idjoueurservice_joueur = {$playerId};";
  59.             }
  61.             if ($updateStmt) {
  62.                 $this->connection->executeQuery($updateStmt);
  63.             }
  64.         }
  65.     }
  67.     public function down(Schema $schema): void
  68.     {
  69.         // this down() migration is auto-generated, please modify it to your needs
  70.         $this->addSql("UPDATE joueur SET positions = '[]'");
  71.     }
  72. }