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>(注意:不是流式逐行读取,而是“一次性异步加载完该结果集”)。
顺序不能错,且不能跳过某个结果集
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>都是原子异步操作,按序执行即可。
