]]> _
Public Class ScriptMain
Inherits UserComponent
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub ProcessInput( _
ByVal InputID As Integer, _
ByVal Buffer As Microsoft.SqlServer.Dts.Pipeline.PipelineBuffer)
Dim colsCount As Integer = m_colsIndex.Length
While Buffer.NextRow()
Dim repeatCount As Integer = Convert.ToInt32(Buffer(m_repeatIndex))
For index As Integer = 0 To repeatCount - 1
MyBase.OutputBuffer.AddRow()
For colIndex As Integer = 0 To colsCount - 1
MyBase.OutputBuffer.Buffer(m_colsIndex(colIndex)) = Buffer(colIndex)
Next
Next
End While
If Buffer.EndOfRowset Then
Call MyBase.OutputBuffer.SetEndOfRowset()
End If
End Sub ' ProcessInput
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PreExecute()
Call MyBase.PreExecute()
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
' Find repeat column index.
m_repeatIndex = MyBase.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
input.InputColumnCollection(Me.RepeatColumn).LineageID)
' Find columns index from input to output.
Dim output As IDTSOutput90 = MyBase.ComponentMetaData.OutputCollection(0)
Dim colsCount As Integer = input.InputColumnCollection.Count
m_colsIndex = New Integer(colsCount - 1) {}
For colIndex As Integer = 0 To colsCount - 1
Dim inputCol As IDTSInputColumn90 = input.InputColumnCollection(colIndex)
' Get input column index.
Dim inputColIndex As Integer = MyBase.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
' Set output column index.
m_colsIndex(inputColIndex) = MyBase.HostComponent.BufferManager.FindColumnByLineageID( _
output.Buffer, _
output.OutputColumnCollection(inputCol.Name).LineageID)
Next
End Sub ' PreExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Function Validate(ByRef errMessage As String) As Boolean
Dim result As Boolean = True
Try
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
Dim virtInput As IDTSVirtualInput90 = input.GetVirtualInput()
If virtInput.VirtualInputColumnCollection.Count > 0 AndAlso _
String.IsNullOrEmpty(Me.RepeatColumn) Then
Throw New Exception("Select repeat column.")
End If
Catch ex As Exception
result = False
errMessage = ex.Message
End Try
Validate = result
End Function 'Validate
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
' Copy input columns to the asynchronous output.
Public Overrides Sub OnInputPathAttached(ByVal inputID As Integer)
Call MyBase.OnInputPathAttached(inputID)
Call MyBase.ComponentMetaData.InputCollection(0).InputColumnCollection.RemoveAll()
Call MyBase.ComponentMetaData.OutputCollection(0).OutputColumnCollection.RemoveAll()
Dim virtInput As IDTSVirtualInput90 = MyBase.ComponentMetaData.InputCollection.GetObjectByID(inputID).GetVirtualInput()
Dim outputCols As IDTSOutputColumnCollection90
outputCols = MyBase.ComponentMetaData.OutputCollection(0).OutputColumnCollection
Dim managedComponent As CManagedComponentWrapper = MyBase.ComponentMetaData.Instantiate()
Dim colsCount As Integer = virtInput.VirtualInputColumnCollection.Count
For colIndex As Integer = 0 To colsCount - 1
Dim inputCol As IDTSVirtualInputColumn90 = virtInput.VirtualInputColumnCollection(colIndex)
' Setup input column.
Call managedComponent.SetUsageType( _
inputID, _
virtInput, _
inputCol.LineageID, _
DTSUsageType.UT_READONLY)
' Add output column.
Dim outputCol As IDTSOutputColumn90 = outputCols.[New]()
outputCol.Name = inputCol.Name
With inputCol
Call outputCol.SetDataTypeProperties(.DataType, .Length, .Precision, .Scale, .CodePage)
End With
Next
End Sub ' OnInputPathAttached
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub OnInputPathDetached(ByVal inputID As Integer)
Call MyBase.OnInputPathDetached(inputID)
Call MyBase.ComponentMetaData.InputCollection(0).InputColumnCollection.RemoveAll()
Call MyBase.ComponentMetaData.OutputCollection(0).OutputColumnCollection.RemoveAll()
End Sub ' OnInputPathDetached
#Region "Properties"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
Public Property RepeatColumn() As String
Get
RepeatColumn = m_repeatColumn
End Get
Set(ByVal value As String)
m_repeatColumn = value
End Set
End Property ' RepeatColumn
#End Region ' Properties
#Region "Attributes"
Private m_repeatColumn As String
Private m_repeatIndex As Integer
Private m_colsIndex() As Integer
#End Region ' Attributes
End Class ' ScriptMain
]]>ScriptComponent_946f5164af91439fadfea81b2e4f1106trueCozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea