vendor/pimcore/pimcore/bundles/CoreBundle/Migrations/Version20221222181745.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /**
  6.  * Pimcore
  7.  *
  8.  * This source file is available under two different licenses:
  9.  * - GNU General Public License version 3 (GPLv3)
  10.  * - Pimcore Commercial License (PCL)
  11.  * Full copyright and license information is available in
  12.  * LICENSE.md which is distributed with this source code.
  13.  *
  14.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  15.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  16.  */
  18. namespace Pimcore\Bundle\CoreBundle\Migrations;
  20. use Doctrine\DBAL\Schema\Schema;
  21. use Doctrine\Migrations\AbstractMigration;
  23. final class Version20221222181745 extends AbstractMigration
  24. {
  25.     public function getDescription(): string
  26.     {
  27.         return 'Add CONSTRAINT of classificationstore_groups in object_classificationstore_groups';
  28.     }
  30.     public function up(Schema $schema): void
  31.     {
  32.         $tableList = $this->connection->fetchAllAssociative("show tables like 'object_classificationstore_groups_%'");
  33.         foreach ($tableList as $tableGroups) {
  34.             $theTableGroups = current($tableGroups);
  35.             $tableArray = explode('_', $theTableGroups);
  36.             $tableNumber = end($tableArray);
  37.             if (!is_numeric($tableNumber)) {
  38.                 continue;
  39.             }
  41.             $this->addSql("DELETE `object_classificationstore_groups_{$tableNumber}`
  42.             FROM `object_classificationstore_groups_{$tableNumber}`
  43.             LEFT JOIN `classificationstore_groups` ON object_classificationstore_groups_{$tableNumber}.groupId = classificationstore_groups.id
  44.             WHERE classificationstore_groups.id IS NULL;");
  46.             $this->addSql("DELETE `object_classificationstore_data_{$tableNumber}`
  47.             FROM `object_classificationstore_data_{$tableNumber}`
  48.             LEFT JOIN `$theTableGroups` ON object_classificationstore_data_{$tableNumber}.o_id = $theTableGroups.o_id AND
  49.             object_classificationstore_data_{$tableNumber}.fieldname = $theTableGroups.fieldname AND
  50.             object_classificationstore_data_{$tableNumber}.groupId = $theTableGroups.groupId
  51.             WHERE $theTableGroups.o_id IS NULL AND  $theTableGroups.fieldname IS NULL AND $theTableGroups.groupId IS NULL;");
  53.             $this->addSql("ALTER TABLE `$theTableGroups` MODIFY COLUMN groupId INT(11) UNSIGNED NOT NULL;");
  54.             $this->addSql("ALTER TABLE `$theTableGroups`
  55.             ADD CONSTRAINT `fk_object_classificationstore_groups_{$tableNumber}__groupId` FOREIGN KEY (`groupId`)
  56.             REFERENCES `classificationstore_groups` (`id`)
  57.             ON DELETE CASCADE;");
  59.             $theTableData = "object_classificationstore_data_$tableNumber";
  60.             $this->addSql("ALTER TABLE `$theTableData` MODIFY COLUMN groupId INT(11) UNSIGNED NOT NULL;");
  61.             $this->addSql("CREATE INDEX `groupKeys` ON `$theTableData` (`o_id`, `fieldname`, `groupId`);");
  62.             $this->addSql("ALTER TABLE `$theTableData`
  63.             ADD CONSTRAINT `fk_object_classificationstore_data_{$tableNumber}__o_id__fieldname__groupId` FOREIGN KEY (`o_id`, `fieldname`, `groupId`)
  64.             REFERENCES `$theTableGroups` (`o_id`, `fieldname`, `groupId`)
  65.             ON DELETE CASCADE;");
  66.         }
  67.     }
  69.     public function down(Schema $schema): void
  70.     {
  71.         $tableList = $this->connection->fetchAllAssociative("show tables like 'object_classificationstore_groups_%'");
  72.         foreach ($tableList as $theTableGroups) {
  73.             $theTableGroups = current($theTableGroups);
  74.             $tableArray = explode('_', $theTableGroups);
  75.             $tableNumber = end($tableArray);
  76.             if (!is_numeric($tableNumber)) {
  77.                 continue;
  78.             }
  80.             $this->addSql("ALTER TABLE `$theTableGroups` DROP FOREIGN KEY `fk_object_classificationstore_groups_{$tableNumber}__groupId`;");
  82.             $theTableData = "object_classificationstore_data_$tableNumber";
  83.             $this->addSql("ALTER TABLE `$theTableData` DROP FOREIGN KEY `fk_object_classificationstore_data_{$tableNumber}__o_id__fieldname__groupId`;");
  84.             $this->addSql("ALTER TABLE `$theTableData` DROP INDEX `groupKeys`;");
  86.             $this->addSql("ALTER TABLE `$theTableData` MODIFY COLUMN groupId BIGINT(20) NOT NULL;");
  87.             $this->addSql("ALTER TABLE `$theTableGroups` MODIFY COLUMN groupId BIGINT(20) NOT NULL;");
  88.         }
  89.     }
  90. }