如何将Sybase循环SQL查询转换为Snowflake SQL查询

需求说明 #

当Products表的unit_price平均值小于30时，循环删除表中单价最高的记录；若表中最高单价小于50，则终止循环。

原Sybase SQL代码 #

WHILE (SELECT AVG(unit_price) FROM Products) < 30 
BEGIN
    DELETE FROM Products
    WHERE UnitPrice = MAX(UnitPrice)
    IF ( SELECT MAX(UnitPrice) FROM Products ) < 50 
        BREAK
END

Snowflake SQL实现 #

Snowflake不支持在DELETE语句的WHERE子句中直接使用聚合函数，需要先获取当前最大单价再执行删除操作，同时优化循环逻辑减少重复查询：

DECLARE
    avg_price NUMBER(10,2);
    max_price NUMBER(10,2);
BEGIN
    -- 初始化获取当前平均价与最高价
    SELECT AVG(unit_price), MAX(unit_price) INTO avg_price, max_price FROM Products;
    
    WHILE avg_price < 30 AND max_price >= 50 DO
        -- 删除所有单价等于当前最高价的记录
        DELETE FROM Products
        WHERE unit_price = max_price;
        
        -- 更新最新的平均价与最高价
        SELECT AVG(unit_price), MAX(unit_price) INTO avg_price, max_price FROM Products;
        
        -- 触发终止条件
        IF max_price < 50 THEN
            BREAK;
        END IF;
    END WHILE;
END;

关键说明 #

• 通过变量存储聚合结果，避免多次全表扫描带来的性能损耗
• 循环条件同时校验平均价和最高价，减少无意义的循环执行
• 每次删除后重新获取最新数据，确保逻辑判断的准确性

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