如何在BigQuery循环中使用decode语句？Oracle转BigQuery语法求助

一、原Oracle语句的BigQuery转换 #

原Oracle语句用于计算Priority字段，核心逻辑是根据last_updated_time加3天后的星期几调整日期，再对比当前时间返回对应优先级值。BigQuery中无decode函数，用CASE WHEN替代，同时注意日期函数差异，转换后的SQL如下：

CAST(
  CASE
    WHEN SIGN(
      CASE EXTRACT(DAYOFWEEK FROM TIMESTAMP_ADD(c.last_updated_time, INTERVAL 3 DAY))
        WHEN 7 THEN TIMESTAMP_ADD(c.last_updated_time, INTERVAL 5 DAY)
        WHEN 1 THEN TIMESTAMP_ADD(c.last_updated_time, INTERVAL 5 DAY)
        WHEN 2 THEN TIMESTAMP_ADD(c.last_updated_time, INTERVAL 5 DAY)
        WHEN 3 THEN TIMESTAMP_ADD(c.last_updated_time, INTERVAL 4 DAY)
        ELSE TIMESTAMP_ADD(c.last_updated_time, INTERVAL 3 DAY)
      END - CURRENT_TIMESTAMP()
    ) = -1 THEN 3
    ELSE 1
  END AS STRING
) AS Priority

关键转换点说明： #

• Oracle的decode全部替换为CASE WHEN结构，逻辑完全等价
• Oracle的sysdate对应BigQuery的CURRENT_TIMESTAMP()（仅需日期可改用CURRENT_DATE()）
• Oracle的to_char(date, 'D')（获取星期几，1=周日、7=周六）对应BigQuery的EXTRACT(DAYOFWEEK FROM timestamp)
• Oracle的日期加减c.last_updated_time + 3对应BigQuery的TIMESTAMP_ADD(c.last_updated_time, INTERVAL 3 DAY)

二、BigQuery循环中实现类似decode的逻辑 #

BigQuery不支持decode函数，无论普通查询还是循环脚本中，都用CASE WHEN替代。以下是循环中使用的示例（基于BigQuery脚本语法）：

-- 示例：循环处理表中数据，用CASE WHEN替代decode逻辑
DECLARE i INT64 DEFAULT 1;
DECLARE total_rows INT64 DEFAULT (SELECT COUNT(*) FROM `your-project.your-dataset.your-table`);

WHILE i <= total_rows DO
  -- 获取当前循环行的目标字段值
  DECLARE status STRING;
  SET status = (SELECT order_status FROM `your-project.your-dataset.your-table` OFFSET(i-1));
  
  -- 用CASE WHEN实现原decode的分支逻辑
  DECLARE status_code INT64;
  SET status_code = CASE status
    WHEN 'PENDING' THEN 1
    WHEN 'PROCESSING' THEN 2
    WHEN 'COMPLETED' THEN 3
    ELSE 0
  END;
  
  -- 后续处理：比如输出结果或写入目标表
  SELECT CONCAT('行', CAST(i AS STRING), '状态码：', CAST(status_code AS STRING)) AS result;
  SET i = i + 1;
END WHILE;

注意事项： #

• BigQuery的循环仅支持在**脚本（Scripting）**中使用，比如存储过程、临时查询脚本
• 若处理大量数据，建议优先用批量SQL（如窗口函数、JOIN）替代循环，循环仅适用于少量数据或特殊业务场景

内容的提问来源于stack exchange，提问作者Zulfikar S Khan