EF Core乐观并发锁怎么用 EF Core RowVersion使用教程-C#.Net教程-PHP中文网

EF Core乐观并发锁怎么用 EF Core RowVersion使用教程

畫卷琴夢

发布： 2025-12-21 10:19:02

原创

141人浏览过

EF Core乐观并发锁通过版本校验实现，不阻塞操作，推荐用[Timestamp]标记byte[]字段自动管理；也可用[ConcurrencyCheck]标记业务字段手动维护版本；冲突时抛DbUpdateConcurrencyException，可重载、合并或重试。

ef core乐观并发锁怎么用 ef core rowversion使用教程

EF Core 乐观并发锁的核心是“不锁数据，只校验版本”，适合读多写少、冲突概率低的场景。它不阻塞其他读写操作，而是在 SaveChanges() 时通过 WHERE 条件比对版本值来判断数据是否被他人修改过。一旦发现不一致，就抛出异常，由你决定如何处理。

加一个 RowVersion 字段并标记为并发令牌

这是最推荐、最省心的方式，尤其在 SQL Server 中天然支持 rowversion 列。

在实体类中添加 byte[] 类型字段，并用 [Timestamp] 特性标记：

public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    public decimal Price { get; set; }
    [Timestamp]  // 自动映射为 rowversion（SQL Server）或 bytea（PostgreSQL）
    public byte[] RowVersion { get; set; }
}

登录后复制

或者用 Fluent API 在 OnModelCreating 中配置（效果等同）：

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<Product>()
        .Property(p => p.RowVersion)
        .IsRowVersion();  // EF Core 会自动设为不可写、每次更新自增
}

登录后复制

注意：该字段无需手动赋值，SQL Server 每次 INSERT/UPDATE 都会自动生成新值；EF Core 会在 UPDATE 语句的 WHERE 子句中自动带上它。

用普通字段做并发检查（灵活但需自己维护）

如果你用的是 MySQL、SQLite 或不想依赖数据库特性，可以用业务字段（如 LastModified、Version）当并发令牌。

用 [ConcurrencyCheck] 标记字段：

public class Order
{
    public int Id { get; set; }
    public string OrderNumber { get; set; }
    [ConcurrencyCheck]
    public int Version { get; set; }  // 手动递增
}

登录后复制

或用 Fluent API 配置：

modelBuilder.Entity<Order>()
    .Property(o => o.Version)
    .IsConcurrencyToken();

登录后复制

关键点：你得在每次更新前主动给 Version 加 1（比如 entity.Version++），否则校验永远通过——EF Core 只负责在 SQL 的 WHERE 中加入 AND Version = 原值，不帮你管理值本身。

CodeBuddy

腾讯云AI代码助手

805

查看详情

保存时自动触发校验，冲突了怎么办？

调用 SaveChanges() 或 SaveChangesAsync() 时，EF Core 会生成类似这样的 SQL：

UPDATE Products 
SET Price = 29.99, Name = 'New Name' 
WHERE Id = 1 AND RowVersion = 0x00000000000007D3

登录后复制

如果 WHERE 条件不匹配（说明别人已改过），影响行数为 0，EF Core 就抛出 DbUpdateConcurrencyException。

捕获异常后，常见处理方式有：

重新加载最新数据（entry.Reload() 或 entry.GetDatabaseValuesAsync()），提示用户“数据已被他人修改”，让用户确认是否覆盖
合并变更：取数据库当前值（databaseValues），保留用户修改的字段（currentValues），再尝试保存
自动重试（配合 Polly 等库）：例如最多重试 3 次，每次间隔递增

示例简写：

try
{
    context.SaveChanges();
}
catch (DbUpdateConcurrencyException ex)
{
    foreach (var entry in ex.Entries)
    {
        var dbValues = entry.GetDatabaseValues();
        if (dbValues != null)
        {
            entry.OriginalValues.SetValues(dbValues); // 刷新原始值，为重试准备
        }
    }
    context.SaveChanges(); // 重试
}

登录后复制

注意事项和避坑点

[Timestamp] 只在 SQL Server / PostgreSQL 有效；MySQL 不支持 rowversion，需改用 int 或 datetime + IsConcurrencyToken()
同一个实体只能有一个 [Timestamp] 字段；但可多个字段用 [ConcurrencyCheck]
使用 AsNoTracking() 查询的数据，即使带 RowVersion，也不会参与并发检查——因为没被上下文跟踪
手动执行 SQL（如 ExecuteSqlInterpolated）不会触发 EF Core 并发逻辑，需自行在 SQL 中加 WHERE 版本条件