1,产生并发冲突

成都创新互联公司是专业的河南网站建设公司,河南接单;提供成都网站制作、成都网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行河南网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
在数据库应用系统中,当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只修改上个用户没被修改的而当前用户修改的字段