重慶分公司,新征程啟航
為企業提供網站建設、域名注冊、服務器等服務
為企業提供網站建設、域名注冊、服務器等服務
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只修改上個用戶沒被修改的而當前用戶修改的字段