[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異動資料庫