填充SqlDataAdapter答案

【问题标题】：Filling SqlDataAdapter填充SqlDataAdapter
【发布时间】：2016-03-14 13:50:15
【问题描述】：

我正在运行一个大约需要 45 秒才能运行并显示结果的 SQLQuery。我正在使用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 秒，而且似乎代码只是在没有延迟的情况下继续运行，让查询执行完成。

【问题讨论】：

您需要该表中的所有数据吗？对于在 Web 应用程序中而不是在某个后台进程中运行的查询来说，45 秒是相当长的时间。
不幸的是，我确实需要查询返回的所有数据。
在这种情况下，您应该查看为什么这样一个简单的查询需要 45 秒。此外，如果您要使用任务，那么您应该查看 TAP 模式和 async/await 关键字。此外，必须特别注意 Web 窗体中的异步，如 Microsoft here 所述。
ddl2.DataSource = tasks[0].Result.Tables[0]; 应该是ddl2.DataSource = tasks[1].Result.Tables[0]; 吗？
@MaxSorin - 很好。我更新了我的帖子。我将其更改为 0，因为我注释掉了第一个以查看 ddl2 是否会在没有调用填充 ddl1 的情况下填充，显然没有这样的芥末。

标签： c# asp.net multithreading webforms

【解决方案1】：

如果您要执行异步以将数据检索到数据表中，它应该看起来更像这样：

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 属性添加到您的页面according to MSDN。

您还应该将您的查询修改为不花费 45 秒，但这完全是一个单独的问题。

【讨论】：