Informatica中如何使用pre sql根据当前处理文件名删除对应记录

首先明确结论：你无法直接在会话级的Pre SQL中调用源端的当前处理文件名端口。因为Pre SQL的执行优先级早于映射逻辑的运行，会话启动时就会先执行Pre SQL，此时还没有读取源文件，自然无法获取到文件名中的日期信息。

下面是两种可落地的实现方案：

方案1：预会话任务拼接删除条件+参数传递（多文件批量处理首选） #

• 先在工作流中会话任务的前面添加一个预会话命令任务，运行对应系统的脚本（Linux用Shell、Windows用PowerShell）
• 脚本逻辑：先读取你间接加载用到的控制文件（Indirect模式下指定的那个存所有源文件路径的列表文件），逐行提取每个production_plan_YYYYMMDD.csv文件名中的8位日期字符串，按你目标表production_date的字段类型拼接成合法的IN查询条件，最终写入Informatica的参数文件，给自定义会话变量比如$$DELETE_DATE_LIST赋值
• 配置会话的Pre SQL为：

DELETE FROM 你的目标表名 WHERE production_date IN ($$DELETE_DATE_LIST);

注意如果production_date是日期类型，需要把每个日期字符串转成对应数据库的日期格式，比如Oracle环境下拼接成TO_DATE('20240520','YYYYMMDD')的格式再赋值给变量

方案2：删除逻辑移入映射（单文件逐批处理首选） #

你已经可以拿到当前处理文件名的端口，直接在映射层面做删除即可，不用依赖会话级Pre SQL：

• 新增表达式转换，从文件名端口中用字符串截取函数提取8位日期字符串，转成和production_date字段类型一致的格式，输出为v_current_file_date端口
• 新增一个SQL转换，连接目标表所在的数据库，写入删除SQL：

DELETE FROM 你的目标表名 WHERE production_date = ?

把上一步得到的v_current_file_date端口作为SQL转换的输入参数绑定到?占位符，该SQL会在每个文件的数据流处理前执行，删完对应日期的数据再走后续的插入逻辑

两种方案都可以稳定实现你的需求，根据你的实际业务是要一次性加载所有日期文件还是逐文件分批处理选择即可。

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