vendor/pimcore/data-importer/src/Migrations/Version20220304130000.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. /**
  17.  * Pimcore
  18.  *
  19.  * This source file is available under two different licenses:
  20.  * - GNU General Public License version 3 (GPLv3)
  21.  * - Pimcore Commercial License (PCL)
  22.  * Full copyright and license information is available in
  23.  * LICENSE.md which is distributed with this source code.
  24.  *
  25.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  26.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  27.  */
  29. namespace Pimcore\Bundle\DataImporterBundle\Migrations;
  31. use Doctrine\DBAL\Schema\Schema;
  32. use Pimcore\Bundle\DataImporterBundle\Queue\QueueService;
  33. use Pimcore\Migrations\BundleAwareMigration;
  35. class Version20220304130000 extends BundleAwareMigration
  36. {
  37.     public function up(Schema $schema): void
  38.     {
  39.         if ($schema->hasTable(QueueService::QUEUE_TABLE_NAME)) {
  40.             $queueTable = $schema->getTable(QueueService::QUEUE_TABLE_NAME);
  41.             $queueTable->addColumn('dispatched', 'bigint', ['notnull' => false, 'default' => null]);
  42.             $queueTable->addColumn('workerId', 'string', ['notnull' => false, 'default' => null, 'length' => 13]);
  43.             $queueTable->addIndex(['executionType', 'workerId'], 'bundle_index_queue_executiontype_workerId');
  44.         }
  45.     }
  47.     public function down(Schema $schema): void
  48.     {
  49.         if ($schema->hasTable(QueueService::QUEUE_TABLE_NAME)) {
  50.             $queueTable = $schema->getTable(QueueService::QUEUE_TABLE_NAME);
  51.             $queueTable->dropColumn('dispatched');
  52.             $queueTable->dropColumn('workerId');
  53.             $queueTable->dropIndex('bundle_index_queue_executiontype_workerId');
  54.         }
  55.     }
  57.     protected function getBundleName(): string
  58.     {
  59.         return 'PimcoreDataImporterBundle';
  60.     }
  61. }