migrations/Version20260712120000.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use Doctrine\DBAL\Schema\Schema;
  8. use Doctrine\Migrations\AbstractMigration;
  10. final class Version20260712120000 extends AbstractMigration
  11. {
  12.     public function getDescription(): string
  13.     {
  14.         return 'Build performance indexes concurrently without rewriting application data.';
  15.     }
  17.     public function isTransactional(): bool
  18.     {
  19.         // PostgreSQL does not allow CREATE/DROP INDEX CONCURRENTLY inside a
  20.         // transaction. Running each statement separately avoids blocking
  21.         // normal writes for the duration of an index build.
  22.         return false;
  23.     }
  25.     public function up(Schema $schema): void
  26.     {
  27.         $this->abortIf('postgresql' !== $this->connection->getDatabasePlatform()->getName(), 'Migration can only be executed safely on postgresql.');
  29.         // Drop first so a retry also repairs an invalid index left behind by
  30.         // an interrupted CREATE INDEX CONCURRENTLY operation.
  31.         $this->rebuildIndex('IDX_M_DEVICE_FINISHED', 'measurements (device_id, finished_at DESC, id DESC)');
  32.         $this->rebuildIndex('IDX_MS_MEASUREMENT_DELETED', 'measurement_settings (measurement_id, is_deleted)');
  33.         $this->rebuildIndex('IDX_DS_DEVICE_LATEST', 'data_samples (device_id, id DESC)');
  34.         $this->rebuildIndex('IDX_DC_DEVICE_COMMAND', 'device_command (device_id, command)');
  35.         $this->rebuildIndex('IDX_PROBE_CHANNEL_TIME', 'probes (channel_id, time DESC)');
  36.     }
  38.     public function down(Schema $schema): void
  39.     {
  40.         $this->abortIf('postgresql' !== $this->connection->getDatabasePlatform()->getName(), 'Migration can only be executed safely on postgresql.');
  42.         $this->addSql('DROP INDEX CONCURRENTLY IF EXISTS IDX_PROBE_CHANNEL_TIME');
  43.         $this->addSql('DROP INDEX CONCURRENTLY IF EXISTS IDX_DC_DEVICE_COMMAND');
  44.         $this->addSql('DROP INDEX CONCURRENTLY IF EXISTS IDX_DS_DEVICE_LATEST');
  45.         $this->addSql('DROP INDEX CONCURRENTLY IF EXISTS IDX_MS_MEASUREMENT_DELETED');
  46.         $this->addSql('DROP INDEX CONCURRENTLY IF EXISTS IDX_M_DEVICE_FINISHED');
  47.     }
  49.     private function rebuildIndex(string $name, string $definition): void
  50.     {
  51.         $this->addSql(sprintf('DROP INDEX CONCURRENTLY IF EXISTS %s', $name));
  52.         $this->addSql(sprintf('CREATE INDEX CONCURRENTLY %s ON %s', $name, $definition));
  53.     }
  54. }