填充SqlDataAdapter

Question

我正在运行一个SQLQuery，运行和显示结果大约需要45秒。我正在使用Task<DataSet>在我的页面上填充两个下拉列表。好的，第一个下拉列表填充得很好(查询大约在2秒内完成)，第二个adapter.Fill(dataSet)似乎没有等待查询完成，然后才开始使用空数据集填充下拉列表。我应该修改什么以使代码执行停止直到查询完全执行？

Task.Factory.ContinueWhenAll(new[]
{
  One("Data Source=server;Initial Catalog=db;Integrated Security=True;MultipleActiveResultSets=True"),
  Two("Data Source=server;Initial Catalog=db;Integrated Security=True;MultipleActiveResultSets=True"),
}, tasks =>
{
  try
  {
    this.ddl1.DataSource = tasks[0].Result.Tables[0];
    this.ddl1.DataTextField = "One";
    this.ddl1.DataValueField = "ID";
    this.ddl1.DataBind();
    int indexOfLastItem = this.ddl1.Items.Count - 1;
    this.ddl1.SelectedIndex = indexOfLastItem;
    ddl2.DataSource = tasks[1].Result.Tables[0];
    this.ddl2.DataTextField = "Two";
    this.ddl2.DataValueField = "ID";
    this.ddl2.DataBind();
    this.ddl2.Items.Insert(0, new ListItem(Constants.All, Constants.All));
  }
  catch (Exception exception) { throw exception; }
}, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.FromCurrentSynchronizationContext());

public System.Threading.Tasks.Task<DataSet> One(string databaseConnection)
{
  return FillDS("Select * from activeemployees", databaseConnection);
}
public System.Threading.Tasks.Task<DataSet> Two(string databaseConnection)
{
  return FillDS("Select * from mastersalesdatabase", databaseConnection);
}
public System.Threading.Tasks.Task<DataSet> FillDS(string sqlQuery, string connectionString)
{
  try
  {
    var dataSet = new DataSet();
    using (var adapter = new SqlDataAdapter(sqlQuery, connectionString))
    {
        adapter.Fill(dataSet);
        return dataSet;
    }
  }
  catch (Exception exception) { throw exception; }
}

我的查询Select * from activeemployees在大约2秒内完成并填充得很好，我的查询Select * from mastersalesdatabase大约需要45秒，而代码似乎只是在w/o上移动一个延迟才能让查询执行到完成。

Answer 1

如果要执行异步操作以将数据检索到datatable中，则应该如下所示：

public static async Task<DataTable> GetDataTableAsync(string connectionString, SqlCommand command)
{
    using (var connection = new SqlConnection(connectionString))
    {
        command.Connection = connection;
        await connection.OpenAsync();
        using (var dataReader = await command.ExecuteReaderAsync())
        {
            var dataTable = new DataTable();
            dataTable.Load(dataReader);
            return dataTable;
        }
    }
}

注意，不需要数据集。

然后，在WebForms中，我们必须以不同的方式处理异步代码。

protected void Page_Load(object sender, EventArgs e)
{
    RegisterAsyncTask(new PageAsyncTask(DoWorkAsync));
}

private async Task DoWorkAsync()
{
    ActiveEmployeesDropDownList.DataSource = GetDataTableAsync(databaseConnection, new SqlCommand("select * from activeemployees"));
    ActiveEmployeesDropDownList.DataBind();
}

注意，我将控件从ddl1重命名为ActiveEmployeesDropDownList，因为ddl1是一个可怕的名称。你们的名字应该有语义意义。

您需要将async=true属性添加到页面根据MSDN中。

您还应该将查询修正为不占用45秒，但这是一个完全不同的问题。