SSIS 2012 - 第二次执行脚本时变量为空

Question

我在数据流中有一个脚本组件转换。 在这个脚本组件中，我从一个对象变量中读取了一个表。通过脚本的第一条记录工作正常。变量正确读取并完美加载到列表对象中。

下一条记录传递到脚本中出现问题。

查看它报告的记录计数为 44 的变量，当它尝试加载到我的列表中时，我得到一个 rowcount = 0

下面是加载列表的脚本

    List<PublicHoliday> PublicHolidays = new List<PublicHoliday>();


    OleDbDataAdapter A = new OleDbDataAdapter();
    DataTable dt = new DataTable();
    A.Fill(dt, Variables.LISTPublicHolidays);

    foreach (DataRow row in dt.Rows)
    {
        object[] array = row.ItemArray;
        var Public = new PublicHoliday()
        {
            DateKey = int.Parse(array[0].ToString()),
            FullDateAlternateKey = DateTime.Parse(array[1].ToString())
        };
        PublicHolidays.Add(Public);
    }

我错过了什么吗？有没有人遇到过这个问题？

Answer 1

试图找出问题

来自以下OleDbDataAdapter.Fill Method (DataTable, Object) documentation：

注意
将 ADO Recordset 或 Record 对象与 .NET Framework 应用程序结合使用时，请务必在完成后调用 Close。这可以确保及时释放与数据源的底层连接，并且还可以防止由于在现有引用仍然存在时被垃圾回收回收非托管 ADO 对象而可能导致的访问冲突。

也指Filling a DataSet with an ADO Recordset or Record - documentation：

请注意，当 Fill 操作完成时，采用 DataSet 和 ADO 对象的 OleDbDataAdapter.Fill 重载会隐式调用 ADO 对象上的 Close。在调用采用 DataTable 的 OleDbDataAdapter.Fill 重载后，您需要显式关闭 ADO Recordset 或 Record 对象。

这意味着在 RecordSet 上调用 Fill 方法时，您必须在第二次使用它之前关闭它，否则不会返回任何行。

---

可能的解决方法

我真的不知道如何从 Object 变量中关闭 Recordset，但我会尝试提供一些可能的解决方法：

(1) 保存到数据表

在下面的链接中，他们提到了以下解决方法：

1. 一旦我的 Recordset @[User::FilePath] 被填充，我就使用 Script Task ，并使用 OledbDataAdapter 将其填充到 DataSet ds 中 数据表。

2. 然后，在同一个脚本任务中，我把 ds 的值放到一个新的 对象类型@[User::FilePathDataTable] 的变量。

通过这样做，FilePathDataTable 的 DataType 变为 System.Data.DataTable.

这个数据表可以很容易地在 For-Each 循环。

我不在 ssis 的 ForEach 循环中使用 DataAdapter.Fill() 方法 现在。我只是将@[User::FilePathDataTable] 的值分配给一个新的 数据集，并将其用于迭代。

参考

• Reading a Recordset multiple times gives 0 rows
• How to reuse a Recordset Object in SSIS

(2) 使用记录集源

尝试使用 RecordSet Source 来代替使用脚本组件从 Object 变量生成行。

(3) 将变量转换为记录集

我没有测试过这种方法，我不确定它是否适用于对象变量

它需要对 Microsoft ActiveX 数据对象的引用。

List<PublicHoliday> PublicHolidays = new List<PublicHoliday>();

var rs = ((ADODB.Recordset)Variables.LISTPublicHolidays);
OleDbDataAdapter A = new OleDbDataAdapter();
DataTable dt = new DataTable();
A.Fill(dt, rs);

foreach (DataRow row in dt.Rows)
{
    object[] array = row.ItemArray;
    var Public = new PublicHoliday()
    {
        DateKey = int.Parse(array[0].ToString()),
        FullDateAlternateKey = DateTime.Parse(array[1].ToString())
    };
    PublicHolidays.Add(Public);
}
rs.Close();

更新 1

基于下面的 cmets 尝试从第一个脚本中删除 rs.Close(); 方法，并在执行 Fill 方法之前在第二个脚本中使用 rs.MoverFirst() 方法以便能够从记录集中检索信息。

根据以下链接删除了第三种方法：

• MoveFirst, MoveLast, MoveNext, and MovePrevious Methods (ADO)

Answer 2

您应该使用 ADO NET 而不是 Ole Db 连接：

Dim dt As Data.DataTable
Dim ds As Data.DataSet = CType(Dts.Variables("Recordset").Value, DataSet)
dt = ds.Tables(0)

参考：https://www.sqlshack.com/execute-sql-tasks-in-ssis-output-parameters-vs-result-sets