SSIS中如何批量将文件夹内SQL查询结果导出为对应CSV文件

你之前将执行SQL任务设为完整结果集后循环失败的核心原因：不需要用执行SQL任务提前存储查询结果，SSIS的对象类型结果集在循环迭代中不会自动重置元数据，且无法直接作为同循环内数据流的动态源，属于冗余步骤，直接在ForEach循环内配置动态数据流即可实现需求。

前置变量准备 #

先在SSIS变量面板创建以下变量，避免后续重复拼接配置：

• FolderPath：字符串类型，存储.sql文件所在文件夹路径，必须在路径末尾加反斜杠，例如D:\SQLScripts\，防止路径拼接错误
• SQLfile：字符串类型，用于ForEach循环映射遍历到的文件名，你已创建可直接复用
• FullSQLPath：字符串类型，设置表达式为@[User::FolderPath] + @[User::SQLfile]，自动生成每个SQL文件的完整路径
• TargetCSVPath：字符串类型，设置表达式为"D:\ExportCSV\" + REPLACE(@[User::SQLfile],".sql",".csv")，自动匹配每个SQL文件对应的CSV输出路径
• SQLCommand：字符串类型，用于存储每个.sql文件内的实际查询语句

ForEach循环容器配置 #

你之前的循环配置基本正确，仅需确认以下配置项：

• 枚举器类型选择Foreach 文件枚举器
• 文件夹路径绑定@[User::FolderPath]变量，文件筛选器填写*.sql，可按需勾选「遍历子文件夹」
• 变量映射页将索引0的枚举值绑定到@[User::SQLfile]变量

循环内任务配置 #

删除你之前放置的、用于存储结果集的执行SQL任务，按顺序添加以下两个任务：

1. 脚本任务（读取SQL文件内容） #

• 脚本任务编辑器中，ReadOnlyVariables选择@[User::FullSQLPath]，ReadWriteVariables选择@[User::SQLCommand]
• 点击「编辑脚本」，在脚本入口添加以下引用和代码：

using System.IO;
using System.Text;

public void Main()
{
    string currentSqlPath = Dts.Variables["User::FullSQLPath"].Value.ToString();
    // 读取当前SQL文件的文本内容，可根据文件实际编码修改Encoding参数
    Dts.Variables["User::SQLCommand"].Value = File.ReadAllText(currentSqlPath, Encoding.UTF8);
    Dts.TaskResult = (int)ScriptResults.Success;
}

• 保存脚本后关闭脚本编辑器。

2. 数据流任务（执行查询并导出CSV） #

先提前创建三个连接管理器：

• 数据库连接管理器：连接你要执行查询的目标数据库，用常规OLE DB连接即可
• SQLFileConn平面文件连接管理器：临时选择任意一个.sql文件作为模板即可，后续不需要加动态配置，仅用于初期元数据校验
• CSVTargetConn平面文件连接管理器：临时选择一个空CSV文件作为模板，给该连接管理器的ConnectionString属性添加表达式，值设置为@[User::TargetCSVPath]，实现每次循环自动切换输出文件

双击打开数据流任务，按以下逻辑配置：

• 拖入OLE DB源组件，连接选择你创建的数据库连接管理器，数据访问模式选择「来自变量的SQL命令」，变量选择@[User::SQLCommand]，点击「列」标签确认能正常读取查询结果的元数据。

  注意：所有15个.sql文件返回的列名、列数、数据类型必须完全一致，这是SSIS数据流的固定元数据要求，结构不一致会直接报错。

• 拖入平面文件目标组件，连接选择CSVTargetConn连接管理器，映射好输入列和目标CSV列即可。

常见问题处理 #

• 执行时报路径不存在错误：检查FolderPath变量末尾是否加了反斜杠，确认CSV输出的文件夹已经提前手动创建，SSIS不会自动生成不存在的文件夹
• 导出CSV中文乱码：打开CSVTargetConn连接管理器，将代码页修改为65001 (UTF-8)即可
• 元数据验证失败：如果15个SQL返回的列结构不统一，无法用同一个数据流实现批量导出，需要用C#脚本任务直接执行查询写文件，绕开SSIS内置的数据流元数据校验

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