_
_
_
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 IDTSInput100 = 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 IDTSOutput100 = 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 IDTSInputColumn100 = 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 IDTSInput100 = MyBase.ComponentMetaData.InputCollection(0)
Dim virtInput As IDTSVirtualInput100 = 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 IDTSVirtualInput100 = MyBase.ComponentMetaData.InputCollection.GetObjectByID(inputID).GetVirtualInput()
Dim outputCols As IDTSOutputColumnCollection100
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 IDTSVirtualInputColumn100 = virtInput.VirtualInputColumnCollection(colIndex)
' Setup input column.
Call managedComponent.SetUsageType( _
inputID, _
virtInput, _
inputCol.LineageID, _
DTSUsageType.UT_READONLY)
' Add output column.
Dim outputCol As IDTSOutputColumn100 = 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
]]> _
Public Class InputBuffer
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 Function NextRow() As Boolean
NextRow = MyBase.NextRow()
End Function
Public Overloads Function EndOfRowset() As Boolean
EndOfRowset = MyBase.EndOfRowset
End Function
End Class
_
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 WriteOnly Property [a]() As String
Set
Me(0) = Value
End Set
End Property
Public WriteOnly Property [a_IsNull] As Boolean
Set
If (value)
SetNull(0)
Else
Throw new InvalidOperationException("IsNull property cannot be set to False. Assign a value to the column instead.")
End If
End Set
End Property
Public WriteOnly Property [repeat]() As Int32
Set
Me(1) = Value
End Set
End Property
Public WriteOnly Property [repeat_IsNull] As Boolean
Set
If (value)
SetNull(1)
Else
Throw new InvalidOperationException("IsNull property cannot be set to False. Assign a value to the column instead.")
End If
End Set
End Property
Public WriteOnly Property [b]() As String
Set
Me(2) = Value
End Set
End Property
Public WriteOnly Property [b_IsNull] As Boolean
Set
If (value)
SetNull(2)
Else
Throw new InvalidOperationException("IsNull property cannot be set to False. Assign a value to the column instead.")
End If
End Set
End Property
Public Overrides ReadOnly Property StaticOutputColumns() As String()
Get
Return New String() {"a", "repeat", "b"}
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
]]>{30D016F9-3734-4E33-A861-5E7D899E18F3};{F184B08F-C81C-45F6-A57F-5ABD9991F28F}DebugAnyCPU8.0.307032.0{CA5F673A-D0AE-4EEC-A898-79E200F83A3A}LibraryMy ProjectScriptComponent_946f5164af91439fadfea81b2e4f1106ScriptComponent_946f5164af91439fadfea81b2e4f1106v4.0512truefullfalse.\bin\Debug\falsetruetrueprompt4falsetrue.\bin\Release\falsefalsetrueprompt4FalseC:\Program Files (x86)\Microsoft SQL Server\110\SDK\Assemblies\CozyRoc.SSISPlus.2012.dllSSIS_SC110BinaryOnOn]]> _
Public Class UserComponent
Inherits ScriptComponentPlus
Public Connections As New Connections(Me)
Public Variables As New Variables(Me)
Public OutputBuffer As OutputBuffer
Dim InputsFinished As Integer = 0
Public Overrides Sub ProcessInput(ByVal InputID As Integer, ByVal InputName As String, ByVal Buffer As PipelineBuffer, ByVal OutputMap As OutputNameMap)
If InputID = MyBase.ComponentMetaData.InputCollection("Input").ID Then
Input_ProcessInput(New InputBuffer(Me, InputID, True, Buffer, OutputMap))
End If
If Buffer.EndOfRowset Then
InputsFinished = InputsFinished + 1
If InputsFinished = 1 Then
FinishOutputs()
MarkOutputsFinished()
End If
End If
End Sub
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()
End Sub
Public Overridable Sub CreateNewOutputRows()
End Sub
Public Overridable Sub Input_ProcessInput(ByVal Buffer As InputBuffer)
While Buffer.NextRow()
Input_ProcessInputRow(Buffer)
End While
End Sub
Public Overridable Sub Input_ProcessInputRow(ByVal Row As InputBuffer)
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
]]>msBuildReference;Import;Folder{9EB24997-E5AE-4A56-BF38-EA8F0D80F5DE}ScriptComponent_946f5164af91439fadfea81b2e4f1106ScriptComponent_946f5164af91439fadfea81b2e4f1106]]>CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus.2012, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34eaScriptComponent_946f5164af91439fadfea81b2e4f1106VisualBasic