C#中如何使用Dapper的存储过程异步执行？示例代码？-C#.Net教程-PHP中文网

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

星降

发布： 2025-09-26 12:32:01

原创

630人浏览过

使用Dapper异步调用存储过程需通过QueryAsync或ExecuteAsync方法，配合IDbConnection和CommandType.StoredProcedure。1. 安装Dapper包后，可使用QueryAsync执行返回结果集的存储过程，如查询用户信息；2. 对于无返回结果的操作（如增删改），使用ExecuteAsync；3. 带输出参数时，结合DynamicParameters设置输入输出参数，并在执行后获取输出值；4. 在控制台程序中演示了完整调用流程，包括打开连接、异步查询并返回实体对象。关键点：正确配置命令类型、参数匹配、异步等待及连接管理。

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;"><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;"><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;"><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;"><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，参数命名与存储过程一致即可。

以上就是C#中如何使用Dapper的存储过程异步执行？示例代码？的详细内容，更多请关注php中文网其它相关文章！