如何在PostgreSQL中将两行转换为键值JSON对象？

Question

我有一个数据模型，如下所示，仅简化以展示您所面临的问题（SQL Fiddle链接在底部）：

人以元表行表示，并具有名称和多个属性，这些属性作为键值对存储在数据表中（键和值分别位于不同的列中）。

期望结果

现在，我想检索所有用户及其所有属性。 属性应以json对象的形式返回到单独的列中。 例如：

name, data
Florian, { "age":23, "color":"blue" }
Markus, { "age":24, "color":"green" }

我的方法

现在我的问题是，我找不到在Postgres中创建键值对的方法。我尝试了以下方法：

SELECT
  name,
  array_to_json(array_agg(row(d.key, d.value))) AS data
FROM meta AS m
JOIN (
  SELECT d.fk_id, d.key, d.value AS value FROM data AS d
  ) AS d
ON d.fk_id = m.id
GROUP BY m.name;

但它将此作为数据列返回：

[{"f1":"age","f2":24},{"f1":"color","f2":"blue"}]

其他解决方案

我知道有一个名为crosstab的函数可以将数据表转换为以列为键，以行为值的表格。但是这不是动态的。而且我不知道数据表中一个人有多少属性。所以这不是一个选择。

我也可以创建一个类似json的字符串，其中包含两个行值并将它们聚合。但也许有一种更好的解决方案。

不，无法更改数据模型，因为真实的数据模型已被多个方使用。

SQLFiddle

请查看并测试我为此问题创建的fiddle： http://sqlfiddle.com/#!15/bd579/14

- cansik

Answer 1

使用聚合函数json_object_agg(key, value)：

select 
    name, 
    json_object_agg(key, value) as data
from data
join meta on fk_id = id
group by 1;

Db<>Fiddle。

该函数在Postgres 9.4中引入。

- klin

Answer 2

当我需要更新数据库中的一些JSON并删除一些元素时，我遇到了同样的问题。下面的查询对我来说足够好用，因为它保留了字符串引号，但不会将其添加到数字中。

select
  '{' || substr(x.arr, 3, length(x.arr) - 4) || '}'
from
(
  select
     replace(replace(cast(array_agg(xx) as varchar), '\"', '"'), '","', ', ') as arr
  from
  (
  select
    elem.key,
    elem.value,
    '"' || elem.key || '":' || elem.value as xx
  from
    quote q
      cross join
    json_each(q.detail::json -> 'bQuoteDetail'-> 'quoteHC'->0)  as elem  
  where
    elem.key != 'allRiskItems'  
  ) f 
) x

- Bitter

Answer 3

我找到了一种方法来返回具有动态列的交叉表数据。也许重写这个代码能更好地满足你的需求：

CREATE OR REPLACE FUNCTION report.usp_pivot_query_amount_generate(
    i_group_id INT[],
    i_start_date TIMESTAMPTZ,
    i_end_date TIMESTAMPTZ,
    i_interval INT
    ) RETURNS TABLE (
    tab TEXT
    ) AS $ab$
DECLARE
    _key_id TEXT;
    _text_op TEXT = '';
    _ret TEXT;
BEGIN
    -- SELECT DISTNICT for query results
    FOR _key_id IN
    SELECT DISTINCT at_name
      FROM report.company_data_date cd 
      JOIN report.company_data_amount cda ON cd.id = cda.company_data_date_id 
      JOIN report.amount_types at ON cda.amount_type_id  = at.id 
     WHERE date_start BETWEEN i_start_date AND i_end_date
       AND group_id = ANY (i_group_id)
       AND interval_type_id = i_interval
    LOOP
    -- build function_call with datatype of column
        IF char_length(_text_op) > 1 THEN
            _text_op := _text_op || ', ' || _key_id || ' NUMERIC(20,2)';
        ELSE
            _text_op := _text_op || _key_id || ' NUMERIC(20,2)';
        END IF;
    END LOOP;
    -- build query with parameter filters
    _ret = '
        SELECT * FROM crosstab(''SELECT date_start, at.at_name,  cda.amount ct 
          FROM report.company_data_date cd 
          JOIN report.company_data_amount cda ON cd.id = cda.company_data_date_id 
          JOIN report.amount_types at ON cda.amount_type_id  = at.id 
         WHERE date_start between $$' || i_start_date::TEXT || '$$ AND $$' || i_end_date::TEXT || '$$ 
           AND interval_type_id = ' || i_interval::TEXT || ' 
           AND group_id = ANY (ARRAY[' || array_to_string(i_group_id, ',') || '])
         ORDER BY date_start'') 
            AS ct (date_start timestamptz, ' || _text_op || ')';
    RETURN QUERY
    SELECT _ret;
END;
$ab$ LANGUAGE 'plpgsql';

调用函数以获取字符串，然后执行该字符串。我认为我尝试在函数中执行它，但效果不佳。

- Caullyn