| 去重 | 主键+批次取最新 |
|---|---|
| 格式 | trim/日期统一 |
| 枚举 | 映射表标准化 |
| 异常 | 归入未知成员 |
去重与格式化
去重与格式化
SELECT order_id,
trim(cust_name) AS cust_name,
to_date(replace(birth_dt,'/','-')) AS birth_date
FROM (SELECT *, row_number() OVER (PARTITION BY order_id ORDER BY etl_load_time DESC) AS rn
FROM ods_order
WHERE dt='2026-10-12') t
WHERE rn = 1;清洗规则用映射表加 SQL 实现，避免散落在多个脚本里的 CASE 分支。