EF9: single transaction spanning all migrations causes transaction-incompatible SQL to fail #35096
Comments
|
@Tornhoof can you please share the part of the migration which causes the error when executing in a transaction? |
|
I'm not sure how much you need, what specifically fails are the 4 sql statements in the log file, the first first one in that file fails. The full migration file, which includes these sql statements is below in details. The migration is basically three different sql scripts, first one cleans some SQL graph tables up, then removes a column in a SQL Graph tables and changes a few constrains and the third one recreates an unrelated table-valued-parameter. The migrations are just used to run the scripts, there are no EF core model changes involved. namespace WebApp.Viewing.Graph.Migrations
{
public static class GraphTableMigrationExtension
{
// THIS ONE FAILS
private const string CleanupDanglingPredecessorsSql = @"
DECLARE @ToDeletePredecessor AS TVP_BIGINT;
INSERT INTO @ToDeletePredecessor SELECT DISTINCT e.Id FROM isPredecessorOf e LEFT OUTER JOIN Nodes n1 ON n1.$node_id = e.$from_id LEFT OUTER JOIN Nodes n2 ON n2.$node_id = e.$to_id WHERE n1.Id IS NULL OR n2.Id IS NULL;
DELETE FROM GraphPaths WHERE Id IN (SELECT [Value] FROM @ToDeletePredecessor);
DELETE FROM isPredecessorOf WHERE Id IN (SELECT [Value] FROM @ToDeletePredecessor)
";
public static void CleanupDanglingPredecessors(this MigrationBuilder migrationBuilder)
{
migrationBuilder.Sql(CleanupDanglingPredecessorsSql, suppressTransaction:true); // requires suppressTransaction in .NET 9 atm
}
private const string RemoveMetadataIdColumn = @"
IF COL_LENGTH('dbo.Nodes', 'MetadataId') IS NOT NULL
BEGIN
ALTER TABLE Nodes ADD CONSTRAINT FK_Nodes_Metadata_Id FOREIGN KEY (Id) REFERENCES Metadata (Id) ON DELETE CASCADE;
ALTER TABLE Nodes DROP CONSTRAINT C_Nodes_Id_MetadataId;
DROP INDEX IX_Nodes_MetadataId ON Nodes;
ALTER TABLE Nodes DROP COLUMN MetadataId;
ALTER TABLE isParentOf ADD CONSTRAINT EC_isParentOf CONNECTION (Nodes TO Nodes) ON DELETE CASCADE;
ALTER TABLE isFollowerOf ADD CONSTRAINT EC_isFollowerOf CONNECTION (Nodes TO Nodes) ON DELETE CASCADE;
ALTER TABLE isPredecessorOf ADD CONSTRAINT EC_isPredecessorOf CONNECTION (Nodes TO Nodes) ON DELETE CASCADE;
END
";
public static void RemoveMetadataId(this MigrationBuilder migrationBuilder)
{
migrationBuilder.Sql(RemoveMetadataIdColumn);
}
private const string DropNodeTvp = "DROP TYPE IF EXISTS TVP_Nodes";
private const string CreateNodeTvp = @"
IF TYPE_ID(N'TVP_Nodes') IS NULL
CREATE TYPE [TVP_Nodes] AS TABLE(
[Id] BIGINT NOT NULL,
[NodeType] INT NOT NULL,
[Text] NVARCHAR(523),
INDEX IX_TVP_Nodes_Id ([Id])
);";
public static void RecreateNodeTvpStatement(this MigrationBuilder migrationBuilder)
{
migrationBuilder.DropNodeTvpStatement();
migrationBuilder.CreateNodeTvpStatement();
}
}
}
using WebApp.Viewing.Graph.Extensions;
using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
namespace WebApp.Viewing.Graph.Migrations
{
/// <inheritdoc />
public partial class RemoveNodesMetadataId : Migration
{
/// <inheritdoc />
protected override void Up(MigrationBuilder migrationBuilder)
{
// this is to add the later node constraints
migrationBuilder.CleanupDanglingPredecessors();
migrationBuilder.RemoveMetadataId();
migrationBuilder.RecreateNodeTvpStatement();
}
/// <inheritdoc />
protected override void Down(MigrationBuilder migrationBuilder)
{
// not supported
}
}
}
// <auto-generated />
using System;
using WebApp.Viewing.Graph.Infrastructure;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Infrastructure;
using Microsoft.EntityFrameworkCore.Metadata;
using Microsoft.EntityFrameworkCore.Migrations;
using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
#nullable disable
namespace WebApp.Viewing.Graph.Migrations
{
[DbContext(typeof(GraphContext))]
[Migration("20230313093754_RemoveNodesMetadataId")]
partial class RemoveNodesMetadataId
{
/// <inheritdoc />
protected override void BuildTargetModel(ModelBuilder modelBuilder)
{
#pragma warning disable 612, 618
modelBuilder
.HasAnnotation("ProductVersion", "7.0.3")
.HasAnnotation("Relational:MaxIdentifierLength", 128);
SqlServerModelBuilderExtensions.UseIdentityColumns(modelBuilder);
modelBuilder.Entity("WebApp.Viewing.Graph.Data.CustomAttribute", b =>
{
b.Property<long>("Id")
.ValueGeneratedOnAdd()
.HasColumnType("bigint");
SqlServerPropertyBuilderExtensions.UseIdentityColumn(b.Property<long>("Id"));
b.Property<string>("Key")
.HasMaxLength(100)
.HasColumnType("nvarchar(100)");
b.Property<long>("MetadataId")
.HasColumnType("bigint");
b.Property<int>("Order")
.HasColumnType("int");
b.Property<byte[]>("RowVersion")
.IsConcurrencyToken()
.IsRequired()
.ValueGeneratedOnAddOrUpdate()
.HasColumnType("rowversion");
b.Property<int>("Type")
.HasColumnType("int");
b.Property<string>("Value")
.IsRequired()
.HasColumnType("nvarchar(max)");
b.HasKey("Id");
b.HasIndex("Type");
b.HasIndex("MetadataId", "Order")
.IsUnique();
b.ToTable("Attributes", (string)null);
});
modelBuilder.Entity("WebApp.Viewing.Graph.Data.GraphPath", b =>
{
b.Property<long>("Id")
.ValueGeneratedOnAdd()
.HasColumnType("bigint");
SqlServerPropertyBuilderExtensions.UseIdentityColumn(b.Property<long>("Id"));
b.Property<DateTimeOffset>("Created")
.HasColumnType("datetimeoffset");
b.Property<string>("Key")
.IsRequired()
.HasMaxLength(128)
.HasColumnType("nvarchar(128)");
b.Property<long>("MetadataId")
.HasColumnType("bigint");
b.Property<byte[]>("RowVersion")
.IsConcurrencyToken()
.IsRequired()
.ValueGeneratedOnAddOrUpdate()
.HasColumnType("rowversion");
b.Property<int>("Type")
.HasColumnType("int");
b.HasKey("Id");
b.HasIndex("Key")
.IsUnique();
b.HasIndex("MetadataId");
b.HasIndex("Type");
b.ToTable("GraphPaths", (string)null);
});
modelBuilder.Entity("WebApp.Viewing.Graph.Data.Metadata", b =>
{
b.Property<long>("Id")
.ValueGeneratedOnAdd()
.HasColumnType("bigint");
SqlServerPropertyBuilderExtensions.UseIdentityColumn(b.Property<long>("Id"));
b.Property<bool>("Extended")
.HasColumnType("bit");
b.Property<byte?>("Operation")
.HasColumnType("tinyint");
b.Property<string>("Path")
.HasMaxLength(500)
.HasColumnType("nvarchar(500)");
b.Property<byte[]>("RowVersion")
.IsConcurrencyToken()
.IsRequired()
.ValueGeneratedOnAddOrUpdate()
.HasColumnType("rowversion");
b.Property<string>("SourceGroupId")
.HasMaxLength(100)
.HasColumnType("nvarchar(100)");
b.Property<string>("SourceNodeId")
.HasMaxLength(100)
.HasColumnType("nvarchar(100)");
b.Property<string>("SourceOperationReference")
.HasMaxLength(200)
.HasColumnType("nvarchar(200)");
b.Property<int>("Type")
.HasColumnType("int");
b.HasKey("Id");
b.HasIndex("Path")
.HasFilter("[Path] IS NOT NULL AND [Type] != 105");
b.HasIndex("SourceNodeId");
b.HasIndex("Type");
b.ToTable("Metadata", (string)null);
});
modelBuilder.Entity("WebApp.Viewing.Graph.Data.VdmIndexedAttributeType", b =>
{
b.Property<int>("Type")
.HasColumnType("int");
b.Property<bool>("Mode")
.HasColumnType("bit");
b.HasKey("Type");
b.ToTable("VdmIndexedAttributeTypes", (string)null);
});
modelBuilder.Entity("WebApp.Viewing.Graph.Data.CustomAttribute", b =>
{
b.HasOne("WebApp.Viewing.Graph.Data.Metadata", null)
.WithMany("CustomAttributes")
.HasForeignKey("MetadataId")
.OnDelete(DeleteBehavior.Cascade)
.IsRequired();
});
modelBuilder.Entity("WebApp.Viewing.Graph.Data.Metadata", b =>
{
b.Navigation("CustomAttributes");
});
#pragma warning restore 612, 618
}
}
} |
|
How does it fail, what's the error? We need some details in order to investigate this. |
|
It happens during the unit tests which create a db via System.InvalidOperationException : An exception has been raised that is likely due to a transient failure. Consider enabling transient error resiliency by adding 'EnableRetryOnFailure' to the 'UseSqlServer' call.
---- Microsoft.Data.SqlClient.SqlException : Transaction (Process ID 54) was deadlocked on lock resources with another process and has been chosen as the deadlock victim. Rerun the transaction.
Stack Trace:
WebApp.Annotation.LongTests.AnnotationHandlerTests.FindRangeMultipleMetadataIdsConsecutive(count: 100, extraIds: True) [FAIL]
at Microsoft.EntityFrameworkCore.SqlServer.Storage.Internal.SqlServerExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.MigrationCommandExecutor.ExecuteNonQueryAsync(IReadOnlyList`1 migrationCommands, IRelationalConnection connection, MigrationExecutionState executionState, Boolean commitTransaction, Nullable`1 isolationLevel, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.Migrator.MigrateImplementationAsync(DbContext context, String targetMigration, MigrationExecutionState state, Boolean useTransaction, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.Migrator.MigrateImplementationAsync(DbContext context, String targetMigration, MigrationExecutionState state, Boolean useTransaction, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.Migrator.<>c.<<MigrateAsync>b__22_1>d.MoveNext()
--- End of stack trace from previous location ---
at Microsoft.EntityFrameworkCore.SqlServer.Storage.Internal.SqlServerExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.Migrator.MigrateAsync(String targetMigration, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.Migrator.MigrateAsync(String targetMigration, CancellationToken cancellationToken)
C:\agent\_work\8\s\Backend\NGP\QA\WebApp.Annotation.LongTests\AnnotationLongTestFixture.cs(45,0): at WebApp.Annotation.LongTests.AnnotationLongTestFixture.GetGraphContext()
C:\agent\_work\8\s\Backend\NGP\QA\WebApp.Annotation.LongTests\AnnotationLongTestFixture.cs(34,0): at WebApp.Annotation.LongTests.AnnotationLongTestFixture.InitializeAsync()
----- Inner Stack Trace -----
at Microsoft.Data.SqlClient.SqlConnection.OnError(SqlException exception, Boolean breakConnection, Action`1 wrapCloseInAction)
at Microsoft.Data.SqlClient.SqlInternalConnection.OnError(SqlException exception, Boolean breakConnection, Action`1 wrapCloseInAction)
at Microsoft.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(TdsParserStateObject stateObj, SqlCommand command, Boolean callerHasConnectionLock, Boolean asyncClose)
at Microsoft.Data.SqlClient.TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, Boolean& dataReady)
at Microsoft.Data.SqlClient.SqlCommand.InternalEndExecuteNonQuery(IAsyncResult asyncResult, Boolean isInternal, String endMethod)
at Microsoft.Data.SqlClient.SqlCommand.EndExecuteNonQueryInternal(IAsyncResult asyncResult)
at Microsoft.Data.SqlClient.SqlCommand.EndExecuteNonQueryAsync(IAsyncResult asyncResult)
at Microsoft.Data.SqlClient.SqlCommand.<>c.<InternalExecuteNonQueryAsync>b__193_1(IAsyncResult asyncResult)
at System.Threading.Tasks.TaskFactory`1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization)
--- End of stack trace from previous location ---
at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteNonQueryAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteNonQueryAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteNonQueryAsync(RelationalCommandParameterObject parameterObject, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.MigrationCommandExecutor.ExecuteAsync(IReadOnlyList`1 migrationCommands, IRelationalConnection connection, MigrationExecutionState executionState, Boolean beginTransaction, Boolean commitTransaction, Nullable`1 isolationLevel, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.Migrations.Internal.MigrationCommandExecutor.ExecuteAsync(IReadOnlyList`1 migrationCommands, IRelationalConnection connection, MigrationExecutionState executionState, Boolean beginTransaction, Boolean commitTransaction, Nullable`1 isolationLevel, CancellationToken cancellationToken)
at Microsoft.EntityFrameworkCore.SqlServer.Storage.Internal.SqlServerExecutionStrategy.ExecuteAsync[TState,TResult](TState state, Func`4 operation, Func`4 verifySucceeded, CancellationToken cancellationToken)
If I read the What's new Document correctly, EF Core 9 now tries to block concurrent migrations, I don't know if Resource deadlock is the expected error if that happens, but I'm really sure that there are no concurrent migrations here and commenting out a specific sql statement should have no impact on concurrent migrations anyway, so I did put that into the topic. |
|
That's very odd indeed. Are you able to put together a minimal repro that shows this happening? That would be the best way to help us investigate and fix this. /cc @AndriySvyryd |
|
I'll see what I can cobble together |
|
I wrote a repro here: https://github.com/Tornhoof/MigrationRepro, just clone it and run it (see program.cs for connection string). |
|
Confirmed, see below for a minimal repro without EF: trying to create a TVP and to declare a variable with that TVP in a transaction fails on SQL Server because of a deadlock. Note that this was a problem in previous versions of EF; the following migration triggers a deadlock also with EF 8.0: protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.Sql("""
CREATE TYPE TVP_BigInt AS TABLE (
[Value] BIGINT,
PRIMARY KEY ([Value])
);
""");
migrationBuilder.Sql("DECLARE @ToDeletePredecessor AS TVP_BIGINT");
}The difference in 9.0 is that the transaction extends across migrations, so the deadlock occurs even when the creation and the declaration are spread across different migrations. I don't think there's anything we can do here really - the workaround for now would be to suppress the transaction as @Tornhoof said above. We can also reach out to the SQL Server people and discuss this. Minimal repro without EFawait using var connection = new SqlConnection("Server=localhost;Database=test;User=SA;Password=Abcd5678;Connect Timeout=60;ConnectRetryCount=0;Encrypt=false");
await connection.OpenAsync();
await using var command = connection.CreateCommand();
command.CommandText = "DROP TYPE IF EXISTS TVP_BigInt";
await command.ExecuteNonQueryAsync();
await using var transaction = (SqlTransaction)await connection.BeginTransactionAsync();
command.Transaction = transaction;
command.CommandText = """
CREATE TYPE TVP_BigInt AS TABLE (
[Value] BIGINT,
PRIMARY KEY ([Value])
)
""";
await command.ExecuteNonQueryAsync();
command.CommandText = "DECLARE @ToDeletePredecessor AS TVP_BIGINT";
await command.ExecuteNonQueryAsync();
await transaction.CommitAsync(); |
roji
changed the title
|
Thanks for bringing to our attention @Tornhoof. I unfortunately don't think there's anything actionable for us here, plus the problem existed before as well, if you happened to perform both actions in a single migration... In addition to the workaround of suppressing the transaction, you can also simply apply the two migrations separately, by explicitly specifying on the command-line which migration state you want to migrate to (although you'd have to remember to do that every time). Other than that, I'll send a note to the SQL Server people about this so that they're aware - you can also follow up with them yourself. |
|
@roji We are seeing perhaps similar behavior and its odd. Prior to the dotnet9 upgrade the SQL generated by our migrations wrapped each migration in its own BEGIN...COMMIT block. So each migration had its own transaction. In dotnet9 that is gone and the entire migration history is a single transaction. One of our migrations modifies an enum value and then a subsequent migration that references the enum errors with the PG message: This didn't happen before because altering the ENUM in a previous migration was committed prior to the latter migration being run. Is this expected behavior in dotnet9? If so, this seems like it could potentially break a lot of databases unless I am missing something (which is entirely possible). In terms of workarounds I could go modify the old migration and explicitly commit the ALTER TYPE command. Any other ideas? |
|
Ok for those hitting same issue I have a potentially better workaround. The Migration created for modifying the enum gave me no way to call into suppressTransaction since it wasn't using migrationBuilder.Sql(). Luckily, the later migration was built using raw sql so I set suppressTransaction=true there and things are working now. By doing that, it commits all previous migration scripts and starts a new transaction AFTER the raw sql runs. Its a bit risky if something goes wrong because that one migration wont be rolled back but I dont think there are any other options here. |
|
@akamor can you provide a bit more context, ideally a sample? I'm assuming you're using PostgreSQL (which version)? |
|
Certainly, I am on Postgres v14.7. The issue happened when we migrated from net8 to net9. On dotnet8 it appears that each migration happens inside its own transaction. We had a migration that modified an enum by adding a new value. In a subsequent migration that enum value was referenced in some custom sql. This worked fine in net8. when we moved to net9 we saw that each migration no longer had its own transaction and instead there is a single transaction for all of the migrations. This lead to the problem that an enum was being modified in the same transaction block where it was later referenced. Postgres didnt like this because to reference a changed enum value that change must first be committed but it no longer was as of net9. The real issue here appears to be the change in behavior where each migration no longer gets its own transaction. Does this make sense? |
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
|
@akamor thanks for the info, I can indeed reproduce this problem on PostgreSQL with the following SQL: CREATE TYPE some_enum AS ENUM ('one', 'two');
CREATE TABLE foo (some_enum some_enum);
BEGIN;
ALTER TYPE some_enum ADD VALUE 'three';
INSERT INTO foo (some_enum) VALUES ('three');
COMMIT;Error: So yes, if you're adding an enum label in one migration, and then using it in another, the change in EF 9 would make that start failing. For now, you can work around this by enabling |
|
I can confirm that the workaround for my drop table issue was resolved by the workaround in the linked issue. Apologise for my tone earlier. Way too much work going on and jumped on the first thing I saw as the problem instead of properly investigating. Something I try to get my team to not do, and I jumped head first in. Sorry. |
|
@AnthonyDewhirst no worries, I understand how upgrading and getting a sudden unexpected break is frustrating. Thanks for engaging and constructively looking for a fix. |
Hi,
I tried to migrate my solution to .NET 9, incl. EF Core 9 with SQL Server as the provider.
Suddenly one of my migrations (old one from .NET 7 times) fails. I looked into the differences between the migration code and it appears that the transaction for migrations is now one large transaction per DbContext? and not one migration per .cs migration file.
If I modify my migration to use suppressTransaction: true from https://learn.microsoft.com/en-us/ef/core/managing-schemas/migrations/managing?tabs=dotnet-core-cli it works again.
Is that an intended breaking change or some config parameter I missed in the migration?
Log see below:
.NET 8:
.NET9:
(I don't really know why this specific sql snippet fails in the existing migration and I have not really looked into that in any detail, I guess it might be related to the TVP not being available in that transaction, but that's just a wild guess).
The text was updated successfully, but these errors were encountered: