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

来源:这里教程网 时间:2026-02-21 17:34:46 作者:

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>
都是原子异步操作,按序执行即可。

相关推荐