如何在BigQuery中实现MySQL风格的动态查询存储过程？

问题核心 #

原MySQL存储过程因BigQuery不支持单引号包裹的跨换行字符串字面量，导致「未闭合字符串字面量」错误，同时BigQuery的动态SQL语法与MySQL存在差异，需要针对性调整。

正确实现方式 #

BigQuery中无需使用PREPARE/EXECUTE/DEALLOCATE流程，直接通过EXECUTE IMMEDIATE执行动态SQL，同时解决字符串换行问题，以下是三种可行写法：

写法1：单行字符串拼接

将SQL语句压缩为单行，避免换行问题：

CREATE OR REPLACE PROCEDURE `test`(IN tab_name STRING)
BEGIN
  EXECUTE IMMEDIATE CONCAT('SELECT * FROM ', tab_name);
END;

写法2：多行字符串（三单引号包裹）

BigQuery支持用三个单引号包裹多行字符串字面量，直接保留换行格式：

CREATE OR REPLACE PROCEDURE `test`(IN tab_name STRING)
BEGIN
  EXECUTE IMMEDIATE CONCAT('''SELECT *
FROM ''', tab_name);
END;

写法3：拆分字符串拼接

将SQL语句拆分为多个单行字符串，通过CONCAT拼接：

CREATE OR REPLACE PROCEDURE `test`(IN tab_name STRING)
BEGIN
  EXECUTE IMMEDIATE CONCAT(
    'SELECT * ',
    'FROM ',
    tab_name
  );
END;

调用方式 #

调用时需注意表名的格式，若包含数据集或特殊字符，需用反引号包裹后作为字符串参数传入：

CALL `test`('`my_dataset.my_table`');

关键说明 #

• BigQuery存储过程使用CREATE OR REPLACE PROCEDURE定义，参数类型推荐使用STRING替代MySQL的CHAR，更适配BigQuery的类型系统。
• EXECUTE IMMEDIATE是BigQuery执行动态SQL的标准方式，直接解析并运行生成的SQL语句。
• 三种字符串写法均规避了跨换行的单引号字符串问题，解决「未闭合字符串字面量」错误。

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