c# - 异步填充数据表？

Question

我在 .NET Core 2.0 应用程序中有以下功能。

public DataTable CallDb(string connStr, string sql)
{
    var dt = new DataTable();
    var da = new SqlDataAdapter(sql, connStr);
    da.Fill(dt);
    return dt;
}

如何将其转换为异步函数？

public async Task<DataTable> CallDb(string connStr, string sql)
{
    var dt = new DataTable();
    var da = new SqlDataAdapter(sql, connStr);
    da.Fill(dt); // No FillAsync to await?
    return dt;
}

我需要使用 DataTable 因为 sql 可能会返回具有不同架构的数据。有更好的方法来处理动态模式吗？

Answer 1

SqlDataAdapter 从未更新为包含方法的 TPL 版本。你可以这样做:

await Task.Run(() => da.Fill(dt));

但这会创建一个无用的线程。

一个好的方法是使用这样的东西:

public async Task<DataTable> CallDb(string connStr, string sql)
{
    var dt = new DataTable();
    var connection = new SqlConnection(connStr);
    var reader = await connection.CreateCommand().ExecuteReaderAsync();
    dt.Load(reader);

    return dt;
}

当然，应该进行一些更改，例如using 语句。但是，这里您使用的是正确的异步调用方式。