ADO.NET大数据查询内存分页处理
在ADO.NET中处理大数据查询时，如果直接在客户端应用程序中进行内存分页，可能会导致内存使用量激增，特别是在处理数十万甚至数百万条记录时。为了避免这种情况，应该优先使用数据库层面的分页（如使用SQL Server的OFFSET和FETCH，或者ROW_NUMBER()函数等）。
然而，如果你确实需要将所有数据加载到客户端应用程序中进行处理，并且数据量太大，不适合一次性加载到内存中，你可以考虑以下几种策略来实现内存分页：
- 分批加载数据：
使用SqlDataReader或DataSet的分批加载功能，每次只从数据库中检索一小部分数据到内存中，处理完这部分数据后再加载下一批。 - 使用yield return实现延迟执行：
你可以编写一个返回IEnumerable<T>的方法，使用yield return关键字来延迟执行查询并一次只返回一个结果。这种方法允许你编写一个像迭代器一样的查询，它一次只从数据库中检索一条记录。 - 使用缓冲区和分页集合：
创建一个自定义的集合类，该类内部实现了一个缓冲区来存储当前页的数据，并提供方法来加载下一页或上一页的数据。
以下是一个使用yield return实现延迟执行查询的示例：
csharp代码
| using System; | |
| using System.Collections.Generic; | |
| using System.Data; | |
| using System.Data.SqlClient; | |
| public class PagedData<T> : IEnumerable<T> | |
| { | |
| private readonly SqlConnection _connection; | |
| private readonly SqlCommand _command; | |
| private int _currentPage; | |
| private int _pageSize; | |
| public PagedData(SqlConnection connection, SqlCommand command, int pageSize) | |
| { | |
| _connection = connection; | |
| _command = command; | |
| _pageSize = pageSize; | |
| } | |
| public IEnumerator<T> GetEnumerator() | |
| { | |
| _currentPage = 1; | |
| LoadPage(); | |
| yield break; | |
| } | |
| System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator() | |
| { | |
| return GetEnumerator(); | |
| } | |
| private void LoadPage() | |
| { | |
| _command.CommandText += $" OFFSET {(_currentPage - 1) * _pageSize} ROWS FETCH NEXT {_pageSize} ROWS ONLY"; | |
| _connection.Open(); | |
| using (SqlDataReader reader = _command.ExecuteReader()) | |
| { | |
| while (reader.Read()) | |
| { | |
| T item = MapRowToItem(reader); | |
| yield return item; | |
| } | |
| } | |
| _connection.Close(); | |
| } | |
| protected virtual T MapRowToItem(SqlDataReader reader) | |
| { | |
| // 实现将数据库行映射到具体类型的逻辑 | |
| throw new NotImplementedException(); | |
| } | |
| public void NextPage() | |
| { | |
| _currentPage++; | |
| LoadPage(); | |
| } | |
| } | |
| // 使用示例 | |
| public class Program | |
| { | |
| static void Main() | |
| { | |
| string connectionString = "你的连接字符串"; | |
| using (SqlConnection connection = new SqlConnection(connectionString)) | |
| { | |
| connection.Open(); | |
| SqlCommand command = new SqlCommand("SELECT * FROM YourTable ORDER BY SomeColumn", connection); | |
| PagedData<YourDataType> pagedData = new PagedData<YourDataType>(connection, command, 10); | |
| foreach (var item in pagedData) | |
| { | |
| // 处理每个项目 | |
| Console.WriteLine(item.SomeProperty); | |
| } | |
| // 加载下一页 | |
| pagedData.NextPage(); | |
| // 再次遍历处理下一页数据 | |
| foreach (var item in pagedData) | |
| { | |
| Console.WriteLine(item.SomeProperty); | |
| } | |
| } | |
| } | |
| } |
在这个示例中，PagedData<T>类实现了IEnumerable<T>接口，并使用yield return来延迟执行查询。它内部维护了一个当前页码和每页的大小，并在每次调用NextPage方法时加载下一页的数据。MapRowToItem方法需要根据你的具体数据类型来实现将数据库行映射到对象的逻辑。
请注意，这种方法的效率取决于数据库查询的性能以及网络延迟。对于非常大的数据集，即使使用延迟执行，也可能会有性能问题。因此，通常推荐在数据库层面进行分页，而不是在客户端应用程序中进行内存分页。
