如何用T-SQL/EF每X条记录后标记N条isAudited为True？

核心逻辑说明 #

需求是按记录顺序，每X条未审核（isAudited=0）记录后，连续标记N条记录为审核状态（isAudited=1），循环此规则。核心判断逻辑为：
将记录按顺序编号（从1开始），计算(行号-1) % (X+N)，若结果大于等于X，则该记录需标记为true。

T-SQL 解决方案 #

1. 批量更新现有数据 #

适用于已存在大量记录，需要一次性按规则标记的场景，不依赖记录ID的连续性：

DECLARE @every INT = 10; -- X：每X条非审核记录
DECLARE @batch INT = 3;  -- N：后续N条设为审核

WITH NumberedRecords AS (
    SELECT 
        evalID,
        isAudited,
        ROW_NUMBER() OVER (ORDER BY evalID) AS rn
    FROM YourTable -- 替换为实际表名
)
UPDATE NumberedRecords
SET isAudited = 1
WHERE (rn - 1) % (@every + @batch) >= @every;

2. 插入新记录时自动设置状态 #

插入前计算下一条记录的位置，自动判断isAudited值：

DECLARE @every INT = 10;
DECLARE @batch INT = 3;

-- 获取当前记录总数
DECLARE @currentCount INT;
SELECT @currentCount = COUNT(*) FROM YourTable;

-- 计算下一条记录的行号
DECLARE @nextRowNum INT = @currentCount + 1;
DECLARE @isAudited BIT = CASE WHEN (@nextRowNum - 1) % (@every + @batch) >= @every THEN 1 ELSE 0 END;

-- 插入新记录（若evalID为自增列，可省略该字段）
INSERT INTO YourTable (isAudited)
VALUES (@isAudited);

3. 触发器实现自动标记（并发场景推荐） #

通过数据库触发器，确保无论从何种渠道插入记录，都自动应用规则，避免并发冲突：

CREATE TRIGGER trg_AutoSetIsAudited
ON YourTable
AFTER INSERT
AS
BEGIN
    SET NOCOUNT ON;
    DECLARE @every INT = 10;
    DECLARE @batch INT = 3;

    -- 计算插入记录的行号
    WITH InsertedWithRowNum AS (
        SELECT 
            i.evalID,
            ROW_NUMBER() OVER (ORDER BY t.evalID) AS rn
        FROM YourTable t
        JOIN inserted i ON t.evalID = i.evalID
    )
    UPDATE t
    SET t.isAudited = CASE WHEN (i.rn - 1) % (@every + @batch) >= @every THEN 1 ELSE 0 END
    FROM YourTable t
    JOIN InsertedWithRowNum i ON t.evalID = i.evalID;
END;

C#/Entity Framework 解决方案 #

1. 批量更新现有数据 #

常规方式（小数据量适用）

int every = 10;
int batch = 3;

using (var context = new YourDbContext())
{
    // 按evalID排序并为记录编号
    var numberedRecords = context.YourEntities
        .OrderBy(e => e.EvalID)
        .Select((entity, index) => new 
        {
            Entity = entity,
            RowNumber = index + 1
        })
        .ToList();

    // 筛选需要更新的记录
    var recordsToUpdate = numberedRecords
        .Where(r => (r.RowNumber - 1) % (every + batch) >= every)
        .Select(r => r.Entity);

    foreach (var record in recordsToUpdate)
    {
        record.IsAudited = true;
    }

    context.SaveChanges();
}

高效批量更新（EF Core 7+，大数据量推荐）

使用ExecuteUpdate直接生成SQL，无需加载所有数据到内存：

int every = 10;
int batch = 3;

using (var context = new YourDbContext())
{
    context.YourEntities
        .OrderBy(e => e.EvalID)
        .Select((e, index) => new { Entity = e, RowNumber = index + 1 })
        .Where(r => (r.RowNumber - 1) % (every + batch) >= every)
        .ExecuteUpdate(setters => setters.SetProperty(e => e.IsAudited, true));
}

2. 插入新记录时自动判断 #

int every = 10;
int batch = 3;

using (var context = new YourDbContext())
{
    int currentCount = context.YourEntities.Count();
    int nextRowNumber = currentCount + 1;
    bool isAudited = (nextRowNumber - 1) % (every + batch) >= every;

    var newRecord = new YourEntity
    {
        // 赋值其他字段
        IsAudited = isAudited
    };

    context.YourEntities.Add(newRecord);
    context.SaveChanges();
}

原代码的问题分析 #

你提供的原代码存在以下缺陷：

1. 依赖evalID的连续性，若存在记录删除或ID断号，行号计算会出错
2. 仅能判断单条记录的状态，无法批量处理或保证全局规则一致性
3. 未考虑并发插入场景，容易出现状态标记错误

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