EntityFramework Core并发导致显式插入主键问题

简介: 前言 之前讨论过EntityFramework Core中并发问题,按照官网所给并发冲突解决方案以为没有什么问题,但是在做单元测试时发现too young,too simple,下面我们一起来看看。 .NET Core 1.1单元测试问题 我们循序渐进,首先从单元测试开始说起,可能其中就有你在.NET Core上进行单元测试会遇到的问题,别着急,不妨一看。

前言

之前讨论过EntityFramework Core中并发问题,按照官网所给并发冲突解决方案以为没有什么问题,但是在做单元测试时发现too young,too simple,下面我们一起来看看。

.NET Core 1.1单元测试问题

我们循序渐进,首先从单元测试开始说起,可能其中就有你在.NET Core上进行单元测试会遇到的问题,别着急,不妨一看。我们需要创建.NET Core类库,,如下:

接下来对project.json进行如下修改。

{
    "version": "1.0.0-*",
    "testRunner": "xunit",
    "dependencies": {
        "xunit": "2.2.0-beta2-build3300",
        "dotnet-test-xunit": "2.2.0-preview2-build1029"
    },
    "frameworks": {
        "netcoreapp1.0": {
            "dependencies": {
                "Microsoft.NETCore.App": {
                    "type": "platform",
                    "version": "1.0.0"
                }
            }
        }
    }
}

此时运行单元测试肯定是好使的,由于.NET Core最新为1.1版本此时我们将其版本修改为1.1如下:

"frameworks": {
    "netcoreapp1.1": {
      "dependencies": {
        "Microsoft.NETCore.App": {
          "type": "platform",
          "version": "1.1.0"
        }
      }
    }
  }

此时我们写一个测试方法,如下:

    public class Test
    {
        [Fact]
        public void PassingTest()
        {
            Assert.Equal(4, Add(2, 2));
        }

        int Add(int x, int y)
        {
            return x + y;
        }
    }

此时运行会出现如下dotnet.exe出现异常关闭。

结果让我们大跌眼镜,根本不知道什么地方出错了,此时你再运行单元测试,因为dotnet.exe已经关闭将导致单元测试无法启动,于是乎我们通过 dotnet test 命令来运行看能否得到一点错误提示,结果还是让我找到了原因。

无法加载 Microsoft.DotNet.InternalAbstractions 程序集,此时我们添加该程序集再看看,如下。

"Microsoft.DotNet.InternalAbstractions": "1.0.1-beta-003206"

完美,结果测试通过,至此关于单元测试我们有必要做下结论:官网所给对应的是针对于.net core 1.0版本,运行测试没问题,若是.net core 1.1版本需要添加 Microsoft.DotNet.InternalAbstractions 包。我是从github上才找到解决方案https://github.com/xunit/xunit/issues/1031,需要添加上述依赖包才可。

EntityFramework Core 1.1并发导致显式插入主键问题 

我们从头讲起,在仓储接口中定义插入Blog的接口,如下:

    public interface IBlogRepository : IEntityBaseRepository<Blog>
    {

        void Create(Blog b);
    }

然后则是实现该接口了,如下:

    public class BlogRepository : EntityBaseRepository<Blog>,
        IBlogRepository
    {
        private EFCoreContext _efCoreContext;
        public BlogRepository(EFCoreContext efCoreContext) : base(efCoreContext)
        {
            _efCoreContext = efCoreContext;
        }

        public void Create(Blog b)
        {
            try
            {
                using (var transaction = _efCoreContext.Database.BeginTransaction())
                {

                    _efCoreContext.Blogs.Add(b);
                    _efCoreContext.SaveChanges();
                    transaction.Commit();
                }

            }
            catch (DbUpdateConcurrencyException ex)
            {...}
         }
   }

接下来一切准备就绪,我们来开始进行单元测试,我们开启两个线程来测试看看。

        [Fact]
        public void TestEFCore()
        {
            var blog = new Blog()
            {
                Name = "Jeffcky",
                Url = "http://www.cnblogs.com/CreateMyself",
                Posts = new List<Post>() { new Post() { Title = "a", Content = "ss" } }

            };

            var tasks = new Task[2];
            for (int i = 0; i < tasks.Length; i++)
            {
                tasks[i] = Task.Factory.StartNew(() =>
                {
                    var _contextOptions = new DbContextOptionsBuilder()
             .UseSqlServer("server=WANGPENG;Database=EFCoreDb;Trusted_Connection=True;")
             .Options;
                    using (var efcoreContext = new EFCoreContext(_contextOptions))
                    {
                        var blogRepository = new BlogRepository(efcoreContext);
                        blogRepository.Create(blog);
                    }

                });
            }
            Task.WaitAll(tasks);
        }

此时演示结果如下,测试也通过。

当修改测试所开线程,开启如下5个线程时。

 var tasks = new Task[5];

此时将抛出异常,具体演示结果如下:

具体错误信息显示如下:

当 IDENTITY_INSERT 设置为 OFF 时,不能为表 'Blog' 中的标识列插入显式值。

当然这种情况不是一定会发生,有可能开启两个线程不会出现上述以上异常,有可能会抛出异常。为什么会出现上述异常呢,请看如下图。

当一个线程过来时,正常提交肯定是没问题,但是此时该插入的Blog已经被追踪,仅接着又来一个线程,此时Blog中的Id是上一个线程插入的值,所以会导致我们的Id本来主键是自动增长的,而此时Id却有了值出现上述异常。在项目中很难把握这样的情况,也尝试去修改实体的变更追踪的状态,结果依然出现上述问题,最终采用写SQL语句的方式来实现,如果有能够修改变更追踪解决的方案请在评论中给出。在我们项目中,利用SQL语句的方式来解决EF Core的并发,同时开启200个线程没有出任何问题,当然我们的逻辑也还算有一点复杂,所以不用担心EF Core的性能问题,我们更多的是关心业务逻辑。一直在思考怎么通过不写SQL语句的方式去解决这样的并发问题,我能够想到的是既然传过来的实体插入后会被变更追踪,那么我将传过来的参数再实例化一个对象,然后将参数传给它这样应该就能解决问题。

        public void Create(Blog b)
        {

            var copyBlog = new Blog() { Name = b.Name, Url = b.Url };
            try
            {
                using (var transaction = _efCoreContext.Database.BeginTransaction())
                {
                    _efCoreContext.Blogs.Add(copyBlog);
                    _efCoreContext.SaveChanges();
                    var posts = b.Posts.Select(d => new Post()
                    {
                        BlogId = copyBlog.Id,
                        Content = d.Content,
                        Title = d.Title
                    });
                    _efCoreContext.Set<Post>().AddRange(posts);
                    _efCoreContext.SaveChanges();
                    transaction.Commit();
                }

            }
            catch (DbUpdateConcurrencyException ex)
            {...}
       }

此时我们开启200个线程来跑跑看看,此时测试通过,如下

我们再来看看数据库是否已经插入200条数据。

这个对于并发导致显式插入主键的问题比较另类的做法,如果有更好的方案请在评论区提出来。

总结 

本节我们讨论了有关EF Core中并发导致的问题,尚未找到更加可靠的方案,期待你阅读后给出最佳方案。

目录
相关文章
|
存储 安全 Devops
爆测一周!22年必看最细致代码托管工具测评
网上代码托管选型的文章不少,不过大多内容有点久远,很多最新的平台没有包括进来,个人花了大概一个星期的时间,把目前市面上比较火的代码托管平台(开源托管平台:Github、Gitee;企业级托管平台:Gitlab、阿里云效Codeup、 腾讯Coding)做了一些比较,比较的维度包括速度、成本、产研工具链完整性、安全、统计报表等,希望可以帮助正在进行代码托管选型的技术同行做决策选型。
2306 0
爆测一周!22年必看最细致代码托管工具测评
如何在桌面电脑上使用 SAS 硬盘
SAS 硬盘要想在普通电脑上使用一般比较麻烦,首先是 SAS 不像普通 IDE/SATA 硬盘那样在主板上提供了接口。电源部分倒是通用、无分 SAS/SATA 的。于是我们必须找一张 SAS 卡,一般是 PCI-E 接口的。
5258 0
|
存储 NoSQL 数据库
MongoDB Sharded cluster架构原理
为什么需要Sharded cluster? MongoDB目前3大核心优势:『灵活模式』+ 『高可用性』 + 『可扩展性』,通过json文档来实现灵活模式,通过复制集来保证高可用,通过Sharded cluster来保证可扩展性。 当MongoDB复制集遇到下面的业务场景时,你就需要考虑使用Sh
43338 155
|
监控 Devops 中间件
测试环境不稳定&复杂的必然性及其对策
为什么测试环境的不稳定是必然的,怎么让它尽量稳定一点?为什么测试环境比生产环境更复杂,怎么让它尽量简单一点?本文将就这两点进行分享。同时,还会谈一谈对测试环境和生产环境的区别的理解。
测试环境不稳定&复杂的必然性及其对策
|
消息中间件 SQL JSON
Maxwell采集MySQL Binlog业务库数据同步方案
针对业务库MySQL Binlog日志数据进行数据同步,从MySQL到Kafka,最终实现实时(准实时)数据采集。其中推荐使用MaxWell,此篇文档只是介绍如何通过Maxwell打通上下游数据点。
2844 0
Maxwell采集MySQL Binlog业务库数据同步方案
|
监控 Java Ruby
日志客户端(Logstash,Fluentd, Logtail)横评
针对主流日志采集客户端(Logstash,Fluentd,以及日志服务客户端Logtail)进行功能、性能和稳定性测评
45513 13
|
存储 人工智能 安全
重磅干货不容错过!2017云栖大会汇总资料,速来领取!
2017云栖大会圆满结束!云栖大会由阿里巴巴集团主办,已经成为全球云计算TOP级峰会,汇聚DT时代最强大脑,描绘云计算发展趋势和蓝图,展现云计算、大数据、人工智能蓬勃发展的技术生态全景。云栖社区福利大放送,本文整理了全年8场峰会的资料,约800份技术资料,等你来下载!
110592 0
|
SQL 分布式计算 关系型数据库
Hive 数仓迁移 JindoFS/OSS 数据湖最佳实践
Hive 数仓是大多数迁移客户都会遇到的场景。在迁移过程中,不建议同时在新集群进行业务升级(比如从 Hive on MR 迁移到 Hive on Tez 或 Spark SQL等),这些业务升级可以在迁移完成后进行。1. 元数据同步Hive 元数据是对于 Hive 表来说非常关键,除了表结构信息,里面还记录着 Hive 表与底层文件系统的关联关系,许多上层服务都依赖 Hive 元数据提供服务。a.
1206 0
|
消息中间件 监控 NoSQL
从ELK到EFK演进
背景 作为中国最大的在线教育站点,目前沪江日志服务的用户包含网校,交易,金融,CCTalk 等多个部门的多个产品的日志搜索分析业务,每日产生的各类日志有好十几种,每天处理约10亿条(1TB)日志,热数据保留最近7天数据,冷数据永久保存。
6143 0
|
算法
烟草行业数字化转型,数字化直营门店不可或缺
在店有人零售的场景下如何用数据+AIOT打通业务闭环?
2805 0