EF6中使用事務的方法

默認情況當你執行SaveChanges()的時候（insert update delete）來操作數據庫時，Entity Framework會把這個操作包裝在一個事務里，當操作結束后，事務也結束了。

EF6中的 Database.ExecuteSqlCommand()也會啟用一個事務，事務的隔離級別是默認級別（Read Commited）。

雖然這種框架默認的事務處理機制對於大多數情況下已經夠用了，但是是EF6為我們提供了API，讓我們能夠更加靈活地對自己代碼中的事務進行控制。

一、在EF中使用事務

1. using System;
2. using System.Collections.Generic;
3. using System.Data.Entity;
4. using System.Data.SqlClient;
5. using System.linq;
6. using System.Transactions;
8. namespace TransactionsExamples
9. {
10. class TransactionsExample
11. {
12. static void StartOwnTransactionWithinContext()
13. {
14. using (var context = new BloggingContext())
15. {
16. using (var dbContextTransaction = context.Database.BeginTransaction())
17. {
18. try
19. {
20. context.Database.ExecuteSqlCommand(
21. @"UPDATE Blogs SET Rating = 5" +
22. " WHERE Name LIKE '%Entity Framework%'"
23. );
25. var query = context.Posts.Where(p => p.Blog.Rating >= 5);
26. foreach (var post in query)
27. {
28. post.Title += "[Cool Blog]";
29. }
31. context.SaveChanges();
33. dbContextTransaction.Commit();
34. }
35. catch (Exception)
36. {
37. dbContextTransaction.Rollback();
38. }
39. }
40. }
41. }
42. }
43. }

 

上面通過一個using語句塊把要使用事務的操作起來，調用context.Database.BeginTransaction()啟動一個事務，最后分別通過dbContextTransaction.Commit();和dbContextTransaction.Rollback();來提交或回滾事務。

注意：開啟一個事務需要事務所有在的數據庫鏈接是打開的，因此當所在數據庫鏈接沒有打開時Database.BeginTransaction()就會打開一個數據庫鏈接。上面調用context.Database.BeginTransaction()是沒有參數的，你可以調用這個BeginTransaction()其它重載函數來控制事務的隔離級別，如果沒傳參數將會使用默認的隔離級別。

 

二、傳遞一個已存在的事務

EF中可以傳遞一個存在的事務給context：

 

1. using System;
2. using System.Collections.Generic;
3. using System.Data.Entity;
4. using System.Data.SqlClient;
5. using System.Linq;
6. sing System.Transactions;
8. namespace TransactionsExamples
9. {
10. class TransactionsExample
11. {
12. static void UsingExternalTransaction()
13. {
14. using (var conn = new SqlConnection("..."))
15. {
16. conn.Open();
18. using (var sqlTxn = conn.BeginTransaction(System.Data.IsolationLevel.Snapshot))
19. {
20. try
21. {
22. var sqlCommand = new SqlCommand();
23. sqlCommand.Connection = conn;
24. sqlCommand.Transaction = sqlTxn;
25. sqlCommand.CommandText =
26. @"UPDATE Blogs SET Rating = 5" +
27. " WHERE Name LIKE '%Entity Framework%'";
28. sqlCommand.ExecuteNonQuery();
30. using (var context =
31. new BloggingContext(conn, contextOwnsConnection: false))
32. {
33. context.Database.UseTransaction(sqlTxn);
35. var query = context.Posts.Where(p => p.Blog.Rating >= 5);
36. foreach (var post in query)
37. {
38. post.Title += "[Cool Blog]";
39. }
40. context.SaveChanges();
41. }
43. sqlTxn.Commit();
44. }
45. catch (Exception)
46. {
47. sqlTxn.Rollback();
48. }
49. }
50. }
51. }
52. }
53. }

  

三、TransactionScope事務

EF中讓多個數據庫操作作為一個整體的事務來處理除了上面使用事務傳遞來實現外，還可以利用TransactionScope對象來處理，如下：

1. using System.Collections.Generic;
2. using System.Data.Entity;
3. using System.Data.SqlClient;
4. using System.Linq;
5. using System.Transactions;
7. namespace TransactionsExamples
8. {
9. class TransactionsExample
10. {
11. static void UsingTransactionScope()
12. {
13. using (var scope = new TransactionScope(TransactionScopeOption.Required))
14. {
15. using (var conn = new SqlConnection("..."))
16. {
17. conn.Open();
19. var sqlCommand = new SqlCommand();
20. sqlCommand.Connection = conn;
21. sqlCommand.CommandText =
22. @"UPDATE Blogs SET Rating = 5" +
23. " WHERE Name LIKE '%Entity Framework%'";
24. sqlCommand.ExecuteNonQuery();
26. using (var context =
27. new BloggingContext(conn, contextOwnsConnection: false))
28. {
29. var query = context.Posts.Where(p => p.Blog.Rating > 5);
30. foreach (var post in query)
31. {
32. post.Title += "[Cool Blog]";
33. }
34. context.SaveChanges();
35. }
36. }
38. scope.Complete();
39. }
40. }
41. }
42. }

 

注意：上面提交事務是通過TransactionScope實例的Complete方法來提交的。

可以看到使用TransactionScope使我們代碼簡化了不少，但是要注意的是TransactionScope也有一些限制：

1、需要NET 4.5.1及以上

2、不能和Database.UseTransaction()方式結合起來使用

3、sql語句中不能有DLL操作

4、不能在雲場景中使用，除非你保證只有一個數據庫連接。（支場景中不支持分布式事務）