如何使用数组聚合、Join 或 Union 成平面 Json 对象?

ttu*_*tes 3 sql t-sql azure-sql-server sql-server-2017 for-json

我的数据看起来像:

客户

CustomerId  CustomerName CustomerEmail  
------------------------------------------
1           Ben          Ben@gmail.com
2           Robert       Robert@gmail.com
3           Paul         Paul@gmail.com
Run Code Online (Sandbox Code Playgroud)

客户联系人

CustomerContactId  CustomerId  ContactName   ContactEmail
----------------------------------------------------------
99                 1           Lisa          Lisa@msn.com
98                 3           Jane          Jane@msn.com
97                 3           Wendy         Wendy@msn.com
Run Code Online (Sandbox Code Playgroud)

这是我正在寻找的结果:

[
    {
        "CustomerId": 1,
        "Names": [ "Ben","Lisa" ],
        "Emails": [ "Ben@gmail.com","Lisa@msn.com" ]
    },
    {
        "CustomerId": 2,
        "Names": [ "Robert" ],
        "Emails": [ "Robert@gmail.com" ]
    },
    {
        "CustomerId": 3,
        "Names": [ "Paul","Jane","Wendy" ],
        "Emails": [ "Paul@gmail.com","Jane@msn.com","Wendy@msn.com" ]
    }
]
Run Code Online (Sandbox Code Playgroud)

我尝试过的: 我很尴尬地说我还没有接近:

CustomerId  CustomerName CustomerEmail  
------------------------------------------
1           Ben          Ben@gmail.com
2           Robert       Robert@gmail.com
3           Paul         Paul@gmail.com
Run Code Online (Sandbox Code Playgroud)

Zoh*_*led 5

不幸的是,SQL Server 加入 JSON 的步伐有点晚了(仅在 2016 年版本中才开始内置支持),这意味着它的 JSON 支持仍然不是很好(尽管它确实知道如何做,但它做得很好)。
就我个人而言,我不知道有任何内置方法可以通过查询
( {"Name":["Value1", "Value2"...]}) 创建 JSON 值数组,尽管生成键值对数组
( ["Name":"Value1", "Name":"Value2"...]) 非常容易 - 至少不使用FOR JSON条款。

但是,由于您使用的是 2017 和 Azure 版本,因此可以很容易地使用string_agg(在早期版本中使用for xml pathstuff聚合字符串)自己生成此类数组。
请注意 的用法WITHIN GROUP (ORDER BY CustomerContactId),它强制聚合字符串具有特定的顺序。如果没有它,联系人的姓名和电子邮件的顺序将是任意的(尽管我很确定在一次查询中它们可能仍会以相同的方式排序)。

话虽如此 - 这是我提出的解决方案:

首先,创建并填充示例表(在您以后的问题中保存此步骤):

CREATE TABLE Customers (
    [CustomerId] int, 
    [CustomerName] varchar(6), 
    [CustomerEmail] varchar(16)
);
    
INSERT INTO Customers ([CustomerId], [CustomerName], [CustomerEmail]) VALUES
(1, 'Ben', 'Ben@gmail.com'),
(2, 'Robert', 'Robert@gmail.com'),
(3, 'Paul', 'Paul@gmail.com');

CREATE TABLE CustomerContacts (
    [CustomerContactId] int, 
    [CustomerId] int, 
    [ContactName] varchar(5), 
    [ContactEmail] varchar(13)
);
    
INSERT INTO CustomerContacts ([CustomerContactId], [CustomerId], [ContactName], [ContactEmail]) VALUES
(99, 1, 'Lisa', 'Lisa@msn.com'),
(98, 3, 'Jane', 'Jane@msn.com'),
(97, 3, 'Wendy', 'Wendy@msn.com');
Run Code Online (Sandbox Code Playgroud)

然后,使用查询 withFOR JSON PATH来获取 json 输出。
这里的技巧是通过将CustomerName/与表中相关列的子查询CustomerEmail的结果连接来生成内部数组。 请注意这些列周围的包装。需要它们来防止 SQL Server 转义json 输出中的字符 - 通过告诉它内容是正确的 JSON。另外,请注意充当 a 的用法- 您将获得所有客户,即使他们在表中没有相应的记录。STRING_AGGCustomerContacts
JSON_QUERY"
ISNULLLEFT JOINCustomerContacts

SELECT  C.CustomerId, 
        JSON_QUERY(
            '["' + C.CustomerName + ISNULL('","'+ 
            (
                SELECT STRING_AGG(CC.ContactName, '","') WITHIN GROUP (ORDER BY CustomerContactId)
                FROM CustomerContacts As CC
                WHERE CC.CustomerId = C.CustomerId
            ), '') + '"]'
        ) As Names,
        JSON_QUERY(
            '["' + C.CustomerEmail + ISNULL('","'+ 
            (
                SELECT STRING_AGG(CC.ContactEmail, '","') WITHIN GROUP (ORDER BY CustomerContactId)
                FROM CustomerContacts As CC
                WHERE CC.CustomerId = C.CustomerId
            ), '') + '"]'
        ) As Emails
FROM Customers AS C
FOR JSON PATH
Run Code Online (Sandbox Code Playgroud)

结果:

[
    {
        "CustomerId": 1,
        "Names": ["Ben", "Lisa"],
        "Emails": ["Ben@gmail.com", "Lisa@msn.com"]
    }, {
        "CustomerId": 2,
        "Names": ["Robert"],
        "Emails": ["Robert@gmail.com"]
    }, {
        "CustomerId": 3,
        "Names": ["Paul", "Wendy", "Jane"],
        "Emails": ["Paul@gmail.com", "Wendy@msn.com", "Jane@msn.com"]
    }
]
Run Code Online (Sandbox Code Playgroud)

您可以看到现场演示 (不幸的是,json 输出没有很好地缩进,但它仍然有效)DB<>Fiddle