SSIS中基于Table A时间范围查询并聚合Table B数据的最优方案

方案一：数据库端直接关联计算（性能最优） #

既然已经用OLE DB Source取Table A的数据，直接把原来的查询换成关联Table B的SQL，让数据库完成筛选和聚合，这是效率最高的方式，不用在SSIS里折腾组件。

示例SQL代码：

SELECT
    A.Id,
    A.StartTime,
    A.EndTime,
    MIN(B.TargetColumn) AS MinValue,
    MAX(B.TargetColumn) AS MaxValue,
    AVG(B.TargetColumn) AS AvgValue
FROM
    TableA A
LEFT JOIN
    TableB B ON B.SourceTime BETWEEN A.StartTime AND A.EndTime
GROUP BY
    A.Id, A.StartTime, A.EndTime

• 用LEFT JOIN是为了保留Table A所有行，哪怕Table B里没匹配的数据（此时聚合值为NULL）；如果只需要有匹配的记录，换成INNER JOIN就行。
• 把这段SQL填到OLE DB Source的「SQL命令」里，后面直接接输出组件（比如OLE DB Destination）就搞定了。

方案二：SSIS组件分步处理（适合需中间调试的场景） #

如果必须在数据流里分步做，按以下步骤来：

1. 加第二个OLE DB Source：拉取Table B的数据，能提前过滤就先过滤（比如去掉早于Table A最小StartTime、晚于最大EndTime的行，减少后续处理量）。
2. 加Lookup组件：把Table A作为参照数据集，关联条件设为B.SourceTime >= A.StartTime AND B.SourceTime <= A.EndTime。注意：Lookup默认是等值匹配，要在高级选项里开自定义关联条件；数据量大的话别用Full Cache模式，换No Cache或Partial Cache避免内存爆掉。
3. 加Aggregate组件：把Lookup后的数据流接进来，分组选Table A的Id、StartTime、EndTime，对目标列分别设置Min、Max、Average这三个聚合操作。
4. 输出结果：把Aggregate的结果接到输出组件，完成写入。

• 提醒：如果Table A数据量很大，Lookup的Full Cache容易内存不足，这时候优先选方案一，或者改用Merge Join（但需要先给Table A按StartTime/EndTime排序、Table B按SourceTime排序，而且范围匹配的设置比SQL麻烦）。

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