在SSIS中批量提取多份平面文件前两列：无需逐个创建连接管理器的方法问询

这个场景我之前处理过好多次，完全不用为每个列数不同的文件单独创建连接管理器，给你两个实用的方案：

方案一：复用平面文件连接管理器（简单高效） #

这是最常用的方法，核心思路是让连接管理器只关注我们需要的前两列：

• 创建一个平面文件连接管理器，选择文件夹内列数最多的文件作为初始模板
• 在连接管理器的列配置里，删除所有ID和name之外的列，只保留前两列
• 找到连接管理器的Delay Validation属性，设置为True——这个属性会让SSIS在运行时才验证文件结构，而不是设计时
• 配置Foreach循环容器，枚举目标文件夹里的所有平面文件，将当前文件的路径赋值给连接管理器的ConnectionString属性
• 后续的数据流任务只处理这两列即可，后面的多余列会被自动忽略

注意：要确保所有文件的前两列使用相同的分隔符（比如逗号、制表符），且数据类型一致（比如ID都是整数，name都是字符串），否则可能出现数据读取错误。

方案二：用脚本组件作为数据源（灵活适配） #

如果你的文件格式有较多差异（比如部分文件表头行数不同、分隔符偶尔变化），可以用脚本组件完全自定义读取逻辑：

• 在数据流任务中添加一个脚本组件，选择“源”类型
• 在脚本编辑器的“输入和输出”选项卡中，添加两个输出列：ID（匹配数据库对应类型）和name（匹配数据库对应类型）
• 在脚本编辑器的“脚本”选项卡中，编写读取文件的代码（以C#为例）：

using System.IO;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
using Microsoft.SqlServer.Dts.Runtime.Wrapper;

[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute]
public class ScriptMain : UserComponent
{
    public override void CreateNewOutputRows()
    {
        // 获取Foreach循环传递的当前文件路径
        string filePath = Variables.CurrentFilePath;
        
        // 跳过表头（如果有需要，可通过变量控制是否跳过）
        bool skipHeader = true;
        
        using (StreamReader reader = new StreamReader(filePath))
        {
            string line;
            if (skipHeader)
            {
                reader.ReadLine(); // 跳过第一行表头
            }
            
            while ((line = reader.ReadLine()) != null)
            {
                if (string.IsNullOrWhiteSpace(line)) continue;
                
                // 按分隔符拆分字段（这里假设是逗号，可根据实际修改）
                string[] fields = line.Split(',');
                
                // 确保至少有两列数据，避免索引越界
                if (fields.Length >= 2)
                {
                    Output0Buffer.AddRow();
                    Output0Buffer.ID = int.Parse(fields[0]); // 注意转换类型，可加异常处理
                    Output0Buffer.name = fields[1].Trim();
                }
            }
        }
    }
}

• 配置Foreach循环，将当前文件路径赋值给自定义变量CurrentFilePath，供脚本组件使用
• 后续直接将脚本组件的输出连接到数据库目标即可

这个方法完全摆脱了平面文件连接管理器的限制，能处理各种复杂的文件格式问题，唯一的缺点是需要写少量代码。

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