如何在Informatica中按ID对比Error表与Success表的行数？

实现步骤： #

1. 配置源组件

   • 分别引入Error表和Success表作为数据源，确认两张表的ID字段可正常读取。

2. 添加聚合转换计算单ID行数

   • 为每个源表单独创建聚合转换：
     • Error表聚合：设置分组字段为ID，新增计算端口ERR_CNT，表达式为COUNT(*)，同时添加过滤器条件ID=1（提前过滤非目标ID，提升效率）。
     • Success表聚合：设置分组字段为ID，新增计算端口SUCC_CNT，表达式为COUNT(*)，同样添加过滤器ID=1。

3. 连接两个聚合数据流

   • 添加全外连接（Full Outer Join）转换，连接条件设为ERR.ID = SUCC.ID，确保其中一张表无ID=1数据时仍能输出结果。

4. 用表达式转换处理空值与对比逻辑

   • 新增端口处理空值（避免无数据时显示NULL）：
     • FINAL_ERR_CNT：IIF(ISNULL(ERR_CNT), 0, ERR_CNT)
     • FINAL_SUCC_CNT：IIF(ISNULL(SUCC_CNT), 0, SUCC_CNT)
   • 新增对比结果端口COMPARE_RESULT，表达式示例：

     IIF(FINAL_ERR_CNT > FINAL_SUCC_CNT, 'Error行数多于Success', 
         IIF(FINAL_ERR_CNT < FINAL_SUCC_CNT, 'Success行数多于Error', '两行数相等'))
     

5. 配置目标输出

   • 创建目标表/文件，包含ID、FINAL_ERR_CNT、FINAL_SUCC_CNT、COMPARE_RESULT字段，将表达式转换的输出映射到目标即可。

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