1

我有一个使用 SqlDataReader 读取数据的方法，yield 返回一个 IEnumerable，例如：

IEnumerable<string> LoadCustomers()
{
 using(SqlDataReader rdr = cmd.ExecuteReader())
 {
    while (rdr.Read())
    {
        yield return rdr.GetString(0); 
    }
 }
}

现在假设我只需要最新的 10 个客户。我可以

LoadCustomers.Take(10)

或将 10 作为参数传递给 sql 并制作我的 sql

SELECT TOP 10 FROM Customers ORDER BY CreationDate DESC

根据这篇文章，即使数据读取器只读取几行（只要连接打开），整个结果集也会从 sql server 传输到客户端 - 我是否应该避免这种Take(10)方法，因为无论如何都会将额外的数据传输到客户端或者避免它会是一个过早的优化（因为在读取 10 行之后，yield 返回代码会关闭连接，然后数据传输无论如何都会停止）？

4

2 回答 2

2

由于优化是否“过早”是主观的，我选择将此问题解释为“使用 aDataReader并在 10 行后停止读取是否具有与在查询中使用相同的性能特征TOP(10)？”

答案是不。传递TOP(10)到服务器允许优化器调整读取、内存授予、I/O 缓冲区、锁定粒度和并行性，并且知道查询将返回（在本例中也是读取）最多 10 行。省略TOP意味着它必须为客户端将读取所有行的情况做准备——无论您是否真的更早停止。

无论您是否阅读它们，服务器都会发送行是不正确的。使用 a 拉取行在SqlDataReader概念上是逐行操作：当您发出 时Reader.MoveNext，您会从服务器获取下一行并且仅获取该行。但出于性能考虑，行在您请求它们之前被缓冲（都在服务器端和网络缓冲区中）。因此，在您第一次.MoveNext调用后，可能会在缓冲区中检索到 100 行，即使您只读取了其中的 10 行。

关于开销，这不是我主要关心的问题，因为这些缓冲区最终具有固定大小：无论结果集有多少行，服务器都不会去缓冲结果集的所有行（这通常会非常低效）。如果您只读取 10 行，那么如果查询运行完成，最终返回 1,000 行还是 1,000,000 行在缓冲方面并不重要，而主要是在查询计划方面。然而，它确实增加了开销。

于 2016-07-29T10:48:59.120 回答
1

您还可以使用分页 Skip(0) 和 Take(10) 更灵活。

SQL 服务器 2012

SELECT name,
       CreationDate        
  FROM customer
 ORDER BY
       CreationDate      
OFFSET @skip ROWS
FETCH NEXT @take ROWS ONLY;

SQL 2005 到 2008

SET @take = (@skip + @take)

;WITH customer_page_cte AS
(SELECT 
        name, 
        CreationDate,
        ROW_NUMBER() OVER (ORDER BY CreationDate desc) AS RowNumber
 FROM customer
)

SELECT name, 
       CreationDate
  FROM customer_page_cte
 WHERE RowNumber > @skip AND RowNumber <= @take

带有 sql 2012 的 C# - 将存储过程用于命令:)

var command = @"SELECT name,
                       CreationDate        
                  FROM customer
                 ORDER BY
                       CreationDate      
                 OFFSET @skip ROWS
                 FETCH NEXT @take ROWS ONLY;";

            using (var conn = new SqlConnection("Data Source=.;Initial Catalog=Stackoverflow;Integrated Security=True"))
            {
                conn.Open();
                using (var cmd = new SqlCommand(command, conn))
                {
                    cmd.Parameters.AddWithValue("skip", 0);
                    cmd.Parameters.AddWithValue("take", 10);

                    var reader = cmd.ExecuteReader();
                    while (reader.Read())
                    {
                        Console.WriteLine(reader.GetString(0));
                    }
                }
            }
于 2016-07-27T10:09:57.800 回答