Freeze migrations before executing sql

lib/Doctrine/Migrations/AbstractMigration.php

@@ -10,6 +10,7 @@
 use Doctrine\DBAL\Schema\AbstractSchemaManager;
 use Doctrine\DBAL\Schema\Schema;
 use Doctrine\Migrations\Exception\AbortMigration;
+use Doctrine\Migrations\Exception\FrozenMigration;
 use Doctrine\Migrations\Exception\IrreversibleMigration;
 use Doctrine\Migrations\Exception\MigrationException;
 use Doctrine\Migrations\Exception\SkipMigration;
@@ -36,6 +37,8 @@ abstract class AbstractMigration
     /** @var Query[] */
     private array $plannedSql = [];
 
+    private bool $frozen = false;
+
     public function __construct(Connection $connection, private readonly LoggerInterface $logger)
     {
         $this->connection = $connection;
@@ -125,6 +128,11 @@ protected function addSql(
         array $params = [],
         array $types = [],
     ): void {
+        if ($this->frozen) {
+            throw FrozenMigration::new();
+        }
+
+
         $this->plannedSql[] = new Query($sql, $params, $types);
     }
 
@@ -134,6 +142,11 @@ public function getSql(): array
         return $this->plannedSql;
     }
 
+    public function freeze(): void
+    {
+        $this->frozen = true;
+    }
+
     protected function write(string $message): void
     {
         $this->logger->notice($message, ['migration' => $this]);

lib/Doctrine/Migrations/Exception/FrozenMigration.php

@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Doctrine\Migrations\Exception;
+
+use LogicException;
+
+final class FrozenMigration extends LogicException implements MigrationException
+{
+    public static function new(): self
+    {
+        return new self('The migration is frozen and cannot be edited anymore.');
+    }
+}

lib/Doctrine/Migrations/Version/DbalExecutor.php

@@ -145,6 +145,8 @@ private function executeMigration(
             $this->addSql(new Query($sql));
         }
 
+        $migration->freeze();
+
         if (count($this->sql) !== 0) {
             if (! $configuration->isDryRun()) {
                 $this->executeResult($configuration);