码迷,mamicode.com
首页 > 其他好文 > 详细

EF并发异常处理

时间:2020-07-16 10:16:39      阅读:103      评论:0      收藏:0      [点我收藏+]

标签:color   stat   eva   msdn   value   null   usr   nbsp   ref   

场景:投票点赞 在更新总条数字段时  EF先读取model 再进行更新的情景  容易出现并发问题

可参考文档:

https://docs.microsoft.com/zh-cn/ef/ef6/saving/concurrency?redirectedfrom=MSDN
https://www.cnblogs.com/JasonShenW/archive/2015/12/29/5085382.html
针对整条记录的并发
EF实现并发控制 需要借助 TimeStamp 标示 ,并且一个类只能有 一个此标示,标示的必须是byte[]类型

直接上代码:

 [Table("SYS_EMP")]
    public class Emp
    {
        [Key]
        public int Id { get; set; }
        [Column("EMP_CODE")]
        public string EmpCode { get; set; }
        public string NAME { get; set; }
        public string USRID { get; set; }
        public int NUM { get; set; }
        [Timestamp]
        public byte[] version { get; set; }
    }
        /// <summary>
        /// 处理并发冲突(点赞场景)
        /// https://docs.microsoft.com/zh-cn/ef/ef6/saving/concurrency?redirectedfrom=MSDN
        /// </summary>
        public void UpdateEmp()
        {
            EmpDbContext Context1 = new EmpDbContext();
            var emp= Context1.Emp.Where(x=>x.EmpCode == "001").FirstOrDefault();
            emp.NUM += 1;
            Context1.Entry<Emp>(emp).State = System.Data.Entity.EntityState.Modified;
            Context1.Emp.AddOrUpdate(emp);

            EmpDbContext Context2 = new EmpDbContext();
            var emp2 = Context2.Emp.Where(x => x.EmpCode == "001").FirstOrDefault();
            emp2.NUM += 1;
            Context2.Entry<Emp>(emp2).State = System.Data.Entity.EntityState.Modified;
            Context2.Emp.AddOrUpdate(emp2);
            int aa = Context2.SaveChanges();

            bool saveFailed;
            do
            {
                saveFailed = false;
                try
                {
                    Context1.SaveChanges();
                }
                catch (DbUpdateConcurrencyException ex)
                {
                    saveFailed = true;
                    ex.Entries.Single().Reload();
                    var entry = ex.Entries.Single();
                    var databaseValues = entry.GetDatabaseValues();
                    databaseValues["NUM"]=databaseValues["NUM"] == null ? 1 : (int)databaseValues["NUM"]+1;
                    entry.CurrentValues.SetValues(databaseValues);
                }
            } while (saveFailed);
        }

 总结:

1、加时间戳

2、更新并发异常捕获处理

EF并发异常处理

标签:color   stat   eva   msdn   value   null   usr   nbsp   ref   

原文地址:https://www.cnblogs.com/cxxtreasure/p/13311905.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!