我有一个父实体，我需要做一个并发检查(如下注释)

1682873666
public byte[] RowVersion { get; set; }

我有一堆客户端进程可以从这个父实体访问只读值，主要是更新它的子实体。

约束

1. 客户端 不应干扰彼此的工作(例如，更新子记录不应在父实体 上引发并发异常)。

2. 我有一个服务器进程更新这个父实体，在这种情况下如果父实体 已更改，则客户端进程 需要抛出。

_{注意:客户端的并发检查是牺牲性的，服务器的工作流是关键任务。}

问题

我需要检查(从客户端进程)父实体是否已更改而不更新父实体的行版本。

在 EF 中对父实体 进行并发检查非常简单:

// Update the row version's original value
_db.Entry(dbManifest)
      .Property(b => b.RowVersion)
      .OriginalValue = dbManifest.RowVersion; // the row version the client originally read

// Mark the row version as modified
_db.Entry(dbManifest)
       .Property(x => x.RowVersion)
       .IsModified = true;

IsModified = true 是交易破坏者，因为它强制更改行版本。或者，在上下文中说，来自客户端进程的这种检查将导致父实体中的行版本更改，这会不必要地干扰其他客户端进程的工作流。 p>

_{解决方法:我可能会将来自客户端进程的 SaveChanges 包装在事务中，然后随后依次读取父实体的行版本，如果行版本已更改则回滚。}

总结

Entity Framework 是否有开箱即用方法，我可以在其中SaveChanges(在客户端进程中 子实体)同时检查父实体的行版本是否已经改变(没有更新父实体行版本).

最佳答案

有一个非常简单的解决方案，“开箱即用”，但它需要进行两项修改，我不确定您是否可以或愿意进行:

• 在包含 ParentRowVersion 列的子表上创建一个可更新 View
• 将子实体映射到此 View

让我来展示一下这是如何工作的。这一切都非常简单。

数据库模型:

CREATE TABLE [dbo].[Parent]
(
[ID] [int] NOT NULL IDENTITY(1, 1),
[Name] [nvarchar] (50) NOT NULL,
[RowVersion] [timestamp] NOT NULL
) ON [PRIMARY]
ALTER TABLE [dbo].[Parent] ADD CONSTRAINT [PK_Parent] PRIMARY KEY CLUSTERED  ([ID]) ON [PRIMARY]

CREATE TABLE [dbo].[Child]
(
[ID] [int] NOT NULL IDENTITY(1, 1),
[Name] [nvarchar] (50) NOT NULL,
[RowVersion] [timestamp] NOT NULL,
[ParentID] [int] NOT NULL
) ON [PRIMARY]
ALTER TABLE [dbo].[Child] ADD CONSTRAINT [PK_Child] PRIMARY KEY CLUSTERED  ([ID]) ON [PRIMARY]
GO
CREATE VIEW [dbo].[ChildView]
WITH SCHEMABINDING
AS
SELECT Child.ID
, Child.Name
, Child.ParentID
, Child.RowVersion
, p.RowVersion AS ParentRowVersion
FROM dbo.Child
INNER JOIN dbo.Parent p ON p.ID = Child.ParentID

View 是可更新的，因为它满足 conditions for Sql Server views to be updatable .

数据

SET IDENTITY_INSERT [dbo].[Parent] ON
INSERT INTO [dbo].[Parent] ([ID], [Name]) VALUES (1, N'Parent1')
SET IDENTITY_INSERT [dbo].[Parent] OFF

SET IDENTITY_INSERT [dbo].[Child] ON
INSERT INTO [dbo].[Child] ([ID], [Name], [ParentID]) VALUES (1, N'Child1.1', 1)
INSERT INTO [dbo].[Child] ([ID], [Name], [ParentID]) VALUES (2, N'Child1.2', 1)
SET IDENTITY_INSERT [dbo].[Child] OFF

类模型

public class Parent
{
    public Parent()
    {
        Children = new HashSet<Child>();
    }
    public int ID { get; set; }
    public string Name { get; set; }
    public byte[] RowVersion { get; set; }
    public ICollection<Child> Children { get; set; }
}

public class Child
{
    public int ID { get; set; }
    public string Name { get; set; }
    public byte[] RowVersion { get; set; }

    public int ParentID { get; set; }
    public Parent Parent { get; set; }
    public byte[] ParentRowVersion { get; set; }
}

上下文

public class TestContext : DbContext
{
    public TestContext(string connectionString) : base(connectionString){ }

    public DbSet<Parent> Parents { get; set; }
    public DbSet<Child> Children { get; set; }

    protected override void OnModelCreating(DbModelBuilder modelBuilder)
    {
        modelBuilder.Entity<Parent>().Property(e => e.RowVersion).IsRowVersion();
        modelBuilder.Entity<Child>().ToTable("ChildView");
        modelBuilder.Entity<Child>().Property(e => e.ParentRowVersion).IsRowVersion();
    }
}

整合

这段代码更新了一个Child，同时一个假的并发用户更新了它的Parent:

using (var db = new TestContext(connString))
{
    var child = db.Children.Find(1);

    // Fake concurrent update of parent.
    db.Database.ExecuteSqlCommand("UPDATE dbo.Parent SET Name = Name + 'x' WHERE ID = 1");
    
    child.Name = child.Name + "y";
    db.SaveChanges();
}

现在 SaveChanges 抛出所需的 DbUpdateConcurrencyException。当父更新被注释掉时，子更新成功。

我认为这种方法的优点是它非常独立于数据访问库。您只需要一个支持乐观并发的 ORM。 future 迁移到 EF-core 不会成为问题。

关于c# - 在不更新行版本的情况下检查实体的并发性，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57048744/