如何扩展QueryA以执行返回列中存储的QueryB并输出其结果？

现有SQL查询QueryA执行后返回一行三列的结果，其中一列存储了另一条查询语句QueryB。QueryA的代码如下：

SELECT
     -- some calculations and manipulations
     x, y, queryB
     .....
FROM INFORMATION_SCHEMA.COLUMNS c
WHERE TABLE_SCHEMA = UPPER($sch_name)
  AND TABLE_NAME = UPPER($tab_name);

QueryA的输出示例：

x,   y,       queryB
aa   bb       select * from stg.new

需要扩展QueryA，使其执行存储的QueryB，并最终返回QueryB的执行结果，而非QueryA原本的结果。

解决方案：通过动态SQL实现 #

核心思路是先执行QueryA获取到QueryB的内容，再动态执行这条QueryB语句。不同数据库的动态SQL语法存在差异，以下是主流数据库的具体实现方式：

1. PostgreSQL #

方式1：匿名DO块（仅执行语句，如需返回结果建议用函数）

DO $$
DECLARE
    v_query text;
BEGIN
    -- 执行QueryA获取QueryB内容
    SELECT queryB INTO v_query
    FROM INFORMATION_SCHEMA.COLUMNS c
    WHERE TABLE_SCHEMA = UPPER($sch_name)
      AND TABLE_NAME = UPPER($tab_name);
    
    -- 动态执行QueryB
    EXECUTE v_query;
END $$;

方式2：创建函数返回QueryB结果

如果需要直接返回QueryB的查询结果，推荐封装为函数：

CREATE OR REPLACE FUNCTION execute_queryB(p_sch_name text, p_tab_name text)
RETURNS SETOF record AS $$
DECLARE
    v_query text;
BEGIN
    SELECT queryB INTO v_query
    FROM INFORMATION_SCHEMA.COLUMNS c
    WHERE TABLE_SCHEMA = UPPER(p_sch_name)
      AND TABLE_NAME = UPPER(p_tab_name);
    
    RETURN QUERY EXECUTE v_query;
END $$ LANGUAGE plpgsql;

-- 调用函数时需指定返回列的名称和类型
SELECT * FROM execute_queryB('your_schema', 'your_table') AS t(col1 varchar, col2 int, ...);

2. MySQL #

使用存储过程结合PREPARE/EXECUTE语句实现：

DELIMITER //

CREATE PROCEDURE execute_queryB(IN p_sch_name VARCHAR(255), IN p_tab_name VARCHAR(255))
BEGIN
    DECLARE v_query TEXT;
    
    -- 获取QueryB内容
    SELECT queryB INTO v_query
    FROM INFORMATION_SCHEMA.COLUMNS c
    WHERE TABLE_SCHEMA = UPPER(p_sch_name)
      AND TABLE_NAME = UPPER(p_tab_name);
    
    -- 动态执行QueryB
    SET @sql = v_query;
    PREPARE stmt FROM @sql;
    EXECUTE stmt;
    DEALLOCATE PREPARE stmt;
END //

DELIMITER ;

-- 调用存储过程
CALL execute_queryB('your_schema', 'your_table');

3. SQL Server #

方式1：直接使用动态SQL

DECLARE @v_query NVARCHAR(MAX);

-- 获取QueryB内容
SELECT @v_query = queryB
FROM INFORMATION_SCHEMA.COLUMNS c
WHERE TABLE_SCHEMA = UPPER(@sch_name)
  AND TABLE_NAME = UPPER(@tab_name);

-- 执行QueryB
EXEC sp_executesql @v_query;

方式2：封装为存储过程

CREATE PROCEDURE execute_queryB
    @sch_name NVARCHAR(255),
    @tab_name NVARCHAR(255)
AS
BEGIN
    DECLARE @v_query NVARCHAR(MAX);
    
    SELECT @v_query = queryB
    FROM INFORMATION_SCHEMA.COLUMNS c
    WHERE TABLE_SCHEMA = UPPER(@sch_name)
      AND TABLE_NAME = UPPER(@tab_name);
    
    EXEC sp_executesql @v_query;
END;

-- 调用存储过程
EXEC execute_queryB 'your_schema', 'your_table';

注意事项 #

• 需确保QueryB是合法的SQL语句，若内容来自不可信来源，要做注入风险校验。
• 执行动态SQL的账号必须拥有QueryB涉及数据库对象的相应权限。
• 以上示例默认QueryA仅返回一行结果，若QueryA可能返回多条QueryB，需添加循环逻辑逐一执行。

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