SSIS 2012 - 第二次脚本执行时变量为空
SSIS 2012 - Variable empty on second script execution
我在数据流中有一个脚本组件转换。
在此脚本组件中,我从对象变量中读取了 table。通过脚本的第一条记录工作正常。变量正确读取并完美加载到列表对象中。
下一条记录传入脚本时出错了。
查看它报告的记录数为 44 的变量,当它尝试加载到我的列表时,我得到一个行数 = 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);
}
我错过了什么吗?以前有人遇到过这个问题吗?
正在尝试找出问题所在
来自以下OleDbDataAdapter.Fill Method (DataTable, Object) documentation:
CAUTION
When using ADO Recordset or Record objects in conjunction with .NET Framework applications, always call Close when you are finished. This ensures that the underlying connection to a data source is released in a timely manner, and also prevents possible access violations due to unmanaged ADO objects being reclaimed by garbage collection when existing references still exist.
也参考Filling a DataSet with an ADO Recordset or Record - documentation:
Note that the OleDbDataAdapter.Fill overload that takes a DataSet and an ADO object implicitly calls Close on the ADO object when the Fill operation is complete. You need to explicitly close the ADO Recordset or Record object after calling the OleDbDataAdapter.Fill overload that takes a DataTable.
这意味着当通过 RecordSet 调用 Fill 方法时,您必须在第二次使用它之前关闭它,否则将不会返回任何行。
可能的解决方法
我真的不知道如何从 Object 变量关闭 Recordset,但我会尝试提供一些可能的解决方法:
(1) 保存到数据表
在下面的 link 中,他们提到了以下解决方法:
As soon as my Recordset @[User::FilePath]
gets populated, I use a Script Task , and Fill it into a DataSet ds using OledbDataAdapter and
DataTable.
Then, in the same script task, I put the value of ds to a new
variable of Object Type @[User::FilePathDataTable]
.
By doing this, the DataType of FilePathDataTable
becomes
System.Data.DataTable
.
This datatable can easily be used any number of times inside the
For-Each Loop.
I don't use DataAdapter.Fill()
method inside ForEach Loop of ssis
now. I just assign the Value of @[User::FilePathDataTable]
to a new
dataset, and use it for the iterations.
参考
(2) 使用记录集源
尝试使用 RecordSet Source 来代替使用脚本组件从对象变量生成行。
(3) 将变量转换为 Recordset
我没有测试过这种方法,我不确定它是否适用于对象变量
它需要对 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
根据下面的评论尝试从第一个脚本和第二个脚本中删除 rs.Close();
方法,然后在执行 Fill 方法之前使用 rs.MoverFirst()
方法以便能够从记录集中检索信息。
第三种方法删除基于以下link:
您应该使用 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
我在数据流中有一个脚本组件转换。 在此脚本组件中,我从对象变量中读取了 table。通过脚本的第一条记录工作正常。变量正确读取并完美加载到列表对象中。
下一条记录传入脚本时出错了。
查看它报告的记录数为 44 的变量,当它尝试加载到我的列表时,我得到一个行数 = 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);
}
我错过了什么吗?以前有人遇到过这个问题吗?
正在尝试找出问题所在
来自以下OleDbDataAdapter.Fill Method (DataTable, Object) documentation:
CAUTION
When using ADO Recordset or Record objects in conjunction with .NET Framework applications, always call Close when you are finished. This ensures that the underlying connection to a data source is released in a timely manner, and also prevents possible access violations due to unmanaged ADO objects being reclaimed by garbage collection when existing references still exist.
也参考Filling a DataSet with an ADO Recordset or Record - documentation:
Note that the OleDbDataAdapter.Fill overload that takes a DataSet and an ADO object implicitly calls Close on the ADO object when the Fill operation is complete. You need to explicitly close the ADO Recordset or Record object after calling the OleDbDataAdapter.Fill overload that takes a DataTable.
这意味着当通过 RecordSet 调用 Fill 方法时,您必须在第二次使用它之前关闭它,否则将不会返回任何行。
可能的解决方法
我真的不知道如何从 Object 变量关闭 Recordset,但我会尝试提供一些可能的解决方法:
(1) 保存到数据表
在下面的 link 中,他们提到了以下解决方法:
As soon as my Recordset
@[User::FilePath]
gets populated, I use a Script Task , and Fill it into a DataSet ds using OledbDataAdapter and DataTable.Then, in the same script task, I put the value of ds to a new variable of Object Type
@[User::FilePathDataTable]
.By doing this, the DataType of
FilePathDataTable
becomesSystem.Data.DataTable
.This datatable can easily be used any number of times inside the For-Each Loop.
I don't use
DataAdapter.Fill()
method inside ForEach Loop of ssis now. I just assign the Value of@[User::FilePathDataTable]
to a new dataset, and use it for the iterations.
参考
(2) 使用记录集源
尝试使用 RecordSet Source 来代替使用脚本组件从对象变量生成行。
(3) 将变量转换为 Recordset
我没有测试过这种方法,我不确定它是否适用于对象变量
它需要对 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
根据下面的评论尝试从第一个脚本和第二个脚本中删除 rs.Close();
方法,然后在执行 Fill 方法之前使用 rs.MoverFirst()
方法以便能够从记录集中检索信息。
第三种方法删除基于以下link:
您应该使用 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