Teradata查询性能优化咨询：含日期运算关联条件的慢查询优化

问题定位 #

原查询执行耗时久、CPU/IO占用高，核心瓶颈在于最后一个关联条件：(I.FUTURE_DATE + DY_CNT) = K.G_DATE。该非等值关联无法利用常规索引快速匹配，会触发大量全表扫描或笛卡尔积计算，导致资源消耗激增。

原查询代码：

SELECT       
        A.CLMN1
        ,COALESCE(G.oDY_CNT,1)        AS DY_CNT 

FROM
DBNAME.TABLE_A     A

LEFT OUTER JOIN DBNAME.TABLE_H          H
ON A.C_NAME = H.C_NAME

LEFT OUTER JOIN DBNAME.TABLE_I           I   
ON H.CAL_ID = I.CAL_ID
AND I.P_DATE = I.G_DATE

LEFT OUTER JOIN DBNAME.TABLE_K        K  
ON H.CAL_ID = K.CAL_ID
AND  (I.FUTURE_DATE + DY_CNT) = K.G_DATE;

优化方法 #

1. 预计算派生字段，转化为等值关联 #

将非等值条件转化为等值关联，让Teradata可以利用索引加速匹配：

• 若有权限修改表结构，给TABLE_I新增计算列：

ALTER TABLE DBNAME.TABLE_I ADD COLUMN CALCULATED_DATE DATE 
GENERATED ALWAYS AS (FUTURE_DATE + DY_CNT);

• 在TABLE_I和TABLE_K上创建对应联合索引：

CREATE INDEX IDX_I_CALID_CALCDATE ON DBNAME.TABLE_I (CAL_ID, CALCULATED_DATE);
CREATE INDEX IDX_K_CALID_GDATE ON DBNAME.TABLE_K (CAL_ID, G_DATE);

• 修改查询的关联条件：

LEFT OUTER JOIN DBNAME.TABLE_K        K  
ON H.CAL_ID = K.CAL_ID
AND I.CALCULATED_DATE = K.G_DATE;

2. 调整关联顺序，缩小中间结果集 #

先将TABLE_I与TABLE_K按关联条件做预处理，再和其他表关联，减少中间数据量：

WITH JOIN_IK AS (
    SELECT 
        I.CAL_ID,
        K.*
    FROM DBNAME.TABLE_I I
    LEFT JOIN DBNAME.TABLE_K K
        ON I.CAL_ID = K.CAL_ID
        AND (I.FUTURE_DATE + I.DY_CNT) = K.G_DATE
    WHERE I.P_DATE = I.G_DATE
)
SELECT       
        A.CLMN1
        ,COALESCE(G.oDY_CNT,1)        AS DY_CNT 
FROM DBNAME.TABLE_A A
LEFT JOIN DBNAME.TABLE_H H
    ON A.C_NAME = H.C_NAME
LEFT JOIN JOIN_IK IK
    ON H.CAL_ID = IK.CAL_ID;

3. 更新统计信息，优化执行计划 #

确保所有涉及表的统计信息最新，让Teradata优化器生成最优执行计划：

COLLECT STATISTICS ON DBNAME.TABLE_A COLUMN(C_NAME);
COLLECT STATISTICS ON DBNAME.TABLE_H COLUMN(C_NAME, CAL_ID);
COLLECT STATISTICS ON DBNAME.TABLE_I COLUMN(CAL_ID, P_DATE, G_DATE, FUTURE_DATE, DY_CNT);
COLLECT STATISTICS ON DBNAME.TABLE_K COLUMN(CAL_ID, G_DATE);

4. 用物化视图缓存关联结果 #

如果TABLE_I和TABLE_K数据更新频率低，可创建物化视图存储关联结果，避免重复计算：

CREATE MATERIALIZED VIEW DBNAME.MV_IK
AS
SELECT 
    I.CAL_ID,
    K.*
FROM DBNAME.TABLE_I I
LEFT JOIN DBNAME.TABLE_K K
    ON I.CAL_ID = K.CAL_ID
    AND (I.FUTURE_DATE + I.DY_CNT) = K.G_DATE
WHERE I.P_DATE = I.G_DATE
WITH DATA;

-- 按需定期刷新物化视图
REFRESH MATERIALIZED VIEW DBNAME.MV_IK;

查询时直接引用物化视图：

SELECT       
        A.CLMN1
        ,COALESCE(G.oDY_CNT,1)        AS DY_CNT 
FROM DBNAME.TABLE_A A
LEFT JOIN DBNAME.TABLE_H H
    ON A.C_NAME = H.C_NAME
LEFT JOIN DBNAME.MV_IK IK
    ON H.CAL_ID = IK.CAL_ID;

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