System.Linq.Dynamic.Core 动态LINQ分组与排序实践指南

背景介绍

在实际开发中，我们经常需要处理动态数据分组和排序的需求。System.Linq.Dynamic.Core库为.NET开发者提供了强大的动态LINQ查询能力，使得我们可以在运行时构建和执行LINQ查询。

核心问题

在数据分析场景中，我们经常需要实现类似SQL中GROUPING SETS的功能，即同时计算详细数据、分组小计和总计，并对结果进行排序。使用传统的LINQ实现这类需求需要编写大量静态代码，而System.Linq.Dynamic.Core则提供了更灵活的解决方案。

解决方案

方法一：使用强类型模型（推荐）

对于已知数据结构的场景，我们可以定义强类型模型来简化操作：

// 定义数据模型
public class GroupedSalesData
{
    public string Region { get; set; }
    public string Product { get; set; }
    public int TotalSales { get; set; }
    public int GroupLevel { get; set; }
}

public class SalesData
{
    public string Region { get; set; }
    public string Product { get; set; }
    public int Sales { get; set; }
}

// 实现分组和排序
var rows = extractedRows.AsQueryable();

// 详细数据分组
var detailed = rows
    .GroupBy("new (Region, Product)")
    .Select<GroupedSalesData>("new (Key.Region as Region, Key.Product as Product, Sum(Sales) as TotalSales, 0 as GroupLevel)");

// 区域小计
var regionSubtotal = rows
    .GroupBy("Region")
    .Select<GroupedSalesData>("new (Key as Region, null as Product, Sum(Sales) as TotalSales, 1 as GroupLevel)");

// 合并结果并排序
var combined = detailed.Concat(regionSubtotal);
var ordered = combined.OrderBy("Product desc").ToDynamicList();

这种方法类型安全，性能较好，适合数据结构已知的场景。

方法二：完全动态方式

对于完全动态的场景，我们可以使用DataTable作为数据源：

// 准备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);

var extractedRows = eInfoJoinTable.AsEnumerable();
var rows = extractedRows.AsQueryable();

// 动态分组和选择
var detailed = rows
    .GroupBy("new (Region, Product)")
    .Select("new (Key.Region as Region, Key.Product as Product, Sum(Convert.ToInt32(Sales)) as TotalSales, 0 as GroupLevel)");

var regionSubtotal = rows
    .GroupBy("Region")
    .Select("new (Key as Region, null as Product, Sum(Convert.ToInt32(Sales)) as TotalSales, 1 as GroupLevel)");

// 合并和排序
var combined = detailed.ToDynamicArray().Concat(regionSubtotal.ToDynamicArray()).AsQueryable();
var ordered = combined.OrderBy("Product").ToDynamicList();

这种方法完全动态，适合数据结构在运行时才确定的场景。

技术要点

1. 动态分组：使用GroupBy方法并传入分组键的字符串表达式
2. 动态选择：使用Select方法构造结果对象
3. 结果合并：使用Concat方法合并多个查询结果
4. 动态排序：使用OrderBy方法并传入排序字段的字符串表达式

最佳实践建议

1. 如果数据结构已知，优先使用强类型方式，可以获得更好的类型安全和性能
2. 对于完全动态的场景，确保字段名称和类型在运行时是已知的
3. 复杂的聚合操作可以使用Sum、Count等聚合函数
4. 注意处理可能为null的字段，使用??操作符提供默认值

总结

System.Linq.Dynamic.Core为.NET开发者提供了强大的动态查询能力，特别是在需要实现类似SQL GROUPING SETS功能的场景下。通过合理选择强类型或完全动态的方式，我们可以灵活应对各种数据分析需求，同时保持代码的简洁和可维护性。