Mulesoft 将 3 个查询结果合并为一个有效载荷

Question

我有来自父表、子表和关系表的结果。我需要使用“ParentId”和“ChildId”根据关系表中的值将三个表合并在一起。我尝试在 AnyPoint Studio 中使用 Scatter Gather 并且可以获得每个查询的结果，但是我无法将它们组合回一个有效负载，以便父、关系值和子都在同一行。 父母可以有多个孩子。

有效负载基于来自 Salesforce 表的查询 -

有效载荷对象 0：

Array<object>:
 [
{"ParentId": "0cE3S0000000HVGUA2", 
 "Name": "job's Pharmacy"
 "Address": "123 4th Ave", 
 "ParentLicense": "PHARM.PF.12345678"}
]

有效载荷对象 1：

Array<Object>:
[
{ "ChildId": "0cE3S0000000GscUAE", 
 "ParentId": 0cE3S0000000HVGUA2, 
 "RelationStatus":"Site Branch"}
]

有效载荷对象 2：

Array<Object>:
[
{ "ChildId": "0cE3S0000000GscUAE", 
 "ChildLicense": PHRM.PF.98765432-MHOUT, 
"ExpirationDate": "2019-02-28",
"PublicStatusDescription": "Closed"}
]

预期结果

[
 {
  "ParentId": "0cE3S0000000HVGUA2", 
  "Name": "job's Pharmacy"
  "Address": "123 4th Ave", 
  "ParentLicense": "PHARM.PF.12345678",
  "ChildId": "0cE3S0000000GscUAE", 
  "ChildLicense": PHRM.PF.98765432-MHOUT, 
  "ExpirationDate": "2019-02-28",
  "PublicStatusDescription": "Closed", 
  "RelationStatus":"Site Branch"
 }
]

Answer 1

如果数据来自同一个数据库和同一个应用程序中的 SQL 查询，最好使用 SQL 来获取已经连接的数据。 SQL 会更高效，它基本上就是这样设计的。

如果数据来自不同的来源，例如不同的 REST API，那么您可以使用 DataWeave 来连接数据。

请注意，为简单起见，我使用 JSON 作为输出格式，但如果您打算进行进一步的转换，则应使用 application/java。

这是一个例子。可能这不是最有效的方法：

%dw 2.0
output application/json
import * from dw::core::Arrays
var parents=payload."0"
var childs=payload."2"
var relation=payload."1"
var parentWithChildId=leftJoin(parents, relation, (p) -> p.ParentId, (r) -> r.ParentId)
    map((item, index) -> item.l ++ {ChildId: item.r.ChildId})
var parentWithChildValues=leftJoin(parentWithChildId, childs, (p) -> p.ChildId, (c) -> c.ChildId)
    map((item, index) -> item.l ++ (item.r - "ChildId"))
---
parentWithChildValues

输入：假设输入是 scatter-gather 的输出，我不得不猜测输入应该是什么样子。

{
    "0": 
        [
            {
                "ParentId": "0cE3S0000000HVGUA2", 
                "Name": "job's Pharmacy",
                "Address": "123 4th Ave", 
                "ParentLicense": "PHARM.PF.12345678"
            }
        ],
    "1":
        [
            {
                "ChildId": "0cE3S0000000GscUAE", 
                "ParentId": "0cE3S0000000HVGUA2", 
                "RelationStatus":"Site Branch"
            }
        ],
    "2":
        [
            { 
                "ChildId": "0cE3S0000000GscUAE", 
                "ChildLicense": "PHRM.PF.98765432-MHOUT", 
                "ExpirationDate": "2019-02-28",
                "PublicStatusDescription": "Closed"
            }
        ]
}

输出：

[
  {
    "ParentId": "0cE3S0000000HVGUA2",
    "Name": "job's Pharmacy",
    "Address": "123 4th Ave",
    "ParentLicense": "PHARM.PF.12345678",
    "ChildId": "0cE3S0000000GscUAE",
    "ChildLicense": "PHRM.PF.98765432-MHOUT",
    "ExpirationDate": "2019-02-28",
    "PublicStatusDescription": "Closed"
  }
]