如何正确将SQL Server存储过程调用方法改为异步？

方法一：使用SqlDataAdapter.FillAsync（最简洁） #

SqlDataAdapter从.NET Framework 4.5及.NET Core开始提供了异步填充方法FillAsync，用法和同步的Fill几乎一致，只需添加await关键字即可：

public async Task<DataTable> GetStoredProcedureDataAsync(string procedureName, SqlParameter[] parameters = null)
{
    var resultTable = new DataTable();
    
    // 用using自动管理连接、命令、适配器资源
    using (var connection = new SqlConnection("你的数据库连接字符串"))
    {
        await connection.OpenAsync(); // 异步打开连接
        
        using (var command = new SqlCommand(procedureName, connection))
        {
            command.CommandType = CommandType.StoredProcedure;
            
            // 添加存储过程参数（如果需要）
            if (parameters != null)
            {
                command.Parameters.AddRange(parameters);
            }
            
            using (var adapter = new SqlDataAdapter(command))
            {
                await adapter.FillAsync(resultTable); // 异步填充DataTable
            }
        }
    }
    
    return resultTable;
}

方法二：使用SqlDataReader异步读取（更灵活，适合复杂场景） #

如果需要更精细地控制数据读取过程（比如处理多结果集），可以用ExecuteReaderAsync获取异步数据读取器，再填充DataTable：

public async Task<DataTable> GetStoredProcedureDataAsync(string procedureName, SqlParameter[] parameters = null)
{
    var resultTable = new DataTable();
    
    using (var connection = new SqlConnection("你的数据库连接字符串"))
    {
        await connection.OpenAsync();
        
        using (var command = new SqlCommand(procedureName, connection))
        {
            command.CommandType = CommandType.StoredProcedure;
            
            if (parameters != null)
            {
                command.Parameters.AddRange(parameters);
            }
            
            // 异步获取数据读取器
            using (var reader = await command.ExecuteReaderAsync())
            {
                // 异步加载表架构（可选，确保DataTable列结构正确）
                await reader.GetSchemaTableAsync();
                // 填充DataTable
                resultTable.Load(reader);
                
                // 如果存储过程返回多个结果集，可循环处理
                // while (await reader.NextResultAsync())
                // {
                //     var anotherTable = new DataTable();
                //     anotherTable.Load(reader);
                //     // 处理第二个结果集
                // }
            }
        }
    }
    
    return resultTable;
}

核心注意事项 #

• 必须加await：所有涉及数据库IO的异步方法（OpenAsync、FillAsync、ExecuteReaderAsync等）都要标记await，否则方法会同步执行，失去异步意义，还会触发编译器警告。
• 资源管理：用using语句包裹SqlConnection、SqlCommand、SqlDataAdapter、SqlDataReader，确保资源自动释放，避免连接泄漏。
• 存储过程配置不变：设置CommandType = CommandType.StoredProcedure、添加参数的逻辑和同步代码完全一致，异步不影响存储过程的调用规则。

内容的提问来源于stack exchange，提问作者Hackerman