vendor/pimcore/data-importer/src/Migrations/Version20211110174732.php line 1

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Commercial License (PCL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  14.  */
  16. namespace Pimcore\Bundle\DataImporterBundle\Migrations;
  18. use Doctrine\DBAL\Schema\Schema;
  19. use Pimcore\Migrations\BundleAwareMigration;
  21. class Version20211110174732 extends BundleAwareMigration
  22. {
  23.     protected const DELTA_CACHE_TABLE = 'bundle_data_hub_data_importer_delta_cache';
  24.     protected const LAST_CRON_TABLE = 'bundle_data_hub_data_importer_last_cron_execution';
  25.     protected const IMPORTER_QUEUE_TABLE = 'bundle_data_hub_data_importer_queue';
  27.     protected function getBundleName(): string
  28.     {
  29.         return 'PimcoreDataImporterBundle';
  30.     }
  32.     /**
  33.      * @param Schema $schema
  34.      */
  35.     public function up(Schema $schema): void
  36.     {
  37.         if ($schema->hasTable(self::DELTA_CACHE_TABLE)) {
  38.             $this->addSql(sprintf('ALTER TABLE `%s` MODIFY `configName` VARCHAR(80)', self::DELTA_CACHE_TABLE));
  39.         }
  41.         if ($schema->hasTable(self::LAST_CRON_TABLE)) {
  42.             $this->addSql(sprintf('ALTER TABLE `%s` MODIFY `configName` VARCHAR(80)', self::LAST_CRON_TABLE));
  43.         }
  45.         if ($schema->hasTable(self::IMPORTER_QUEUE_TABLE)) {
  46.             $this->addSql(sprintf('ALTER TABLE `%s` MODIFY `configName` VARCHAR(80)', self::IMPORTER_QUEUE_TABLE));
  47.         }
  48.     }
  50.     /**
  51.      * @param Schema $schema
  52.      */
  53.     public function down(Schema $schema): void
  54.     {
  55.         if ($schema->hasTable(self::DELTA_CACHE_TABLE)) {
  56.             $this->addSql(sprintf('ALTER TABLE `%s` MODIFY `configName` VARCHAR(50)', self::DELTA_CACHE_TABLE));
  57.         }
  59.         if ($schema->hasTable(self::LAST_CRON_TABLE)) {
  60.             $this->addSql(sprintf('ALTER TABLE `%s` MODIFY `configName` VARCHAR(50)', self::LAST_CRON_TABLE));
  61.         }
  63.         if ($schema->hasTable(self::IMPORTER_QUEUE_TABLE)) {
  64.             $this->addSql(sprintf('ALTER TABLE `%s` MODIFY `configName` VARCHAR(50)', self::IMPORTER_QUEUE_TABLE));
  65.         }
  66.     }
  67. }