如何在 PostgreSQL 的 SELECT 语句中使用行值作为列？

Question

我的 PostgreSQL 9.2.8 数据库中有这三个表的表结构：

我试图弄清楚如何选择orders一行并在同一行上添加来自order_points和 的一些列points。

您可以将该points表想象为一个人可以购买的所有物品的列表，其中 内部知道abbrev它并且它的成本为amount。

该order_points表是购买的每件商品，因此points.id == order_points.points_id，amount类似于说他们购买了 5 个糖果棒。它通过以下方式链接到订单order_points.order_id == orders.id

当我选择一个订单时，我希望为每个abbrev存在的以及amount来自order_points表的列都有一列。

所以如果points有这个：

 id | name      | abbrev | amount
 --------------------------------
  1 | Snickers  | sn     | 1.34
  2 | Milky Way | mw     | 1.73
  3 | Coffee    | cf     | 10.12

并order_points有这个：

 id | order_id | points_id | amount
 ----------------------------------
  1 |        1 |         1 |     10
  2 |        1 |         3 |      1

然后当我得到我的行时，我想要订单中的所有列，加上三个额外的列。我不想列出上面订单中显示的每一列，但基本上假设我只想要其中的 4 个，加上points我最终将其作为一行输出的所有内容：

 id | created    | due        | name  | sn | mw | cf
 ------------------------------------------------
  1 | 2018-04-21 | 2018-05-01 | Fooey | 10 |  0 |  1

我不知道如何abbrev从表查找中动态添加具有名称 (the ) 的列。

Answer 1

正如 Adam Silenko 所说，您不能在运行时添加列。您可以做的最好的事情是使用 2 个查询。一个函数将创建一个包含您需要的列的临时表，另一个函数用于查询表并获取结果。这是解释here。

将创建临时表的函数：

CREATE OR REPLACE FUNCTION get_order(orderId BIGINT)
  RETURNS VOID AS
  $$
  DECLARE column_names varchar[];
  DECLARE column_values float[];
  DECLARE final_select TEXT := 'SELECT id, name points_columns FROM orders where id=' || orderId;
  DECLARE create_table_statement TEXT := 'CREATE TEMP TABLE temp_result_table ON COMMIT DROP AS select_statement';
  DECLARE columns_values_concatenated TEXT := '';
  BEGIN
    SELECT array_agg(abbrev),  array_agg(CASE WHEN amount IS NULL THEN 0 ELSE amount END)
    into column_names, column_values FROM
     (SELECT abbrev, order_points.amount as amount FROM points LEFT JOIN order_points ON points.id = order_points.points_id and order_id = orderId
     ORDER BY points.id) points_amount;

     FOR i IN 1 .. array_upper(column_names, 1)
       LOOP
       columns_values_concatenated := columns_values_concatenated || ', ' || column_values[i] || ' as ' || column_names[i];
     end loop;
    final_select := replace(final_select, 'points_columns',columns_values_concatenated);
    create_table_statement:= replace(create_table_statement, 'select_statement', final_select);
    EXECUTE create_table_statement;
end;

$$ LANGUAGE Plpgsql;

我们使用 2 个数组，column_names并column_values分别存储所选订单的名称（“sn”、“mw”、“cf”）和这些名称的值。

我们使用这 2 个数组来生成 select 语句（在当前代码中，我只从 orders 表中获取 id 和 name，但您可以轻松更改它）。我们将 select 语句存储到final_select变量中。最后，我们将生成的 select 语句添加到 中，create_table_statement然后创建并填充临时表。

现在，如上面链接中所述，因为我们需要 2 个查询来访问数据，所以我们必须在单个事务中执行这两个查询（以避免在多次调用该函数时发生名称冲突）。

BEGIN;
SELECT * FROM get_order(1);
SELECT * FROM temp_result_table;
COMMIT; --The temporary table will be dropped on commit