c# - 您能否使用 Linq-to-SQL 获得类似 DataReader 的流？

Question

我使用 Linq-to-SQL 已经有一段时间了，而且效果很好。但是，最近我一直在尝试使用它来提取大量数据，但遇到了一些问题。 (当然，我知道 L2S 可能不是这种特殊处理的正确工具，但这就是我进行试验的原因 - 找出它的局限性。)

这是一个代码示例:

var buf = new StringBuilder();
var dc = new DataContext(AppSettings.ConnectionString);
var records = from a in dc.GetTable<MyReallyBigTable>() where a.State == "OH" select a;
var i = 0;
foreach (var record in records) {
   buf.AppendLine(record.ID.ToString());
   i += 1;
   if (i > 3) {
      break; // Takes forever...
   }
}

一旦我开始遍历数据，查询就会按预期执行。当单步执行代码时，我立即进入循环，这正是我所希望的——这意味着 L2S 似乎在幕后使用 DataReader，而不是先提取所有数据。但是，一旦到达 break，查询将继续运行并提取所有其余记录。以下是我对 SO 社区的问题:

1.) 有没有办法像使用 DataReader 那样阻止 Linq-to-SQL 在中间完成一个非常大的查询的执行？

2.) 如果您执行大型 Linq-to-SQL 查询，是否有办法防止 DataContext 填充每个返回对象的更改跟踪信息。基本上，我能否像使用 DataReader 技术那样使用较短的对象生命周期进行大型查询，而不是填满内存？

如果这不是 DataContext 本身的内置功能并且需要通过一些自定义来扩展功能，我没意见。我只是想利用 Linq 的简单性和强大功能来处理夜间处理任务的大型查询，而不是依赖 T-SQL 来处理所有事情。

Answer 1

1.) Is there a way to stop Linq-to-SQL from finishing execution of a really big query in the middle the way you can with a DataReader?

不完全是。最终执行查询后，底层 SQL 语句将返回匹配记录的结果集。查询会延迟到该点，但不会在遍历期间延迟。

对于您的示例，您可以简单地使用 records.Take(3)，但我理解您停止进程的实际逻辑可能在 SQL 外部或不易翻译。

您可以通过构建强类型 LINQ 查询然后使用老式 ADO.NET 执行它来使用组合方法。缺点是您丢失了到类的映射并且必须手动处理 SqlDataReader 结果。下面显示了一个示例:

var query = from c in Customers
            where c.ID < 15
            select c;

using (var command = dc.GetCommand(query))
{
    command.Connection.Open();
    using (var reader = command.ExecuteReader())
    {
        int i = 0;
        while (reader.Read())
        {
            Customer c = new Customer();
            c.ID = reader.GetInt32(reader.GetOrdinal("ID"));
            c.Name = reader.GetString(reader.GetOrdinal("Name"));
            Console.WriteLine("{0}: {1}", c.ID, c.Name);
            i++;
            if (i > 3)
                break;
        }
    }
}

2.) If you execute a large Linq-to-SQL query, is there a way to prevent the DataContext from filling up with change tracking information for every object returned.

如果您对特定查询的意图是将其用于只读目的，那么您可以通过设置 DataContext.ObjectTrackingEnabled property 来禁用对象跟踪以提高性能。为假:

using (var dc = new MyDataContext())
{
    dc.ObjectTrackingEnabled = false;
    // do stuff
}

您还可以阅读此 MSDN 主题:How to: Retrieve Information As Read-Only (LINQ to SQL) .