EntityFramework用法探索（八）事務處理

使用前文中描述的Retail示例，在Customer對象的Mapping中設置Name屬性：

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

要求該屬性不能為空，並且長度不超過256。

我們構造一個有效的Customer對象，再構造一個無效的Name屬性為空的對象。

      DomainModels.Customer customer1 = new DomainModels.Customer()
      {
        Name = "Dennis Gao",
        Address = "Beijing",
        Phone = "18888888888",
      };
      DomainModels.Customer customer2 = new DomainModels.Customer()
      {
        //Name = "Degang Guo", // 創造一個無效的對象，此處客戶名稱不能為空
        Address = "Beijing",
        Phone = "16666666666",
      };

我們使用如下代碼添加Customer對象數據到數據庫中，

      Customer entity1 = Mapper.Map<DomainModels.Customer, Customer>(customer1);
      Customer entity2 = Mapper.Map<DomainModels.Customer, Customer>(customer2);

      using (RetailEntities context = new RetailEntities())
      {
        context.Customers.Add(entity1);
        context.Customers.Add(entity2);
        context.SaveChanges(); // 提交時將拋出異常

        customer1.Id = entity1.Id;
        customer2.Id = entity2.Id;
      }

      Console.WriteLine(customer1);
      Console.WriteLine(customer2);

得到結果：

EntityFramework已經明確的告訴我們某Entity驗證失敗。此時查詢數據庫，兩條記錄均不存在。EntityFramework自帶的事務已經幫助回滾了操作。

現在我們修改下程序，改為提交兩次：

      try
      {
        using (RetailEntities context = new RetailEntities())
        {
          context.Customers.Add(entity1);
          context.SaveChanges(); // 順利執行
          context.Customers.Add(entity2);
          context.SaveChanges(); // 提交時將拋出異常

          customer1.Id = entity1.Id;
          customer2.Id = entity2.Id;
        }
      }
      catch (Exception ex)
      {
        Console.WriteLine(FlattenException(ex));
      }

此時得到結果：

通過查詢，可以確定，第一條數據已經被成功保存。

然后我們修改代碼，增加TransactionScope，

        using (var transactionScope = new TransactionScope(
          TransactionScopeOption.RequiresNew))
        {
          Customer entity1 = Mapper.Map<DomainModels.Customer, Customer>(customer1);
          Customer entity2 = Mapper.Map<DomainModels.Customer, Customer>(customer2);

          using (RetailEntities context = new RetailEntities())
          {
            context.Customers.Add(entity1);
            context.SaveChanges(); // 順利提交
            context.Customers.Add(entity2);
            context.SaveChanges(); // 提交時將拋出異常

            customer1.Id = entity1.Id;
            customer2.Id = entity2.Id;
          }

          transactionScope.Complete();
        }
      }
      catch (Exception ex)
      {
        Console.WriteLine(FlattenException(ex));
      }

此時，仍然在第二個SaveChanges()處拋出異常，但第一個SaveChanges()的提交也被回滾了。

證明事務Scope起到了作用。

完整代碼和索引

EntityFramework用法探索系列

• （一）DatabaseFirst
• （二）CodeFirst
• （三）CodeFirst流暢API
• （四）Repository和UnitOfWork
• （五）引入Unity
• （六）靜態Repository
• （七）線程安全實踐
• （八）事務處理

完整代碼下載