.NET 核心执行非查询异步事务 - C#

在.NET Core应用程序中，执行数据库操作时，异步操作是一个非常常见的需求。在本文中，我们将介绍如何使用C#代码来执行非查询异步事务。

前提条件

在开始之前，您需要在.NET Core应用程序中安装Microsoft.Extensions.DependencyInjection包，并引用适当的命名空间。您还需要安装与您的数据库相对应的适当提供程序。

配置数据访问

首先，我们需要在启动类中配置数据访问服务。在Startup类中添加以下代码：

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;

public void ConfigureServices(IServiceCollection services)
{
    var connectionString = Configuration.GetConnectionString("DefaultConnection");
    services.AddDbContext<ApplicationDbContext>(options => options.UseSqlServer(connectionString));
}

此代码将注册数据库上下文类(ApplicationDbContext)到DI容器中，使它能够在需要时自动注入。请注意，此代码将DefaultConnection配置为默认连接字符串。我们需要在appsettings.json文件中提供此值：

{
  "ConnectionStrings": {
    "DefaultConnection": "Server=(localdb)\\mssqllocaldb;Database=MyDatabase;Trusted_Connection=True;MultipleActiveResultSets=true"
  }
}

执行非查询异步事务

我们可以使用Entity Framework Core提供的BeginTransactionAsync方法来执行非查询异步事务。以下是一个使用这种方法来在事务中插入新记录的示例：

public async Task InsertRecordAsync(Record record)
{
    using var dbContext = new ApplicationDbContext();

    using var transaction = await dbContext.Database.BeginTransactionAsync();
    try
    {
        dbContext.Records.Add(record);
        await dbContext.SaveChangesAsync();

        await transaction.CommitAsync();
    }
    catch (Exception)
    {
        await transaction.RollbackAsync();
        throw;
    }
}

这个方法使用了dbContext来插入一个新的记录，然后通过调用dbContext.SaveChangesAsync()来将更改保存到数据库中。首先我们开始一个事务，然后在try/catch块中执行操作。如果操作成功，则提交事务并保存更改。如果操作失败，则回滚事务并重新抛出异常。

结论

本文介绍了如何使用.NET Core执行非查询异步事务。我们使用Entity Framework Core的扩展方法来开始事务，并在代码中执行查询操作。此外，我们采用了一种具有适当异常处理的事务模型，以确保数据库更新的一致性。