如何处理Entity Framework中的DbUpdateConcurrencyException异常

时间:2021-08-27 07:55:41

1. Concurrency的作用

场景

有个修改用户的页面功能,我们有一条数据User, ID是1的这个User的年龄是20, 性别是female(数据库中的原始数据)

正确的该User的年龄是25, 性别是male

这个时候A发现User的年龄不对, 就给改成25, 那么在Entity Framework中,我们会这样做。

var user = dbConext.User.Find();

//B用户在这里完成修改了User的性别

user.age = ;

dbContext.SaveChanges();

但是加入在上面注释处,有个B用户发现性别不对,完成了对用户性别的修改,改成male. 会出现什么结果呢。

var user = dbConext.User.Find(1);

当A执行这个代码的时候,获取的性别是female

user.age = 25;

当A执行这个代码的时候, 不知道B已经修改了这个记录的性别,这个时候A的user的性别还是female

dbContext.SaveChanges();

保存修改的时候,会把female覆盖回去,这样B用户的修改就作废了。

但这不是A的本意,A其实只是想修改年龄而已。

Entity Framework使用[ConcurrencyCheck] 来解决这种问题, 当标记为[ConcurrencyCheck] 的Entity属性,如果发现在从数据库中取下来和提交的时候不一致,就会出现DbUpdateConcurrencyException异常,避免错误提交。

2. 如何正确处理DbUpdateConcurrencyException异常

2.1 数据库优先方式

原理是在出现异常的时候,重新加载数据库中的数据,覆盖Context本地数据

using (var context = new BloggingContext())
{
  var blog = context.Blogs.Find();
  blog.Name = "The New ADO.NET Blog";  
  bool saveFailed;
  do
  {
    saveFailed = false;
    try
    {
      context.SaveChanges();
    }
    catch (DbUpdateConcurrencyException ex)
    {
      saveFailed = true;
      // Update the values of the entity that failed to save from the store
      ex.Entries.Single().Reload();
    }
  } while (saveFailed);
}

 

2.2 客户端优先方式

以Context保存的客户端数据为主,覆盖数据库中的数据

using (var context = new BloggingContext())
{
  var blog = context.Blogs.Find();
  blog.Name = "The New ADO.NET Blog";
  bool saveFailed;
  do
  {
    saveFailed = false;
    try
    {
      context.SaveChanges();
    }
    catch (DbUpdateConcurrencyException ex)
    {
      saveFailed = true;
      // Update original values from the database
      var entry = ex.Entries.Single();
      entry.OriginalValues.SetValues(entry.GetDatabaseValues());
    }
  } while (saveFailed);
}

3.3 综合方式

有时候,不是非A即B的关系,我们希望综合数据库中的数据和context中修改的数据,再保存到数据库中

使用下面的CurrentValues, GetDatabaseValues(), 得到Context数据和数据库数据,重新构建一个正确的Entity,再更新到数据库中

using (var context = new BloggingContext())
{
  var blog = context.Blogs.Find();
  blog.Name = "The New ADO.NET Blog";
  bool saveFailed;
  do
  {
    saveFailed = false;
    try
    {
      context.SaveChanges();
    }
    catch (DbUpdateConcurrencyException ex)
    {
      saveFailed = true;
      // Get the current entity values and the values in the database
      var entry = ex.Entries.Single();
      var currentValues = entry.CurrentValues;
      var databaseValues = entry.GetDatabaseValues();
      // Choose an initial set of resolved values. In this case we
      // make the default be the values currently in the database.
      var resolvedValues = databaseValues.Clone();
      // Have the user choose what the resolved values should be
      HaveUserResolveConcurrency(currentValues, databaseValues, resolvedValues);
      // Update the original values with the database values and
      // the current values with whatever the user choose.
      entry.OriginalValues.SetValues(databaseValues);
      entry.CurrentValues.SetValues(resolvedValues);
    }
  } while (saveFailed);
}
public void HaveUserResolveConcurrency(DbPropertyValues currentValues,
DbPropertyValues databaseValues,
DbPropertyValues resolvedValues)
{
  // Show the current, database, and resolved values to the user and have
  // them edit the resolved values to get the correct resolution.
}

对上面方法的优化

使用DbPropertyValues总是别扭,使用Enttiy对象就会方便很多,下面就是转换成Entity对象操作的方法

using (var context = new BloggingContext())
{
  var blog = context.Blogs.Find();
  blog.Name = "The New ADO.NET Blog";
  bool saveFailed;
  do
  {
    saveFailed = false;
    try
    {
      context.SaveChanges();
    }
    catch (DbUpdateConcurrencyException ex)
    {
      saveFailed = true;
      // Get the current entity values and the values in the database
      // as instances of the entity type
      var entry = ex.Entries.Single();
      var databaseValues = entry.GetDatabaseValues();
      var databaseValuesAsBlog = (Blog)databaseValues.ToObject();
      // Choose an initial set of resolved values. In this case we
      // make the default be the values currently in the database.
      var resolvedValuesAsBlog = (Blog)databaseValues.ToObject();
      // Have the user choose what the resolved values should be
      HaveUserResolveConcurrency((Blog)entry.Entity,
        databaseValuesAsBlog,
        resolvedValuesAsBlog);
      // Update the original values with the database values and
      // the current values with whatever the user choose.
      entry.OriginalValues.SetValues(databaseValues);
      entry.CurrentValues.SetValues(resolvedValuesAsBlog);
    }
  } while (saveFailed);
}
public void HaveUserResolveConcurrency(Blog entity,
  Blog databaseValues,
  Blog resolvedValues)
{
// Show the current, database, and resolved values to the user and have
// them update the resolved values to get the correct resolution.
}

 

 
 

如何处理Entity Framework中的DbUpdateConcurrencyException异常的更多相关文章

  1. 如何处理Entity Framework / Entity Framework Core中的DbUpdateConcurrencyException异常(转载)

    1. Concurrency的作用 场景有个修改用户的页面功能,我们有一条数据User, ID是1的这个User的年龄是20, 性别是female(数据库中的原始数据)正确的该User的年龄是25, ...

  2. 在Entity Framework中使用事务

    继续为想使用Entity Framework的朋友在前面探路,分享的东西虽然技术含量不高,但都是经过实践检验的. 在Entity Framework中使用事务很简单,将操作放在TransactionS ...

  3. Entity Framework 教程——Entity Framework中的实体类型

    Entity Framework中的实体类型 : 在之前的章节中我们介绍过从已有的数据库中创建EDM,它包含数据库中每个表所对应的实体.在EF 5.0/6.0中,存在POCO 实体和动态代理实体两种. ...

  4. 关于Entity Framework中的Attached报错相关解决方案的总结

    关于Entity Framework中的Attached报错的问题,我这里分为以下几种类型,每种类型我都给出相应的解决方案,希望能给大家带来一些的帮助,当然作为读者的您如果觉得有不同的意见或更好的方法 ...

  5. 关于Entity Framework中的Attached报错的完美解决方案终极版

    之前发表过一篇文章题为<关于Entity Framework中的Attached报错的完美解决方案>,那篇文章确实能解决单个实体在进行更新.删除时Attached的报错,注意我这里说的单个 ...

  6. &lbrack;转&rsqb;在Entity Framework中使用LINQ语句分页

    本文转自:http://diaosbook.com/Post/2012/9/21/linq-paging-in-entity-framework 我们知道,内存分页效率很低.并且,如果是WebForm ...

  7. Entity Framework中的多个库操作批量提交、事务处理

    在Entity Framework 中使用SaveChanges()是很频繁的,单次修改或删除数据后调用SaveChanges()返回影响记录数. 要使用批量修改或者批量删除数据,就需要SaveCha ...

  8. LinqToSql和ASP&period;NET Entity FrameWork 中使用事务

    ASP.NET Entity FrameWork中: int flag = -1; if (this.URPmanagementEntities1.Connection.State != System ...

  9. Lazy&lt&semi;T&gt&semi;在Entity Framework中的性能优化实践

    Lazy<T>在Entity Framework中的性能优化实践(附源码) 2013-10-27 18:12 by JustRun, 328 阅读, 4 评论, 收藏, 编辑 在使用EF的 ...

随机推荐

  1. spring mvc 中文参数乱码

    最近做项目,springmvc的url中文参数乱码: 请求url: http://localhost:8080/supply/supply_list.htm?productName=测试&is ...

  2. 如此低价的ZBrush,你能想象?

      作为3D艺术的*者,你是否曾为找不到一款适合自己的雕刻软件而苦恼?要么,你已经找到了,却因为昂贵的价格而迟迟不肯入手? 作为改变整个三维行业的业界先进的数字雕刻和绘画软件,ZBrush向来拥有广 ...

  3. win7刷新图标缓存

    建立bat文件 rem 关闭explorer.exetaskkill /f /im explorer.exeattrib -h -i %userprofile%\AppData\Local\IconC ...

  4. vim配置及插件安装管理(超级详细)&lbrack;转&rsqb;

    1 写在前面   Linux下编程一直被诟病的一点是: 没有一个好用的IDE, 但是听说Linux牛人, 黑客之类的也都不用IDE. 但是对我等从Windows平台转移过来的Coder来说, 一个好用 ...

  5. html5 canvas图片渐变

    <!doctype html> <html> <head> <meta charset="utf-8"> <title> ...

  6. JDBC的批量查询报告内存溢出解决方法

    由于表中的数据过多(我的超过了50W+),查询select * from table ....报告内存溢出 Exception in thread "main" java.lang ...

  7. spring boot &sol; cloud &lpar;十二&rpar; 异常统一处理进阶

    spring boot / cloud (十二) 异常统一处理进阶 前言 在spring boot / cloud (二) 规范响应格式以及统一异常处理这篇博客中已经提到了使用@ExceptionHa ...

  8. RecyclerView下拉刷新上拉加载(一)

    listview下拉刷新上拉加载扩展(一) http://blog.csdn.net/baiyuliang2013/article/details/50252561 listview下拉刷新上拉加载扩 ...

  9. RQNOJ 1 明明的随机数

    查重和排序,这里我用的set进行存储数据,利用了set的唯一性和自动性,方便了很多 #include <iostream> using namespace std; #include &l ...

  10. android -------- 解决NDK开发中的 Method &&num;39&semi;NewStringUTF&&num;39&semi; could not be resolved

    创建NDK项目时, .cpp文件中出现错误, Method 'NewStringUTF' could not be resolved 如图: 网上看了很多解决方式 项目右键->属性->c/ ...