]]> _
_
_
Public Class ScriptMain
Inherits UserComponent
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub Input_ProcessInputRow(ByVal Row As InputBuffer)
Dim key As Object = Row.Buffer(m_keyIndex)
Dim keyArray As Byte() = TryCast(key, Byte())
If Not keyArray Is Nothing Then
' Key value is byte array. Transform to base64.
key = Convert.ToBase64String(keyArray)
End If
Try
Call m_dictionary.Add(key, Row.Buffer(m_valueIndex))
Catch ex As Exception
Call FireError_(ex.Message)
End Try
End Sub ' Input_ProcessInputRow
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PreExecute()
Call MyBase.PreExecute()
Dim input As IDTSInput90 = Me.ComponentMetaData.InputCollection(0)
' Find key column index.
m_keyIndex = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
input.InputColumnCollection(Me.KeyColumn).LineageID)
' Find value column index.
m_valueIndex = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
input.InputColumnCollection(Me.ValueColumn).LineageID)
If Me.IsResultCache Then
' Acquire distributed cache.
m_connection = CType( _
Me.ComponentMetaData.RuntimeConnectionCollection("Cache").ConnectionManager.AcquireConnection(Nothing), _
ICacheConnection)
m_dictionary = CType(m_connection.Connect(), IDictionary)
Else
' Setup dictionary object.
Dim vars As IDTSVariables90
Call Me.VariableDispenser.LockOneForWrite(Me.ResultVariable, vars)
Try
Try
m_dictionary = CType(vars(Me.ResultVariable).Value, IDictionary)
Catch ex As Exception
' Dictionary not yet initialized.
m_dictionary = New Hashtable()
vars(Me.ResultVariable).Value = m_dictionary
End Try
Finally
Call vars.Unlock()
End Try
End If
End Sub ' PreExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PostExecute()
Call MyBase.PostExecute()
m_keyIndex = -1
m_valueIndex = -1
m_dictionary = Nothing
If Not m_connection Is Nothing Then
Call m_connection.Close()
m_connection = Nothing
End If
End Sub ' PostExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Function Validate(ByRef errMessage As String) As Boolean
Dim result As Boolean = True
Try
If String.IsNullOrEmpty(Me.KeyColumn) Then
Throw New Exception("Select key column.")
ElseIf String.IsNullOrEmpty(Me.ValueColumn) Then
Throw New Exception("Select value column.")
ElseIf String.IsNullOrEmpty(m_result) Then
Throw New Exception("Select result.")
Else
Dim managedComponent As CManagedComponentWrapper = Me.ComponentMetaData.Instantiate()
Dim input As IDTSInput90 = Me.ComponentMetaData.InputCollection(0)
Dim virtInput As IDTSVirtualInput90 = input.GetVirtualInput()
Call input.InputColumnCollection.RemoveAll()
' Setup selected key column.
Dim keyColumn As IDTSInputColumn90 = managedComponent.SetUsageType( _
input.ID, _
virtInput, _
virtInput.VirtualInputColumnCollection(Me.KeyColumn).LineageID, _
DTSUsageType.UT_READONLY)
' Setup selected value column.
Dim valueColumn As IDTSInputColumn90 = managedComponent.SetUsageType( _
input.ID, _
virtInput, _
virtInput.VirtualInputColumnCollection(Me.ValueColumn).LineageID, _
DTSUsageType.UT_READONLY)
If Me.IsResultCache Then
Dim conn As IDTSRuntimeConnection90 = Me.ComponentMetaData.RuntimeConnectionCollection.[New]()
conn.Name = "Cache"
conn.ConnectionManagerID = Me.ResultCache
Else
Call Me.ComponentMetaData.RuntimeConnectionCollection.RemoveAll()
End If
End If
Catch ex As Exception
result = False
errMessage = ex.Message
End Try
Validate = result
End Function 'Validate
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
' Returns list of current properties based on current state.
Public Function GetProperties() As String()
Dim result As New ArrayList
' Base properties.
Call result.Add("KeyColumn")
Call result.Add("ValueColumn")
Call result.Add("IsResultCache")
Call result.Add(IIf(Me.IsResultCache, "ResultCache", "ResultVariable"))
Return CType(result.ToArray(GetType(String)), String())
End Function ' GetProperties
#Region "Properties"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
_
Public Property KeyColumn() As String
Get
KeyColumn = m_keyColumn
End Get
Set(ByVal value As String)
m_keyColumn = value
End Set
End Property ' KeyColumn
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
_
Public Property ValueColumn() As String
Get
ValueColumn = m_valueColumn
End Get
Set(ByVal value As String)
m_valueColumn = value
End Set
End Property ' ValueColumn
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
_
Public Property IsResultCache() As Boolean
Get
IsResultCache = m_isResultCache
End Get
Set(ByVal value As Boolean)
m_isResultCache = value
m_result = String.Empty
End Set
End Property ' IsResultCache
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
_
Public Property ResultVariable() As String
Get
ResultVariable = m_result
End Get
Set(ByVal value As String)
m_result = value
End Set
End Property ' ResultVariable
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
_
Public Property ResultCache() As String
Get
ResultCache = m_result
End Get
Set(ByVal value As String)
m_result = value
End Set
End Property ' ResultCache
#End Region ' Properties
#Region "Internals"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private ReadOnly Property CacheConnectionType() As String()
Get
CacheConnectionType = New String() {"CACHE+"}
End Get
End Property ' CacheConnectionType
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Sub FireError_(ByVal message As String)
Dim cancel As Boolean = False
Call MyBase.ComponentMetaData.FireError( _
0, _
"Dictionary Destination", _
message, _
String.Empty, _
0, _
cancel)
End Sub ' FireError_
#End Region ' Internals
#Region "Attributes"
Private m_keyColumn As String
Private m_valueColumn As String
Private m_isResultCache As Boolean
Private m_result As String
Private m_keyIndex As Integer
Private m_valueIndex As Integer
Private m_dictionary As IDictionary
Private m_connection As ICacheConnection
#End Region ' Attributes
End Class ' ScriptMain
]]>ScriptComponent_6c68f9432c9a4de8b29402396d88cf94trueCozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea