System.Linq.Dynamic.Core 实现分组汇总与总计行的技巧

在实际数据处理中，我们经常需要对数据进行分组统计并添加总计行(GrandTotal)。本文将介绍如何使用System.Linq.Dynamic.Core库来实现这一常见需求。

数据准备

首先创建一个示例DataTable，包含区域、产品和销售额三列：

var eInfoJoinTable = new DataTable();
eInfoJoinTable.Columns.Add("Region", typeof(string));
eInfoJoinTable.Columns.Add("Product", typeof(string));
eInfoJoinTable.Columns.Add("Sales", typeof(int));

eInfoJoinTable.Rows.Add("North", "Apples", 100);
eInfoJoinTable.Rows.Add("North", "Oranges", 150);
eInfoJoinTable.Rows.Add("South", "Apples", 200);
eInfoJoinTable.Rows.Add("South", "Oranges", 250);

基础分组统计

使用System.Linq.Dynamic.Core可以方便地进行动态分组统计：

var extractedRows = from row in eInfoJoinTable.AsEnumerable() select row;
var rows = extractedRows.AsQueryable();

// 按Region分组统计
var regionGrouped = rows
    .GroupBy("Region")
    .Select("new (Key as Region, Sum(Convert.ToInt32(Sales)) as TotalSales, 0 as GroupLevel)")
    .ToDynamicList();

这段代码会生成按区域分组的销售总额，GroupLevel设为0表示这是普通分组行。

添加总计行

在SQL中我们可以使用GROUPING SETS或ROLLUP来添加总计行，但在System.Linq.Dynamic.Core中，可以通过以下方式实现：

// 计算总计行(将所有数据视为一组)
var grandTotal = rows
    .GroupBy("1") // 将所有行分到同一组
    .Select("new (\"TOTAL\" as Region, Sum(Convert.ToInt32(Sales)) as TotalSales, 1 as GroupLevel)")
    .ToDynamicList();

// 合并分组结果和总计行
var combined = regionGrouped.Concat(grandTotal).ToList();

结果验证

我们可以验证结果是否符合预期：

// 验证结果数量
Assert.AreEqual(combined.Count, 3);

// 验证第一行(北区)
var row0 = combined[0];
Assert.AreEqual("North", row0.Region);
Assert.AreEqual(250, row0.TotalSales);
Assert.AreEqual(0, row0.GroupLevel);

// 验证第二行(南区)
var row1 = combined[1];
Assert.AreEqual("South", row1.Region);
Assert.AreEqual(450, row1.TotalSales);
Assert.AreEqual(0, row1.GroupLevel);

// 验证第三行(总计)
var row2 = combined[2];
Assert.AreEqual("TOTAL", row2.Region);
Assert.AreEqual(700, row2.TotalSales);
Assert.AreEqual(1, row2.GroupLevel);

技术要点

1. 动态分组：使用GroupBy方法传入字符串参数实现动态分组
2. 汇总计算：在Select中使用Sum等聚合函数
3. 总计行技巧：通过将所有数据分到同一组(GroupBy("1"))实现总计计算
4. 结果合并：使用Concat方法合并分组结果和总计行

这种方法虽然与SQL中的GROUPING SETS语法不同，但能达到相同的效果，且实现简单明了。GroupLevel字段可以用来区分普通分组行和总计行，便于后续处理。

对于更复杂的分组需求，可以考虑多次分组计算后合并结果，或者使用其他LINQ扩展方法来实现。System.Linq.Dynamic.Core为动态LINQ查询提供了强大支持，特别适合需要动态构建查询条件的场景。