vendor/pimcore/pimcore/bundles/CoreBundle/Migrations/Version20230616085142.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;
  22. use Pimcore\Model\Dao\AbstractDao;
  24. final class Version20230616085142 extends AbstractMigration
  25. {
  26.     private const ID_COLUMN = 'o_id';
  28.     private const PK_COLUMNS = '`' . self::ID_COLUMN .
  29.     '`,`dest_id`, `type`, `fieldname`, `column`, `ownertype`, `ownername`, `position`, `index`';
  31.     private const UNIQUE_KEY_NAME = 'metadata_un';
  33.     private const AUTO_ID = 'auto_id';
  35.     public function getDescription(): string
  36.     {
  37.         return 'Migrate object_metadata schema to have a auto increment column';
  38.     }
  40.     public function up(Schema $schema): void
  41.     {
  42.         $this->addSql('SET foreign_key_checks = 0');
  44.         $metaDataTables = $this->connection->fetchAllAssociative(
  45.             "SHOW FULL TABLES
  46.                    WHERE `Tables_in_{$this->connection->getDatabase()}`
  47.                     LIKE 'object_metadata_%' AND Table_type = 'BASE TABLE'"
  48.         );
  50.         foreach ($metaDataTables as $table) {
  51.             $tableName = current($table);
  52.             $metaDataTable = $schema->getTable($tableName);
  53.             $foreignKeyName = AbstractDao::getForeignKeyName($tableName, self::ID_COLUMN);
  55.             if (!$metaDataTable->hasColumn(self::AUTO_ID)) {
  56.                 if ($recreateForeignKey = $metaDataTable->hasForeignKey($foreignKeyName)) {
  57.                     $this->addSql('ALTER TABLE `' . $tableName . '` DROP FOREIGN KEY `' . $foreignKeyName . '`');
  58.                 }
  60.                 if ($metaDataTable->hasPrimaryKey()) {
  61.                     $this->addSql('ALTER TABLE `' . $tableName . '` DROP PRIMARY KEY');
  62.                 }
  64.                 $this->addSql('ALTER TABLE ' . $tableName . ' ADD `' . self::AUTO_ID .
  65.                     '` int(11) UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY FIRST');
  67.                 if (!$metaDataTable->hasIndex(self::UNIQUE_KEY_NAME)) {
  68.                     $this->addSql(
  69.                         'ALTER TABLE `' . $tableName . '`
  70.                             ADD CONSTRAINT `' . self::UNIQUE_KEY_NAME . '`
  71.                             UNIQUE (' . self::PK_COLUMNS . ')'
  72.                     );
  73.                 }
  75.                 if ($recreateForeignKey) {
  76.                     $this->addSql(
  77.                         'ALTER TABLE `' . $tableName . '`
  78.                             ADD CONSTRAINT `'.$foreignKeyName.'`
  79.                             FOREIGN KEY (`' . self::ID_COLUMN . '`)
  80.                             REFERENCES `objects` (`' . self::ID_COLUMN . '`)
  81.                             ON UPDATE NO ACTION
  82.                             ON DELETE CASCADE;'
  83.                     );
  84.                 }
  85.             }
  86.         }
  88.         $this->addSql('SET foreign_key_checks = 1');
  89.     }
  91.     public function down(Schema $schema): void
  92.     {
  93.         $this->addSql('SET foreign_key_checks = 0');
  95.         $metaDataTables = $this->connection->fetchAllAssociative(
  96.             "SHOW FULL TABLES
  97.                    WHERE `Tables_in_{$this->connection->getDatabase()}`
  98.                     LIKE 'object_metadata_%' AND Table_type = 'BASE TABLE'"
  99.         );
  101.         foreach ($metaDataTables as $table) {
  102.             $tableName = current($table);
  103.             $metaDataTable = $schema->getTable($tableName);
  104.             $foreignKeyName = AbstractDao::getForeignKeyName($tableName, self::ID_COLUMN);
  106.             if ($metaDataTable->hasColumn(self::AUTO_ID)) {
  107.                 if ($recreateForeignKey = $metaDataTable->hasForeignKey($foreignKeyName)) {
  108.                     $this->addSql('ALTER TABLE `' . $tableName . '` DROP FOREIGN KEY `' . $foreignKeyName . '`');
  109.                 }
  111.                 $this->addSql('ALTER TABLE `' . $tableName . '` DROP COLUMN `' . self::AUTO_ID . '`');
  112.                 $this->addSql(
  113.                     'ALTER TABLE `' . $tableName . '` ADD PRIMARY KEY (' . self::PK_COLUMNS  . ')'
  114.                 );
  116.                 if ($metaDataTable->hasIndex(self::UNIQUE_KEY_NAME)) {
  117.                     $this->addSql(
  118.                         'ALTER TABLE `' . $tableName . '` DROP INDEX `' . self::UNIQUE_KEY_NAME . '`'
  119.                     );
  120.                 }
  122.                 if ($recreateForeignKey) {
  123.                     $this->addSql(
  124.                         'ALTER TABLE `' . $tableName . '`
  125.                             ADD CONSTRAINT `'.$foreignKeyName.'`
  126.                             FOREIGN KEY (`' . self::ID_COLUMN . '`)
  127.                             REFERENCES `objects` (`' . self::ID_COLUMN . '`)
  128.                             ON UPDATE RESTRICT
  129.                             ON DELETE CASCADE;'
  130.                     );
  131.                 }
  132.             }
  133.         }
  135.         $this->addSql('SET foreign_key_checks = 1');
  136.     }
  137. }