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

如何在Script Task中访问RecordSet变量？

下面列出的是我用来从记录集或结果集变量中加载C#脚本任务中的数据表的代码."User :: transactionalRepDBs"是Object(System.Object)的SSIS变量,它是通过执行SQL任务脚本的"完整结果集"加载的.这个链接帮助了我.

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
}

在脚本选项卡上,确保将变量放在readonlyvariables或readwritevariables文本框中.

这是一个简单的脚本,用于将数据流中的错误(保存在RecordSet变量中)格式化为电子邮件正文.基本上我将记录集varialbe读入数据表并使用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