EntityFramework进阶——数据变更冲突

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("name=TimeStampModel"){}public virtual DbSet<Product> 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属性可以获取其返回的IEnumerable<DbEntityEntry>对象，其中存取未成功更新的实体数据对象。 

重新调整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.GetValue<int>("Quantity");long timestamp = BitConverter.ToInt64(current.GetValue<byte[]>("Timestamp"),0);DbPropertyValues dbvalue = entry.GetDatabaseValues();//数据库中的实体数据int dbquantity = dbvalue.GetValue<int>("Quantity");long dbtimestamp = BitConverter.ToInt64(dbvalue.GetValue<byte[]>("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字段的值，便会报错：

       

 

 

 

 

 

 

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/548496.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

MyBatis 数据持久层

MyBatis 数据持久层

引用&#xff1a;http://baike.baidu.com/view/4372646.htm MyBatis 的前身就是 iBatis 。是一个数据持久层(ORM)框架。 MyBatis框架 [1]iBATIS一词来源于“internet”和“abatis”的组合&#xff0c;是一个基于Java的持久层框架。iBATIS提供的持久层框架包括SQL Maps和Data Ac…
阅读更多...
EntityFramework进阶——事务

EntityFramework进阶——事务

事务处理 EF支持事务处理操作&#xff0c;以下语句会获取当前DbContext对象专用的DbContextTransaction事务处理的对象&#xff1a; DbContextTransaction transaction context.Database.BeginTransaction() 获取transaction之后&#xff0c;期间任何与context有关的数据均…
阅读更多...
TP类库解析和使用系列[Input类]

TP类库解析和使用系列[Input类]

2019独角兽企业重金招聘Python工程师标准>>> [ 概述 ] Input类是新版新增的一个输入数据管理类&#xff0c;提供了一些输入数据的管理和过滤。 [ 方法 ] getInstance 实例化Input类 filter 设置数据过滤方法 以下方法都是动态方法&#xff1a; get 获取get数据 post…
阅读更多...
简单描述char(n)、varchar(n)、nchar(n)、nvarchar(n)的区别

简单描述char(n)、varchar(n)、nchar(n)、nvarchar(n)的区别

它们的区别概括成&#xff1a; char&#xff0c;nchar &#xff1a;定长&#xff0c;速度快&#xff0c;占空间大&#xff0c;需处理 varchar&#xff0c;nvarchar &#xff1a;不定长&#xff0c;空间小&#xff0c;速度慢&#xff0c;无需处理 nchar、nvarchar&#xff1a;处…
阅读更多...
详解CSMA/CD

详解CSMA/CD

学网络的人&#xff0c;恐怕都得知道在总线网络中必须要用到CSMA/CD来传输数据。 CSMA/CD——带冲突检测的载波侦听多路访问机制&#xff0c;用来决定某一时刻介质访问权限问题&#xff0c;原理如下&#xff1a;所有站点共享一条传输线路&#xff08;总线&#xff09;&…
阅读更多...
SqlServer中dateTime、dateTime2、date、datetimeoffset的区别

SqlServer中dateTime、dateTime2、date、datetimeoffset的区别

date 存入的数据格式为&#xff1a;yyyy-mm-dd datetime 存入的数据格式为&#xff1a;yyyy-mm-dd hh:mm:ss.fff(精确到1毫秒) datetime2 存入的数据格式为&#xff1a;yyyy-mm-dd hh:mm:ss.fffffff&#xff08;精确到0.1微秒&#xff09; datetimeoffset 存入的数据格式为&…
阅读更多...
php读取checkbox数组值

php读取checkbox数组值

2019独角兽企业重金招聘Python工程师标准>>> 用在批量删除或者更新等操作方面 <form method"post" action"CheckAction.php"> <input type"checkbox" value"h" name"flags[]">头条[h] <input ty…
阅读更多...
EntityFramework进阶——Entity Splitting和Table Splitting

EntityFramework进阶——Entity Splitting和Table Splitting

Entity Splitting——把单个实体拆分成多个表。Table Splitting——把单个表拆分成多个实体 Entity Splitting 下面通过例子来说明&#xff1a; 假设存在如下实体类&#xff1a; public class Employee{public int EmployeeId { get; set; }public string Name { get; set; …
阅读更多...
[转]android webview学习

[转]android webview学习

本文转自&#xff1a;http://hi.baidu.com/relayon/blog/item/92b15463677d3e6b0d33fa79.html 在移动互联网的争夺日趋白热化&#xff0c;各个互联网巨头纷纷推出自己的手机浏览器&#xff0c;浏览器市场的争夺从桌面转移到了手机。在Android手机中内置了一款高性能webkit内核浏…
阅读更多...
EntityFramework进阶——CodeFirst数据库迁移

EntityFramework进阶——CodeFirst数据库迁移

与视觉操作界面相比&#xff0c;CodeFirst机制提供了一套命令行模式的迁移工具&#xff0c;协助开发人员有效的进行数据库与数据模型的同步维护操作。 新建一个控制台项目CFMigrationsDemo&#xff0c;选用来自数据库的EF设计器模式&#xff0c; 并向其中添加一个Product.cs类文…
阅读更多...
java远程debug

java远程debug

常常会遇到在应用部署在weblogic,tomcat,jetty等服务器下&#xff0c;而我们的代码却在本地&#xff0c;如何用本地的代码调试远程服务器上的程序呢 在web服务器上添加jvm参数,如以下是我们启动jetty服务器的参数&#xff0c;8000代表的是远程debug的端口号 java -Xdebug -Xrun…
阅读更多...
前端控件JQuery Datatables使用——常用功能初始化

前端控件JQuery Datatables使用——常用功能初始化

本文用于自己记录&#xff0c;忘记时可以用来回顾。点击这里进入JQuerydatatable官网API地址 JQuery Datatables初始化 个人比较喜欢JQueryDatatables的Bootstrap4风格&#xff0c;所以文章以Bootstrap4风格为例。 JQueryDatatable的初始化很简单&#xff0c;按照官网的举例说…
阅读更多...
ASP.NET中常用的26个优化性能方法(1-10)

ASP.NET中常用的26个优化性能方法(1-10)

1. 数据库访问性能优化 数据库的连接和关闭 访问数据库资源需要创建连接、打开连接和关闭连接几个操作。这些过程需要多次与数据库交换信息以通过身份验证&#xff0c;比较耗费服务器资源。ASP.NET中提供了连接池(Connection Pool)改善打开和关闭数据库对性能的影响。系统将用户…
阅读更多...
一款轻量级的消息提示插件 —— toastr

一款轻量级的消息提示插件 —— toastr

toastr是一款轻量级的消息提示插件&#xff0c;基于JQuery&#xff0c;使用简单方便&#xff0c;外观大气漂亮。 点击这里进入toastr在线调试使用 点击这里进入toastr官方网站 使用效果如下图所示&#xff1a; 插件使用需要引用的JS和CSS文件如下图所示&#xff1a; 各版…
阅读更多...
《Spring Recipes》第二章笔记：Creating Beans by Invokin...

《Spring Recipes》第二章笔记：Creating Beans by Invokin...

2019独角兽企业重金招聘Python工程师标准>>> 《Spring Recipes》第二章笔记&#xff1a;Creating Beans by Invoking an Instance Factory Method 问题 用户希望使用工厂类来实例化bean。 解决方案 Spring的bean元素中提供了factory-bean属性来配置工厂类&#xff0…
阅读更多...
JQuery Datatables editor进行增删改查操作(一)

JQuery Datatables editor进行增删改查操作(一)

背景 editor作为Datatables的插件之一&#xff0c;功能十分强大&#xff0c;有全行编辑模式、泡泡编辑模式、行内编辑模式。个人觉得&#xff0c;除了泡泡编辑模式外&#xff0c;其他两种模式功能在实际项目中会经常使用到&#xff0c;泡泡模式提供了模态框可以对表格内的数据…
阅读更多...
将C#中DateTime类型转化为JavaScript中的Date类型

将C#中DateTime类型转化为JavaScript中的Date类型

将C#中的DateTime类型数据返回到前端页面时&#xff0c;显示的样子如下图所示&#xff1a; 可以用JS前端操作转化成JS的Date格式&#xff0c;直接上代码 &#xff1a; // 对Date的扩展&#xff0c;将 Date 转化为指定格式的String // 月(M)、日(d)、小时(h)、分(m)、秒(s)、季…
阅读更多...
如何在ashx页面获取Session值 (仅供个人参考)

如何在ashx页面获取Session值 (仅供个人参考)

在一般事务处理页面&#xff0c;可以轻松的得到 Request,Response对象&#xff0c;从而进行相应的操作&#xff0c;如下&#xff1a; HttpRequest Request context.Request; HttpResponse Response context.Response; 但是要得到 Session的值就没有那么简单了。比如你要在as…
阅读更多...
FusionCharts V3图表导出图片和PDF属性说明

FusionCharts V3图表导出图片和PDF属性说明

百闻不如一见&#xff0c;狠狠点击&#xff0c;快快下载&#xff1a;&#xff08;演示文档有错误&#xff0c;不提供下载了。待新的演示文档出来。&#xff09; 许多朋友说上面的DEMO用不了。fusioncharts官方的演示非常不错&#xff0c;就是来不及整理&#xff0c;各位大侠们…
阅读更多...
JQuery Datatables editor进行增删改查操作(二)

JQuery Datatables editor进行增删改查操作(二)

背景 上一篇对editor进行了一个基本功能的初始化操作演示&#xff0c;本文进一步了解下editor在上一篇文章功能的基础上添加了部分常用基本功能。 整体界面如下图所示&#xff1a; 新增界面&#xff1a; 新增界面增加了单选按钮&#xff0c;下拉框&#xff0c;和时间选择器&am…
阅读更多...
最新文章

Copyright @ 2022~2023