Dapper Reader 已处理异常
本文关键字:异常 处理 Reader Dapper | 更新日期: 2023-09-27 18:34:29
我确实用下面的代码扩展了GridReader;
/// <summary>
///
/// </summary>
public static class Extentions
{
/// <summary>
/// Maps the specified reader.
/// </summary>
/// <typeparam name="TFirst">The type of the first.</typeparam>
/// <typeparam name="TSecond">The type of the second.</typeparam>
/// <typeparam name="TKey">The type of the key.</typeparam>
/// <param name="reader">The reader.</param>
/// <param name="firstKey">The first key.</param>
/// <param name="secondKey">The second key.</param>
/// <param name="addChildren">The add children.</param>
/// <returns></returns>
public static IEnumerable<TFirst> Map<TFirst, TSecond, TKey>
(
this Dapper.SqlMapper.GridReader reader,
Func<TFirst, TKey> firstKey,
Func<TSecond, TKey> secondKey,
Action<TFirst, IEnumerable<TSecond>> addChildren
)
{
var first = reader.Read<TFirst>().ToList();
var childMap = reader
.Read<TSecond>()
.GroupBy(s => secondKey(s))
.ToDictionary(g => g.Key, g => g.AsEnumerable());
foreach (var item in first)
{
IEnumerable<TSecond> children;
if (childMap.TryGetValue(firstKey(item), out children))
{
addChildren(item, children);
}
}
return first;
}
}
读取器已被释放;这可能在所有数据都已使用之后发生
这里的品脱然后当调用该方法时,读取器在第一次读取所有数据,但赢得输入的方法
var first = reader.Read<TFirst>().ToList();
这一行给出了上面的例外。 那么除了查询之外,有什么方法可以让 Dapper Reader 保持活力。
提前谢谢.
注意;该方法的调用方式如下
var sql = (@"SELECT *
FROM [pubs].[dbo].[authors] as a
right join pubs.dbo.titleauthor as b
ON a.au_id = b.au_idT");
var data = connection.QueryMultiple(sql).Map<authors, titleauthor, string>(
au => au.au_id,
tit => tit.au_idT,
(au, tits) => { au.titleauthor = tits; });
QueryMultiple
API 适用于通过多个结果网格涉及垂直分区的查询,即:
select * from Parent where Id = @id;
select * from Child where ParentId = @id;
您使用的是水平分区 - 您只需要使用Query<,,>
API:
var records = connection.Query<TFirst, TSecond, TFirst>(...);
或者:重新构建 SQL 以实际返回多个网格。
它引发异常的原因是您的代码正在请求不存在的第二个网格。