您好,登錄后才能下訂單哦!
1,產(chǎn)生并發(fā)沖突
在數(shù)據(jù)庫應(yīng)用系統(tǒng)中,當(dāng)2個(gè)或者2個(gè)以上的用戶,試圖對同一數(shù)據(jù)庫行記錄進(jìn)行更新,這種情形叫并發(fā).當(dāng)他們同時(shí)嘗試向同一數(shù)據(jù)庫行記錄的一列或多咧提交更新數(shù)據(jù)時(shí),此時(shí)會出現(xiàn)并發(fā)沖突.
2,并發(fā)沖突檢測
開發(fā)者通過設(shè)置每個(gè)成員的System.Data.Linq.Mapping.ColumnAttribute中的UpdateCheck屬性,可以控制數(shù)據(jù)庫的每個(gè)字段控制如何進(jìn)行并發(fā)沖突檢測,控制并發(fā)沖突的檢測頻率.
UpdateCheck的屬性列表
Always 始終使用此成員檢測并發(fā)沖突
Never 永不使用此成員檢測并發(fā)沖突
WhenChanged 只有當(dāng)應(yīng)用程序已經(jīng)改變此成員值時(shí),才使用此成員檢測并發(fā)沖突
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,并發(fā)沖突模式
指的是什么時(shí)候報(bào)告并發(fā)沖突.開發(fā)者設(shè)置并發(fā)沖突模式,就是指定并發(fā)異常的引發(fā)時(shí)間
ConflictMode
FailOnFirstConflict 在第一次并發(fā)沖突發(fā)生時(shí)即引發(fā)異常,默認(rèn)
ContinueOnConflict 發(fā)生并發(fā)沖突時(shí),繼續(xù)后面的所有更新,直到所有更新完成后在觸發(fā)異常.
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,并發(fā)沖突處理
在發(fā)生并發(fā)沖突時(shí),需要在異常處理語句塊中對并發(fā)沖突進(jìn)行處理.一般來說,解決并發(fā)沖突的辦法是調(diào)用System.Data.Linq.ChangeConflictCollection中的ResolvAll()方法,在方法的輸入?yún)?shù)中設(shè)置System.Data.Linq.RefreshMode處理沖突的3種方式.即KeepCurrentValues,OverwriteCurrentValues,KeepChanges
①保留當(dāng)前值
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(); } } }
②,覆蓋當(dāng)前值
OverwriteCurrentValues
③保留修改
KeepChanges只修改上個(gè)用戶沒被修改的而當(dāng)前用戶修改的字段
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。