如何使用MuleSoft DataWeave聚合数据库关联查询结果

先看一个和你数据库输出结构一致的典型输入示例：

[
  {
    "ID": 1,
    "Title": "DataWeave Guide",
    "Author": "Alice"
  },
  {
    "ID": 1,
    "Title": "DataWeave Guide",
    "Author": "Bob"
  },
  {
    "ID": 2,
    "Title": "MuleSoft Basics",
    "Author": "Charlie"
  }
]

你之前用distinctBy和filter没成功，是因为这两个方法只能做单条记录的去重或筛选，没法合并同ID下的多个Author字段。正确思路是先按ID分组，再对每个分组做字段整合，具体DataWeave代码如下：

%dw 2.0
output application/json
---
payload groupBy ($.ID) mapObject ((records, id) -> {
    ID: id,
    // 假设同ID的Title一致，直接取第一个记录的Title即可
    Title: records[0].Title,
    // 把每个记录的Author转成带Name属性的对象，收集成数组并去重
    Authors: records map ((item) -> {Name: item.Author}) distinctBy $.Name
}) pluck $

代码说明： #

• groupBy ($.ID)：把原数组按ID分组，生成一个以ID为键、对应同ID记录数组为值的对象
• mapObject：遍历每个分组，处理同ID的记录集合：
  • 保留分组的ID作为新对象的ID字段
  • 提取同ID下的Title（如果同ID的Title可能不一致，可以改成records.Title distinctBy $来保留所有不重复的标题）
  • 将每个记录的Author字段转换为{Name: 作者名}的结构，收集成Authors数组，用distinctBy $.Name避免重复作者
• pluck $：把分组处理后的对象转换回数组格式（groupBy返回的是对象，pluck会提取所有值组成数组）

运行后得到的输出结果：

[
  {
    "ID": 1,
    "Title": "DataWeave Guide",
    "Authors": [
      {"Name": "Alice"},
      {"Name": "Bob"}
    ]
  },
  {
    "ID": 2,
    "Title": "MuleSoft Basics",
    "Authors": [
      {"Name": "Charlie"}
    ]
  }
]

内容的提问来源于stack exchange，提问作者DevTC