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; [Association(Storage="_myLevel",ThisKey="level_id")] public EntityRef _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只修改上个用户没被修改的而当前用户修改的字段