使用Dapper异步调用存储过程需通过QueryAsync或ExecuteAsync方法，配合IDbConnection和CommandType.StoredProcedure。1. 安装Dapper包后，可使用QueryAsync执行返回结果集的存储过程，如查询用户信息；2. 对于无返回结果的操作（如增删改），使用ExecuteAsync；3. 带输出参数时，结合DynamicParameters设置输入输出参数，并在执行后获取输出值；4. 在控制台程序中演示了完整调用流程，包括打开连接、异步查询并返回实体对象。关键点：正确配置命令类型、参数匹配、异步等待及连接管理。
在C#中使用Dapper调用存储过程并以异步方式执行，可以通过 QueryAsync、ExecuteAsync 等方法实现。你需要配合 IDbConnection 接口（如 SqlConnection）使用，并设置 CommandType.StoredProcedure。
1. 引入 Dapper 包
确保项目已安装 Dapper：
Install-Package Dapper
2. 异步查询存储过程（返回结果集）
以下示例展示如何异步调用返回数据的存储过程：
示例代码：
using (var connection = new SqlConnection(connectionString))
{
var parameters = new { UserId = 123 };
var users = await connection.QueryAsync(
"sp_GetUserById",
parameters,
commandType: CommandType.StoredProcedure);
return users.ToList();
}
说明：
- sp_GetUserById 是数据库中的存储过程名称。
- User 是你定义的实体类。
- 参数通过匿名对象传入。
3. 异步执行无返回结果的存储过程
用于插入、更新或删除操作：
using (var connection = new SqlConnection(connectionString))
{
var parameters = new
{
Name = "张三",
Email = "zhangsan@example.com"
};
await connection.ExecuteAsync(
"sp_InsertUser",
parameters,
commandType: CommandType.StoredProcedure);}
4. 调用带输出参数的存储过程（异步+Output）
Dapper 原生不直接支持异步获取输出参数，但你可以使用 DynamicParameters 配合异步调用：
using (var connection = new SqlConnection(connectionString))
{
var dbParams = new DynamicParameters();
dbParams.Add("@Name", "李四");
dbParams.Add("@NewId", dbType: DbType.Int32, direction: ParameterDirection.Output);
await connection.ExecuteAsync(
"sp_InsertUserWithOutput",
dbParams,
commandType: CommandType.StoredProcedure);
int newId = dbParams.Get("@NewId");
Console.WriteLine($"新用户ID: {newId}"); }
5. 完整示例：控制台程序调用异步存储过程
class Program
{
static async Task Main(string[] args)
{
string connStr = "Server=.;Database=TestDB;Integrated Security=true;";
using var conn = new SqlConnection(connStr);
await conn.OpenAsync();
var result = await GetUserByIdAsync(conn, 1);
Console.WriteLine($"用户名: {result.Name}");
}
static async Task GetUserByIdAsync(IDbConnection conn, int userId)
{
var param = new { UserId = userId };
var sql = "sp_GetUserById";
var user = await conn.QueryFirstOrDefaultAsync(
sql,
param,
commandType: CommandType.StoredProcedure);
return user;
} }
public class User
{
public int Id { get; set; }
public string Name { get; set; }
public string Email { get; set; }
}
基本上就这些。注意连接要正确打开，异步方法记得加 await，参数命名与存储过程一致即可。
