sql-server - SSIS - 如何使用结果集作为 SQL 任务的输入并获得正确的数据类型？

Question

我正在尝试将 Oracle 数据库表中的记录合并到我的本地 SQL 表中。

我有一个用于包的变量，它是一个对象，称为 OWell。

我有一个数据流任务，将Oracle数据作为SQL语句获取(select well_id, well_name from OWell order by Well_ID)，然后是一个转换任务，将well_id从长度为15的DT_STR转换为DT_WSTR；并将 well_name 从长度为 15 的 DT_STR 转换为长度为 50 的 DT_WSTR。然后将其存储在记录集 OWell 中。

转换的原因是我要向其添加记录的表具有标识字段:SSIS 将 well_id 显示为长度为 15 的 DT_WSTR，将 well_name 显示为长度为 50 的 DT_WSTR。

然后我有一个 SQL 任务连接到本地数据库并尝试添加尚不存在的记录。我尝试过各种方法:使用 OWell 作为结果集并在我的 SQL 语句中引用它。目前，我将 ResultSet 设置为 None，以及以下 SQL 语句:

Insert into WELL (WELL_ID, WELL_NAME)
Select OWELL_ID, OWELL_NAME
from OWell
where OWELL_ID not in 
   (select WELL.WELL_ID from WELL)

对于参数映射，我有参数 0，称为 OWell_ID，来 self 的变量 User::OWell。参数 1，名为 OWell_Name，来自同一个变量。两者都设置为 VARCHAR，尽管我也尝试过 NVARCHAR。我没有结果集。

我收到以下错误:错误:0xC002F210 在将记录插入 FLEDG，执行 SQL 任务:执行查询“插入 WELL(WELL_ID，WELL_NAME)选择 OWELL...”失败，出现以下错误:“将结果提取到 (DBTYPE_STR) 类型的变量时发生错误”。可能的失败原因:查询问题、“ResultSet”属性未正确设置、参数未设置正确，或未正确建立连接。

我认为这不是数据类型问题，而是我没有正确使用结果集。我应该如何在我的 SQL 任务中引用该记录集，以便我可以使用这两个记录集字段并添加丢失的记录？

Answer 1

您的问题是您试图将对象变量读入 sql 任务，并在 sql 任务中引用该变量。

要执行您想要执行的操作，您可以使用 foreach 循环任务。您可以将每个的枚举器设置为一个对象(记录集)变量，并将其列映射到变量，然后您可以将这些变量作为参数传递到您的 sql 任务中。上面示例中的 sql 代码还有另一个缺陷，即您试图引用包中的变量，就好像它是数据库中的表一样。您需要将 sql 更改为类似 Insert into well(?,?)

然而，这种方法省去了您可以在插入记录之前检查记录是否存在的步骤。更好的整体方法是在数据流中完成所有这些工作。

在您从 Oracle 数据流中选择时执行您正在执行的所有操作。在最后一步，不是使用指向变量 USER::OWell 的记录集目标，而是从本地 sql 表添加查找。将您的 sql 语句设置为 select WELL.WELL_ID from WELL。在查找中的列选项卡上，通过将 well_id 字段从左侧拖动到右侧以在框之间形成连接器，将数据流中的 Well_ID(左侧字段)与查找中的 Well_ID(右侧字段)匹配。在对话框的底部，单击配置错误输出并将查找输出行的错误列值设置为重定向行。选择确定以保存并关闭此查找。接下来，将 oledb 目标添加到数据流并将其连接到查找的错误输出(红色箭头)。将目标指向 sql 表，并将数据流中的列映射到输出表中的相应列。这会将 oracle 数据流中不存在于 sql 表中的行传递到 sql 表的批量插入中。