扫一扫,手机访问
15194118449

EFCore 5 中的 Savepoints

发表日期:2021-01-27 10:59 文章编辑:管理员 浏览次数:183

EFCore 5中引入了一个新特性,叫做 Savepoints,主要是事务中使用,个人感觉有点类似于 Windows 上的系统还原点,如果事务发生了异常,可以回滚到某一个还原点。

Savepoints

 

当我们在一个事务里执行 SaveChanges 的时候,EF Core 会在保存数据之前自动的创建一个 savepointSavepoints 有点类似于系统还原点的概念,我们可以回滚到指定的 savepoint,

当事务发生错误的时候,会自动回滚到事务创建的 savepoint 回滚到事务开始之前的状态,以便于我们做重试或可能的修复错误或其他逻辑。

我们可以通过 CreateSavepoint 来手动创建一个 savepoint,使用 RollbackToSavepoint 来回滚到某一个 savepoint

来看一个微软的示例代码吧:

using var context = new BloggingContext();

using var transaction = context.Database.BeginTransaction();

 

try

{

    context.Blogs.Add(new Blog { Url = "https://devblogs.microsoft.com/dotnet/" });

    context.SaveChanges();

 

    transaction.CreateSavepoint("BeforeMoreBlogs");

 

    context.Blogs.Add(new Blog { Url = "https://devblogs.microsoft.com/visualstudio/" });

    context.Blogs.Add(new Blog { Url = "https://devblogs.microsoft.com/aspnet/" });

    context.SaveChanges();

 

    transaction.Commit();

}

catch (Exception)

{

    // If a failure occurred, we rollback to the savepoint and can continue the transaction

    transaction.RollbackToSavepoint("BeforeMoreBlogs");

 

    // TODO: Handle failure, possibly retry inserting blogs

}

Sample

 

我们自己来动手一试,示例代码如下:

var services = new ServiceCollection();

services.AddDbContext<TestDbContext>(options =>

{

    options.UseSqlite("Data Source=Application.db;Cache=Shared")

        .LogTo(Console.WriteLine, LogLevel.Warning)

        ;

});

using var provider = services.BuildServiceProvider();

using var scope = provider.CreateScope();

var dbContext = scope.ServiceProvider.GetRequiredService<TestDbContext>();

dbContext.Database.EnsureCreated();

Console.WriteLine($"Posts count:{dbContext.Posts.Count()}");

using var transaction = dbContext.Database.BeginTransaction();

try

{

    dbContext.Posts.Add(new Post() { Author = "Tom", Title = "Date changed", PostedAt = DateTime.UtcNow, });

    dbContext.Posts.Add(new Post() { Author = "Tom", Title = "Date changed", PostedAt = DateTime.UtcNow, });

    dbContext.SaveChanges();

    transaction.CreateSavepoint("Stage1");

    Console.WriteLine($"Posts count:{dbContext.Posts.Count()}");

 

    dbContext.Posts.Add(new Post() { Author = "Alice", Title = "Test", PostedAt = DateTime.UtcNow, });

    dbContext.SaveChanges();

    transaction.CreateSavepoint("Stage2");

    Console.WriteLine($"Posts count:{dbContext.Posts.Count()}");

 

    throw new InvalidOperationException();

    

    transaction.Commit();

}

catch (Exception)

{

    Console.WriteLine("Exception throw");

    transaction.RollbackToSavepoint("Stage1");

}

 

Console.WriteLine($"Posts count:{dbContext.Posts.Count()}");

示例代码中创建了两个 savepoint,然后抛出了一个异常,捕获异常后回滚到第一个 savepoint

 

可以看到,只有第一个 savepoint 之前的数据保存了下来,第二个 savepoint 虽然数据成功保存了,但是又被回滚了,最终只有第一个 savepoint 之前的数据变更被保存了下来

More

 

通过 savepoint 我们就可以使得事务控制更加精细,可以更能够好的控制事务中的数据变更

但是需要注意的是,这个功能不要和 Sql Server 中的 Multiple Active Result Sets 一起使用,一旦发生了错误,事务控制可能会发生不可预期的情况。

Savepoints are incompatible with SQL Server's Multiple Active Result Sets, and are not used. If an error occurs during SaveChanges, the transaction may be left in an unknown state.

相关资讯
济南做网站,济南做公众号,济南做小程序 首选金昇网站
金昇网站是一家在济南做网站、公众号、小程序的公司