Dapper的GridReader如何实现异步 Dapper异步读取多结果集

Dapper 的 GridReader 本身不支持异步读取，但需通过 QueryMultipleAsync 异步获取实例，并按顺序调用 ReadAsync() 逐个读取结果集，且连接必须保持打开直至全部读取完成。

Dapper 的 GridReader 本身不直接支持异步操作，但它提供的 QueryMultipleAsync 方法可返回一个支持异步读取多结果集的 GridReader 实例——关键在于：你得用对方法、注意调用顺序，并确保底层数据库连接支持异步（如 SQL Server 的 SqlConnection 启用 async）。

必须用 QueryMultipleAsync 获取 GridReader

GridReader 是 Dapper 执行多结果集查询（如存储过程返回多个 SELECT 或用分号分隔的多个语句）后返回的“游标式”读取器。它本身没有 ReadAsync 方法，但它的创建入口是异步的：

• ✅ 正确方式：using var reader = await connection.QueryMultipleAsync(sql);
• ❌ 错误方式：connection.QueryMultiple(sql) —— 这是同步版，会阻塞线程，且后续 Read() 也是同步的

每个结果集需单独调用 ReadAsync 对应的泛型方法

GridReader 不提供通用的 ReadAsync<t>()</t>，而是为每个结果集显式调用类型安全的异步读取方法，例如：

• var users = await reader.ReadAsync<user>();</user>
• var orders = await reader.ReadAsync<order>();</order>
• var logs = await reader.ReadAsync<log>();</log>

这些方法内部会异步拉取对应结果集的全部数据并映射为 IEnumerable<t></t>（注意：不是流式逐行读取，而是“一次性异步加载完该结果集”）。

Browse AI

AI驱动的网页内容抓取和数据采集工具

105

查看详情

顺序不能错，且不能跳过某个结果集

GridReader 是按声明顺序逐个消费结果集的，调用 ReadAsync<t>()</t> 会自动推进到下一个结果集：

• 第一次 ReadAsync<user>()</user> 读取第一个结果集
• 第二次 ReadAsync<order>()</order> 读取第二个结果集（即使你其实只想读第三个，也必须先读前两个或调用 Read<object>()</object> 占位）
• 如果跳过某个结果集未读取，后续读取会偏移错乱，甚至抛出 InvalidOperationException

配合 async/await 使用时注意连接生命周期

由于整个链路是异步的，务必保证数据库连接在所有 ReadAsync 完成前保持打开状态：

• 推荐用 using await（C# 8+）或显式 await using 管理连接
• 避免在 ReadAsync 之间关闭连接，否则会触发 ObjectDisposedException
• 示例片段：

  await using var conn = new SqlConnection(connStr);<br>await conn.OpenAsync();<br>using var reader = await conn.QueryMultipleAsync("SELECT * FROM Users; SELECT * FROM Orders;");<br>var users = await reader.ReadAsync<User>();<br>var orders = await reader.ReadAsync<Order>();

  登录后复制

基本上就这些。Dapper 的异步多结果集读取不复杂但容易忽略调用入口和顺序约束——记牢 QueryMultipleAsync 是唯一起点，每个 ReadAsync<t></t> 都是原子异步操作，按序执行即可。

以上就是Dapper的GridReader如何实现异步 Dapper异步读取多结果集的详细内容，更多请关注php中文网其它相关文章！