EntityFramework用法探索(八)事务处理

简介:

使用前文中描述的Retail示例,在Customer对象的Mapping中设置Name属性:

1       this.Property(t => t.Name)
2           .IsRequired()
3           .HasMaxLength(256);

要求该属性不能为空,并且长度不超过256。

我们构造一个有效的Customer对象,再构造一个无效的Name属性为空的对象。

复制代码
 1       DomainModels.Customer customer1 = new DomainModels.Customer()
 2       {
 3         Name = "Dennis Gao",
 4         Address = "Beijing",
 5         Phone = "18888888888",
 6       };
 7       DomainModels.Customer customer2 = new DomainModels.Customer()
 8       {
 9         //Name = "Degang Guo", // 创造一个无效的对象,此处客户名称不能为空
10         Address = "Beijing",
11         Phone = "16666666666",
12       };
复制代码

我们使用如下代码添加Customer对象数据到数据库中,

复制代码
 1       Customer entity1 = Mapper.Map<DomainModels.Customer, Customer>(customer1);
 2       Customer entity2 = Mapper.Map<DomainModels.Customer, Customer>(customer2);
 3 
 4       using (RetailEntities context = new RetailEntities())
 5       {
 6         context.Customers.Add(entity1);
 7         context.Customers.Add(entity2);
 8         context.SaveChanges(); // 提交时将抛出异常
 9 
10         customer1.Id = entity1.Id;
11         customer2.Id = entity2.Id;
12       }
13 
14       Console.WriteLine(customer1);
15       Console.WriteLine(customer2);
复制代码

得到结果:

EntityFramework已经明确的告诉我们某Entity验证失败。此时查询数据库,两条记录均不存在。EntityFramework自带的事务已经帮助回滚了操作。

现在我们修改下程序,改为提交两次:

复制代码
 1       try
 2       {
 3         using (RetailEntities context = new RetailEntities())
 4         {
 5           context.Customers.Add(entity1);
 6           context.SaveChanges(); // 顺利执行
 7           context.Customers.Add(entity2);
 8           context.SaveChanges(); // 提交时将抛出异常
 9 
10           customer1.Id = entity1.Id;
11           customer2.Id = entity2.Id;
12         }
13       }
14       catch (Exception ex)
15       {
16         Console.WriteLine(FlattenException(ex));
17       }
复制代码

此时得到结果:

通过查询,可以确定,第一条数据已经被成功保存。

然后我们修改代码,增加TransactionScope,

复制代码
 1         using (var transactionScope = new TransactionScope(
 2           TransactionScopeOption.RequiresNew))
 3         {
 4           Customer entity1 = Mapper.Map<DomainModels.Customer, Customer>(customer1);
 5           Customer entity2 = Mapper.Map<DomainModels.Customer, Customer>(customer2);
 6 
 7           using (RetailEntities context = new RetailEntities())
 8           {
 9             context.Customers.Add(entity1);
10             context.SaveChanges(); // 顺利提交
11             context.Customers.Add(entity2);
12             context.SaveChanges(); // 提交时将抛出异常
13 
14             customer1.Id = entity1.Id;
15             customer2.Id = entity2.Id;
16           }
17 
18           transactionScope.Complete();
19         }
20       }
21       catch (Exception ex)
22       {
23         Console.WriteLine(FlattenException(ex));
24       }
复制代码

此时,仍然在第二个SaveChanges()处抛出异常,但第一个SaveChanges()的提交也被回滚了。

证明事务Scope起到了作用。

完整代码和索引

EntityFramework用法探索系列

完整代码下载





本文转自匠心十年博客园博客,原文链接:http://www.cnblogs.com/gaochundong/archive/2013/06/09/entityframework_usage_transaction_scope.html,如需转载请自行联系原作者


目录
相关文章
|
7月前
|
SQL 存储 开发框架
EntityFramework数据持久化复习资料6、EntityFramework引入
EntityFramework数据持久化复习资料6、EntityFramework引入
55 0
|
关系型数据库 MySQL PHP
MySQL事务的四种隔离类型以及PHP框架Yii2中的源码解读和实际应用
MySQL事务的四种隔离类型以及PHP框架Yii2中的源码解读和实际应用
373 0
|
SQL 关系型数据库 数据库
|
数据库 .NET 开发框架
【译】EntityFramework6与EntityFrameworkCore的区别
EntityFramework6 EF6 是一个久经考验的数据库访问技术,发展多年,拥有许多特性,并且成熟稳定。2008年EF作为 .Net 3.5 Sp1 和Visual Studio 2008 SP1 的一部分首次发布。
1465 0