使用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，参数命名与存储过程一致即可。
以上就是C#中如何使用Dapper的存储过程异步执行？示例代码？的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1440005.html
微信扫一扫 
支付宝扫一扫 
