_ _ _ _ Public Class ScriptMain Inherits UserComponent ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Overrides Sub CreateNewOutputRows() Dim colsIdx As Hashtable = GetColumnsIdx_() ' Get rows. Dim rows() As String = GetRows_() Dim rowsCount As Integer = rows.Length ' Get column names. Dim columns() As String = GetColumns_(rows(0)) Dim colsCount As Integer = columns.Length For rowIndex As Integer = 1 To rowsCount - 1 ' First row is column names. Call Me.OutputBuffer.AddRow() Dim data() As String = GetColumns_(rows(rowIndex)) For colIndex As Integer = 0 To colsCount - 1 If colIndex >= data.Length Then ' This line ends earlier Exit For End If Dim value As String = data(colIndex) Dim bufIndex As Integer = CInt(colsIdx(columns(colIndex))) If String.IsNullOrEmpty(value) Then Call Me.OutputBuffer.Buffer.SetNull(bufIndex) Else Me.OutputBuffer.Buffer(bufIndex) = value End If Next Next Call Me.OutputBuffer.SetEndOfRowset() End Sub ' CreateNewOutputRows ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Function Validate(ByRef errMessage As String) As Boolean Dim result As Boolean = True Try If String.IsNullOrEmpty(Me.Data) Then Throw New Exception("Specify data.") End If If String.IsNullOrEmpty(Me.ColumnDelimiter) Then Throw New Exception("Specify column delimiter.") End If Dim output As IDTSOutput100 = MyBase.ComponentMetaData.OutputCollection(0) If output.OutputColumnCollection.Count = 0 Then ' Setup collection output columns. Call SetupOutputColumns_() End If Catch ex As Exception result = False errMessage = ex.Message End Try Validate = result End Function ' Validate #Region "Properties" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ Public Property Data() As String Get Data = m_data End Get Set(ByVal value As String) If m_data <> value Then If Not String.IsNullOrEmpty(m_data) Then ' Force output columns to be setup. If Me.ComponentMetaData.OutputCollection.Count > 0 Then Dim output As IDTSOutput100 = Me.ComponentMetaData.OutputCollection(0) Call output.OutputColumnCollection.RemoveAll() End If End If m_data = value End If End Set End Property ' Data ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ Public Property ColumnDelimiter() As String Get ColumnDelimiter = m_colDelimiter End Get Set(ByVal value As String) m_colDelimiter = value End Set End Property ' ColumnDelimiter #End Region ' Properties #Region "Internals" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Sub SetupOutputColumns_() ' First line in test data defines column names. Dim columns() As String = GetColumns_(GetRows_()(0)) Dim output As IDTSOutput100 = MyBase.ComponentMetaData.OutputCollection(0) Call output.OutputColumnCollection.RemoveAll() For Each column As String In columns Dim outColumn As IDTSOutputColumn100 = output.OutputColumnCollection.[New]() outColumn.Name = column.Trim() Call outColumn.SetDataTypeProperties(DataType.DT_WSTR, 250, 0, 0, 0) Next End Sub ' SetupOutputColumns_ ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' ' Setup column name -> buffer index map. Private Function GetColumnsIdx_() As Hashtable Dim result As Hashtable = New Hashtable Dim output As IDTSOutput100 = Me.ComponentMetaData.OutputCollection(0) Dim colsCount As Integer = output.OutputColumnCollection.Count For colIndex As Integer = 0 To colsCount - 1 Dim column As IDTSOutputColumn100 = output.OutputColumnCollection(colIndex) ' Setup buffer index. Call result.Add( _ column.Name, _ Me.HostComponent.BufferManager.FindColumnByLineageID( _ output.Buffer, _ column.LineageID)) Next GetColumnsIdx_ = result End Function ' GetColumnsIdx_ ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Function GetRows_() As String() GetRows_ = Me.Data.Split(New String() {vbLf}, StringSplitOptions.RemoveEmptyEntries) End Function ' GetRows_ ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Function GetColumns_(ByVal row As String) As String() GetColumns_ = row.Split(New String() {Me.ColumnDelimiter}, StringSplitOptions.None) End Function ' GetColumns_ #End Region ' Internals #Region "Attributes" Private m_data As String Private m_colDelimiter As String #End Region ' Attributes End Class ' ScriptMain ]]> {30D016F9-3734-4E33-A861-5E7D899E18F3};{F184B08F-C81C-45F6-A57F-5ABD9991F28F} Debug AnyCPU 8.0.30703 2.0 {BD7FE0D2-99E1-4174-B46C-C2EFEAE1ACA8} Library My Project ScriptComponent_221f90294f004536ba9a4d9fdf0d984d ScriptComponent_221f90294f004536ba9a4d9fdf0d984d v4.0 512 Binary On On true full false .\bin\Debug\ false true true prompt 4 false true .\bin\Release\ false false true prompt 4 False C:\Program Files (x86)\Microsoft SQL Server\120\SDK\Assemblies\CozyRoc.SSISPlus.2014.dll False False False SSIS_SC120 ]]> _ Public Class OutputBuffer Inherits ScriptBufferPlus Public Sub New(ByVal Component As ScriptComponent, ByVal ObjectID As Integer, ByVal IsInput As Boolean, ByVal Buffer As PipelineBuffer, ByVal OutputMap As OutputNameMap) MyBase.New(Component, ObjectID, IsInput, Buffer, OutputMap) End Sub Public Overrides ReadOnly Property StaticInputColumns() As String() Get Return New String() {} End Get End Property Public Overrides ReadOnly Property StaticOutputColumns() As String() Get Return New String() {} End Get End Property Public Overloads Sub AddRow() MyBase.AddRow() End Sub Public Overloads Sub SetEndOfRowset() MyBase.SetEndOfRowset() End Sub Public Overloads Function EndOfRowset() As Boolean EndOfRowset = MyBase.EndOfRowset End Function End Class ]]> _ Public Class UserComponent Inherits ScriptComponentPlus Public Connections As New Connections(Me) Public Variables As New Variables(Me) Public OutputBuffer As OutputBuffer Public Overridable Sub FinishOutputs() End Sub Private Sub MarkOutputsFinished() If OutputBuffer IsNot Nothing Then OutputBuffer.SetEndOfRowset OutputBuffer = Nothing End If End Sub Public Overrides Sub PrimeOutput(ByVal Outputs As Integer, ByVal OutputIDs() As Integer, ByVal Buffers() As PipelineBuffer, ByVal OutputMap As OutputNameMap) For I As Integer = 0 To Outputs - 1 If OutputIDs(I) = GetOutputID(OutputMap, "Output") Then OutputBuffer = New OutputBuffer(Me, OutputIDs(I), False, Buffers(I), OutputMap) End If Next CreateNewOutputRows() FinishOutputs() MarkOutputsFinished() End Sub Public Overridable Sub CreateNewOutputRows() End Sub End Class Public Class Connections Dim ParentComponent As ScriptComponent _ Public Sub New(ByVal Component As ScriptComponent) ParentComponent = Component End Sub End Class Public Class Variables Dim ParentComponent As ScriptComponent _ Public Sub New(ByVal Component As ScriptComponent) ParentComponent = Component End Sub End Class ]]> msBuild ScriptComponent_221f90294f004536ba9a4d9fdf0d984d ScriptComponent_221f90294f004536ba9a4d9fdf0d984d {54C365F0-6BA0-4F62-8BDC-771815F43514} ]]>CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus.2014, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34eaScriptComponent_221f90294f004536ba9a4d9fdf0d984dVisualBasic