Как получить доступ к переменной RecordSet внутри задачи Script?
SSIS - Как получить доступ к переменной RecordSet внутри задачи Script
Ответ 1
На вкладке script убедитесь, что вы поместили эту переменную в текстовые поля readonlyvariables или readwritevariables.
Вот простой script, который я использую для форматирования ошибок в потоке данных (сохраненных в переменной RecordSet) в теле письма. В основном я читаю varialbe набора записей в datatable и обрабатываю его по строкам с помощью циклов for. По завершении этой задачи я проверю значение uvErrorEmailNeeded, чтобы определить, есть ли что-нибудь по электронной почте, используя условный соединитель потока процесса. Вам также нужно добавить ссылку на system.xml в свой vb script. Это в 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
Ответ 2
Ниже приведен код, который я использовал для загрузки datatable в задаче С# script из набора записей или результатов. "User:: transactionalRepDBs" - это переменная SSIS объекта Object (System.Object), которая была загружена через "Полный набор результатов" из задачи выполнения SQL script. Эта ссылка помогла мне.
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
}
Ответ 3
Более простой способ, который я нашел (используя С#), - это просто лить объект в виде массива строк. Вот как выглядит мой код на С#:
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
}
...
}