EF中关于TransactionScope的使用

时间 2019-12-11

标签关于 transactionscope 使用繁體版

原文原文链接

前提条件

TransactionScope类须要引用System.Transactions;

数据库环境及需求

如今假设有两个表如图：数据库

　　　　　　　　　　　表TA 　　　　　　　　　表TB ide

现有数据：　　　　　　　　　　　　　　　　　　　　　 spa

如今的需求是：每往TA中插入一条数据，就更新TB的第一行，值为表TA的全部行的Age的平均值3d

能够看到表TB的Remark长度仅仅为2，待会利用这个制造错误code

当不使用TransactionScope时：

 using (EFTestEntities db = new EFTestEntities())
            {
                //数据库TA原有2行，此时添加第3行
                var aEntity = new TA
                {
                    Name = "a",
                    Age = 20
                };
                db.TA.Add(aEntity);

                var listTA = db.TA.ToList();//此时list只有2行，新添加的没有读取到
                int totalAge = 0;
                listTA.ForEach(p => totalAge += p.Age);

                //获取表TB的第一行，并修改AvgAge值
                var bEntity = db.TB.First();
                bEntity.AvgAge = totalAge / listTA.Count;
                bEntity.Remark = "bb";
                db.SaveChanges();
                //结果是Tb的值没有变化
            }

View Code

你认为是添加TA后没有db.SaveChanges();？的确，添加这个以后，能够读取到新添加的值了，可是没有事务了，如：blog

using (EFTestEntities db = new EFTestEntities())
            {
                //数据库TA原有2行，此时添加第3行
                var aEntity = new TA
                {
                    Name = "a",
                    Age = 20
                };
                db.TA.Add(aEntity);
                db.SaveChanges();

                var listTA = db.TA.ToList();//此时list有3行了，新添加的能够被读取到
                int totalAge = 0;
                listTA.ForEach(p => totalAge += p.Age);

                //获取表TB的第一行，并修改AvgAge值
                var bEntity = db.TB.First();
                bEntity.AvgAge = totalAge / listTA.Count;
                bEntity.Remark = "bbc";//故意超出长度，制造错误
                db.SaveChanges();
                //结果是TA添加了新行，可是TB修改时出错致使修改失败。形成了数据不一致
            }

View Code

结果是TA添加了新行，可是TB由于remark超出长度致使致使修改失败，此时TB的数据是错的。事务

怎样能够避免这个问题？答案就是用事务。rem

使用TransactionScope：

using (EFTestEntities db = new EFTestEntities())
            {
                using (TransactionScope ts = new TransactionScope())
                {
                    //数据库TA原有2行，此时添加第3行
                    var aEntity = new TA
                    {
                        Name = "a",
                        Age = 20
                    };
                    db.TA.Add(aEntity);
                    db.SaveChanges();//重点，必需要db.SaveChanges()，而后下面才能获取到新添加的行

                    var listTA = db.TA.ToList();//此时list有3行了，新添加的能够被读取到
                    int totalAge = 0;
                    listTA.ForEach(p => totalAge += p.Age);

                    //获取表TB的第一行，并修改AvgAge值
                    var bEntity = db.TB.First();
                    bEntity.AvgAge = totalAge / listTA.Count;
                    bEntity.Remark = "bbc";//故意超出长度，制造错误
                    db.SaveChanges(); //执行到此处程序报错

                    ts.Complete();//事务提交未执行
                    //结果是自动回滚，至关于这次没有对数据库作任何操做。保持了数据一致性
                }
            }

View Code

下面给出正确的示例，实现以上需求：it

using (EFTestEntities db = new EFTestEntities())
            {
                using (TransactionScope ts = new TransactionScope())
                {
                    //数据库TA原有2行，此时添加第3行
                    var aEntity = new TA
                    {
                        Name = "a",
                        Age = 20
                    };
                    db.TA.Add(aEntity);
                    db.SaveChanges();//重点，必需要db.SaveChanges()，而后下面才能获取到新添加的行

                    var listTA = db.TA.ToList();//此时list有3行了，新添加的能够被读取到
                    int totalAge = 0;
                    listTA.ForEach(p => totalAge += p.Age);

                    //获取表TB的第一行，并修改AvgAge值
                    var bEntity = db.TB.First();
                    bEntity.AvgAge = totalAge / listTA.Count;
                    bEntity.Remark = "bb";//数据符合规范
                    db.SaveChanges(); //保存

                    ts.Complete();//提交事务
                    //结果是执行成功，TA多一条数据，同时TB的值也变了
                }
            }

View Code

一切都nice了！io