asp.net - 异步 ADO.NET 或 TaskFactory

Question

我有 4 个繁重的数据库表（每个表 3000 万行），我的查询从所有 4 个表中获取数据并进行联合以组合所有数据，并且查询没有返回很多行（最多 1000 行）。因此，假设整个查询需要 20 秒才能完成，我正在考虑为每个表编写一个单独的查询并使用异步或 TPL 调用它们，然后将结果组合到我的业务对象（c#.Net 4.0）中，然后返回到 ASP.NET Web 表单。

我看过 BeginExecuteReader 和 Task.Factory.StartNew 但我不知道如何把所有东西放在一起，以前有没有人做过这样的事情？知道我该怎么做吗？

Answer 1

我终于自己做了这个，如果其他人需要它，就把它放在这里。

DataTable dtReturn = new DataTable();
var connection = new SqlConnection((_connectionstring.IndexOf("MultipleActiveResultsets") == -1) ? _connectionstring + "MultipleActiveResultsets=True;" : _connectionstring);
try
{
    connection.Open();

    Task<DataTable>[] tasks = new Task<DataTable>[source.Rows.Count];
    for (int i = 0; i < source.Rows.Count; i++)
    {
        int s = Convert.ToInt32(source.Rows[i][0]);
        Task<DataTable> t = Task.Factory.StartNew(() =>
        {
            var command = connection.CreateCommand();
            command.CommandText = commandText;
            command.CommandType = CommandType.StoredProcedure;
            command.CommandTimeout = timeout;

            foreach (SqlParameter p in parms)
            {
                if (p.ParameterName == "@Sources")
                    command.Parameters.Add(new SqlParameter() { SqlDbType = System.Data.SqlDbType.Structured, ParameterName = p.ParameterName, Value = s.ToString().ToIDList() });
                else
                    command.Parameters.Add(new SqlParameter() { ParameterName = p.ParameterName, Value = p.Value });
            }
            var dr = command.ExecuteReader();
            command.Parameters.Clear();
            DataTable dt = new DataTable();
            if (dr.HasRows)
            {
                dt.Load(dr);
                dr.Close();
            }
            return dt;
        });
        tasks[i] = t;
    }

    Task.WaitAll(tasks);
    if (tasks.Length > 0)
    {
        bool isSchemaCloned = false;
        foreach (var t in tasks)
        {
            if (!isSchemaCloned && t.Result.Columns.Count > 0 )
            {
                dtReturn = t.Result.Clone();
                isSchemaCloned = true; 
            }

            foreach (DataRow r in t.Result.Rows)
            {
                dtReturn.Rows.Add(r.ItemArray);
            }
        }
    }
}
catch (Exception ex)
{
    throw ex;
}
finally
{
    if (connection.State != ConnectionState.Closed)
        connection.Close();
}

return dtReturn;