c# - 如果两个或更多人同时更新一条记录会怎样？

Question

我使用的 NHibernate 的版本属性会在每次更新聚合根时自动递增。如果两个或更多人同时更新同一条记录会怎样？

此外，我将如何测试它？

请注意，这不是我遇到过的情况，只是想知道。

Answer 1

什么是原子的，什么不是

正如其他人所说，SQL Server 中的更新是原子操作。但是，当使用 NHibernate(或任何 O/RM)更新数据时，您通常首先 select数据，对对象进行更改，然后 update包含您的更改的数据库。该事件序列不是原子的。即使选择和更新是在彼此的毫秒内执行的，另一个更新也有可能在中间滑动。如果两个客户端获取相同数据的相同版本，如果他们认为当时只有他们自己编辑该数据，他们可能会无意中覆盖彼此的更改。

问题说明

如果我们不防范这种并发更新的情况，可能会发生奇怪的事情——看似不可能发生的偷偷摸摸的错误。假设我们有一个模拟水的状态变化的类:

public class BodyOfWater
{
    public virtual int Id { get; set; }
    public virtual StateOfMatter State { get; set; }

    public virtual void Freeze()
    {
        if (State != StateOfMatter.Liquid)
            throw new InvalidOperationException("You cannot freeze a " + State + "!");
        State = StateOfMatter.Solid;
    }

    public virtual void Boil()
    {
        if (State != StateOfMatter.Liquid)
            throw new InvalidOperationException("You cannot boil a " + State + "!");
        State = StateOfMatter.Gas;
    }
}

假设数据库中记录了以下水体:

new BodyOfWater
{
    Id = 1,
    State = StateOfMatter.Liquid
};

两个用户大致同时从数据库中获取这条记录，修改它，并将修改保存回数据库。用户A卡住了水:

using (var transaction = sessionA.BeginTransaction())
{
    var water = sessionA.Get<BodyOfWater>(1);
    water.Freeze();
    sessionA.Update(water);

    // Same point in time as the line indicated below...

    transaction.Commit();
}

用户 B 试图将水烧开(现在是冰!)...

using (var transaction = sessionB.BeginTransaction())
{
    var water = sessionB.Get<BodyOfWater>(1);

    // ... Same point in time as the line indicated above.

    water.Boil();
    sessionB.Update(water);
    transaction.Commit();
}

...并且成功!!!什么？用户 A 卡住了水。难道不应该抛出一个异常(exception)说“你不能煮固体!”吗？用户 B 在用户 A 保存他的更改之前获取了数据，因此对于两个用户来说，水最初看起来是液体，因此两个用户都被允许保存他们的冲突状态更改。

解决方案

为了防止这种情况，我们可以添加一个 Version属性到类并使用 <version /> 在 NHibernate 中映射它映射:

public virtual int Version { get; set; }

这只是一个数字，NHibernate 每次更新记录时都会递增，它会检查以确保在我们不在的时候没有其他人递增版本。而不是像...这样的并发天真的 sql 更新

update BodyOfWater set State = 'Gas' where Id = 1;

... NHibernate 现在将使用更智能的查询，如下所示:

update BodyOfWater set State = 'Gas', Version = 2 where Id = 1 and Version = 1;

如果受查询影响的行数为 0，则 NHibernate 知道出现了错误 - 其他人更新了该行，因此版本号现在不正确，或者有人删除了该行，因此该 ID 不再存在。 NHibernate 然后将抛出一个 StaleObjectStateException .

关于网络应用的特别说明

初始select之间的时间越多数据和随后的 update ，出现此类并发问题的可能性就越大。考虑网络应用程序中的典型“编辑”表单。实体的现有数据从数据库中选择，放入 HTML 表单中，然后发送到浏览器。用户可能会花几分钟时间修改表单中的值，然后再将其发送回服务器。很有可能其他人正在同时编辑相同的信息，并且他们在我们之前保存了他们的更改。

确保版本在我们实际保存更改的几毫秒内不会更改，在这种情况下可能还不够。要解决此问题，您可以将版本号作为隐藏字段与其余表单字段一起发送到浏览器，然后检查以确保在保存之前从数据库中取回实体时版本没有更改.此外，您可以限制初始 select 之间的时间量。和最后的 update通过提供单独的“查看”和“编辑” View ，而不是仅对所有内容使用“编辑” View 。用户花在“编辑” View 上的时间越少，向他们展示更改无法保存的恼人错误消息的可能性就越小。