如何基于SQL表状态调度ETL？修正SSIS查询特定任务最新状态问题

方法一：修正子查询过滤条件 #

原代码的核心问题是获取最大ETL_ID的子查询未限定任务名称，导致取到全表最大ID。只需在子查询中添加任务过滤条件即可：

SELECT 
    CASE 
        WHEN ETL_STATUS = 'Running' THEN 'No'
        ELSE 'Yes'
    END AS CanETLbeExecuted
FROM (SELECT 1 AS DummyColumn FROM DUAL) DummyRow 
LEFT OUTER JOIN ETL_TABLE 
    ON 1=1 
    AND JOB = 'Load new files' 
    AND ETL_ID = (SELECT MAX(ETL_ID) FROM ETL_TABLE WHERE JOB = 'Load new files');

修改说明：

• 在SELECT MAX(ETL_ID) FROM ETL_TABLE后添加WHERE JOB = 'Load new files'，确保只统计“Load new files”任务下的ETL_ID，取该任务的最新记录ID。
• 结合你的表数据，该任务最新ETL_ID为199143（状态为Completed），查询结果会返回Yes，符合启动下一个ETL的判断逻辑。

方法二：使用窗口函数（更直观易扩展） #

如果需要后续扩展到多任务场景，推荐用窗口函数直接定位目标任务的最新记录：

SELECT 
    CASE 
        WHEN ETL_STATUS = 'Running' THEN 'No'
        ELSE 'Yes'
    END AS CanETLbeExecuted
FROM (
    SELECT 
        ETL_STATUS,
        ROW_NUMBER() OVER (PARTITION BY JOB ORDER BY ETL_ID DESC) AS rn
    FROM ETL_TABLE
    WHERE JOB = 'Load new files'
) t
WHERE rn = 1;

修改说明：

• 内层查询通过ROW_NUMBER()按JOB分组，按ETL_ID降序排序，给每个任务的记录标记序号，最新记录序号为1。
• 外层查询筛选出目标任务的最新记录，直接判断其状态生成结果。这种写法逻辑更清晰，也方便后续添加其他任务的判断逻辑。

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