如何用EF在C#中实现SQL Server带OUTPUT inserted的更新并返回ID

刚好我之前处理过类似的队列锁需求，这里分EF Core和EF6两种常用场景给你说下实现方式：

EF Core 实现方式 #

EF Core支持直接执行原生SQL并返回结果集，你可以通过以下步骤实现：

1. 先定义一个简单的DTO类用来接收返回的ID（如果不想用DTO，也可以直接返回基础类型）：

public class LockedQueueId
{
    public int ID { get; set; } // 如果你的ID是Guid类型，改成Guid即可
}

2. 在你的DbContext实例中执行原生SQL，获取锁定的ID：

using (var context = new YourDbContext())
{
    var lockedId = context.Set<LockedQueueId>()
        .FromSqlRaw(@"UPDATE TOP (1) GlobalTrans 
                      SET LockDateTime = GETUTCDATE() 
                      OUTPUT inserted.ID 
                      WHERE LockDateTime IS NULL")
        .FirstOrDefault()?.ID;

    // 拿到lockedId后就可以进行后续业务处理了
    if (lockedId.HasValue)
    {
        // 处理逻辑
    }
}

如果你不想额外定义DTO，也可以直接用SqlQuery方法返回基础类型（EF Core 5.0+支持）：

var lockedId = context.Database.SqlQuery<int>(@"UPDATE TOP (1) GlobalTrans 
                                                SET LockDateTime = GETUTCDATE() 
                                                OUTPUT inserted.ID 
                                                WHERE LockDateTime IS NULL")
    .FirstOrDefault();

EF6 实现方式 #

EF6的实现更直接，直接通过Database.SqlQuery执行原生SQL并返回结果：

using (var db = new YourDbContext())
{
    int? lockedId = db.Database.SqlQuery<int>(@"UPDATE TOP (1) GlobalTrans 
                                                SET LockDateTime = GETUTCDATE() 
                                                OUTPUT inserted.ID 
                                                WHERE LockDateTime IS NULL")
        .FirstOrDefault();

    if (lockedId.HasValue)
    {
        // 处理被锁定的记录
    }
}

注意事项 #

• 这个UPDATE语句本身是原子操作，不用担心并发下的重复锁定问题，SQL Server会保证同一时间只有一个请求能锁定那条记录
• 如果你的ID字段类型不是int，记得把代码里的返回类型改成对应的类型（比如Guid、long等）
• 如果后续还要基于这个ID做其他数据库操作，建议把整个逻辑放在一个事务里，保证数据一致性

内容的提问来源于stack exchange，提问作者Daniel