Как оптимизировать запросы на чтение используя EF Core?

Оптимизация запросов на чтение в Entity Framework Core

Оптимизация запросов на чтение в EF Core — критически важный аспект для производительности приложений, особенно в высоконагруженных системах. Вот комплексный подход к решению этой задачи.

1. Выбор правильной стратегии загрузки данных

Отложенная загрузка (Lazy Loading) обычно не рекомендуется для операций чтения, так как вызывает N+1 проблему. Вместо этого используйте:

// ПЛОХО: N+1 запрос
var orders = context.Orders.ToList();
foreach (var order in orders)
{
    var customer = order.Customer; // Отдельный запрос для каждого заказа
}

// ХОРОШО: Eager Loading с Include
var orders = context.Orders
    .Include(o => o.Customer)
    .Include(o => o.OrderItems)
        .ThenInclude(oi => oi.Product)
    .Where(o => o.Date > DateTime.Now.AddDays(-30))
    .ToList();

2. Проекции и выборка только нужных полей

Селективная загрузка данных уменьшает объем передаваемой информации и ускоряет выполнение запросов:

// Выбираем только необходимые поля
var orderSummaries = context.Orders
    .Where(o => o.Status == OrderStatus.Completed)
    .Select(o => new OrderSummaryDto
    {
        Id = o.Id,
        OrderDate = o.OrderDate,
        CustomerName = o.Customer.Name,
        TotalAmount = o.OrderItems.Sum(oi => oi.Price * oi.Quantity)
    })
    .Take(100)
    .ToList();

3. AsNoTracking для операций только на чтение

Для сценариев, где данные не нужно отслеживать для изменений:

var products = context.Products
    .AsNoTracking() // Убирает отслеживание изменений, повышает производительность
    .Where(p => p.CategoryId == categoryId)
    .ToList();

4. Пагинация для больших наборов данных

public async Task<PagedResult<ProductDto>> GetProducts(int page, int pageSize)
{
    var query = context.Products
        .AsNoTracking()
        .Where(p => p.IsActive);
    
    var totalCount = await query.CountAsync();
    
    var items = await query
        .OrderBy(p => p.Name)
        .Skip((page - 1) * pageSize)
        .Take(pageSize)
        .Select(p => new ProductDto
        {
            Id = p.Id,
            Name = p.Name,
            Price = p.Price
        })
        .ToListAsync();
    
    return new PagedResult<ProductDto>(items, totalCount, page, pageSize);
}

5. Использование явной загрузки (Explicit Loading) когда это уместно

var order = context.Orders
    .FirstOrDefault(o => o.Id == orderId);

// Загружаем связанные данные только при необходимости
if (needOrderItems)
{
    context.Entry(order)
        .Collection(o => o.OrderItems)
        .Query()
        .Where(oi => oi.Quantity > 0)
        .Load();
}

6. Оптимизация запросов с помощью индексов

// Настройка индексов в контексте
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<Order>()
        .HasIndex(o => o.OrderDate)
        .HasDatabaseName("IX_Orders_OrderDate");
    
    modelBuilder.Entity<Order>()
        .HasIndex(o => new { o.CustomerId, o.Status })
        .HasDatabaseName("IX_Orders_CustomerId_Status");
}

7. Разделение запросов (Split Queries) для сложных включений

var orders = context.Orders
    .Include(o => o.OrderItems)
    .Include(o => o.Customer)
    .AsSplitQuery() // Выполняет несколько запросов вместо одного большого
    .Where(o => o.Date.Year == 2024)
    .ToList();

8. Кэширование результатов запросов

// Использование MemoryCache
public class ProductService
{
    private readonly IMemoryCache _cache;
    
    public async Task<List<Product>> GetTopProducts()
    {
        const string cacheKey = "top_products";
        
        if (!_cache.TryGetValue(cacheKey, out List<Product> products))
        {
            products = await context.Products
                .Where(p => p.Rating > 4)
                .Take(10)
                .ToListAsync();
                
            _cache.Set(cacheKey, products, TimeSpan.FromMinutes(5));
        }
        
        return products;
    }
}

9. Мониторинг и анализ запросов

// Включение логирования запросов
optionsBuilder.UseSqlServer(connectionString)
    .LogTo(Console.WriteLine, LogLevel.Information)
    .EnableSensitiveDataLogging();

// Использование диагностических счетчиков
var counts = context.GetService<IDiagnosticsLogger<DbLoggerCategory.Query>>();

10. Использование сырых SQL-запросов для сложных операций

var salesReport = context.SalesReports
    .FromSqlRaw(@"
        SELECT p.Name, SUM(oi.Quantity) as TotalQuantity, 
               SUM(oi.Quantity * oi.Price) as TotalRevenue
        FROM Products p
        JOIN OrderItems oi ON p.Id = oi.ProductId
        GROUP BY p.Id, p.Name
        ORDER BY TotalRevenue DESC")
    .AsNoTracking()
    .ToList();

Ключевые рекомендации:

• Всегда используйте AsNoTracking для операций только на чтение
• Применяйте проекции (Select) вместо загрузки полных сущностей
• Настраивайте индексы для часто фильтруемых полей
• Реализуйте пагинацию для больших наборов данных
• Избегайте N+1 проблемы через правильное использование Include
• Мониторьте производительность запросов с помощью инструментов EF Core
• Используйте кэширование для данных, которые редко изменяются

Правильная комбинация этих подходов может улучшить производительность операций чтения на порядки, особенно в сценариях с большими объемами данных и высокой нагрузкой. Важно тестировать производительность после каждой оптимизации и выбирать подходы, наиболее подходящие для конкретного сценария использования.