[C#] EntityFramework交易寫法 Sample Code

EntityFramework transaction Sample Code

第一種寫法,只需一個db.SaveChanges()即可。

            NorthwindEntities db = new NorthwindEntities();
            

            try
           {
            Product p1 = db.Products.FirstOrDefault(m => m.ProductID == 1);
            p1.UnitPrice -= 1;//修改資料
            
            //假裝這裡意外發生
            throw new Exception("Crash");


            Product p2 = db.Products.FirstOrDefault(m => m.ProductID == 2);
            p2.UnitPrice += 1;//修改資料


            db.SaveChanges(); //都成功才SaveChanges()
            
            }catch(Exception ex)
            {
              
            }

第二種寫法,之前已呼叫過db.SaveChanges(),想Rollback復原資料

須事先加入System.Transactions的參考

 NorthwindEntities db = new NorthwindEntities();
              
            //想要交易的範圍
            using (System.Transactions.TransactionScope scope=new System.Transactions.TransactionScope())
            {
                try
                {
                    Product p1 = db.Products.FirstOrDefault(m => m.ProductID == 1);
                    p1.UnitPrice -= 1;//修改資料
                    db.SaveChanges();//提交變更

                    //假裝意外發生,但之前已執行 db.SaveChanges();
                    throw new Exception("Crash");

                    Product p2 = db.Products.FirstOrDefault(m => m.ProductID == 2);
                    p2.UnitPrice += 1;//修改資料
                    db.SaveChanges();
                    scope.Complete();//都成功
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                } 
            }//end using 
         

上述TransactionScope建構式預設值↓  (最嚴格等級,只要其中一筆交易失敗,就整個失敗,其它連線要讀取異動資料,都必須等待此交易完成)

  NorthwindEntities db = new NorthwindEntities();
     
           
            //想要交易的範圍
            using(TransactionScope scope=new  TransactionScope( TransactionScopeOption.Required,
                                                      new TransactionOptions() { IsolationLevel=IsolationLevel.Serializable})) 
            {
                try
                {
                    Product p1 = db.Products.FirstOrDefault(m => m.ProductID == 1);
                    p1.UnitPrice -= 1;//修改資料
                    db.SaveChanges();//提交變更

                    //假裝意外發生,但之前已執行 db.SaveChanges();
                    throw new Exception("Crash");

                    Product p2 = db.Products.FirstOrDefault(m => m.ProductID == 2);
                    p2.UnitPrice += 1;//修改資料
                    db.SaveChanges();
                    scope.Complete();//都成功
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                } 
            }//end using 
         

※第二種寫法也支援在TransactionScope區塊裡透過ADO.net異動資料庫

要留意scope.Complete();之後不可以再異動&查詢DB資料,否則會出現錯誤:“The current TransactionScope is already complete”

//想要交易的範圍
using (System.Transactions.TransactionScope scope=new System.Transactions.TransactionScope())
{
                try
                {
                    Product p1 = db.Products.FirstOrDefault(m => m.ProductID == 1);
                    p1.UnitPrice -= 1;//修改資料
                    db.SaveChanges();//提交變更
                    scope.Complete();//都成功
 
                    //↓在scope.Complete()之後異動DB資料會報錯
                    Product p2 = db.Products.FirstOrDefault(m => m.ProductID == 2);
                    p2.UnitPrice += 1;//修改資料
                    db.SaveChanges();
                    //↑另一解套方法:把此段異動資料動作移至scope範圍(using)區域外面 或 全部DB資料異動完才呼叫.Complete();
                   
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                } 
}//end using