Linq并发冲突

1,产生并发冲突

在数据库应用系统中,当2个或者2个以上的用户,试图对同一数据库行记录进行更新,这种情形叫并发.当他们同时尝试向同一数据库行记录的一列或多咧提交更新数据时,此时会出现并发冲突.

2,并发冲突检测

开发者通过设置每个成员的System.Data.Linq.Mapping.ColumnAttribute中的UpdateCheck属性,可以控制数据库的每个字段控制如何进行并发冲突检测,控制并发冲突的检测频率.

UpdateCheck的属性列表

Always 始终使用此成员检测并发冲突

Never 永不使用此成员检测并发冲突

WhenChanged 只有当应用程序已经改变此成员值时,才使用此成员检测并发冲突

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.Linq;
using System.Data.Linq.Mapping;
namespace LinqObject.models
{
    [Table(Name = "Player")]
    public class PlayerInfoVO
    {
                                                                                                                                                                                  
        private string name;
        [Column(Name="name")]
        public string Name
        {
            get { return name; }
            set { name = value; }
        }
                                                                                                                                                                                  
        private int id;
        [Column(IsPrimaryKey=true,Name="id")]
        public int Id
        {
            get { return id; }
            set { id = value; }
        }
                                                                                                                                                                                  
        private int level;
        [Column(Name = "level_id",UpdateCheck=UpdateCheck.Never)]
        public int Level
        {
            get { return level; }
            set {
                level = value;
            }
        }
        private EntityRef<MyLevel> _myLevel;
        [Association(Storage="_myLevel",ThisKey="level_id")]
        public EntityRef<MyLevel> _MyLevel
        {
            get { return _myLevel; }
            set { _myLevel = value; }
        }
    }
}

3,并发冲突模式

指的是什么时候报告并发冲突.开发者设置并发冲突模式,就是指定并发异常的引发时间

ConflictMode

FailOnFirstConflict 在第一次并发冲突发生时即引发异常,默认

ContinueOnConflict 发生并发冲突时,继续后面的所有更新,直到所有更新完成后在触发异常.

private static void modifyQuery()
 {
     var db = new MYDBDataContext();
     int count = db.Player.Where(c => c.name == "Aonaufly").Count();
     if (count == 1)
     {
         var existingPlayer = db.Player.First();
         existingPlayer.level_id = 7;
         db.SubmitChanges(ConflictMode.ContinueOnConflict);
     }
 }

4,并发冲突处理

在发生并发冲突时,需要在异常处理语句块中对并发冲突进行处理.一般来说,解决并发冲突的办法是调用System.Data.Linq.ChangeConflictCollection中的ResolvAll()方法,在方法的输入参数中设置System.Data.Linq.RefreshMode处理冲突的3种方式.即KeepCurrentValues,OverwriteCurrentValues,KeepChanges

①保留当前值

private static void modifyQuery()
{
    var db = new MYDBDataContext();
    int count = db.Player.Where(c => c.name == "Aonaufly").Count();
    if (count == 1)
    {
        var existingPlayer = db.Player.First();
        existingPlayer.level_id = 7;
                                    
        try
        {
            db.SubmitChanges();
        }
        catch (ChangeConflictException) {
                                        
            db.ChangeConflicts.ResolveAll(RefreshMode.KeepCurrentValues);
            db.SubmitChanges();
        }
    }
}

②,覆盖当前值

OverwriteCurrentValues

③保留修改

KeepChanges只修改上个用户没被修改的而当前用户修改的字段