SSIS技术求助：如何从目标数据库获取关联ID？

作为SSIS新手遇到这种跨库数据类型映射的问题很正常，我来给你分享几个可行的方案，你可以根据数据量和环境选择最适合的：

方法1：用缓存转换（Cache Transform）+ Lookup组件（适合大数据量） #

你之前用Lookup组件找不到目标连接管理器，大概率是没用到全缓存模式。跨不同数据库（SQL Server到Oracle）直接用Lookup的部分/无缓存模式可能会有驱动兼容性问题，试试全缓存+缓存转换的方式：

• 第一步：在数据流任务里新增一个辅助数据流分支，从Oracle的Roles表读取RoleID和RoleName两列，然后添加Cache Transform组件，把数据写入一个缓存连接管理器（大数据量可选磁盘缓存，小数据量用内存缓存即可）。
• 第二步：回到主数据流（读取SQL Server的Employee表），添加Lookup组件，选择Full Cache模式，指定刚才创建的缓存连接管理器，关联条件设为源Employee.RoleName = 缓存中的RoleName，最后把缓存里的RoleID映射到目标Employee的RoleID字段。

这种方式是把目标Roles表预加载到缓存里，Lookup时直接从缓存取数据，性能比逐行查询好很多，也能解决跨库连接的适配问题。

方法2：用OLE DB Command组件（适合小数据量） #

如果你的Employee表数据量不大（比如几万条以内），可以用OLE DB Command逐行查询目标Oracle的Roles表：

• 在读取源Employee表之后，添加OLE DB Command组件，连接到你的Oracle目标库。
• 在组件的SQL命令里写：SELECT RoleID FROM Roles WHERE RoleName = ?，然后把源的RoleName字段映射到这个参数（?）。
• 把查询返回的RoleID映射到目标Employee表的RoleID字段即可。

注意：这个方法是逐行执行SQL，数据量大的话性能会很差，所以只适合小数据集。

方法3：源端SQL预处理（如果能建立Linked Server） #

如果你的SQL Server能通过Linked Server连接到Oracle数据库，那可以直接在源查询里完成关联，把预处理好的数据拿到SSIS里：

• 先在SQL Server上配置好到Oracle的Linked Server，然后编写查询语句：

  SELECT 
      e.EmployeeID,
      e.EmployeeName,
      -- 其他需要迁移的字段
      r.RoleID AS TargetRoleID
  FROM SourceDB.dbo.Employee e
  INNER JOIN OPENQUERY(OracleLinkedServerName, 'SELECT RoleID, RoleName FROM Roles') r
      ON e.RoleName = r.RoleName
  

• 在SSIS的源组件里直接用这个查询，然后把TargetRoleID映射到目标Oracle的Employee.RoleID即可，不用在数据流里做关联处理。

方法4：用Script Component自定义逻辑（灵活度高） #

如果上面的方法都不适用，你可以用Script Component自己写代码来完成关联：

• 添加Script Component作为Transformation，选择输入列时勾选源Employee的RoleName，然后添加一个输出列TargetRoleID（数据类型设为Int32）。
• 在脚本编辑器里（比如用C#），先初始化Oracle连接（用ODP.NET驱动，记得引用对应的库），然后在ProcessInputRow方法里，根据当前行的RoleName查询Oracle的Roles表，把返回的RoleID赋值给TargetRoleID。

提示：为了提升性能，不要每次查询都新建连接，把连接对象放在PreExecute方法里初始化，用连接池来复用连接。

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