使用NHibernate流式傳輸大型結果集實際上工作嗎？

Question

我使用ayende這裏提出的方法：

http://ayende.com/Blog/archive/2010/06/27/nhibernate-streaming-large-result-sets.aspx

的SQL Server 2005與NHibernate 3.0。

我的測試（試圖用10,000,000項流式傳輸結果集）表明結果沒有被流式傳輸（看來整個結果集首先被加載到內存中）。

我該如何得到這個工作？我將接受任何允許在NHibernate中傳輸結果集的解決方案，它不一定非得是ayende的解決方案。

Answer 1

Ayende這樣說：

我們仍然有內存消耗的問題，雖然。會話 將跟蹤所有加載的對象，並且如果我們加載了大量的數據，它將最終以內存不足異常的形式出現。

這很可能是原因。你確定會話不跟蹤對象嗎？嘗試選擇不是實體，但他們的一些成員來測試這一點。

Answer 2

您可以從LINQ的與NH 4.0.0.4000以下擴展方法流結果（如果你不喜歡的反射黑客傳遞ISessionImplementor）：

public static EnumerableImpl Stream<T>(this IQueryable<T> source) 
{ 
    var provider = ((NhQueryable<T>) source).Provider as DefaultQueryProvider; 
    var sessionImpl = (ISessionImplementor)provider.GetType() 
     .GetProperty("Session", BindingFlags.NonPublic | 
      BindingFlags.Instance).GetValue(provider); 
    var expression = new NhLinqExpression(source.Expression, sessionImpl.Factory); 
    var query = sessionImpl.CreateQuery(expression); 
    query.SetParameters(expression.ParameterValuesByName); 
    provider.SetResultTransformerAndAdditionalCriteria(
     query, expression, expression.ParameterValuesByName); 
    return (EnumerableImpl)((AbstractQueryImpl2)query).Enumerable(); 
} 

private static void SetParameters(this IQuery query, 
    IDictionary<string, Tuple<object, IType>> parameters) 
{ 
    foreach (var parameterName in query.NamedParameters) 
    { 
     var param = parameters[parameterName]; 
     if (param.Item1 == null) 
     { 
      if (typeof(IEnumerable).IsAssignableFrom(param.Item2.ReturnedClass) && 
       param.Item2.ReturnedClass != typeof(string)) 
       query.SetParameterList(parameterName, null, param.Item2); 
      else query.SetParameter(parameterName, null, param.Item2); 
     } 
     else 
     { 
      if (param.Item1 is IEnumerable && !(param.Item1 is string)) 
       query.SetParameterList(parameterName, (IEnumerable)param.Item1); 
      else if (param.Item2 != null) 
       query.SetParameter(parameterName, param.Item1, param.Item2); 
      else query.SetParameter(parameterName, param.Item1); 
     } 
    } 
} 

你需要把它包在using語句，以確保讀寫器關閉：

using (var results = session.Query<Fark>().Take(50).Where(x => x.Enabled).Stream()) 
{ 
    results.ForEach(x => writer.WriteLine(x.ToCsv())); 
}