问题描述

在某些情况下，我已经在存储库函数中使用事务，因为我有时需要一次将数据插入两个表，并且如果其中一个插入失败，我希望整个操作失败。

现在我遇到了这样一种情况：我必须将对多个存储库/函数的调用包装在另一个事务中，但是当其中一个函数已经在内部使用事务时，我将收到错误The connection is already in a transaction and cannot participate in another transaction。我不想从存储库功能中删除事务，因为这意味着我必须知道事务需要哪些存储库功能，然后我必须在服务层中实现这些功能。另一方面，我似乎不能在事务中使用存储库函数，因为它们已经在内部使用了事务。以下是我面临此问题的一个示例：

// Reverse engineered classes
public partial class TblProject
{
    public TblProject()
    {
        TblProjectStepSequences = new HashSet<TblProjectStepSequence>();
    }
    
    public int ProjectId { get; set; }

    public virtual ICollection<TblProjectStepSequence> TblProjectStepSequences { get; set; }
}

public partial class TblProjectTranslation
{
    public int ProjectId { get; set; }
    public string Language { get; set; }
    public string ProjectName { get; set; }

    public virtual TblProject Project { get; set; }
}

public partial class TblProjectStepSequence
{
    public int SequenceId { get; set; }
    public int ProjectId { get; set; }
    public int StepId { get; set; }
    public int SequencePosition { get; set; }

    public virtual TblStep Step { get; set; }
    public virtual TblProject Project { get; set; }
}

// Creating a project in the ProjectRepository
public async Task<int> CreateProjectAsync(TblProject project, ...)
{
    using (var transaction = this.Context.Database.BeginTransaction())
    {
        await this.Context.TblProjects.AddAsync(project);
        await this.Context.SaveChangesAsync();
        // Insert translations... (project Id is required for this)
        await this.Context.SaveChangesAsync();
        transaction.Commit();
        
        return entity.ProjectId;
    }
}

// Creating the steps for a project in the StepRepository
public async Task<IEnumerable<int>> CreateProjectStepsAsync(int projectId, IEnumerable<TblProjectStepSequence> steps)
{
    await this.Context.TblProjectStepSequences.AddRangeAsync(steps);
    await this.Context.SaveChangesAsync();

    return steps.Select(step =>
    {
        return step.SequenceId;
    }
    );
}

// Creating a project with its steps in the service layer
public async Task<int> CreateProjectWithStepsAsync(TblProject project, IEnumerable<TblProjectStepSequence> steps)
{
    // This is basically a wrapper around Database.BeginTransaction() and IDbContextTransaction
    using (Transaction transaction = await transactionService.BeginTransactionAsync())
    {
        int projectId = await projectRepository.CreateProjectAsync(project);
        await stepRepository.CreateProjectStepsAsync(projectId, steps);

        return projectId;
    }
}

推荐答案

您可以检查CurrentTransaction属性并执行如下操作：

var transaction = Database.CurrentTransaction ?? Database.BeginTransaction()

如果已存在使用该事务的事务，则启动一个新事务.

编辑：删除了使用挡路的，请参阅评论。提交/回滚超越需要更多逻辑.

这篇关于如何在EF Core6中嵌套事务？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！