在BigQuery的CASE语句中执行动态查询遇问题求助

问题原因 #

多数SQL方言中，CASE是表达式，仅用于返回单个值，不能嵌入执行动态SQL的命令（比如EXECUTE IMMEDIATE）。EXECUTE IMMEDIATE是独立的执行语句，无法放在CASE表达式内部，这就是你遇到"Unexpected keyword Immediate"错误的核心原因。

解决方法 #

你需要通过循环遍历表1的记录，用CASE拼接对应操作的SQL语句，再单独执行动态SQL。以下是两种主流数据库的实现示例：

示例1：MySQL实现 #

假设表1结构为operation_table(col_name VARCHAR(50), op_type VARCHAR(50))，目标表为target_table，编写存储过程处理：

DELIMITER //
CREATE PROCEDURE execute_column_operations()
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE col_name_var VARCHAR(50);
    DECLARE op_type_var VARCHAR(50);
    DECLARE sql_stmt VARCHAR(255);
    
    DECLARE cur CURSOR FOR SELECT col_name, op_type FROM operation_table;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
    
    OPEN cur;
    read_loop: LOOP
        FETCH cur INTO col_name_var, op_type_var;
        IF done THEN
            LEAVE read_loop;
        END IF;
        
        -- 根据操作类型拼接SQL
        CASE op_type_var
            WHEN 'count' THEN
                SET sql_stmt = CONCAT('SELECT COUNT(', col_name_var, ') FROM target_table;');
            WHEN 'CHAR LENGTH' THEN
                SET sql_stmt = CONCAT('SELECT SUM(CHAR_LENGTH(', col_name_var, ')) FROM target_table;');
            ELSE
                SET sql_stmt = NULL; -- 跳过未知操作类型
        END CASE;
        
        -- 执行动态SQL
        IF sql_stmt IS NOT NULL THEN
            PREPARE stmt FROM sql_stmt;
            EXECUTE stmt;
            DEALLOCATE PREPARE stmt;
        END IF;
    END LOOP;
    
    CLOSE cur;
END //
DELIMITER ;

-- 调用存储过程执行所有操作
CALL execute_column_operations();

示例2：PostgreSQL实现 #

PostgreSQL使用EXECUTE执行动态SQL，存储过程写法如下：

CREATE OR REPLACE PROCEDURE execute_column_operations()
LANGUAGE plpgsql
AS $$
DECLARE
    rec RECORD;
    sql_stmt TEXT;
BEGIN
    FOR rec IN SELECT col_name, op_type FROM operation_table LOOP
        CASE rec.op_type
            WHEN 'count' THEN
                sql_stmt := format('SELECT COUNT(%I) FROM target_table;', rec.col_name);
            WHEN 'CHAR LENGTH' THEN
                sql_stmt := format('SELECT SUM(CHAR_LENGTH(%I)) FROM target_table;', rec.col_name);
            ELSE
                sql_stmt := NULL;
        END CASE;
        
        IF sql_stmt IS NOT NULL THEN
            EXECUTE sql_stmt;
        END IF;
    END LOOP;
END $$;

-- 调用存储过程
CALL execute_column_operations();

关键点说明 #

• 用CASE表达式拼接SQL字符串，而不是直接在CASE里执行动态SQL。
• 通过游标或循环遍历表1的每一条记录，逐个生成并执行对应操作的查询。
• 使用format()（PostgreSQL）或字符串拼接函数时，注意处理列名的转义，避免SQL注入风险。

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