Reader.IsConsumption是假的，但对象被释放了

Question

我正在使用返回GridReader的QueryMultiple。

由于我不知道我要读取多少数据，所以我在读取器上循环，停止条件为 IsConsumed ：

using (var reader = conn.QueryMultiple(mySql)) {
  while(!reader.IsConsumed) {
    reader.Read<...>
  }
}

但是，我总是在最后一次阅读时得到ObjectDisposedException。IsConsumed的价值仍然false。

我试图将DynamicParameters传递给查询，目的是获得回调（这似乎通过 IParameterCallbacks 很有用），但我无法将其修补在一起。

我真的宁愿代码中没有这样的预期异常。感谢您的任何帮助。

我正在使用 SQL Server，我的提供程序在 .NET 4.5 中System.Data.SqlClient，Dapper 版本 1.40.0.0

失败的测试，例如：

        [TestMethod]
        public void QueryMultipleWithCursor()
        {
            const string sql = @"
DECLARE @CurrentDate DATE
DECLARE DatesCursor CURSOR LOCAL FOR
    SELECT DISTINCT DataDate FROM Data_Table ORDER BY DataDate 
OPEN DatesCursor
FETCH NEXT FROM DatesCursor INTO @CurrentDate
WHILE @@FETCH_STATUS = 0 BEGIN
    SELECT DISTINCT
        DataDate AS Date1,
        DataDate AS Date2
        FROM Data_Table
        WHERE DataDate=@CurrentDate
    FETCH NEXT FROM DatesCursor INTO @CurrentDate
END
CLOSE DatesCursor
DEALLOCATE DatesCursor";
            using (var conn = _database.GetConnection())
            {
                    var reader = conn.QueryMultiple(sql);
                    while (!reader.IsConsumed)
                    {
                            reader.Read<DateTime, DateTime, DateTime>(
                                (date1, date2) => date1,
                                splitOn: "Date2").ToList();
                    }
            }
        }

我得到了以下堆栈的NullReferenceException：

at Dapper.SqlMapper.GridReader.NextResult() in D:Devdapper-dot-netDapper NET40SqlMapper.cs:line 4440
   at Dapper.SqlMapper.GridReader.<MultiReadInternal>d__9`8.System.IDisposable.Dispose()
   at Dapper.SqlMapper.GridReader.<MultiReadInternal>d__9`8.MoveNext() in D:Devdapper-dot-netDapper NET40SqlMapper.cs:line 4309
   at System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
   at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
   at Dapper.SqlMapper.GridReader.Read[TFirst,TSecond,TReturn](Func`3 func, String splitOn, Boolean buffered) in D:Devdapper-dot-netDapper NET40SqlMapper.cs:line 4330
   at Project.MyTests.QueryMultipleWithCursor() in C:ProjectMyTests.cs:line 171
Result Message: 
Test method Project.MyTests.QueryMultipleWithCursor threw exception: 
System.NullReferenceException: Object reference not set to an instance of an object.

Answer 1

我已经推送了以下内容，它传递了SQL Server/SqlConnection; 所以它可以工作：

[Fact]
public void SO35554284_QueryMultipleUntilConsumed()
{
    using (var reader = connection.QueryMultiple(
        "select 1 as Id; select 2 as Id; select 3 as Id;"))
    {
        List<HazNameId> items = new List<HazNameId>();
        while (!reader.IsConsumed)
        {
            items.AddRange(reader.Read<HazNameId>());
        }
        items.Count.IsEqualTo(3);
        items[0].Id.IsEqualTo(1);
        items[1].Id.IsEqualTo(2);
        items[2].Id.IsEqualTo(3);
    }
}

我想知道这里的问题是否是特定 ADO.NET 提供商的问题。您可能希望准确指定：

• 您正在使用什么后端RDBMS/等（SQL Server？神谕？Postgresql？...?)
• 您正在使用哪个 ADO.NET 提供程序
• 您正在使用什么运行时（.NET what.what？core-clr？）/操作系统
• 您使用的确切库版本（以上是针对源代码的，与 1.50.0-beta8 最相似）

Answer 2

我在使用Dapper时遇到了同样的问题，并且我正在使用版本1.42.0和SQL Server 2012作为后端。调试时，我发现仅当我们尝试在最后一个结果集上使用 Dapper 的 splitOn 选项创建多个对象时，才会发生此问题。

我在 GitHub 上提交了新问题https://github.com/StackExchange/dapper-dot-net/issues/469

Answer 3

好吧，这似乎是 Dapper 实现的一个问题，同时我同时使用 Dapper 和 SqlDataReader ，这更可靠：

public static SqlMapper.GridReader QueryMultipleStoredProcedure(this IDbConnection dbConnection, string spName, object parameters, out SqlDataReader sqlDataReader)
        {
            var gridReader = dbConnection.QueryMultiple(spName, new DynamicParameters(parameters), commandType: CommandType.StoredProcedure);
            sqlDataReader = typeof (SqlMapper.GridReader).GetInstanceField<SqlDataReader>(gridReader, "reader");
            return gridReader;
        }
        private static T GetInstanceField<T>(this Type type, object instance, string fieldName)
        {
            var bindFlags = BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic;
            var field = type.GetField(fieldName, bindFlags);
            return (T) field?.GetValue(instance);
        }

然后我可以使用sqlDataReader.HasRows