【EFCORE筆記】使用事務

默認事務行為

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

示例代碼：/TransactionSample/DefaultTransaction/Sample.cs

using (var context = new BloggingContext())
{
        context.Blogs.Add(new Blog { Url = "https://www.xcode.me/dotnet" });

        context.Blogs.Add(new Blog { Url = "https://www.xcode.me/visualstudio", 
BlogId = 123 });

        context.SaveChanges();
}

　　

以上代碼   BlogId    為自增列，不允許設置顯式值，所以第二條插入語句將引發異常，這將導致整個事務回滾，第一條添加數據雖然成功，但事務回滾，數據庫無任何數據添加成功。

context.Database.AutoTransactionsEnabled = false;

　　

使用微軟 SQL Server Profiler 工具監控事務。

可通過：context.Database.AutoTransactionsEnabled 關閉 SaveChanges 默認事務支持。

對於大部分應用程序來說，默認的事務行為已經夠用了。只有在應用程序需求認為有必要時你才需要手動去控制事務。

 

控制事務（相同DbContext上下文）

示例代碼：/TransactionSample/ControllingTransaction/Sample.cs

using (var context = new BloggingContext())
{
        using (var transaction = context.Database.BeginTransaction())
        {
                try
                {
                        context.Blogs.Add(new Blog
 { Url = "https://www.xcode.me/dotnet" });
                        context.SaveChanges();

                        context.Blogs.Add(new Blog
 { Url = "https://www.xcode.me/visualstudio" });
                        context.SaveChanges();

                        context.Database.ExecuteSqlCommand("INSERT INTO [Blogs]
([Url]) VALUES({0})", "https://www.xcode.me/efcore");

                        // Commit transaction if all commands succeed, transaction 
will auto-rollback

                        // when disposed if either commands fails

                        transaction.Commit();
                }
                catch (Exception)
                {
                        // TODO: Handle failure
                }
        }
}

　　

以上三條添加語句共享同一個事務，最后使用    transaction.Commit()   統一提交，三條全部執行成功，則影響到數據庫，如果任何一個命令失敗，則在事務被回收（Dispose）時會自動回滾，對數據庫無影響。

 

控制事務（跨DbContext上下文）

示例代碼：/TransactionSample/SharingTransaction/Sample.cs

共享DbConnection 要求能夠在構造上下文實例時傳入鏈接對象。實現外部提供DbConnection 的最簡單方式是避免使用

DbContext.OnConfiguring 方法來配置上下文，並且在其外部創建DbConetxtOpions，然后將其傳遞給上下文類型的構造方法。

public class BloggingContext : DbContext
{
        public BloggingContext(DbContextOptions<BloggingContext> options) : 
base(options)
        { }
        public DbSet<Blog> Blogs { get; set; }
}

　　

另一種替代方案是仍然使用 DbContext.OnConfiguring，但是接受並保存一個 DbConnection，然后在DbContext.OnConfiguring 中使用它。

public class BloggingContext2 : DbContext
{
        private DbConnection _connection;
        public BloggingContext2(DbConnection connection)
        {
                _connection = connection;
        }
        public DbSet<Blog> Blogs { get; set; }
        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
                optionsBuilder.UseSqlServer(_connection);
        }
}

　　

現在可以創建共享同一個連接的多個上下文了。之后可以使用 DbContext.Database.UseTransaction(DbTransaction))  API  來在一個事務中收集這些上下文。

var options = new DbContextOptionsBuilder<BloggingContext>
().UseSqlServer(new SqlConnection(connectionString)).Options;

using (var context1 = new BloggingContext(options))
{
        using (var transaction = context1.Database.BeginTransaction())
        {
                try
                {

                        context1.Blogs.Add(new Blog { Url = 
"https://www.xcode.me/dotnet" });
                        context1.SaveChanges();

                        using (var context2 = new BloggingContext(options))
                        {
                         context2.Database.UseTransaction(transaction.GetDbTransaction());

                                context2.Database.ExecuteSqlCommand("INSERT INTO 
[Blogs]([Url]) VALUES({0})", "https://www.xcode.me/efcore");

                                context1.Blogs.Add(new Blog { Url = 
"https://www.xcode.me/aspnetcore" });
                                context1.SaveChanges();
                        }

                        // Commit transaction if all commands succeed, transaction 
will auto-rollback
                        // when disposed if either commands fails

                        transaction.Commit();
                }
                catch (Exception)
                {
                        // TODO: Handle failure
                }
        }
}

　　

使用外部 DbTransactions 事務

如果你正在使用多個數據訪問技術來訪問關系數據庫，那么你可能會想要在這些不同技術執行的操作中共享事務。

以下代碼樣例顯示了如何在同一個事務中執行一個 ADO.NET SqlClient 操作和一個 Entity Framework Core 操作。

示例代碼：/TransactionSample/ExternalDbTransaction/Sample.cs

using (var connection = new SqlConnection(connectionString))
{
        connection.Open();

        using (var transaction = connection.BeginTransaction())
        {
                try
                {
                        // Run raw ADO.NET command in the transaction
                        var command = connection.CreateCommand();
                        command.Transaction = transaction;
                        command.CommandText = "DELETE FROM dbo.Blogs";
                        command.ExecuteNonQuery();

                        // Run an EF Core command in the transaction
                        var options = new 
DbContextOptionsBuilder<BloggingContext> ().UseSqlServer(connection).Options;

                        using (var context = new BloggingContext(options))
                        {
                                context.Database.UseTransaction(transaction);
                                context.Blogs.Add(new Blog
 { Url = "https://www.xcode.me/dotnet" });
                                context.SaveChanges();
                        }

// Commit transaction if all commands succeed, transaction will auto-rollback
                        // when disposed if either commands fails
                        transaction.Commit();
                }
                catch (Exception)
                {
                        // TODO: Handle failure
                }
        }
}

　　

使用 System.Transactions 環境事務

如果需要跨較大作用域進行協調，則可以使用環境事務。

示例代碼：/TransactionSample/AmbientTransaction/Sample.cs

using (var scope = new TransactionScope(TransactionScopeOption.Required, 
new TransactionOptions { IsolationLevel 
= IsolationLevel.ReadCommitted }))
{
        using (var connection = new SqlConnection(connectionString))
        {
                connection.Open();

                try
                {
                        // Run raw ADO.NET command in the transaction
                        var command = connection.CreateCommand();
                        command.CommandText = "DELETE FROM dbo.Blogs";
                        command.ExecuteNonQuery();

                        // Run an EF Core command in the transaction
                        var options = new 
DbContextOptionsBuilder<BloggingContext> 
().UseSqlServer(connection).Options;

                        using (var context = new BloggingContext(options))
                        {
                                context.Blogs.Add(new Blog
 { Url = "https://www.xcode.me/dotnet" });
                                context.SaveChanges();
                        }

                        // Commit transaction if all commands succeed, transaction
will auto-rollback
                        // when disposed if either commands fails
                        scope.Complete();
                }
                catch (Exception)
                {
                        // TODO: Handle failure
                }
        }
}

　　

示例代碼：/TransactionSample/CommitableTransaction/Sample.cs

自版本 2.1 起，.NET Core 中的System.Transactions 實現將不包括對分布式事務的支持，因此不能使用TransactionScope 或

CommittableTransaction 來跨多個資源管理器協調事務。

System.PlatformNotSupportedException:“This platform does not support distributed transactions.”

Introducing the new Microsoft.Data.SqlClient

https://github.com/dotnet/corefx/issues/2949

　　

主要分布式事務需要依賴於 Windows 系統的 MSDTC 服務，但 .NET Core 要實現跨平台，基於跨平台的分布式事務沒有統一的標准，后續版希望改進。