使用 Dapper 并行执行多个查询

Question

我尝试使用 Dapper 和存储过程并行执行三个相似的 SQL 查询，以便在所有查询完成后获得三个相似的结果。

这是我的代码：

public class SomeReport
{
    private static readonly string ConnectionString = ConfigurationManager.ConnectionStrings["SomeContext"].ToString();
    public ReportStatus ReportStatus { get; set; }
    public long NetworkServerTime { get; set; }
    public string ReportLastErrorMessage { get; set; }

    public RowSet[] FirstRowSet { get; set; }
    public RowSet[] SecondRowSet { get; set; }
    public RowSet[] ThirdRowSet { get; set; }

    public Report()
    {
        NetworkServerTime = 0;
        ReportStatus = ReportStatus.NotCreated;
    }


    public async Task GetReportDataAsync(ReportParameters parameters)
    {
        DynamicParameters requestParameters = new DynamicParameters();
        requestParameters.Add("@sinceDateFilter", parameters.SinceDate?.Date, DbType.DateTime);
        requestParameters.Add("@untilDateFilter", parameters.UntilDate?.Date, DbType.DateTime);
        requestParameters.Add("@countryId", parameters.CountryId, DbType.Int32);

        ReportLastErrorMessage = null;

        Task allTasks = null;
        var stopWatch = new Stopwatch();

        try
        {
            var firstTask = GetRows("[dbo].[GET_Report_FirstRowSet]", requestParameters);
            var secondTask =
                GetRows("[dbo].[GET_Report_SecondRowSet]", requestParameters);
            var thirdTask =
                GetRows("[dbo].[GET_Report_ThirdRowSet]", requestParameters);

            allTasks = Task.WhenAll(firstTask, secondTask, thirdTask);

            FirstRowSet = await firstTask;
            SecondRowSet = await secondTask;
            ThirdRowSet = await thirdTask;
        }
        catch (Exception ex)
        {
            ReportStatus = ReportStatus.Error;
            ReportLastErrorMessage = allTasks?.Exception?.InnerExceptions.Last().Message;
        }
        finally
        {
            if (ReportStatus != ReportStatus.Error)
            {
                ReportStatus = ReportStatus.Success;
                NetworkServerTime = stopWatch.ElapsedMilliseconds;
            }

        }
        stopWatch.Reset();
    }

    private async Task<RowSet[]> GetRows(string procName, DynamicParameters parameters)
    {
        using (var conn = new SqlConnection(ConnectionString))
        {
            RowSet[] rowsSet;

            try
            {
                var sqlString = string.Concat(procName, " @sinceDateFilter, @untilDateFilter, @countryId");
                var query = await conn.QueryAsync<RowSet>(sqlString, parameters, commandTimeout: 500);
                rowsSet = query.ToArray();
            }
            catch (SqlException sqlEx)
            {
                rowsSet = new RowSet[0];
                throw;
            }

            return rowsSet;
        }
    }
}

但是当我启动调试器和 SQL Server Profiler 时，我看到在创建与它们对应的任务时，查询是按顺序执行的。

如何让查询同时开始运行ning 和运行并行？

Answer 1

if I use debugger and sql-profiler, I see that the first query in the profiler is executed when I am on the line of code var firstTask = GetRows("[dbo].[GET_Report_FirstRowSet]", requestParameters); but not when i am on the line of code allTasks = Task.WhenAll (firstTask, secondTask, thirdTask);

这是正确且正常的。 async/await 的工作方式是，一旦第一个不完整的 await 发生，控制权就会返回调用堆栈，在您的情况下是 await conn.QueryAsync<RowSet>。但是，您仍然只是通过调用异步方法开始了工作。该操作不会保持在等待您调用 Task.WhenAll 的某个挂起状态，因此我们预计它已经开始。 Task.WhenAll 除了聚合 await 步骤之外， 什么都不做 - 它没有让事情真正发生的作用。

所以：我怀疑一切都已按预期工作，但只是：任务按照您请求的顺序报告为 starting。这正是...正是我们所期望的。

使用 Dapper 并行执行多个查询

Execute multiple queries in parallel with Dapper

c#

task-parallel-library

dapper