C#中如何使用Dapper的存储过程异步执行？示例代码？

在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 };
<pre class="brush:php;toolbar:false;">var users = await connection.QueryAsync<User>(
    "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"
    };
<pre class="brush:php;toolbar:false;">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);
<pre class="brush:php;toolbar:false;">await connection.ExecuteAsync(
    "sp_InsertUserWithOutput",
    dbParams,
    commandType: CommandType.StoredProcedure);
int newId = dbParams.Get<int>("@NewId");
Console.WriteLine($"新用户ID: {newId}");

}

5. 完整示例：控制台程序调用异步存储过程

class Program
{
    static async Task Main(string[] args)
    {
        string connStr = "Server=.;Database=TestDB;Integrated Security=true;";
<pre class="brush:php;toolbar:false;">    using var conn = new SqlConnection(connStr);
    await conn.OpenAsync();
    var result = await GetUserByIdAsync(conn, 1);
    Console.WriteLine($"用户名: {result.Name}");
}
static async Task<User> GetUserByIdAsync(IDbConnection conn, int userId)
{
    var param = new { UserId = userId };
    var sql = "sp_GetUserById";
    var user = await conn.QueryFirstOrDefaultAsync<User>(
        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，参数命名与存储过程一致即可。