SSIS中按POLNO等字段组合生成分组自增序列号求助

嘿，我来帮你搞定这个按POLNO、RNWNO、ENDNO、RISKNO分组生成序列号的需求！结合你的Oracle数据源场景，给你两种靠谱的实现方式，优先推荐第一种，省心又高效：

方法一：直接在Oracle数据源查询中生成（强烈推荐） #

数据库本身对分组排序的处理效率远高于SSIS组件，所以直接在取数的SQL里用窗口函数生成序列号是最优解。你只需要修改SSIS数据源的查询语句，用ROW_NUMBER()函数按指定字段分组，每组从1开始递增：

SELECT 
    POLNO,
    RNWNO,
    ENDNO,
    RISKNO,
    ID,
    -- 按四个字段分组，每组内按ID排序生成序列号
    ROW_NUMBER() OVER (
        PARTITION BY POLNO, RNWNO, ENDNO, RISKNO 
        ORDER BY ID  -- 这里可以换成你需要的排序字段，比如创建时间等
    ) AS Seqno
FROM YOUR_SOURCE_TABLE_NAME;

把这个查询放到SSIS的“OLE DB源”组件里，直接就能拿到带Seqno的数据集，后续直接映射到目标Oracle数据库的对应字段就行，全程不用额外的SSIS组件，简单高效。

方法二：在SSIS数据流中用脚本组件生成（适合无法修改数据源查询的场景） #

如果因为某些限制不能修改源查询，那可以在SSIS数据流里通过排序+脚本组件实现：

1. 添加排序组件：把数据源输出连接到“排序”组件，排序字段选择POLNO、RNWNO、ENDNO、RISKNO，确保同一分组的记录连续排列（这一步很重要，脚本组件需要同组记录连续才能正确计数）。
2. 添加脚本组件：选择“转换”类型，在输入列里勾选需要的分组字段（POLNO、RNWNO、ENDNO、RISKNO）以及其他要输出的字段（比如ID）。
3. 配置脚本逻辑：
   • 打开脚本编辑器，选择C#或VB作为脚本语言（这里以C#为例）。
   • 在脚本的类级别声明变量，用来保存上一组的字段值和当前序列号：

     // 保存上一组的分组字段值
     string prevPOLNO = string.Empty;
     string prevRNWNO = string.Empty;
     string prevENDNO = string.Empty;
     string prevRISKNO = string.Empty;
     // 当前组的序列号
     int currentSeq = 1;
     

   • 在Input0_ProcessInputRow方法里编写判断逻辑：

     public override void Input0_ProcessInputRow(Input0Buffer Row)
     {
         // 处理字段为NULL的情况，避免空引用
         string currPOLNO = Row.IsPOLNONull ? string.Empty : Row.POLNO;
         string currRNWNO = Row.IsRNWNONull ? string.Empty : Row.RNWNO;
         string currENDNO = Row.IsENDNONull ? string.Empty : Row.ENDNO;
         string currRISKNO = Row.IsRISKNONull ? string.Empty : Row.RISKNO;
     
         // 判断当前行是否属于新分组
         if (currPOLNO != prevPOLNO || currRNWNO != prevRNWNO || currENDNO != prevENDNO || currRISKNO != prevRISKNO)
         {
             currentSeq = 1;
             // 更新上一组的字段值
             prevPOLNO = currPOLNO;
             prevRNWNO = currRNWNO;
             prevENDNO = currENDNO;
             prevRISKNO = currRISKNO;
         }
     
         // 给当前行赋值序列号
         Row.Seqno = currentSeq;
         currentSeq++;
     }
     

   • 在脚本组件的“输入和输出”选项里，添加一个名为Seqno的输出列，数据类型选择整数（比如DT_I4）。
4. 连接目标组件：把脚本组件的输出连接到“OLE DB目标”，映射Seqno字段到目标表即可。

注意事项 #

• 如果数据量很大，方法一的性能会远优于方法二，因为SSIS的排序组件需要把数据加载到内存中处理，可能会有性能瓶颈。
• 脚本组件里一定要处理字段为NULL的情况，否则会抛出空引用异常。

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