Hello World
Spiga

在Linq to Sql中管理并发更新时的冲突(2):引发更新冲突

2007-11-20 19:30 by 老赵, 3263 visits

在上一讲中,我们提到了一些诸如“乐观并发控制”、“悲观并发控制”的概念,以及察看Linq to Sql自动生成sql语句的方法。从这篇文章起我们将继续来查看Linq to Sql在管理并发更新时是如何发现冲突问题的。

要使用Linq to Sql,我们自然需要一个数据库环境。为了说明问题,我们这里使用一个非常简单的数据表。

我们这里创建了一个Video表,只有3个字段,没有约束,没有外键——我们只要能够说明问题就可以了,不是吗?

  1. VideoID:主键,int,自增长
  2. Introduction:nvarchar(max),not null
  3. SiteID:int,not null

上面的图片是使用Visual Studio 2008中提供的Object Relational Designer根据数据表的Schema自动生成的。您在使用时也可以通过VS 2008提供的命令行工具“SqlMetal.exe”来自动生成Object Model代码。这都不是这次的重点。

目前,Video表中有这么一条记录:

VideoID Introduction SiteID
1 Introduction 1 1

现在就开始我们的尝试吧:

LinqToSqlDemoDataContext dataContext = new LinqToSqlDemoDataContext();
dataContext.Log = Console.Out;

Video video = dataContext.Videos.Single(v => v.VideoID == 1);
video.Introduction = "1235";

dataContext.SubmitChanges();
Console.ReadLine();

首先,我们获取了VideoID为1的那条记录,并构造成一个Video对象。接着我们修改了这个Video对象的Introduction属性,最后调用了DataContext的SubmitChange方法将修改提交至数据库。运行以上代码之后,我们捕获了输出:

SELECT [t0].[VideoID], [t0].[Introduction], [t0].[SiteID]
FROM [dbo].[Video] AS [t0]
WHERE [t0].[VideoID] = @p0
-- @p0: Input Int (Size = 0; Prec = 0; Scale = 0) [1]
-- Context: SqlProvider(Sql2005) Model: AttributedMetaModel Build: 3.5.21004.1

UPDATE [dbo].[Video]
SET [Introduction] = @p3
WHERE ([VideoID] = @p0) AND ([Introduction] = @p1) AND ([SiteID] = @p2)
-- @p0: Input Int (Size = 0; Prec = 0; Scale = 0) [1]
-- @p1: Input NVarChar (Size = 14; Prec = 0; Scale = 0) [Introduction 1]
-- @p2: Input Int (Size = 0; Prec = 0; Scale = 0) [2]
-- @p3: Input NVarChar (Size = 16; Prec = 0; Scale = 0) [New Introduction]
-- Context: SqlProvider(Sql2005) Model: AttributedMetaModel Build: 3.5.21004.1

获取VideoID为1的记录的Sql语句不必多说,关键在于那条用于更新的语句。根据它的WHERE Condition以及传入的参数,我们不难发现它在更新时作了什么样的判断:除了传入了主键——这是为了标识更新的那条记录——它还将记录原有的值传入了Sql语句中。也就是说,只有当“更新”时,那条记录的状态和“获取”时完全相同,更新才会成功。

这就是“乐观并发控制”——直到更新时才判断是否出现了并发问题。

严格说来,这只是“乐观并发控制”的一部分,“乐观并发控制”还包括在并发问题出现之后“处理问题”的过程。

这种“乐观并发控制”方式(以后还会提到其他的“乐观并法控制”方式)的一个特点是,它并不关心这条记录是否被“修改过”,而只是比较当前以及之前的状态是否相同(可能记录被修改过,但是数值保持不变,不是吗?)。那么我们来尝试着产生以下并发问题吧:

try
{
    LinqToSqlDemoDataContext dataContext = new LinqToSqlDemoDataContext();

    Video video = dataContext.Videos.Single(v => v.VideoID == 1);
    // 在下一行代码上设断点,并在运行时改变数据库内纪录的值。
    video.Introduction = "12356";
    dataContext.SubmitChanges();
}
catch (ChangeConflictException e)
{
    Console.WriteLine(e.Message);
}

Consoleonsole.ReadLine();

现在,我们需要在改变video对象属性的那行代码上设置断点,并且在运行进入该断点时改变该纪录任一字段的值(例如:UPDATE Video SET SiteID = 10 WHERE VideoID = 1)。当我们继续运行程序时,就会发现SubmitChange方法抛出了异常,而控制台输出了以下字样:

Row not found or changed.

我们很容易想到,这是由于WHERE条件没有满足,导致了更新时ExecuteNonQuery方法返回了0,于是Linq to Sql意识到该记录被修改了(或者被删除了,从另一个角度上来看,这也是一种改变)。我们使用以下的方法再进行一次实验:

LinqToSqlDemoDataContext dataContext = new LinqToSqlDemoDataContext();
dataContext.Log = Console.Out;

Video video = new Video();
video.VideoID = 1;
dataContext.Videos.Attach(video, false);

video.Introduction = "123";
dataContext.SubmitChanges();

猜猜现在的输出是什么?想清楚了吗?那么我们来揭晓答案:

UPDATE [dbo].[Video]
SET [Introduction] = @p0
WHERE 0 = 1
-- @p0: Input NVarChar (Size = 3; Prec = 0; Scale = 0) [123]
-- Context: SqlProvider(Sql2005) Model: AttributedMetaModel Build: 3.5.21004.1

看看WHERE条件:“0 == 1”,这是什么意思?Attach方法又是做什么的呢?关于这些问题我们以后再进行讨论。不过可以得知的是,这个绝对不成立的WHERE条件不会更新任何记录,于是Linq to Sql又抛出了ChangeConflictException。

不过,您是否觉得“乐观并发控制”的这种方式非常古怪(累赘?)呢?下一篇文章我们再来更进一步的讨论。

相关文章

Creative Commons License

本文基于署名 2.5 中国大陆许可协议发布,欢迎转载,演绎或用于商业目的,但是必须保留本文的署名赵劼(包含链接),具体操作方式可参考此处。如您有任何疑问或者授权方面的协商,请给我留言

Add your comment

18 条回复

  1. Cat Chen
    *.*.*.*
    链接

    Cat Chen 2007-11-20 17:48:00

    自动编号的ID不能这样设的吧?至于底层为什么生成0 = 1,我也不知道。

  2. 老赵
    admin
    链接

    老赵 2007-11-20 18:47:00

    @Cat Chen
    可以这么设的,只要在Attach之前,因为那时候context还没有开始Track这些状态。

  3. 伍迷
    *.*.*.*
    链接

    伍迷 2007-11-20 20:09:00

    好一个“乐观并发控制”,谢谢分享。

  4. 伍迷
    *.*.*.*
    链接

    伍迷 2007-11-20 20:38:00

    我查了MSDN
    public void Attach(
    TEntity entity,
    bool asModified
    )

    asModified
    类型:System..::.Boolean
    True if the entity is to be attached as modified.


    看了你代码中的
    Video video = new Video();
    video.VideoID = 1;
    dataContext.Videos.Attach(video, false);

    我感觉很费解,这样做是什么意思?

  5. 老赵
    admin
    链接

    老赵 2007-11-20 21:41:00

    @伍迷
    false则表明告诉DataContext,对象在被Attach时的状态作为“初始状态(asModified为false,意思是对象没有被修改过)”,以这个状态为标准进行State Track。

  6. 1-2-3
    *.*.*.*
    链接

    1-2-3 2007-11-21 09:32:00

    详细看完,受教了。
    WHERE ([VideoID] = @p0) AND ([Introduction] = @p1) AND ([SiteID] = @p2)
    这个where子句中的字段不可能都是索引的吧,那么我很担心它的执行速度啊。当然只几条数据是没有问题的,不过有时也会有成百上千条数据的时候呀。

  7. 老赵
    admin
    链接

    老赵 2007-11-21 09:36:00

    @1-2-3
    这里不是查询而是更新,Primary Key上有个Clustered Index,定位到某个特定的纪录是非常迅速的,然后比较后面的字段就可以了。不过性能可能会在数据传输上和字符串比较上有点消耗,这点我下一篇文章会提到的。

  8. Cat Chen
    *.*.*.*
    链接

    Cat Chen 2007-11-21 09:39:00

    @Jeffrey Zhao
    我只记得Typed DataSet的自动编号字段是只读的,entity是如何还没测试过呢。

  9. 老赵
    admin
    链接

    老赵 2007-11-21 09:46:00

    @Cat Chen
    两个实现机制其实不同的。
    还有我觉得Linq to Sql的Object Model是可以做到Domain Object和Data Access Logic分离的。现在说“不分离”也是因为支持Object Model的类和DataContext等东西放在一个程序集里了,呵呵。

  10. txdlf
    *.*.*.*
    链接

    txdlf 2007-11-21 14:39:00

    --引用--------------------------------------------------
    Jeffrey Zhao: @Cat Chen
    两个实现机制其实不同的。
    还有我觉得Linq to Sql的Object Model是可以做到Domain Object和Data Access Logic分离的。现在说“不分离”也是因为支持Object Model的类和DataContext等东西放在一个程序集里了,呵呵。
    --------------------------------------------------------
    有道理,Object Model的类应该和DataContext分开在不同程序集,这样实现分层或者其它就容易多了

  11. 老赵
    admin
    链接

    老赵 2007-11-21 14:45:00

    @txdlf
    其实我觉得并不需要那么严格.
    我们为什么要分开呢?最主要的原因是为了让Domain Model或者其他组件能够单独地测试。
    如果只是纯粹为了理论上的XXXX……就没有什么意义了。

  12. 小智
    *.*.*.*
    链接

    小智 2007-11-21 18:13:00

    期待下文

  13. flyingchen
    *.*.*.*
    链接

    flyingchen 2007-11-21 21:28:00

    怎么还是Video啊?呵呵

  14. vainnetwork
    *.*.*.*
    链接

    vainnetwork 2007-11-23 00:11:00

    不错,分析的很好

  15. 韦恩卑鄙
    *.*.*.*
    链接

    韦恩卑鄙 2008-11-12 12:34:00

    我很关心如何取消并发控制 以前用tableadepter我是通过修改 adepter的update sql语句来取消多个字段的 where限制的

    不知道 目前版本的 linq to sql 这方面如何处理?如果还是要修改command sql 我就要对m$竖起中指了

  16. 老赵
    admin
    链接

    老赵 2008-11-12 13:49:00

    @韦恩卑鄙
    把字段的UpdateCheck设为Never就没事了.

  17. 韦恩卑鄙
    *.*.*.*
    链接

    韦恩卑鄙 2008-11-17 22:03:00

    好的 我厂随后实验下 多谢!

  18. panzi
    *.*.*.*
    链接

    panzi 2009-06-04 10:23:00

    ding

发表回复

登录 / 登录并记住我 ,登陆后便可删除或修改已发表的评论 (请注意保留评论内容)

昵称:(必填)

邮箱:(必填,仅用于Gavatar

主页:(可选)

评论内容(大于5个字符):

  1. Your Name yyyy-MM-dd HH:mm:ss

使用Live Messenger联系我