]]> _
_
_
Public Class ScriptMain
Inherits UserComponent
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub Input_ProcessInputRow(ByVal Row As InputBuffer)
Try
If Not m_service2011 Is Nothing Then
' CRM 2011
Dim req As New CRM2011.OrganizationRequest
req.RequestName = m_requestName
' Setup relationship parameters.
Dim entity1 As New CRM2011.EntityReference
entity1.LogicalName = CStr(Row.Buffer(m_fenIndex))
entity1.Id = New Guid(Row.Buffer(m_feiIndex).ToString())
Dim entity2 As New CRM2011.EntityReference
entity2.LogicalName = CStr(Row.Buffer(m_senIndex))
entity2.Id = New Guid(Row.Buffer(m_seiIndex).ToString())
req("Target") = New CRM2011.EntityReference() {entity1, entity2}
' Execute action.
Call m_service2011.Execute(req)
Else
' CRM 4.0
' Setup relationship parameters.
Dim target As New CRM4.TargetRelatedDynamic
target.Entity1Name = CStr(Row.Buffer(m_fenIndex))
target.Entity1Id = New Guid(Row.Buffer(m_feiIndex).ToString())
target.Entity2Name = CStr(Row.Buffer(m_senIndex))
target.Entity2Id = New Guid(Row.Buffer(m_seiIndex).ToString())
' Execute action.
Select Case Me.Action
Case ActionTypes.SetRelated
Dim addReq As New CRM4.SetRelatedRequest()
addReq.Target = target
Call m_service4.Execute(addReq)
Case ActionTypes.RemoveRelated
Dim removeReq As New CRM4.RemoveRelatedRequest()
removeReq.Target = target
Call m_service4.Execute(removeReq)
Case Else
Throw New ApplicationException("Unhandled action type.")
End Select
End If
Catch ex As SoapException
Call FireError_(ex.Detail.InnerXml)
Catch ex As Exception
Call FireError_(ex.Message)
End Try
End Sub ' Input_ProcessInputRow
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PreExecute()
Call MyBase.PreExecute()
' Setup CRM service.
m_connection = CType( _
Me.Connections.CrmConnection.AcquireConnection(Nothing), _
ICrmConnection)
Call m_connection.Connect()
Dim service As Object = m_connection.GetService(0)
m_service2011 = TryCast(service, CRM2011.OrganizationServiceClient)
If m_service2011 Is Nothing Then
m_service4 = TryCast(m_connection.GetService(0), CRM4.CrmService) ' 0 - CRM Service
If m_service4 Is Nothing Then
Throw New Exception("Unhandled service object.")
End If
End If
' Setup request name for CRM 2011.
Select Case Me.Action
Case ActionTypes.SetRelated
m_requestName = "SetRelated"
Case ActionTypes.RemoveRelated
m_requestName = "RemoveRelated"
Case Else
Throw New ApplicationException("Unhandled action type.")
End Select
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
Dim inputCol As IDTSInputColumn90
' Get input column indexes.
inputCol = GetInputColumn_("FirstEntityName")
m_fenIndex = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
inputCol = GetInputColumn_("FirstEntityId")
m_feiIndex = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
inputCol = GetInputColumn_("SecondEntityName")
m_senIndex = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
inputCol = GetInputColumn_("SecondEntityId")
m_seiIndex = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
End Sub ' PreExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PostExecute()
Call MyBase.PostExecute()
Call m_connection.Close()
End Sub ' PostExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Function Validate(ByRef errMessage As String) As Boolean
Dim result As Boolean
Try
If String.IsNullOrEmpty(Me.CrmConnection) Then
Throw New ApplicationException("Select Dynamics CRM connection.")
End If
Dim input As IDTSInput90 = Me.ComponentMetaData.InputCollection(0)
If input.IsAttached AndAlso _
(input.InputColumnCollection.Count = 0 OrElse _
input.InputColumnCollection.Count < 4) Then
Throw New Exception("Map input columns.")
End If
' Store connection information in the runtime connection collection, too.
' Cannot directly use RuntimeConnectionCollection in the property get/set
' because of issues with multi-threading.
Me.ComponentMetaData.RuntimeConnectionCollection("CrmConnection").ConnectionManagerID = Me.CrmConnection
result = True
Catch ex As Exception
result = False
errMessage = ex.Message
End Try
Validate = result
End Function 'Validate
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub ReinitializeMetaData()
Call MyBase.ReinitializeMetaData()
If MyBase.ComponentMetaData.InputCollection.Count = 0 Then
' At least one input must exist.
Throw New Exception("No inputs.")
End If
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
' Cleanup.
input.ExternalMetadataColumnCollection.IsUsed = True
Call input.InputColumnCollection.RemoveAll()
Call input.ExternalMetadataColumnCollection.RemoveAll()
Dim column As IDTSExternalMetadataColumn90
' Setup first entity.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "FirstEntityName"
column.DataType = DataType.DT_WSTR
column.Length = 100
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "FirstEntityId"
column.DataType = DataType.DT_GUID
' Setup second entity.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "SecondEntityName"
column.DataType = DataType.DT_WSTR
column.Length = 100
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "SecondEntityId"
column.DataType = DataType.DT_GUID
End Sub ' ReinitializeMetaData
#Region "Properties"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
_
Public Property CrmConnection() As String
Get
CrmConnection = m_crmConnection
End Get
Set(ByVal value As String)
m_crmConnection = value
End Set
End Property ' CrmConnection
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
Public Property Action() As ActionTypes
Get
Action = m_action
End Get
Set(ByVal value As ActionTypes)
m_action = value
End Set
End Property ' Action
#End Region ' Properties
#Region "Internals"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private ReadOnly Property CrmConnectionType() As String()
Get
CrmConnectionType = New String() {"DYNAMICS-CRM"}
End Get
End Property ' CrmConnectionType
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Sub FireError_(ByVal message As String)
Dim cancel As Boolean = False
Call MyBase.ComponentMetaData.FireError( _
0, _
"Dynamics CRM Relationships", _
message, _
String.Empty, _
0, _
cancel)
End Sub ' FireError_
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Function GetInputColumn_(ByVal externalName As String) As IDTSInputColumn90
Dim result As IDTSInputColumn90
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
Dim extColumn As IDTSExternalMetadataColumn90 = input.ExternalMetadataColumnCollection(externalName)
' Find input column for specified external column.
For Each inputCol As IDTSInputColumn90 In input.InputColumnCollection
If inputCol.ExternalMetadataColumnID = extColumn.ID Then
' Found input column.
result = inputCol
Exit For
End If
Next
If result Is Nothing Then
Throw New Exception("Input column not found.")
End If
GetInputColumn_ = result
End Function ' GetInputColumn_
#End Region ' Internals
#Region "Attributes"
Enum ActionTypes
SetRelated
RemoveRelated
End Enum ' ActionTypes
Private m_crmConnection As String
Private m_action As ActionTypes
Private m_connection As ICrmConnection
Private m_service2011 As CRM2011.OrganizationServiceClient
Private m_service4 As CRM4.CrmService
Private m_requestName As String
Private m_fenIndex As Integer
Private m_feiIndex As Integer
Private m_senIndex As Integer
Private m_seiIndex As Integer
#End Region ' Attributes
End Class ' ScriptMain
]]>ScriptComponent_94a431126e834e959139035d1a744e5ctrueCozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea