我有一个通过entity-framework-core（efcore 7）对postgresql数据库执行的命令。该命令旨在“声明”某些记录。每个记录应该声明一次且仅声明一次。

UPDATE command AS c
SET execution_heartbeat = @__GetTimeUtc_2,
    claim_id = @__claimId_1
FROM (
    SELECT c0.command_id, c0.active, c0.claim_id, c0.execution_heartbeat, c0.sid, c0.started_on, c0.status, c0.tenant_id
    FROM command AS c0
    WHERE c0.status = 0 AND (c0.claim_id IS NULL)
    ORDER BY c0.sid
    LIMIT @__p_0  --1 in this case
) AS t
WHERE c.command_id = t.command_id

字符串
上述语句通过以下代码块执行

Guid claimId = Guid.NewGuid();
int affected = 0;

using (var context = DbContextFactory.CreateDbContext())
{
    affected = await context.MyTable
        .Where(c => c.Status == CommandStatus.QUEUED)
        .Where(c => c.ClaimId == null)
        .OrderBy(c => c.Sid)
        .Take(maxClaims)
        .ExecuteUpdateAsync(
            setPropertyCalls: calls => calls
                .SetProperty(c => c.ClaimId, claimId)
                .SetProperty(c => c.ExecutionHeartbeat, TimeAccessor.GetTimeUtc()),
            cancellationToken: cancellationToken);

    var claimedIds = await context.MyTable
        .Where(c => c.ClaimId == claimId)
        .Select(c => c.Id)
        .ToListAsync(cancellationToken);

    this.Logger.LogDebug("Claiming {Count} records: {Ids} with Claim: {ClaimId}", affected, string.Join(", ", claimedIds), claimId);

    return claimedIds;
}

型
然而，当有多个线程并行运行此，一些记录最终得到'声称'多次. IE，有两个不同的线程.

• 声明唯一的claimId
• 将某些记录（其claimId应为NULL）更新为新的claimId
• 选择现在具有新claimId的记录

这似乎不太可能，因为我假设update语句是事务性运行的，并且只更新以前没有更新过的记录。
我相信我可以找到一种方法来“围绕这一点编写代码”。但希望有人能阐明这里可能发生的事情，以及我可能做出的错误假设。