事務處理

EF支持事務處理操作，以下語句會獲取當前DbContext對象專用的DbContextTransaction事務處理的對象：

DbContextTransaction transaction = context.Database.BeginTransaction()

獲取transaction之后，期間任何與context有關的數據均會被納入此事務處理的范圍。

調用transaction.Commit方法即可完成事務處理，若要放棄事務處理，調用transaction.Rollback方法即可，以下列舉相關語句：

using(var transaction = context.Database.BeginTransaction) {//事務處理操作 }

using語句是建立事務處理的常見語句，在結構上也比較容易理解，一旦using語句結束，transaction對象便自動調用Dispose回收事務處理對象。

下面通過一段示例代碼來說明：

假設存在如下圖實體類：

public class Product{public int Id { get; set; }public string Name { get; set; }public int Price { get; set; }public int SPrice { get; set; }}

編寫一段事務代碼如下圖所示：

static void Main(string[] args) {using (KTStoreModel context = new KTStoreModel()){using (var transaction = context.Database.BeginTransaction()){try{var products = context.Product;foreach (Product product in products){int p = (int)(product.Price * 0.5);product.SPrice = p;}int c = context.SaveChanges();transaction.Commit();Console.WriteLine("更新了{0}項數據",c);}catch(Exception ex){transaction.Rollback();Console.WriteLine("事務處理失敗");}}} }

?

---

共享事務處理連接?

?不同的context對象可以通過共享連接將數據的更新操作合并在相同的事務處理范圍中，參考以下的設置：

KTStoreContext context_s = new kTStoreContext (context.Database.Connection,contextOwnsConnection:false )

為了共享事務處理，因此調用另一個版本的構造函數創建所需的context對象：除此之外，還要指定使用此連接的事務處理環境。

context_s.Database.UseTransaction(transaction.UnderlyingTransaction);

完成以上設置，context與context_s就會同時被限定在同一個事務處理范圍中。?

?列舉如下一個代碼例子：

首先需要新增上下文類中的構造函數：

public class ConcurrencyCheckModel : DbContext {public ConcurrencyCheckModel(): base("name=ConcurrencyCheckModel"){}public ConcurrencyCheckModel(DbConnection conn, bool contextOwnsConnection) : base(conn, contextOwnsConnection)//新增構造函數{}public virtual DbSet<Product> Product { get; set; } } static void Main(string[] args) {using (ConcurrencyCheckModel context = new ConcurrencyCheckModel()){using (var transaction = context.Database.BeginTransaction()){try{var products = context.Product;foreach (Product product in products){int p = (int)(product.Price * 0.5);product.SPrice = p;}int c = context.SaveChanges();ConcurrencyCheckModel context_s = new ConcurrencyCheckModel(context.Database.Connection, contextOwnsConnection: false);context_s.Database.UseTransaction(transaction.UnderlyingTransaction);context_s.Database.ExecuteSqlCommand("Update product set SPrice = 0 Where Id = 10");transaction.Commit();Console.WriteLine("更新了{0}項數據",c);}catch (Exception ex){transaction.Rollback();Console.WriteLine("處理事務失敗:{0}",ex.ToString());}}} }

---

?

?

?

?

?

?

?

?

總結

以上是生活随笔為你收集整理的EntityFramework进阶——事务的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。