]]> _
Public Class ScriptMain
Inherits UserComponent
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub ProcessInput( _
ByVal InputID As Integer, _
ByVal Buffer As Microsoft.SqlServer.Dts.Pipeline.PipelineBuffer)
While Buffer.NextRow()
Dim splitValue() As String = New String() {}
If Not Buffer.IsNull(m_splitIndex) Then
splitValue = Buffer.GetString(m_splitIndex).Split(m_splitChars)
End If
Dim splitCount As Integer = splitValue.Length
For splitItem As Integer = 0 To splitCount - 1
Call MyBase.OutputBuffer.AddRow()
For Each pair As DictionaryEntry In m_colsIndex
Dim iIndex As Integer = CInt(pair.Key)
Dim oIndex As Integer = CInt(pair.Value)
If iIndex <> m_splitIndex Then
Dim value As Object = Buffer(iIndex)
If TypeOf value Is BlobColumn Then
value = Buffer.GetString(iIndex)
End If
If value Is Nothing Then
Call MyBase.OutputBuffer.Buffer.SetNull(oIndex)
Else
MyBase.OutputBuffer.Buffer(oIndex) = value
End If
Else
' Set current split value.
MyBase.OutputBuffer.Buffer(oIndex) = splitValue(splitItem)
End If
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)
Dim output As IDTSOutput90 = MyBase.ComponentMetaData.OutputCollection(0)
' Find split column index.
m_splitIndex = MyBase.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
input.InputColumnCollection(Me.SplitColumn).LineageID)
' Get split chars.
m_splitChars = Regex.Unescape(Me.SplitSymbol).ToCharArray()
' Find columns index from input to output.
Dim colsCount As Integer = input.InputColumnCollection.Count
m_colsIndex = New Hashtable()
For colIndex As Integer = 0 To colsCount - 1
Dim inColumn As IDTSInputColumn90 = input.InputColumnCollection(colIndex)
Dim inIndex As Integer = MyBase.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inColumn.LineageID)
Dim outIndex As Integer = MyBase.HostComponent.BufferManager.FindColumnByLineageID( _
output.Buffer, _
output.OutputColumnCollection(inColumn.Name).LineageID)
' Set input -> output column index.
m_colsIndex(inIndex) = outIndex
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.SplitColumn) Then
Throw New Exception("Select split column.")
ElseIf String.IsNullOrEmpty(Me.SplitSymbol) Then
Throw New Exception("Specify split symbol.")
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 SplitColumn() As String
Get
SplitColumn = m_splitColumn
End Get
Set(ByVal value As String)
m_splitColumn = value
End Set
End Property ' SplitColumn
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
Public Property SplitSymbol() As String
Get
SplitSymbol = m_splitSymbol
End Get
Set(ByVal value As String)
m_splitSymbol = value
End Set
End Property ' SplitSymbol
#End Region ' Properties
#Region "Internals"
#End Region ' Internals
#Region "Attributes"
Private m_splitColumn As String
Private m_splitSymbol As String
Private m_splitIndex As Integer
Private m_splitChars() As Char
Private m_colsIndex As Hashtable
#End Region ' Attributes
End Class ' ScriptMain
]]>ScriptComponent_946f5164af91439fadfea81b2e4f1106trueCozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea