时间戳

首页 > 解决方案 > 尝试在向上迁移中更改列数据时出现锁定问题

entity-framework-core - 尝试在向上迁移中更改列数据时出现锁定问题

问题描述

我正在尝试将 sql 语句添加到我当前项目的迁移的 up-method 中。该数据库是一个 Ms Access 数据库。迁移在运行时应用。情况如下：我有一个基础Initial-create迁移，在我的情况下假设已经应用了它。由于这个应用程序的性质，我们有一个表A它包含某种外键，但没有定义任何 sql-constraints。这意味着外键关系是通过程序代码设计的，而不是在 sql 中表示外键关系。键是一个字符串，如果没有外部元素，则值为空。现在我们要添加一个新的迁移，它通过 sql-constraints 强制执行这种关系。这可以通过标准的 ef-core 迁移代码正常工作，但是当迁移应用于非空数据库时就会出现问题。sql 外键需要表A中的所有空字符串为空（否则会出现异常）

看似简单的解决方案是在新迁移的 up-method 中添加以下语句：

UPDATE A SET ForeignKeyColumn = NULL WHERE ForeignKeyColumn & \"\" = \"\""

但这会导致以下异常：

System.Data.OleDb.OleDbException (0x80040E14): The database engine could not lock table 'A' because it is already in use by another person or process.
   at System.Data.OleDb.OleDbCommand.ExecuteCommandTextErrorHandling(OleDbHResult hr)
   at System.Data.OleDb.OleDbCommand.ExecuteCommandTextForSingleResult(tagDBPARAMS dbParams, Object& executeResult)
   at System.Data.OleDb.OleDbCommand.ExecuteCommandText(Object& executeResult)
   at System.Data.OleDb.OleDbCommand.ExecuteCommand(CommandBehavior behavior, Object& executeResult)
   at System.Data.OleDb.OleDbCommand.ExecuteReaderInternal(CommandBehavior behavior, String method)
   at System.Data.OleDb.OleDbCommand.ExecuteNonQuery()
   at EntityFrameworkCore.Jet.Data.JetCommand.ExecuteNonQueryCore()
   at EntityFrameworkCore.Jet.Data.JetCommand.<>c.<ExecuteNonQuery>b__40_0(Int32 _, JetCommand command)
   at System.Linq.Enumerable.Aggregate[TSource,TAccumulate](IEnumerable`1 source, TAccumulate seed, Func`3 func)
   at EntityFrameworkCore.Jet.Data.JetCommand.ExecuteNonQuery()
   at Microsoft.EntityFrameworkCore.Storage.RelationalCommand.ExecuteNonQuery(RelationalCommandParameterObject parameterObject)
   at Microsoft.EntityFrameworkCore.Migrations.MigrationCommand.ExecuteNonQuery(IRelationalConnection connection, IReadOnlyDictionary`2 parameterValues)
   at Microsoft.EntityFrameworkCore.Migrations.Internal.MigrationCommandExecutor.ExecuteNonQuery(IEnumerable`1 migrationCommands, IRelationalConnection connection)
   at Microsoft.EntityFrameworkCore.Migrations.Internal.Migrator.Migrate(String targetMigration)
   at Microsoft.EntityFrameworkCore.RelationalDatabaseFacadeExtensions.Migrate(DatabaseFacade databaseFacade)
   at X.Infrastructure.Setup.Migrate(IFactory`1 pDatabaseContextFactory, String pDatabasePath)
   at X.COM.XCOMWrapper.Setup(ISettingsProvider pSettingsProvider)

但是，如果我们从迁移代码中删除此 sql 语句并按如下方式执行它，则在调用之前context.Database.Migrate()：

 var dbConnection = context.Database.GetDbConnection();
                     dbConnection.Open();
                     using (var transaction = dbConnection.BeginTransaction())
                     {
                         var updateForeignKeyReferences= dbConnection.CreateCommand();
                         updateForeignKeyReferences.CommandText = "UPDATE A SET ForeignKeyColumn = NULL WHERE ForeignKeyColumn & \"\" = \"\"";
                         updateForeignKeyReferences.ExecuteNonQuery();
                         transaction.Commit();
                     }
                     dbConnection.Close();

它工作得很好。我在 up-method 中使用 sql 代码的方法完全错误吗？这可能是什么原因？最重要的是，我该如何解决这个问题？第二种方法是我目前解决这个问题的方法，但我担心这意味着从长远来看，我不能使用迁移机制，而必须使用自定义解决方案（或其他框架）。我宁愿坚持使用 ef 核心。

重要提示：此应用程序与旧应用程序一起使用，我们必须在初始启动时通过 sql 代码插入应用程序历史记录。为此，我们创建一个事务并简单地创建历史表并插入最初创建的表。这工作得很好，事务和命令都应该关闭。这个函数永远不会触及表A。

标签： entity-framework-corejet-ef-provider

解决方案

使用migrationBuilder.Sql("UPDATE `A` SET `ForeignKeyColumn` = NULL WHERE `ForeignKeyColumn` = ''")是正确的程序。

它应该执行得很好。

不幸的是，似乎存在一个问题，当执行语句时（已为您的新导航属性生成并且是迁移方法的一部分） ，Jet 仍然持有UPDATE命令中使用的表的锁。CREATE INDEXUp()

这只是一个问题，如果两个语句都在同一个事务中执行（默认情况下迁移就是这种情况）。否则，不持有任何锁且CREATE INDEX语句成功。

解决此问题的最简单方法是将migrationBuilder.Sql()参数设置suppressTransaction为true.

这将在事务的其余部分之外执行语句，而不是锁定表：

protected override void Up(MigrationBuilder migrationBuilder)
{
    migrationBuilder.Sql(
        "UPDATE `A` SET `ForeignKeyColumn` = NULL WHERE `ForeignKeyColumn` = ''",
        suppressTransaction: true);
    
    migrationBuilder.CreateIndex(/* ... */);
    migrationBuilder.AddForeignKey(/* ... */);
}

另一种能够UPDATE在事务中执行语句的方式是在其自己的专用迁移中执行命令：

  • 添加一个空迁移。将您的migrationBuilder.Sql()调用添加Up()到此迁移的空方法。
  • 添加实际迁移（包含CreateIndex()andAddForeignKey()操作）。
  • 将这两个迁移应用到您的数据库。

推荐阅读