产品级价格弹性计算：临时表连接无结果及周度计算优化求助

一、当前查询无数据的原因及修正 #

你的查询返回空结果，核心有两个问题：

1. LEFT JOIN 被WHERE条件强制转为INNER JOIN：使用LEFT JOIN后又加WHERE x1.PRODUCT_NAME = y1.PRODUCT_NAME，会过滤掉所有左表无匹配的行，逻辑上等价于INNER JOIN，但如果存在x1.PRODUCT_NAME为NULL的情况（比如左表有产品但右表无匹配），会直接排除有效数据。
2. NetPrice计算可能产生NULL：若某产品对应周的VOLUME为0，NET_SALES/VOLUME会得到NULL，最终关联后的计算结果会被默认过滤。

修正后的两周对比代码：

WITH week1 AS (
    SELECT 
        PRODUCT_NAME,
        VOLUME AS volume1,
        CASE WHEN VOLUME > 0 THEN NET_SALES/VOLUME ELSE NULL END AS netprice1
    FROM sales2022YTD
    WHERE DATE_FROM = '2022-01-03'
),
week2 AS (
    SELECT 
        PRODUCT_NAME,
        VOLUME AS volume2,
        CASE WHEN VOLUME > 0 THEN NET_SALES/VOLUME ELSE NULL END AS netprice2
    FROM sales2022YTD
    WHERE DATE_FROM = '2022-08-03'
)
SELECT 
    w2.PRODUCT_NAME,
    w2.netprice2 / w1.netprice1 AS pricediff,
    w2.volume2 / w1.volume1 AS volumediff
FROM week2 w2
INNER JOIN week1 w1 ON w2.PRODUCT_NAME = w1.PRODUCT_NAME
WHERE w1.netprice1 IS NOT NULL 
  AND w2.netprice2 IS NOT NULL
  AND w1.volume1 > 0 
  AND w2.volume2 > 0;

二、扩展至52周的周度弹性计算方案 #

用窗口函数LAG()可以一次性完成全周度的弹性计算，无需重复创建临时表，效率更高：

SELECT 
    DATE_FROM AS current_week,
    LAG(DATE_FROM) OVER (PARTITION BY PRODUCT_NAME ORDER BY DATE_FROM) AS previous_week,
    PRODUCT_NAME,
    -- 价格变动比值（当前周/上周）
    (current_netprice / LAG(current_netprice) OVER (PARTITION BY PRODUCT_NAME ORDER BY DATE_FROM)) AS pricediff,
    -- 销量变动比值（当前周/上周）
    (current_volume / LAG(current_volume) OVER (PARTITION BY PRODUCT_NAME ORDER BY DATE_FROM)) AS volumediff,
    -- 价格弹性：销量变动率 / 价格变动率（标准弹性公式，可根据需求调整为比值形式）
    ( (current_volume - LAG(current_volume) OVER w) / LAG(current_volume) OVER w ) 
    / 
    ( (current_netprice - LAG(current_netprice) OVER w) / LAG(current_netprice) OVER w ) AS price_elasticity
FROM (
    SELECT 
        DATE_FROM,
        PRODUCT_NAME,
        VOLUME AS current_volume,
        CASE WHEN VOLUME > 0 THEN NET_SALES/VOLUME ELSE NULL END AS current_netprice
    FROM sales2022YTD
    WHERE VOLUME > 0 -- 提前过滤无效销量数据
) AS weekly_data
WINDOW w AS (PARTITION BY PRODUCT_NAME ORDER BY DATE_FROM)
-- 过滤无上周数据的第一周
WHERE LAG(DATE_FROM) OVER w IS NOT NULL;

关键说明： #

• PARTITION BY PRODUCT_NAME：按产品分组，确保每个产品单独计算周度变动
• ORDER BY DATE_FROM：按周排序，保证LAG()取到的是上一周的对应数据
• WINDOW子句：复用窗口定义，简化代码
• 可根据需求调整弹性计算逻辑：如果需要用比值（current/previous）代替变动百分比，直接用volumediff / pricediff即可

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