我在一个.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 可能会返回具有不同模式的数据。有没有更好的方法来处理动态模式？
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;
}
dt.Load。要获得该好处，您应该使用SqlDataReader提供的异步方法：NextResultAsync和ReadAsync，或创建自己的dt.LoadAsync。 - Saeb Amini虽然在这种情况下对ExecuteReaderAsync()的初始调用不会阻塞，但是dt.Load(reader)可能执行的是reader.Read()的等效操作而不是await reader.ReadAsync()，并且在检索行时可能会阻塞调用线程。
如果您确实需要一个用于与外部API一起使用或因为不预先知道字段定义而需要完全异步行为的DataTable，那么最好使用自己的代码构建DataTable，根据reader.GetName()和reader.GetFieldType()添加所需的列，然后使用循环使用await reader.ReadAsync()和dt.Rows.Add()填充它的行。
在Camilo Terevinto的回答基础上，我想异步处理从异步读取器(DataTable.Load)加载数据表的操作。
我创建了一个SqlCommand扩展，以每次读取一条记录的方式读取数据。虽然数据仍然同步加载，但使用ReadAsync进行异步迭代，每次迭代一条记录。
public static class SqlExtensions
{
public static async Task<DataTable> FillDataTableAsync(this SqlCommand cmd)
{
DataTable dt = null;
using (var reader = await cmd.ExecuteReaderAsync(CommandBehavior.SequentialAccess))
{
DataTable schemaTable = await reader.GetSchemaTableAsync();
dt = new DataTable();
foreach (DataRow row in schemaTable.Rows)
dt.Columns.Add(row.Field<string>("ColumnName"), row.Field<Type>("DataType"));
while (await reader.ReadAsync())
{
DataRow dr = dt.Rows.Add();
foreach (DataColumn col in dt.Columns)
dr[col.ColumnName] = reader[col.ColumnName];
}
}
return dt;
}
}
并且像这样使用它：
DataTable dt = null;
using (SqlCommand cmd = new SqlCommand("SELECT * FROM TABLE", conn))
{
dt = await cmd.FillDataTableAsync();
}
如果我需要异步更新DataTable，我会先删除记录，然后在事务内使用SqlBulkCopy的WriteToServerAsync(dt)方法。
using (SqlCommand cmd = new SqlCommand("DELETE FROM TABLE", transaction.Connection))
{
cmd.Transaction = transaction;
await cmd.ExecuteNonQueryAsync();
}
using (SqlBulkCopy copy = new SqlBulkCopy(transaction.Connection, SqlBulkCopyOptions.Default, transaction))
{
copy.DestinationTableName = "TABLE";
await copy.WriteToServerAsync(dt);
}
注意：我尚未测试其效率与SqlDataAdapter相比。
await reader.ReadAsync().ConfigureAwait(false)，我不确定为什么会这样。 - clamchodaDataTable dt = new();
using (var reader = await sqlComm.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
{
var values = new Object[reader.FieldCount];
reader.GetValues(values);
dt.Rows.Add(values);
}
}
return dt; - TreeAndLeafDataTable dt = new();
using (var reader = await sqlComm.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
{
var values = new Object[reader.FieldCount];
reader.GetValues(values);
dt.Rows.Add(values);
}
}
return dt; - undefined
O'Brien的人这样的天真数据问题，并且它们有助于提高性能。其次，这种态度会导致其他项目中出现糟糕的代码，当它确实很重要时。参数只是正确的做法。学会正确使用它们并在您的常见数据模式中考虑它们，这样当仅用于娱乐的代码突然变得真实时，您已经在正确的方式下进行操作了。 - Joel Coehoorn