使用异步方法调用数据库存储过程需通过executereaderasync、executenonqueryasync或executescalarasync配合sqlcommand，确保方法返回task或task，并用await实现非阻塞操作。1. 设置异步环境：定义async task方法，使用sqlconnection.openasync建立连接，sqlcommand配置存储过程名及参数类型；2. 处理输出参数和返回值：为输出参数创建sqlparameter并设置direction为output，returnvalue接收返回值，执行executenonqueryasync后读取结果；3. 读取结果集：对查询类存储过程使用executereaderasync与sqldatareader.readasync逐行解析数据填充实体列表；4. asp.net core中直接在控制器action内await调用异步方法返回ok结果。正确使用异步api可提升应用响应性能。
在C#中调用数据库存储过程并实现异步操作，完全可以使用 await 和异步方法来完成。关键在于使用支持异步的 ADO.NET 方法，如 ExecuteReaderAsync、ExecuteNonQueryAsync 或 ExecuteScalarAsync，配合 SqlCommand 调用存储过程。
1. 设置异步调用环境
确保你的方法是异步的，并返回 Task 或 Task<t></t>。例如：
public async Task<int> CallStoredProcedureAsync(int userId)
{
string connectionString = "your_connection_string";
using (var connection = new SqlConnection(connectionString))
{
await connection.OpenAsync();
using (var command = new SqlCommand("YourStoredProcedureName", connection))
{
command.CommandType = CommandType.StoredProcedure;
// 添加参数
command.Parameters.AddWithValue("@UserId", userId);
command.Parameters.AddWithValue("@OtherParam", "value");
// 执行并返回影响行数
int result = await command.ExecuteNonQueryAsync();
return result;
}
}
}
2. 获取返回值或输出参数
如果存储过程有输出参数或返回值，需要显式定义：
NetShop网店系统
下载
NetShop软件特点介绍： 1、使用ASP.Net(c#)2.0、多层结构开发 2、前台设计不采用任何.NET内置控件读取数据，完全标签化模板处理，加快读取速度3、安全的数据添加删除读取操作，利用存储过程模式彻底防制SQL注入式攻击4、前台架构DIV+CSS兼容IE6,IE7,FF等，有利于搜索引挚收录5、后台内置强大的功能，整合多家网店系统的功能，加以优化。6、支持三种类型的数据库：Acces
public async Task<int> CallStoredProcedureWithOutputAsync(int input, out string outputValue)
{
outputValue = string.Empty;
string connectionString = "your_connection_string";
using (var connection = new SqlConnection(connectionString))
{
await connection.OpenAsync();
using (var command = new SqlCommand("ProcWithOutput", connection))
{
command.CommandType = CommandType.StoredProcedure;
// 输入参数
command.Parameters.AddWithValue("@InputParam", input);
// 输出参数
var outputParam = new SqlParameter("@OutputParam", SqlDbType.VarChar, 50)
{
Direction = ParameterDirection.Output
};
command.Parameters.Add(outputParam);
// 返回值参数
var returnParam = new SqlParameter("@ReturnVal", SqlDbType.Int)
{
Direction = ParameterDirection.ReturnValue
};
command.Parameters.Add(returnParam);
await command.ExecuteNonQueryAsync();
outputValue = outputParam.Value?.ToString();
return (int)returnParam.Value;
}
}
}
3. 读取结果集（如查询类存储过程）
若存储过程返回数据，使用 ExecuteReaderAsync：
public async Task<List<User>> GetUsersFromStoredProcedureAsync()
{
var users = new List<User>();
string connectionString = "your_connection_string";
using (var connection = new SqlConnection(connectionString))
{
await connection.OpenAsync();
using (var command = new SqlCommand("GetUsers", connection))
{
command.CommandType = CommandType.StoredProcedure;
using (var reader = await command.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
{
users.Add(new User
{
Id = reader.GetInt32("Id"),
Name = reader.GetString("Name")
});
}
}
}
}
return users;
}
4. 在 ASP.NET Core 中调用示例
控制器中可以直接 await 异步方法：
[HttpGet]
public async Task<IActionResult> GetUsers()
{
var users = await _repository.GetUsersFromStoredProcedureAsync();
return Ok(users);
}
基本上就这些。只要使用正确的异步 ADO.NET 方法，配合 await，就能高效地异步调用存储过程，避免阻塞线程，提升应用响应能力。
