文化建设网站,山东机械加工网,郑州短视频培训机构,盗版视频网站建设费用TimeStamp
更新操作可能伴随数据冲突#xff0c;我们可以通过并发处理妥善解决这一方面的问题。避免数据冲突比较方便的做法是自动加入字节数组#xff08;byte[]#xff09;类型的TimeStamp属性#xff0c;对应到数据表中的rowvewsion类型字段#xff0c;自动监控数据的…TimeStamp
更新操作可能伴随数据冲突我们可以通过并发处理妥善解决这一方面的问题。避免数据冲突比较方便的做法是自动加入字节数组byte[]类型的TimeStamp属性对应到数据表中的rowvewsion类型字段自动监控数据的更新操作。
下面通过一个例子来说明
新建一个项目名称为TimeStampDemo新增实体类如下图所示 public class Product{public int Id { get; set; }public string Name { get; set; }public int Price { get; set; }public int Quantity { get; set; }[Timestamp]public byte[] Timestamp { get; set; }}
上下文代码如下图所示 public class TimeStampModel : DbContext{public TimeStampModel(): base(nameTimeStampModel){}public virtual DbSetProduct Product { get; set; }}
首次运行项目在数据库中生成了如下表结构 下面编写程序来查看其中的Timestamp字段值
static void Main(string[] args)
{using (TimeStampModel model new TimeStampModel()){Product product model.Product.Where(p p.Id 1).First();long ts BitConverter.ToInt64(product.Timestamp,0);Console.WriteLine(Quantity:{0} \t Timestamp:{1},product.Quantity,ts);product.Quantity 150;model.SaveChanges();ts BitConverter.ToInt64(product.Timestamp,0);Console.WriteLine(Quantity:{0} \t Timestamp:{1},product.Quantity,ts);Console.ReadKey();}
}
运行效果下图所示 可以看到每一次更新数据时EF都会修改Timestamp的值。如果期间有其他程序抢先完成更新造成数据变更那么EF就会报错。
我们重新执行程序在首次出现Timestamp语句时打上断点。然后在SQL查询界面直接更新用SQL语句更新数据 UPDATE dbo.Products SET Quantity 200 WHERE Id 1 SQL执行之前Timestamp的值 SQL执行之后Timestamp的值 可以看到每次更新数据后Timestamp的数值会发生改变 这时继续运行程序就会报错 此信息描述找不到要更新的数据这是因为EF在更新每一项数据时除了主键之外还会对比当时取出的TimeStamp的值。由于我们使用外部SQL更新EF无法检测这个字段就出现报错。
异常DbUpdateConcurrencyException派生自DbUpdateException表示一个并发更新冲突当这个异常出现时显示SaveChanges更新失败通过DbUpdateException.Entries属性可以获取其返回的IEnumerableDbEntityEntry对象其中存取未成功更新的实体数据对象。
重新调整Main方法中的代码如下图所示
static void Main(string[] args)
{using (TimeStampModel model new TimeStampModel()){Product product model.Product.Where(p p.Id 1).First();long ts BitConverter.ToInt64(product.Timestamp, 0);Console.WriteLine(Quantity:{0} \t TimeStamp:{1}, product.Quantity, ts);try{Console.WriteLine(新的 Quantity 值);int quantity 500;product.Quantity quantity;model.SaveChanges();ts BitConverter.ToInt64(product.Timestamp, 0);Console.WriteLine(Quantity:{0} \t TimeStamp:{1}, product.Quantity, ts);}catch (DbUpdateConcurrencyException ex){DbEntityEntry entry ex.Entries.Single();DbPropertyValues current entry.CurrentValues;//当前实体数据int quantity current.GetValueint(Quantity);long timestamp BitConverter.ToInt64(current.GetValuebyte[](Timestamp),0);DbPropertyValues dbvalue entry.GetDatabaseValues();//数据库中的实体数据int dbquantity dbvalue.GetValueint(Quantity);long dbtimestamp BitConverter.ToInt64(dbvalue.GetValuebyte[](Timestamp),0);Console.WriteLine(DbUpdateConcurrentException.....);Console.WriteLine(当前实体的属性值 Quantity:{0} \t TimeStamp:{1},quantity,timestamp);Console.WriteLine(数据库中的字段值Quantity:{0} \t TimeStamp:{1},dbquantity,dbtimestamp);}}
}
再次在首次出现Timestamp语句时打上断点。然后在SQL查询界面直接更新用SQL语句更新数据后继续运行程序如下图所示 并发冲突处理——Database Wins 或者 Client Wins
处理更新冲突有几种方式想以数据库中的值来覆盖当前数据对象的值则可以调用DbEntityEntry类定义的Reload方法此方法执行的是Database Wins(数据库优先)策略执行完毕之后数据对象当前的值将与数据库同步。
entry.Relaod();
entry.SaveChanges();
另一种方式则是反向以当前的值覆盖数据库的值称为Clinet Wins(客户优先)策略。
entry.OriginalValues.SetValues(entry.GetDatabaseValues());
model.SaveChanges() 添加一个ResolveConcurrency方法来支持并发冲突处理
public static void ResolveConcurrency(TimeStampModel model, DbEntityEntry entry)
{Console.WriteLine(1.Database wins 2.Client wins:);int i int.Parse(Console.ReadLine());if (i 1){entry.Reload();model.SaveChanges();Console.WriteLine(与数据库同步完成——DataBase Wins);}else{entry.OriginalValues.SetValues(entry.GetDatabaseValues());model.SaveChanges();Console.WriteLine(重新更新数据库完成——Client Wins);}
}
将ResolveConcurrency方法插入上述例子的catch语句中并在并发冲突中选择与数据库同步完成结果如下图所示 ConcurrencyCheck注解
TimeStamp注解属性会导致EF在更新时监控整项数据的更新状态如果对特定字段进行数据冲突的监控则可以通过ConcurrencyCheck注解来达到目的。
下面通过程序来说明新建一个控制台应用程序ConcurrencyCheckDemo有如下一个实体类 public class Product{public int Id { get; set; }public string Name { get; set; }public int Price { get; set; }[ConcurrencyCheck]public int SPrice { get; set; }}
在特价字段(SPrice)设置【ConcurrencyCheck】当程序更新任何一项Product数据时SPrice字段将受到监控期间不受EF监控的程序变更了SPrice字段的值时便会产生冲突。其他字段没有设置因此数据的更新不会有冲突。
在Main函数中增加如下图代码
static void Main(string[] args)
{using (ConcurrencyCheckModel db new ConcurrencyCheckModel()){try{Console.WriteLine(指定更新操作:A.商品名称 B.商品特价);string ab Console.ReadLine();if (ab A){Console.WriteLine(输入第一项商品的新名称);string name Console.ReadLine();db.Product.First().Name name;}if (ab B){Console.WriteLine(输入第一项商品的新特价);int price int.Parse(Console.ReadLine());db.Product.First().SPrice price;}Console.WriteLine(按任意键完成更热);Console.ReadKey();db.SaveChanges();Console.WriteLine(完成更新);}catch (Exception ex){Console.WriteLine(ex.ToString());Console.WriteLine(ex.Message);}}
}
当修改商品特价时去数据库修改SPrice字段的值便会报错
