能否在SQL SELECT语句中使用for循环批量生成聚合查询字段？

核心结论 #

标准ANSI SQL 不支持你示例中FOR column LOOP columns这类直接在SELECT子句中循环遍历列的语法。要实现不用手动罗列150+列的需求，通用方案是使用动态SQL：先通过数据库的系统表查询到目标表的所有列名，再自动拼接出带聚合逻辑的完整SQL语句，最后执行生成的语句即可。

不同数据库的实现示例 #

MySQL 示例 #

-- 第一步：拼接所有列的聚合逻辑
SET @agg_columns = NULL;
SELECT GROUP_CONCAT(
  CONCAT('COUNT(DISTINCT `', COLUMN_NAME, '`) AS `', COLUMN_NAME, '_distinct_cnt`')
) INTO @agg_columns
FROM INFORMATION_SCHEMA.COLUMNS
WHERE TABLE_SCHEMA = '替换为你的库名'
  AND TABLE_NAME = '替换为你的表名'
  AND COLUMN_NAME != 'AGREEMENT_NO'; -- 排除GROUP BY用到的字段

-- 第二步：拼接完整查询SQL
SET @final_sql = CONCAT(
  'SELECT AGREEMENT_NO, ',
  @agg_columns,
  ' FROM 替换为你的表名 WHERE 替换为你的WHERE条件 GROUP BY AGREEMENT_NO;'
);

-- 可选：打印生成的SQL检查正确性
-- SELECT @final_sql;

-- 第三步：执行SQL
PREPARE stmt FROM @final_sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

PostgreSQL 示例 #

DO $$
DECLARE
    v_agg_columns text;
    v_final_sql text;
BEGIN
    -- 拼接所有列的聚合逻辑
    SELECT string_agg(
        format('COUNT(DISTINCT %I) AS %I', column_name, column_name || '_distinct_cnt'),
        ', '
    ) INTO v_agg_columns
    FROM information_schema.columns
    WHERE table_schema = '替换为你的schema名'
      AND table_name = '替换为你的表名'
      AND column_name != 'AGREEMENT_NO'; -- 排除GROUP BY字段

    -- 拼接完整查询SQL
    v_final_sql := format(
        'SELECT AGREEMENT_NO, %s FROM 替换为你的表名 WHERE 替换为你的WHERE条件 GROUP BY AGREEMENT_NO',
        v_agg_columns
    );
    
    -- 打印生成的SQL检查
    RAISE NOTICE '生成的SQL：%', v_final_sql;
    
    -- 如需直接执行并返回结果，可结合RETURN QUERY使用，也可把打印的SQL复制出来手动运行
END $$;

Oracle 示例 #

DECLARE
    v_agg_columns VARCHAR2(32767);
    v_final_sql VARCHAR2(32767);
BEGIN
    -- 拼接聚合列
    SELECT LISTAGG('COUNT(DISTINCT "' || COLUMN_NAME || '") AS "' || COLUMN_NAME || '_distinct_cnt"', ', ')
    INTO v_agg_columns
    FROM ALL_TAB_COLUMNS
    WHERE OWNER = '替换为你的用户名'
      AND TABLE_NAME = '替换为你的表名'
      AND COLUMN_NAME != 'AGREEMENT_NO';

    -- 拼接完整SQL
    v_final_sql := 'SELECT AGREEMENT_NO, ' || v_agg_columns || ' FROM 替换为你的表名 WHERE 替换为你的WHERE条件 GROUP BY AGREEMENT_NO';
    
    -- 打印SQL
    DBMS_OUTPUT.PUT_LINE(v_final_sql);
    
    -- 执行，如需返回结果可以用REF CURSOR接收
    EXECUTE IMMEDIATE v_final_sql;
END;
/

注意事项 #

• 建议执行动态SQL前先打印生成的完整语句，检查列名、聚合逻辑是否符合预期，避免关键字冲突、过滤条件错误等问题
• 若存在不需要应用聚合的字段，在系统表查询的WHERE条件里补充排除规则即可
• 如果你的表列数过多导致拼接的字符串超出长度限制，可以调整数据库的字符串长度参数，或者分批拼接列再合并

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