如何在C#中用LINQ动态分组和计算聚合和/最大值数据

Question

我们有一个API来处理来自不同来源的数据（数据库、webservices、纯文本、...)所以我们将它存储在列表结构中。我们有这段代码来选择它们中的一些列，并应用函数来获取新数据（如和两列，...)

Func<dynamic[], object>[] leftFunctions = new Func<dynamic[], object>[this.Columns.Count];
IEnumerable<dynamic[]> returnValue = null
j = 0;
foreach (JoinDataColumn dataColum in this.Columns.OrderBy(x => x.Index))
{
     //Obtenemos para cada columna la funcion
     leftFunctions[j++] = dataColum.getLeftFunction(LeftDataQuery);
}
returnValue = (await LeftDataQuery.ExecuteAsync(parameters))
    .Select(x => leftFunctions.Select(f => f.Invoke(x)).ToArray());

在上面的代码中：LeftDataquery是一个获取列表的类，其中的数据执行此操作，并返回list

await LeftDataQuery.ExecuteAsync(parameters)

LeftFuncions是从源数据创建新数据的公式，“lefdataquery[1]+lefdataquery[2]”或简单地“lefdataquery[0]”以获得第一列的数据。

在JoinDataColumn类中，我对结果列表的每一列都有一个描述：name、type和agregate函数。

最后，用户可以选择要分组的列和其他列的Aggregation公式（sum,max,min,count distinct,...）。现在，我有了带有原始源的列子集的returnvalue和要分组的列的索引列表，以及带有它们的Aggreation公式的索引列表（例如，索引1是一个和，等等）

public enum DataColumnAggregation { NONE = 0, SUM = 1, MAX = 2, MIN = 3 }

任何关于如何按这些数据分组并得到和/最大/最小值的想法…

做了一些测试，我编写了这段代码，但问题是Groupby不能使用对象数组作为参数。有没有想过让GroupBy用这个方法工作？“

    public enum DataColumnAggregation { NONE = 0, SUM = 1, MAX = 2, MIN = 3 }

    static void Main(string[] args)
    {
        List<object[]> returnValue = new List<object[]> { new object[] { "C1", 1, 2 }, new object[] { "C2", 3, 4 }, new object[] { "C1", 1, 3 } };


        DataColumnAggregation[] config = new DataColumnAggregation[] { DataColumnAggregation.NONE, DataColumnAggregation.SUM, DataColumnAggregation.MAX };
        //TODO agregar por la columna 0 , sumar la columna 1 y maximo de la columna 2 de returnvalue

        var resultado2 = returnValue.GroupBy(x => getGroupByColumns(x,config)).Select(x=>agregar(x, config));

    }

    private static object[] agregar(IGrouping<string[], object[]> x, DataColumnAggregation[] config)
    {
        List<object> result = new List<object>();
        for (int i = 0; i < config.Length; i++)
        {
            if (config[i] == DataColumnAggregation.NONE)
            {
                result.Add(x.Select(xy => xy[i]).FirstOrDefault());
            }
            if (config[i] == DataColumnAggregation.SUM)
            {
                result.Add(x.Sum(xy => Convert.ToInt32(xy[i]))); 
            }
            if (config[i] == DataColumnAggregation.MAX)
            {
                result.Add(x.Max(xy => xy[i])); 
            }
            if (config[i] == DataColumnAggregation.MIN)
            {
                result.Add(x.Min(xy => xy[i])); 
            }
        }
        return result.ToArray();
    }


    private static string[] getGroupByColumns(object[] x, DataColumnAggregation[] config)
    {
        List<string> group = new List<string>();
        for (int i = 0; i< config.Length; i++)
        {
            if (config[i] == DataColumnAggregation.NONE) group.Add(x[i].ToString());
        }
        return group.ToArray();
    }

谢谢

Answer 1

由于您正在尝试按String[]（或更好的List )分组，因此需要将IEqualityComparer传递给比较元素的GroupBy。

public class IEnumerableSequenceEqualityComparer<T> : IEqualityComparer<IEnumerable<T>> {
    public bool Equals(IEnumerable<T> x, IEnumerable<T> y) =>
        Object.ReferenceEquals(x, y) || (x != null && y != null && (x.SequenceEqual(y)));

    public int GetHashCode(IEnumerable<T> src) {
        // Will not throw an OverflowException
        //unchecked {
        //    return src.Where(e => e != null).Select(e => e.GetHashCode()).Aggregate(17, (a, b) => 23 * a + b);
        //}
        var hc = new HashCode();
        foreach (var v in src)
            hc.Add(v);
        return hc.ToHashCode();
    }
}

名为make的工厂类帮助创建比较器：

public static class Make {
    public static IEqualityComparer<IEnumerable<T>> SequenceEqualityComparer<T>() => new IEnumerableSequenceEqualityComparer<T>();
    public static IEqualityComparer<IEnumerable<T>> SequenceEqualityComparer<T>(T _) => new IEnumerableSequenceEqualityComparer<T>();
}

现在可以使用序列相等比较器调用groupby:

var resultado2 = returnValue.GroupBy(x => getGroupByColumns(x,config), Make.SequenceEqualityComparer<string>()).Select(x=>agregar(x, config));

注意：这导致组键为IEnumerable 。如果您更喜欢ilist ，只需在相等比较器类和因子类中用ilist替换IEnumerable。或者添加具有适当名称更改的其他ilist版本。