使用Dapper QueryMultipleAsync时区分返回值与结果集的问题
用Dapper QueryMultipleAsync处理存储过程返回值与多结果集
这个场景我太熟悉了!之前做权限校验的时候刚好碰到过类似需求,用Dapper的QueryMultipleAsync配合存储过程的返回值完全能搞定,给你一步步说怎么实现:
首先,核心思路是:我们需要给存储过程的调用添加一个返回值参数,用来捕获存储过程里RETURN 3这类返回码,然后在读取结果集之前先判断这个返回码,再决定后续逻辑。
具体实现步骤
构建带返回值的参数集合
用Dapper的DynamicParameters来封装输入参数,同时专门添加一个Direction为ReturnValue的参数,用来接收存储过程的返回码。执行QueryMultipleAsync调用存储过程
调用的时候要指定commandType为StoredProcedure,确保Dapper知道这是调用存储过程。先读取返回值做权限判断
这里一定要注意顺序:先从参数里获取返回值,再去读结果集。因为如果存储过程触发了RETURN 3,后续的结果集根本不会生成,先判断返回值能避免无效的结果集读取操作。权限通过后读取多结果集
如果返回码不是3,就按照存储过程里SELECT语句的顺序,依次读取对应的结果集即可。
完整代码示例
public async Task<(List<Order> UserOrders, List<Payment> UserPayments)> GetUserRelatedDataAsync(int requestUserId, int currentUserRole) { // 初始化数据库连接(建议用依赖注入的方式管理连接,这里是示例) using var connection = new SqlConnection("Your_Connection_String_Here"); var parameters = new DynamicParameters(); // 添加存储过程需要的输入参数 parameters.Add("@RequestUserId", requestUserId, DbType.Int32); parameters.Add("@CurrentUserRole", currentUserRole, DbType.Int32); // 关键:添加捕获存储过程返回值的参数 parameters.Add("@ProcReturnCode", dbType: DbType.Int32, direction: ParameterDirection.ReturnValue); // 调用存储过程,指定CommandType using var multiResult = await connection.QueryMultipleAsync( "Your_Stored_Procedure_Name", parameters, commandType: CommandType.StoredProcedure ); // 先获取返回值,判断权限 var returnCode = parameters.Get<int>("@ProcReturnCode"); if (returnCode == 3) { // 权限不足的处理逻辑,比如抛出自定义异常或者返回空结果 throw new UnauthorizedAccessException("权限不足,无法访问该用户的数据"); } // 权限通过后,按顺序读取结果集(要和存储过程里SELECT的顺序一致) var userOrders = await multiResult.ReadAsync<Order>().ToListAsync(); var userPayments = await multiResult.ReadAsync<Payment>().ToListAsync(); return (userOrders, userPayments); }
几个关键注意点
- 返回值参数的方向必须设对:一定要把参数的
direction设为ParameterDirection.ReturnValue,否则Dapper不会自动捕获存储过程的RETURN值。 - 读取顺序不能乱:先取返回值,再读结果集。如果存储过程因为权限问题直接
RETURN了,后续的SELECT不会执行,这时候结果集是空的,提前判断能避免不必要的IO操作。 - 结果集顺序要匹配:
ReadAsync<T>的调用顺序必须和存储过程里SELECT语句的执行顺序完全一致,否则会读错数据。
内容的提问来源于stack exchange,提问作者JustWork
相关产品推荐
相关产品推荐

