【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 要實現跨平台，基於跨平台的分布式事務沒有統一的標准，后續版希望改進。