sql - 如何在 PostgreSQL 的 SELECT 语句中将行值用作列？

Question

我的 PostgreSQL 9.2.8 数据库中有一个包含这三个表的表结构:

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

您可以将 points 表想象成一个人可以购买的所有项目的列表，它在内部通过 abbrev 知道并且花费 amount 。

order_points 表是每件购买的商品，因此 points.id == order_points.points_id 和 amount 类似于说他们买了5 block 糖。它通过 order_points.order_id == orders.id

链接到订单

当我选择订单时，我想为每个存在的 abbrev 以及 order_points 表中的 amount 设置一列.

所以如果 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)的列。

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 语句(在当前代码中，我只从订单表中获取 ID 和名称，但您可以轻松更改它)。我们将 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