PostgreSQL中如何动态查询多Schema下同构表统计各企业用户数

• 静态SQL场景下，PostgreSQL无法将字符串拼接结果动态解析为合法的表对象引用，concat(c.schema, '.users') 会被识别为普通字符串字面量，而非跨schema的业务表
• 原语句的聚合函数写法不符合SQL语法规范，count(...) 后直接跟随from子查询的格式本身无法通过语法校验

因为需要动态拼接schema标识符，纯静态SQL无法实现该需求。你之前接触的预处理方案通常用于单表的单次动态查询，若用该方案实现全量统计，需要逐企业循环构造预处理语句、执行、收集结果，代码冗余且多次执行查询的效率低，通过plpgsql动态SQL批量拼接统计片段是更适配业务的实现方式。

一次性临时统计实现 #

适用于临时查询场景，执行后生成临时结果表：

DO $$
DECLARE
  stats_sql TEXT;
BEGIN
  -- 遍历所有企业，拼接为可合并的统计SQL片段
  SELECT string_agg(
    format(
      'SELECT %L AS enterprise_name, count(id) AS users_count FROM %I.users',
      c.name,
      c.schema
    ),
    ' UNION ALL '
  ) INTO stats_sql
  FROM catalog.companies c;

  -- 执行拼接好的全量统计语句，结果存入临时表
  CREATE TEMP TABLE IF NOT EXISTS temp_enterprise_user_stats AS EXECUTE stats_sql;
END $$;

-- 查询最终统计结果
SELECT * FROM temp_enterprise_user_stats;

封装为可复用函数 #

适用于需要频繁调用统计逻辑的场景，直接返回结构化结果集：

CREATE OR REPLACE FUNCTION get_enterprise_user_total()
RETURNS TABLE(enterprise_name text, users_count bigint)
LANGUAGE plpgsql
AS $$
DECLARE
  stats_sql TEXT;
BEGIN
  SELECT string_agg(
    format(
      'SELECT %L AS enterprise_name, count(id) AS users_count FROM %I.users',
      c.name,
      c.schema
    ),
    ' UNION ALL '
  ) INTO stats_sql
  FROM catalog.companies c;

  RETURN QUERY EXECUTE stats_sql;
END $$;

调用时直接执行：
SELECT * FROM get_enterprise_user_total();

• 拼接语句时使用format()的%I占位符，会自动对schema名做合法标识符转义，解决schema名含特殊字符、大小写敏感导致的报错，同时规避SQL注入风险
• 使用%L占位符处理企业名称，自动对字符串类型的企业名做字面量转义，避免名称含单引号等特殊字符导致的语法错误
• 若存在部分企业schema下不存在users表的情况，可在拼接前增加过滤逻辑：通过关联information_schema.tables确认对应schema的users表存在后，再纳入拼接的统计片段，避免整体执行报错

内容的提问来源于stack exchange，提问作者Matheus Blödorn Claudino