SSIS - Как получить доступ к переменной RecordSet внутри задачи скрипта

Question

Как получить доступ к переменной RecordSet внутри задачи скрипта?

Answer 1

Ниже приведен код, который я использовал для загрузки данных в задаче сценария C # из набора записей или переменной набора результатов. «User ::actionalRepDBs» - это переменная SSIS объекта (System.Object), которая была загружена через «Полный набор результатов» из сценария задачи «Выполнение 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
}

Answer 2

На вкладке сценария убедитесь, что вы поместили переменную в текстовые поля readonlyvariables или readwritevariables.

Вот простой скрипт, который я использую для форматирования ошибок в потоке данных (сохраненных в переменной RecordSet) в тело письма. По сути, я считываю набор записей varialbe в таблицу данных и обрабатываю его построчно с помощью циклов for. После завершения этой задачи я проверяю значение uvErrorEmailNeeded, чтобы определить, есть ли что-нибудь, чтобы отправить электронное письмо, используя условный соединитель потока процесса. Вам также необходимо добавить ссылку на system.xml в вашем скрипте vb. Это в 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

Answer 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
 }

 ...
}