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(),而是为每个结果集显式调用类型安全的异步读取方法,例如:

  • var users = await reader.ReadAsync();
  • var orders = await reader.ReadAsync();
  • var logs = await reader.ReadAsync();

这些方法内部会异步拉取对应结果集的全部数据并映射为 IEnumerable(注意:不是流式逐行读取,而是“一次性异步加载完该结果集”)。

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

GridReader 是按声明顺序逐个消费结果集的,调用 ReadAsync() 会自动推进到下一个结果集:

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

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

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

  • 推荐用 using await(C# 8+)或显式 await using 管理连接
  • 避免在 ReadAsync 之间关闭连接,否则会触发 ObjectDisposedException
  • 示例片段:
    await using var conn = new SqlConnection(connStr);
    await conn.OpenAsync();
    using var reader = await conn.QueryMultipleAsync("SELECT * FROM Users; SELECT * FROM Orders;");
    var users = await reader.ReadAsync();
    var orders = await reader.ReadAsync();

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