填充 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

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

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 秒，但这完全是一个单独的问题。

填充 SqlDataAdapter

Filling SqlDataAdapter

c#

asp.net

multithreading

webforms