Don't break transactions across batches

Author: AndriySvyryd

src/EFCore.Relational/Migrations/HistoryRepository.cs

@@ -233,7 +233,7 @@ private IReadOnlyList<MigrationCommand> GetCreateIfNotExistsCommands()
     ///     Gets an exclusive lock on the database.
     /// </summary>
     /// <param name="cancellationToken">A <see cref="CancellationToken" /> to observe while waiting for the task to complete.</param>
-    /// 
+    ///
     /// <returns>An object that can be disposed to release the lock.</returns>
     /// <exception cref="OperationCanceledException">If the <see cref="CancellationToken" /> is canceled.</exception>
     public abstract Task<IMigrationsDatabaseLock> AcquireDatabaseLockAsync(CancellationToken cancellationToken = default);

src/EFCore.Relational/Migrations/Internal/MigrationCommandExecutor.cs

@@ -156,7 +156,7 @@ public virtual Task ExecuteNonQueryAsync(
         CancellationToken cancellationToken = default)
         => ExecuteNonQueryAsync(
             migrationCommands.ToList(), connection, new MigrationExecutionState(), commitTransaction: true, System.Data.IsolationLevel.Unspecified, cancellationToken);
-    
+
     /// <summary>
     ///     This is an internal API that supports the Entity Framework Core infrastructure and not subject to
     ///     the same compatibility standards as public APIs. It may be changed or removed without notice in

src/EFCore.Relational/Migrations/Internal/Migrator.cs

@@ -633,8 +633,7 @@ private static void GenerateSqlScript(
                 if (!transactionStarted && !command.TransactionSuppressed)
                 {
                     builder
-                        .AppendLine(sqlGenerationHelper.StartTransactionStatement)
-                        .Append(sqlGenerationHelper.BatchTerminator);
+                        .AppendLine(sqlGenerationHelper.StartTransactionStatement);
                     transactionStarted = true;
                 }
 
@@ -663,7 +662,10 @@ private static void GenerateSqlScript(
                 builder.Append(command.CommandText);
             }
 
-            builder.Append(sqlGenerationHelper.BatchTerminator);
+            if (!transactionStarted)
+            {
+                builder.Append(sqlGenerationHelper.BatchTerminator);
+            }
         }
     }
 
@@ -680,10 +682,18 @@ protected virtual IReadOnlyList<MigrationCommand> GenerateUpSql(
         var insertCommand = _rawSqlCommandBuilder.Build(
             _historyRepository.GetInsertScript(new HistoryRow(migration.GetId(), ProductInfo.GetVersion())));
 
-        return _migrationsSqlGenerator
-            .Generate(migration.UpOperations, FinalizeModel(migration.TargetModel), options)
-            .Concat([new MigrationCommand(insertCommand, _currentContext.Context, _commandLogger)])
-            .ToList();
+        var operations = _migrationsSqlGenerator
+            .Generate(
+                migration.UpOperations,
+                FinalizeModel(migration.TargetModel),
+                options);
+
+        return
+        [
+            .. operations,
+            new MigrationCommand(insertCommand, _currentContext.Context, _commandLogger,
+                transactionSuppressed: operations.Any(o => o.TransactionSuppressed)),
+        ];
     }
 
     /// <summary>
@@ -700,11 +710,17 @@ protected virtual IReadOnlyList<MigrationCommand> GenerateDownSql(
         var deleteCommand = _rawSqlCommandBuilder.Build(
             _historyRepository.GetDeleteScript(migration.GetId()));
 
-        return _migrationsSqlGenerator
+        var operations = _migrationsSqlGenerator
             .Generate(
-                migration.DownOperations, previousMigration == null ? null : FinalizeModel(previousMigration.TargetModel), options)
-            .Concat([new MigrationCommand(deleteCommand, _currentContext.Context, _commandLogger)])
-            .ToList();
+                migration.DownOperations,
+                previousMigration == null ? null : FinalizeModel(previousMigration.TargetModel),
+                options);
+
+        return [
+            .. operations,
+            new MigrationCommand(deleteCommand, _currentContext.Context, _commandLogger,
+                transactionSuppressed: operations.Any(o => o.TransactionSuppressed))
+            ];
     }
 
     private IModel? FinalizeModel(IModel? model)