Entity Framework: применение операций между оптимизацией временных интервалов

Question

Определение проблемы: У меня есть таблица базы данных с миллионами записей. Эта таблица определяется следующими столбцами: Date, Value и NumberOfEvents.Мне нужно получить данные между несколькими временными интервалами и применить функцию (Sum, Average, Max, Min) ко всем возвращенным записям для каждого интервала.

Текущее решение:

   List<SingleSeries> series = new List<SingleSeries>();
            //Iterate intervals
            for (int i = 0; i < intervals.Count(); i++)
            {
                if (i == 0)
                {
                }
                if (i + 1 < intervals.Count())
                {
                    //Get database entries between interval
                    var validKpis = kpis.Where(x => x.Date >= intervals.ElementAt(i) && x.Date < intervals.ElementAt(i + 1));
                    //Apply calc operation (SUM; AVG; MAX;MIN)
                    var result= CalcOperations.Calculate(calcOperation, validKpis);
                    //Add result to results array
                    series.Add(new SingleSeries()
                    {
                        Value = result,
                        Name = DateOperations.ConvertToMilliseconds(intervals.ElementAt(i + 1)).ToString()
                    });
                };
            }
            return series;

Текущая проблема: В настоящее время эта функция выполняет N запросов к базе данных, где N = interval.Count () / 2.Я хотел бы, чтобы он выполнял только один запрос , но я не могу понять, как использовать массив интервалов для агрегирования значений для каждого интервала и применить к нему операцию calc .Sugestions?

Answer 1

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

Это немного больше кода, но гораздо более эффективное использование запросов к базе данных.

Вот примерный фрагмент, демонстрирующий вышесказанное - обратите внимание, что я не проверял это - просто чтобы дать вам конкретное представление о том, как выполнить это с помощью одного запроса.

        List<SingleSeries> series = new List<SingleSeries>();
        var kpiQuery = kpis;

        //Iterate intervals and build a single query to retrieve all of them
        for (int i = 0; i < intervals.Count(); i++)
        {
            if (i + 1 < intervals.Count())
            {
                // add each target interval sequentially - without running the query yet
                kpiQuery = kpiQuery.Where(x => x.Date >= intervals.ElementAt(i) && x.Date < intervals.ElementAt(i + 1));
            }
        }

        var validKpis = kpiQuery.ToList(); // now get all database results in a single transaction

        //Iterate the intervals again, this time to split the combined results that are now in memory
        for (int i = 0; i < intervals.Count(); i++)
        {
            if (i + 1 < intervals.Count())
            {
                //select only the results applicable to the current interval
                var kpisInThisInterval = validKpis.Where(x =>
                    x.Date >= intervals.ElementAt(i) && x.Date < intervals.ElementAt(i + 1));

                //Apply calc operation (SUM; AVG; MAX;MIN)
                var result = CalcOperations.Calculate(calcOperation, kpisInThisInterval);
                //Add result to results array
                series.Add(new SingleSeries()
                {
                    Value = result,
                    Name = DateOperations.ConvertToMilliseconds(intervals.ElementAt(i + 1)).ToString()
                });
            }
        }

        return series;