migrations/Version20230302154818.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use App\Entity\Role;
  8. use Doctrine\DBAL\Exception;
  9. use Doctrine\DBAL\Schema\Schema;
  10. use Doctrine\Migrations\AbstractMigration;
  12. /**
  13.  * Auto-generated Migration: Please modify to your needs!
  14.  */
  15. final class Version20230302154818 extends AbstractMigration {
  16.     public function getDescription(): string {
  17.         return '';
  18.     }
  20.     public function up(Schema $schema): void {
  21.         $this->addRoleDiplome();
  22.         $this->addRoleEntreprise();
  23.         $this->addRoleEtablissement();
  24.     }
  26.     /**
  27.      * @throws Exception
  28.      */
  29.     private function addRoleEntreprise(): void {
  30.         $roleId = $this->connection->executeQuery(
  31.             'SELECT r.id as id
  32.                 FROM role r
  33.                 WHERE r.role = ?',
  34.             [Role::ROLE_ENTREPRISE])
  35.             ->fetchOne();
  37.         if (!$roleId) {
  38.             $addRole = $this->connection->prepare(
  39.                 'INSERT INTO role (role) VALUES (:roleName)'
  40.             );
  41.             $addRole->bindValue('roleName', Role::ROLE_ENTREPRISE);
  42.             $addRole->executeStatement();
  44.             $roleId = $this->connection->lastInsertId();
  45.         }
  47.         // Add ROLE_DIPLOME to person_degree not having this role
  48.         $user_ids = $this->connection->executeQuery(
  49.             'SELECT u.id as id
  50.                 FROM company p, user u
  51.                 WHERE p.user_id = u.id'
  52.         )->fetchAllAssociative();
  54.         foreach ($user_ids as $user_id) {
  55.             $this->addSql('INSERT INTO user_role (user_id, role_id)
  56.                     SELECT ?, ?
  57.                     WHERE NOT EXISTS (
  58.                         SELECT 1 FROM user_role ur
  59.                         WHERE ur.user_id = ? AND ur.role_id = ?
  60.                     )', [$user_id['id'], $roleId, $user_id['id'], $roleId]);
  62.         }
  63.     }
  65.     /**
  66.      * @throws Exception
  67.      */
  68.     private function addRoleEtablissement(): void {
  69.         /// Add ROLE_ETABLISSEMENT if not exist and get ID
  70.         $roleId = $this->connection->executeQuery(
  71.             'SELECT r.id as id
  72.                 FROM role r
  73.                 WHERE r.role = ?',
  74.             [Role::ROLE_ETABLISSEMENT])
  75.             ->fetchOne();
  77.         if (!$roleId) {
  78.             $addRole = $this->connection->prepare(
  79.                 'INSERT INTO role (role) VALUES (:roleName)'
  80.             );
  81.             $addRole->bindValue('roleName', Role::ROLE_ETABLISSEMENT);
  82.             $addRole->executeStatement();
  84.             $roleId = $this->connection->lastInsertId();
  85.         }
  87.         // Add ROLE_ETABLISSEMENT to person_degree not having this role
  88.         $user_ids = $this->connection->executeQuery(
  89.             'SELECT u.id as id
  90.                 FROM school p, user u
  91.                 WHERE p.user_id = u.id'
  92.         )->fetchAllAssociative();
  94.         foreach ($user_ids as $user_id) {
  95.             $this->addSql('INSERT INTO user_role (user_id, role_id)
  96.                     SELECT ?, ?
  97.                     WHERE NOT EXISTS (
  98.                         SELECT 1 FROM user_role ur
  99.                         WHERE ur.user_id = ? AND ur.role_id = ?
  100.                     )', [$user_id['id'], $roleId, $user_id['id'], $roleId]);
  102.         }
  103.     }
  105.     private function addRoleDiplome(): void {
  106.         /// Add ROLE_DIPLOME if not exist and get ID
  107.         $roleId = $this->connection->executeQuery(
  108.             'SELECT r.id as id
  109.                 FROM role r
  110.                 WHERE r.role = ?',
  111.             [Role::ROLE_DIPLOME])
  112.             ->fetchOne();
  114.         if (!$roleId) {
  115.             $addRole = $this->connection->prepare(
  116.                 'INSERT INTO role (role) VALUES (:roleName)'
  117.             );
  118.             $addRole->bindValue('roleName', Role::ROLE_DIPLOME);
  119.             $addRole->executeStatement();
  121.             $roleId = $this->connection->lastInsertId();
  122.         }
  124.         // Add ROLE_DIPLOME to person_degree not having this role
  125.         $user_ids = $this->connection->executeQuery(
  126.             'SELECT u.id as id
  127.                 FROM person_degree p, user u
  128.                 WHERE p.user_id = u.id'
  129.         )->fetchAllAssociative();
  131.         foreach ($user_ids as $user_id) {
  132.             $this->addSql('INSERT INTO user_role (user_id, role_id)
  133.                     SELECT ?, ?
  134.                     WHERE NOT EXISTS (
  135.                         SELECT 1 FROM user_role ur
  136.                         WHERE ur.user_id = ? AND ur.role_id = ?
  137.                     )', [$user_id['id'], $roleId, $user_id['id'], $roleId]);
  139.         }
  140.     }
  142.     public function down(Schema $schema): void {
  143.     }
  144. }