SSIS - 如何在脚本任务中访问 RecordSet 变量答案

【问题标题】：SSIS - How to access a RecordSet variable inside a Script TaskSSIS - 如何在脚本任务中访问 RecordSet 变量
【发布时间】：2011-02-05 12:31:07
【问题描述】：

如何访问脚本任务中的 RecordSet 变量？

【问题讨论】：

标签： ssis etl script-task

【解决方案1】：

下面列出的是我用来从记录集或结果集变量加载 C# 脚本任务中的数据表的代码。 “User::transactionalRepDBs”是对象 (System.Object) 的 SSIS 变量，它是通过执行 SQL 任务脚本的“完整结果集”加载的。 This link assisted me.

using System.Data.OleDb;

DataTable dt= new DataTable();
OleDbDataAdapter adapter = new OleDbDataAdapter();
adapter.Fill(dt, Dts.Variables["User::transactionalRepDBs"].Value);

foreach (DataRow row in dt.Rows)
{
   //insert what you want to do here
}

【讨论】：

【解决方案2】：

在脚本选项卡上，确保将变量放入 readonlyvariables 或 readwritevariables 文本框中。

这是一个简单的脚本，我用它来将数据流中的错误（保存在 RecordSet 变量中）格式化为电子邮件正文。基本上，我将记录集变量读入数据表并使用 for 循环逐行处理它。此任务完成后，我检查 uvErrorEmailNeeded 的值以确定是否有任何内容要使用条件流程连接器通过电子邮件发送。您还需要在 vb 脚本中添加对 system.xml 的引用。这是在 SQL 2005 中。

Imports System
Imports System.Data
Imports System.Math
Imports Microsoft.SqlServer.Dts.Runtime
Imports System.Xml
Imports System.Data.OleDb


Public Class ScriptMain


    Public Sub Main()


        Dim oleDA As New OleDbDataAdapter
        Dim dt As New DataTable
        Dim col As DataColumn
        Dim row As DataRow
        Dim sMsg As String
        Dim sHeader As String


        oleDA.Fill(dt, Dts.Variables("uvErrorTable").Value)
        If dt.Rows.Count > 0 Then
            Dts.Variables("uvErrorEmailNeeded").Value = True
            For Each col In dt.Columns
                sHeader = sHeader & col.ColumnName & vbTab
            Next
            sHeader = sHeader & vbCrLf
            For Each row In dt.Rows
                For Each col In dt.Columns
                    sMsg = sMsg & row(col.Ordinal).ToString & vbTab
                Next
                sMsg = sMsg & vbCrLf
            Next
            Dts.Variables("uvMessageBody").Value = "Error task. Error list follows:" & vbCrLf & sHeader & sMsg & vbCrLf & vbCrLf
        End If

        Dts.TaskResult = Dts.Results.Success
    End Sub

End Class

【讨论】：

【解决方案3】：

我发现（使用 C#）的一种更简单的方法是将对象转换为字符串数组。这就是我的 C# 代码现在的样子：

public void Main()
{
 string[] arreglo = (string[])Dts.Variables["User::arreglo"].Value;

 ...

 foreach (string elemento in arreglo)
 {
  // do stuff on each element of the array/collection
 }

 ...
}

【讨论】：

我认为这行不通，除非您的变量恰好是 varchar 字段列表这样简单的东西。否则，这将引发异常，就像我的情况一样。