NHibernate - 流大的结果集？

Question

我必须读一个大的记录集，处理它，然后写出一个平面文件。

大的结果集来自于一个存储过程在SQL 2000

我目前有：
VAR的结果=执行Session.createSQLQuery（ “EXEC usp_SalesExtract”）名单（）;

我希望能够按行读取结果集行，减少内存占用

感谢

Answer 1

NHibernate的不是设计用于使用。另外，你并没有真正使用它的功能。

因此，在这种情况下，最好使用原始的ADO.NET。

Answer 2

为什么不直接使用SQL Server的BCP实用工具：http://msdn.microsoft.com/en-us/library/aa174646%28SQL.80%29.aspx写在文件存储过程。如果您需要对数据进行逻辑处理，请修改该程序以执行您的需要。

Answer 3

NHibernate不允许直接执行此操作。

可以使用session.Connection财产与ADO.NET SqlDataReader做到这一点：

SqlCommand MyCommand = new SqlCommand("sp_SalesExtract", session.Connection); 
MyCommand.CommandType = CommandType.StoredProcedure; 
SqlDataReader MyDataReader = MyCommand.ExecuteReader(); 

while (MyDataReader.Read()) 
{ 
    // handle row data (MyDataReader[0] ...) 
} 

Answer 4

如果你可以用LINQ查询的数据NH可以流与下面的扩展方法的结果（通过中，如果你不喜欢的反射黑客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())); 
}