第五節：EF Core中的三類事務(SaveChanges、DbContextTransaction、TransactionScope)

一. 說明

?EF版本的事務介紹詳見：

　　第七節: EF的三種事務的應用場景和各自注意的問題(SaveChanges、DBContextTransaction、TransactionScope)。

　　本節主要介紹EF Core下的三種事務的用法和各自的使用場景，其中SaveChanges和DBContextTransaction事務與EF版本的基本一致，在該章節中補充一些新的使用場景和配置方式，TransactionScope環境事務與EF 版本的有著本質的區別，它目前不支持分布式數據庫事務。

　　后面章節將繼續介紹事務的基礎概念、事務的隔離級別和帶來的各種問題。

二. 默認事務(SaveChanges)

(1).默認情況下，如果數據庫提供程序支持事務，單個 SaveChanges() 調用中的所有變更都會在一個事務中被提交。如果其中任何一個變更失敗了，?那么事務就會回滾，沒有任何變更會被應用到數據庫。這意味著 SaveChanges() 能夠確保要么成功保存，要么在發生錯誤時不對數據庫做任何修改。

(2).關閉默認事務：context.Database.AutoTransactionsEnabled = false; 如：Test3()方法，第一條數據保存成功，第二條失敗。

?代碼分享：

        /// <summary>
        /// 全部成功
        /// </summary>
        public static void Test1()
        {
            using (EFDB01Context db = new EFDB01Context())
            {
                db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員2", addTime = DateTime.Now });
                db.SaveChanges();
            }
        }

        /// <summary>
        /// 全部失敗
        /// </summary>
        public static void Test2()
        {
            using (EFDB01Context db = new EFDB01Context())
            {
                try
                {
                    db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                    db.T_RoleInfor.Add(new T_RoleInfor() { id = 123, roleName = "管理員2", addTime = DateTime.Now });
                    db.SaveChanges();
                }
                catch (Exception)
                {
                    Console.WriteLine("出錯了，兩條數據都沒有執行成功");
                }
            }
        }

        /// <summary>
        /// 第一條成功，第二條失敗
        /// </summary>
        public static void Test3()
        {
            using (EFDB01Context db = new EFDB01Context())
            {
                try
                {
                    //關閉SaveChanges的默認事務
                    db.Database.AutoTransactionsEnabled = false;

                    db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                    db.T_RoleInfor.Add(new T_RoleInfor() { id = 123, roleName = "管理員2", addTime = DateTime.Now });

                    //db.T_UserInfor.Add(new T_UserInfor() { id = Guid.NewGuid().ToString("N"), userName = "管理員1", addTime = DateTime.Now });
                    //db.T_UserInfor.Add(new T_UserInfor() { id = Guid.NewGuid().ToString("N")+"123", userName = "管理員2", addTime = DateTime.Now });

                    db.SaveChanges();
                }
                catch (Exception)
                {
                    Console.WriteLine("出錯了，第一條數據插入成功了");
                }
            }
        }

?

三. DbContextTransaction

1. 使用方式

　　BeginTransaction開啟事務、Commit提交事務、Rollback回滾事務、Dispose銷毀，如果用Using包裹的話，不再需要手動Rollback，走完Using會自動回滾。如果不用Using包裹事務，就需要在Catch中手動RollBack回滾，并且最好最后手動的Dispose一下。(如SameDbContext文件夾中的Test1和Test2方法)

2. 使用場景

　A. 同一個上下文多個SaveChanges的方法（如：自增主鍵后續要用到,如Test2方法）、SaveChanges和EF調用SQL語句混用(如Test2方法)

       /// <summary>
        /// 三條添加語句共享同一個事務，最后使用 transaction.Commit() 統一提交，三條全部執行成功，則影響到數據庫，
        /// 如果任何一個命令失敗，則在事務被回收（Dispose）時會自動回滾，對數據庫無影響。 
        /// </summary>
        public static void Test1()
        {
            using (EFDB01Context db = new EFDB01Context())
            {
                using (var transaction = db.Database.BeginTransaction())
                {
                    try
                    {
                        db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        db.SaveChanges();

                        db.T_RoleInfor.Add(new T_RoleInfor() { id = 111, roleName = "管理員2", addTime = DateTime.Now });  //報錯
                        db.SaveChanges();

                        string sql1 = @"insert into T_RoleInfor (roleName,roleDescription,addTime) values (@roleName,@roleDescription,@addTime)";
                        SqlParameter[] pars1 ={
                                                 new SqlParameter("@roleName","管理員3"),
                                                 new SqlParameter("@roleDescription","txt11"),
                                                 new SqlParameter("@addTime",DateTime.Now)
                                            };
                        db.Database.ExecuteSqlCommand(sql1, pars1);
                        transaction.Commit();

                        Console.WriteLine("成功了");
                    }
                    catch (Exception)
                    {
                        Console.WriteLine("失敗了");
                    }
                }
            }
        }

        /// <summary>
        /// 如果不用Using包裹事務，就需要在Catch中手動RollBack回滾
        /// </summary>
        public static void Test2()
        {
            using (EFDB01Context db = new EFDB01Context())
            {
                var transaction = db.Database.BeginTransaction();
                try
                {
                    var d1 = new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now };
                    db.T_RoleInfor.Add(d1);
                    db.SaveChanges();

                    db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員2"+d1.id, addTime = DateTime.Now });
                    db.SaveChanges();

                    string sql1 = @"insert into T_RoleInfor (roleName,roleDescription,addTime) values (@roleName,@roleDescription,@addTime)";
                    SqlParameter[] pars1 ={
                                                 new SqlParameter("@roleName","管理員3"),
                                                 new SqlParameter("@roleDescription","txt11"),
                                                 new SqlParameter("@addTime",DateTime.Now)
                                            };
                    db.Database.ExecuteSqlCommand(sql1, pars1);
                    transaction.Commit();

                    Console.WriteLine("成功了");

                }
                catch (Exception)
                {
                    transaction.Rollback();
                    Console.WriteLine("失敗了");
                }
                finally
                {
                    transaction.Dispose();
                }

            }
        }

　B. 同一個數據庫多個上下文但“同一個連接”的事務。其中一個上下文開啟事務，另外上下文通過UseTransaction方法來實現共享事務。

　情況①：

　　EFDB01Context直接在OnConfiguring中寫死連接字符串，多次new上下文，如Test1方法，則是多個連接，不能共享事務。

 /// <summary>
        /// 情況一：在OnConfiguring中書寫連接字符串，創建兩個上下文，相當于兩個連接，兩個連接之間不能通過使用UseTransaction，建立事務連接。
        /// 會報下面的錯。
        /// The specified transaction is not associated with the current connection. Only transactions associated with the current connection may be used.
        /// </summary>
        public static void Test1()
        {
            using (EFDB01Context context1 = new EFDB01Context())
            {
                using (var transaction = context1.Database.BeginTransaction())
                {
                    try
                    {
                        context1.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        context1.SaveChanges();

                        using (EFDB01Context context2 = new EFDB01Context())
                        {
                            context2.Database.UseTransaction(transaction.GetDbTransaction());

                            context1.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                            context1.SaveChanges();
                        }

                        //統一提交
                        transaction.Commit();
                        Console.WriteLine("成功了");
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }
            }


        }

　情況②：

　　EFDB01Context2通過 public EFDB01Context2(DbContextOptions<EFDB01Context2> options) : base(options)這種形式的構造函數，然后new的時候?統一傳入： new? DbContextOptionsBuilder<EFDB01Context2>().UseSqlServer(new SqlConnection(connectionString)).Options;，從而共享連接，如Test2方法。

        /// <summary>
        /// 情況二：通過父類構造函數
        /// </summary>
        public static void Test2()
        {
            var connectionString = "Server=localhost;Database=EFDB01;User ID=sa;Password=123456;";
            //將連接拿出來，傳到多個上下文中，這樣是共享同一個連接
            var option = new DbContextOptionsBuilder<EFDB01Context2>().UseSqlServer(new SqlConnection(connectionString)).Options;

            using (var context1 = new EFDB01Context2(option))
            {
                using (var transaction = context1.Database.BeginTransaction())
                {
                    try
                    {
                        context1.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        context1.SaveChanges();

                        using (var context2 = new EFDB01Context2(option))
                        {
                            context2.Database.UseTransaction(transaction.GetDbTransaction());

                            context1.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                            context1.SaveChanges();
                        }

                        //統一提交
                        transaction.Commit();
                        Console.WriteLine("成功了");
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }
            }
        }

　情況③：

　EFDB01Context3通過 傳入SqlConnection來實現共享連接，如Test3方法。

        public static void Test3()
        {
            var connectionString = "Server=localhost;Database=EFDB01;User ID=sa;Password=123456;";
            //將連接拿出來，傳到多個上下文中，這樣是共享同一個連接
            var connection = new SqlConnection(connectionString);

            using (var context1 = new EFDB01Context3(connection))
            {
                using (var transaction = context1.Database.BeginTransaction())
                {
                    try
                    {
                        context1.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        context1.SaveChanges();

                        using (var context2 = new EFDB01Context3(connection))
                        {
                            context2.Database.UseTransaction(transaction.GetDbTransaction());

                            context1.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                            context1.SaveChanges();
                        }

                        //統一提交
                        transaction.Commit();
                        Console.WriteLine("成功了");
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }
            }
        }

　C. 多種數據庫技術同一個數據庫的事務

?　如ADO.Net和EF共同使用，利用方法 “UseTransaction”共享同一個事務，共同提交。 如：Test1方法

        /// <summary>
        /// ADO.Net 和 EF混用，多種數據庫技術訪問同一個數據庫
        /// </summary>
        public static void Test1()
        {
            var conStr = @"Server=localhost;Database=EFDB01;User ID=sa;Password=123456;";
            using (var connection=new SqlConnection(conStr))
            {
                connection.Open();
                using (var transaction=connection.BeginTransaction())
                {
                    try
                    {
                        //ADO.Net
                        var command = connection.CreateCommand();
                        command.Transaction = transaction;
                        command.CommandText = "DELETE FROM T_RoleInfor";
                        command.ExecuteNonQuery();

                        //EF
                        var options = new DbContextOptionsBuilder<EFDB01Context>().UseSqlServer(connection).Options;
                        using (var context = new EFDB01Context(options))
                        {
                            context.Database.UseTransaction(transaction);
                            context.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                            context.SaveChanges();
                        }
                        //綜合提交
                        transaction.Commit();

                        Console.WriteLine("成功了");

                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }
               
            }
        }

?

四. 環境事務

1.使用方式

　　new TransactionScope創建事務、Complete提交事務、 Transaction.Current.Rollback();回滾事務、Dispose銷毀對象。如果用Using包裹的話，不再需要手動Rollback，走完Using會自動回滾。如果不用Using包裹事務，就需要在Catch中手動RollBack回滾，并且最好最后手動的Dispose一下。

2.用途

　A. 同一個上下文的事務。(多個SaveChanges(自增主鍵后續用到的情況)、SaveChanges和EF調用SQL語句混用)（如Test1方法)

 /// <summary>
        /// A. 同一個上下文的事務。(多個SaveChanges(自增主鍵后續用到的情況)、SaveChanges和EF調用SQL語句混用)
        /// </summary>
        public static void Test1()
        {
            using (EFDB01Context1 db = new EFDB01Context1())
            {
                using (var scope = new TransactionScope(/*TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted }*/))
                {
                    try
                    {
                        var data1 = new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now };
                        db.T_RoleInfor.Add(data1);
                        db.SaveChanges();

                        db.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員2" + data1.id, addTime = DateTime.Now });  //報錯
                        db.SaveChanges();

                        string sql1 = @"insert into T_RoleInfor (roleName,roleDescription,addTime) values (@roleName,@roleDescription,@addTime)";
                        SqlParameter[] pars1 ={
                                                 new SqlParameter("@roleName","管理員3"),
                                                 new SqlParameter("@roleDescription","txt11"),
                                                 new SqlParameter("@addTime",DateTime.Now)
                                            };
                        db.Database.ExecuteSqlCommand(sql1, pars1);
                        scope.Complete();


                        Console.WriteLine("成功了");
                    }
                    catch (Exception)
                    {
                        Console.WriteLine("失敗了");
                    }
                }
            }
        }

　B. 多種數據庫技術訪問同一個數據庫的事務 （如Test2方法)

        /// <summary>
        /// B. 多種數據庫技術訪問同一個數據庫的事務
        /// </summary>
        public static void Test2()
        {
            var conStr = @"Server=localhost;Database=EFDB01;User ID=sa;Password=123456;";
            using (var connection = new SqlConnection(conStr))
            {
                connection.Open();
                using (var scope = new TransactionScope())
                {
                    try
                    {
                        //ADO.Net
                        var command = connection.CreateCommand();
                        command.CommandText = "DELETE FROM T_RoleInfor";
                        command.ExecuteNonQuery();

                        //EF
                        using (var context = new EFDB01Context1())
                        {
                            context.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                            context.SaveChanges();
                        }
                        //綜合提交
                        scope.Complete();

                        Console.WriteLine("成功了");

                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                    }
                }
            }
        }

　C. 同一個數據庫多個不同的上下文是支持的（如Test3方法）

上下文代碼:

  public partial class EFDB01Context1 : DbContext
    {
        public virtual DbSet<T_RoleInfor> T_RoleInfor { get; set; }
        public virtual DbSet<T_UserInfor> T_UserInfor { get; set; }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            optionsBuilder.UseSqlServer("Server=localhost;Database=EFDB01;User ID=sa;Password=123456;");
        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            modelBuilder.HasAnnotation("ProductVersion", "2.2.0-rtm-35687");

            modelBuilder.Entity<T_RoleInfor>(entity =>
            {
                entity.Property(e => e.roleDescription).IsUnicode(false);

                entity.Property(e => e.roleName).IsUnicode(false);
            });

            modelBuilder.Entity<T_UserInfor>(entity =>
            {
                entity.Property(e => e.id)
                    .IsUnicode(false)
                    .ValueGeneratedNever();

                entity.Property(e => e.userName).IsUnicode(false);

                entity.Property(e => e.userSex).IsUnicode(false);
            });
        }
    }

  public partial class EFDB01Context2 : DbContext
    {
        public virtual DbSet<T_RoleInfor> T_RoleInfor { get; set; }
        public virtual DbSet<T_UserInfor> T_UserInfor { get; set; }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            optionsBuilder.UseSqlServer("Server=localhost;Database=EFDB01;User ID=sa;Password=123456;");
        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            modelBuilder.HasAnnotation("ProductVersion", "2.2.0-rtm-35687");

            modelBuilder.Entity<T_RoleInfor>(entity =>
            {
                entity.Property(e => e.roleDescription).IsUnicode(false);

                entity.Property(e => e.roleName).IsUnicode(false);
            });

            modelBuilder.Entity<T_UserInfor>(entity =>
            {
                entity.Property(e => e.id)
                    .IsUnicode(false)
                    .ValueGeneratedNever();

                entity.Property(e => e.userName).IsUnicode(false);

                entity.Property(e => e.userSex).IsUnicode(false);
            });
        }
    }

運行代碼：

       /// <summary>
        ///C. 同一個數據庫兩個不同上下文是支持的
        /// </summary>
        public static void Test3()
        {
            using (var scope = new TransactionScope())
            {
                try
                {
                    using (var context = new EFDB01Context1())
                    {
                        context.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        context.SaveChanges();
                    }
                    using (var context = new EFDB01Context2())
                    {
                        context.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        context.SaveChanges();
                    }

                    //綜合提交
                    scope.Complete();

                    Console.WriteLine("成功了");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
        }

　D. 不同數據庫的上下文是不支持的，(如Test4方法,開啟msdtc服務的步驟： cmd命令→ net start msdtc ，然后發現報錯：This platform does not support distributed transactions.說明目前Core平臺下不支持分布式事務）

上下文代碼：

 public partial class dbCore1Context : DbContext
    {
        public dbCore1Context()
        {
        }

        public dbCore1Context(DbContextOptions<dbCore1Context> options)
            : base(options)
        {
        }

        public virtual DbSet<UserInfors> UserInfors { get; set; }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            optionsBuilder.UseSqlServer("Server=localhost;Database=dbCore1;User ID=sa;Password=123456;");

        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            modelBuilder.HasAnnotation("ProductVersion", "2.2.0-rtm-35687");

            modelBuilder.Entity<UserInfors>(entity =>
            {
                entity.Property(e => e.id).ValueGeneratedNever();
            });
        }
    }

  public partial class EFDB01Context1 : DbContext
    {
        public virtual DbSet<T_RoleInfor> T_RoleInfor { get; set; }
        public virtual DbSet<T_UserInfor> T_UserInfor { get; set; }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            optionsBuilder.UseSqlServer("Server=localhost;Database=EFDB01;User ID=sa;Password=123456;");
        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            modelBuilder.HasAnnotation("ProductVersion", "2.2.0-rtm-35687");

            modelBuilder.Entity<T_RoleInfor>(entity =>
            {
                entity.Property(e => e.roleDescription).IsUnicode(false);

                entity.Property(e => e.roleName).IsUnicode(false);
            });

            modelBuilder.Entity<T_UserInfor>(entity =>
            {
                entity.Property(e => e.id)
                    .IsUnicode(false)
                    .ValueGeneratedNever();

                entity.Property(e => e.userName).IsUnicode(false);

                entity.Property(e => e.userSex).IsUnicode(false);
            });
        }
    }

運行代碼：

        /// <summary>
        ///D. 不同數據庫之間的事務
        /// </summary>
        public static void Test4()
        {
            using (var scope = new TransactionScope())
            {
                try
                {
                    using (var context = new EFDB01Context1())
                    {
                        context.T_RoleInfor.Add(new T_RoleInfor() { roleName = "管理員1", addTime = DateTime.Now });
                        context.SaveChanges();
                    }
                    using (var context = new dbCore1Context())
                    {
                        context.UserInfors.Add(new UserInfors() { id = Guid.NewGuid().ToString("N"), userName = "管理員1", userSex = "男" });
                        context.SaveChanges();
                    }

                    //綜合提交
                    scope.Complete();

                    Console.WriteLine("成功了");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
        }

　注：EF Core中的 System.Transactions 實現將不包括對分布式事務的支持，因此不能使用 TransactionScope 或 CommittableTransaction 來跨多個資源管理器協調事務。主要分布式事務需要依賴于 Windows 系統的 MSDTC 服務，但.NET Core要實現跨平臺，基于跨平臺的分布式事務沒有統一的標準，后續版希望改進。

?

?

?

!

• 作???????者 : Yaopengfei(姚鵬飛)
• 博客地址 : http://www.cnblogs.com/yaopengfei/
• 聲?????明1 : 本人才疏學淺，用郭德綱的話說“我是一個小學生”，如有錯誤，歡迎討論，請勿謾罵^_^。
• 聲?????明2 : 原創博客請在轉載時保留原文鏈接或在文章開頭加上本人博客地址，否則保留追究法律責任的權利。