Redshift表更新语法问题：每日调度查询实现及代码修正

原代码中的核心错误 #

• 临时表创建逻辑错误：create temp table [temp_table_name] as [SELECT * FROM temp_table_name]; 属于循环引用，用待创建的临时表自身作为数据源，必然报错。需替换为实际的业务数据源查询。
• 更新语句笔误：value2 = NVL(value2, temp_table_name.value1) 和 value3 = NVL(value3, temp_table_name.value1) 中，错误引用了临时表的value1，应对应temp_table_name.value2和temp_table_name.value3。
• 缺少近一周数据过滤：未添加「仅更新近一周行」的条件，会错误修改历史数据。
• 插入语句逻辑完全错误：where value1 <> temp_table_name.value1 and value2 <> temp_table_name.value2 是拿临时表自身字段做无效比较，无法筛选出prod表中不存在的新行。
• 字段匹配风险：插入时用select *可能因prod表与临时表字段顺序/数量不一致报错，建议显式指定字段。

修正后的代码示例 #

假设prod表存在时间字段event_date用于判断数据是否在近一周内，唯一键为key1 + key2，修正后的代码如下：

-- 替换为实际的临时表数据源，比如从业务表查询每日新数据
create temp table temp_table_name as 
SELECT key1, key2, key3, key4, value1, value2, value3, event_date 
FROM your_actual_data_source 
WHERE event_date = current_date; -- 按实际业务逻辑筛选每日新事件

begin transaction;

-- 仅更新近一周内、prod表对应value为null的行
update prod_table_name 
set value1 = NVL(prod_table_name.value1, temp_table_name.value1),
    value2 = NVL(prod_table_name.value2, temp_table_name.value2),
    value3 = NVL(prod_table_name.value3, temp_table_name.value3)
from temp_table_name
where prod_table_name.key1 = temp_table_name.key1
  and prod_table_name.key2 = temp_table_name.key2
  and prod_table_name.event_date >= current_date - interval '7 days'; -- 近一周数据过滤

-- 插入prod表中不存在的新行（基于key1+key2唯一判断）
insert into prod_table_name (key1, key2, key3, key4, value1, value2, value3, event_date)
select temp.key1, temp.key2, temp.key3, temp.key4, temp.value1, temp.value2, temp.value3, temp.event_date
from temp_table_name temp
where not exists (
    select 1 from prod_table_name prod
    where prod.key1 = temp.key1 and prod.key2 = temp.key2
);

end transaction;

额外注意事项 #

• 确认prod表的时间字段（示例中为event_date）类型正确，若字段名不同需替换为实际业务字段（如create_time）。
• 若key3、key4属于业务匹配必要字段，可在update和insert的where条件中补充，但需以用户指定的key1+key2为唯一判断依据。
• 调度执行时，确保临时表的数据源逻辑能稳定获取每日新事件数据。

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