]]> _
_
Public Class ScriptMain
Inherits UserComponent
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub Input_ProcessInputRow(ByVal Row As InputBuffer)
Try
Dim targetEntity As String = Row.Buffer(m_teIndex).ToString().ToLower()
Dim targetId As Guid = New Guid(Row.Buffer(m_tiIndex).ToString())
Dim principalEntity As String = Row.Buffer(m_peIndex).ToString()
Dim principalId As Guid = New Guid(Row.Buffer(m_piIndex).ToString())
Dim ar As Integer = Convert.ToInt32(Row.Buffer(m_arIndex))
If Not m_service2011 Is Nothing Then
' CRM 2011
' Setup Target.
Dim target As New CRM2011.EntityReference
target.LogicalName = targetEntity
target.Id = targetId
' Setup Principal.
Dim principal As New CRM2011.EntityReference
principal.LogicalName = principalEntity.ToLower()
principal.Id = principalId
' Revoke previous access first.
Try
Dim raReq As New CRM2011.OrganizationRequest
raReq.RequestName = "RevokeAccess"
raReq("Target") = target
raReq("Revokee") = principal
Call m_service2011.Execute(raReq)
Catch ex As Exception
' Ignore the failure.
End Try
If ar <> 0 Then
' Grant new access.
Dim gaReq As New CRM2011.OrganizationRequest
gaReq.RequestName = "GrantAccess"
gaReq("Target") = target
Dim pa As New CRM2011.PrincipalAccess
pa.Principal = principal
pa.AccessMask = CType(ar, CRM2011.AccessRights)
gaReq("PrincipalAccess") = pa
Call m_service2011.Execute(gaReq)
End If
ElseIf Not m_service4 Is Nothing Then
' CRM 4.0
' Setup Target.
Dim target As New CRM4.TargetOwnedDynamic
target.EntityName = targetEntity
target.EntityId = targetId
' Setup Principal.
Dim principal As New CRM4.SecurityPrincipal()
principal.Type = CType( _
System.Enum.Parse(GetType(CRM4.SecurityPrincipalType), principalEntity), _
CRM4.SecurityPrincipalType)
principal.PrincipalId = principalId
' Revoke previous access first.
Try
Dim raReq As New CRM4.RevokeAccessRequest
raReq.Target = target
raReq.Revokee = principal
Call m_service4.Execute(raReq)
Catch ex As Exception
' Ignore the failure.
End Try
If ar <> 0 Then
' Grant new access.
Dim gaReq As New CRM4.GrantAccessRequest
gaReq.Target = target
Dim pa As New CRM4.PrincipalAccess
pa.Principal = principal
pa.AccessMask = CType(ar, CRM4.AccessRights)
gaReq.PrincipalAccess = pa
Call m_service4.Execute(gaReq)
End If
Else
' CRM 3.0
' Setup Target.
Dim target As New CRM3.TargetOwnedDynamic
target.EntityName = targetEntity
target.EntityId = targetId
' Setup Principal.
Dim principal As New CRM3.SecurityPrincipal()
principal.Type = CType( _
System.Enum.Parse(GetType(CRM3.SecurityPrincipalType), principalEntity), _
CRM3.SecurityPrincipalType)
principal.PrincipalId = principalId
' Revoke previous access first.
Try
Dim raReq As New CRM3.RevokeAccessRequest
raReq.Target = target
raReq.Revokee = principal
Call m_service3.Execute(raReq)
Catch ex As Exception
' Ignore the failure.
End Try
If ar <> 0 Then
Dim gaReq As New CRM3.GrantAccessRequest
gaReq.Target = target
' Grant new access.
Dim pa As New CRM3.PrincipalAccess
pa.Principal = principal
pa.AccessMask = CType(ar, CRM3.AccessRights)
gaReq.PrincipalAccess = pa
Call m_service3.Execute(gaReq)
End If
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) ' 0 - CRM Service
m_service2011 = TryCast(service, CRM2011.OrganizationServiceClient)
If m_service2011 Is Nothing Then
m_service4 = TryCast(service, CRM4.CrmService)
If m_service4 Is Nothing Then
m_service3 = TryCast(service, CRM3.CrmService)
If m_service3 Is Nothing Then
Throw New Exception("Unhandled service object.")
End If
End If
End If
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
For Each inputCol As IDTSInputColumn90 In input.InputColumnCollection
Dim extCol As IDTSExternalMetadataColumn90 = input.ExternalMetadataColumnCollection.GetObjectByID( _
inputCol.ExternalMetadataColumnID)
Dim index As Integer = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
Select Case extCol.Name
Case "TargetEntity"
m_teIndex = index
Case "TargetId"
m_tiIndex = index
Case "PrincipalEntity"
m_peIndex = index
Case "PrincipalId"
m_piIndex = index
Case "AccessRights"
m_arIndex = index
Case Else
Throw New Exception("Unhandled column.")
End Select
Next
End Sub ' PreExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PostExecute()
Call MyBase.PostExecute()
Call m_connection.Close()
m_teIndex = -1
m_tiIndex = -1
m_peIndex = -1
m_piIndex = -1
m_arIndex = -1
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 Exception("Select Dynamics CRM Connection.")
End If
Dim input As IDTSInput90 = Me.ComponentMetaData.InputCollection(0)
If input.IsAttached AndAlso input.InputColumnCollection.Count < 5 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 target entity column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "TargetEntity"
column.DataType = DataType.DT_WSTR
column.Length = 50
' Setup target id column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "TargetId"
column.DataType = DataType.DT_GUID
' Setup principal entity column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "PrincipalEntity"
column.DataType = DataType.DT_WSTR
column.Length = 50
' Setup principal id column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "PrincipalId"
column.DataType = DataType.DT_GUID
' Setup access rights column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "AccessRights"
column.DataType = DataType.DT_I4
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
#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 Grant Access", _
message, _
String.Empty, _
0, _
cancel)
End Sub ' FireError_
#End Region ' Internals
#Region "Attributes"
Private m_crmConnection As String
Private m_connection As ICrmConnection
Private m_service2011 As CRM2011.OrganizationServiceClient
Private m_service4 As CRM4.CrmService
Private m_service3 As CRM3.CrmService
Private m_teIndex As Integer
Private m_tiIndex As Integer
Private m_peIndex As Integer
Private m_piIndex As Integer
Private m_arIndex As Integer
#End Region ' Attributes
End Class ' ScriptMain
]]>ScriptComponent_a52b8cc7033d4f6c9c5ddd4a3a832e3dtrueCozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea