请求生成PostgreSQL动态行转列SELECT查询语句

针对你的需求——将srv字段值转为动态列，展示各table_name对应服务器的heartbeat数据，且srv会随时新增或删除，以下提供两种可行方案：

方案1：动态生成静态查询（直接返回表格） #

由于srv是动态变化的，无法写死列名，需要用PostgreSQL的PL/pgSQL生成动态SQL执行：

DO $$
DECLARE
  col_defs TEXT;
BEGIN
  -- 自动生成所有服务器对应的列处理逻辑
  SELECT string_agg(
    format('MAX(CASE WHEN srv = %L THEN heartbeat END) AS %I', srv, srv),
    ', '
  ) INTO col_defs
  FROM (SELECT DISTINCT srv FROM your_table ORDER BY srv) AS server_list;

  -- 执行动态拼接的查询语句
  EXECUTE format('
    SELECT
      table_name,
      %s
    FROM your_table
    GROUP BY table_name
    ORDER BY table_name;
  ', col_defs);
END $$;

说明： #

• 替换your_table为实际的数据表名
• 每次执行时会自动读取当前所有存在的srv值，生成对应列
• 直接返回你期望的表格格式结果

方案2：返回JSON格式动态列（适合程序处理） #

如果需要更灵活的输出，或者要将结果作为可复用的数据源，可以创建函数返回JSONB格式的列集合：

CREATE OR REPLACE FUNCTION get_heartbeat_summary()
RETURNS TABLE (table_name TEXT, server_heartbeats JSONB) AS $$
BEGIN
  RETURN QUERY EXECUTE format('
    SELECT
      table_name,
      jsonb_object_agg(srv, heartbeat) AS server_heartbeats
    FROM your_table
    GROUP BY table_name
    ORDER BY table_name;
  ');
END $$ LANGUAGE plpgsql;

调用方式：

SELECT * FROM get_heartbeat_summary();

说明： #

• 返回的server_heartbeats字段会以键值对形式包含所有服务器的心跳数据，自动适配srv的新增/删除
• 适合后端程序直接解析使用

静态场景参考（若srv固定不变） #

如果是srv固定的情况，也可以直接写静态查询：

SELECT
  table_name,
  MAX(CASE WHEN srv = 'server1' THEN heartbeat END) AS server1,
  MAX(CASE WHEN srv = 'server2' THEN heartbeat END) AS server2,
  MAX(CASE WHEN srv = 'server3' THEN heartbeat END) AS server3
FROM your_table
GROUP BY table_name
ORDER BY table_name;

内容的提问来源于stack exchange，提问作者funtus