异步ADO.NET或TaskFactory

Question

我有4个繁重的数据库表(每个表有3000万行)，我的查询从所有4个表中获取数据，并执行联合操作来合并所有表，并且查询没有返回很多行(最多1000行)。假设整个查询需要20秒才能完成，我正在考虑为每个表编写一个单独的查询，并使用异步或第三方调用它们，然后将结果组合到我的业务对象(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;