_ _ _ _ _ Public Class ScriptMain Inherits UserComponent ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Overrides Sub CreateNewOutputRows() Dim startDate As DateTime = GetDate_(m_startDate, Me.IsStartDateVariable) Dim endDate As DateTime = GetDate_(m_endDate, Me.IsEndDateVariable) ' Get updated id list. Dim idList() As String = Nothing Dim connection As ISforceConnection = CType( _ MyBase.Connections.Connection.AcquireConnection(Nothing), _ ISforceConnection) Try Dim service As SforceService = CType(connection.Connect(), SforceService) idList = service.getUpdated(Me.SalesforceObject, startDate, endDate).ids Catch ex As Exception Call FireError_(ex.Message) Finally Call connection.Close() End Try If Not idList Is Nothing Then For Each id As String In idList With MyBase.OutputBuffer .AddRow() .Id = id End With Next End If Call MyBase.OutputBuffer.SetEndOfRowset() End Sub ' CreateNewOutputRows ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Function Validate(ByRef errMessage As String) As Boolean Dim result As Boolean Try If String.IsNullOrEmpty(Me.Connection) Then Throw New ApplicationException("Select Salesforce connection.") End If If String.IsNullOrEmpty(Me.SalesforceObject) Then Throw New ApplicationException("Select object.") End If If String.IsNullOrEmpty(m_startDate) Then Throw New ApplicationException("Specify start date.") End If If String.IsNullOrEmpty(m_endDate) Then Throw New ApplicationException("Specify end date.") 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("Connection").ConnectionManagerID = Me.Connection result = True 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 ' Setup static. Call result.Add("Connection") Call result.Add("SalesforceObject") ' Setup dynamic. Call result.Add("IsStartDateVariable") Call result.Add(IIf(Me.IsStartDateVariable, "StartDateVariable", "StartDate")) Call result.Add("IsEndDateVariable") Call result.Add(IIf(Me.IsEndDateVariable, "EndDateVariable", "EndDate")) Return CType(result.ToArray(GetType(String)), String()) End Function ' GetProperties ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' ' Returns list of objects in the currently selected Salesforce connection. Public Function GetObjectList() As String() Dim result As New ArrayList Dim connection As ISforceConnection = CType( _ Me.DesignConnections(Me.Connection).AcquireConnection(Nothing), _ ISforceConnection) Dim service As SforceService = CType(connection.Connect(), SforceService) Try Dim dgr As DescribeGlobalResult = service.describeGlobal() For Each sobject As DescribeGlobalSObjectResult In dgr.sobjects If sobject.queryable Then Call result.Add(sobject.name) End If Next Call result.Sort() Finally Call connection.Close() End Try GetObjectList = CType(result.ToArray(GetType(String)), String()) End Function ' GetObjectList #Region "Properties" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property Connection() As String Get Connection = m_sforceConnection End Get Set(ByVal value As String) m_sforceConnection = value End Set End Property ' Connection ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property SalesforceObject() As String Get SalesforceObject = m_object End Get Set(ByVal value As String) m_object = value End Set End Property ' SalesforceObject ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ _ Public Property IsStartDateVariable() As Boolean Get IsStartDateVariable = m_isStartDateVar End Get Set(ByVal value As Boolean) If m_isStartDateVar <> value Then m_isStartDateVar = value m_startDate = String.Empty End If End Set End Property ' IsStartDateVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ Public Property StartDate() As DateTime Get Dim result As DateTime If Not String.IsNullOrEmpty(m_startDate) Then result = Convert.ToDateTime(m_startDate) End If StartDate = result End Get Set(ByVal value As DateTime) m_startDate = value.ToString() End Set End Property ' StartDate ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property StartDateVariable() As String Get StartDateVariable = m_startDate End Get Set(ByVal value As String) m_startDate = value End Set End Property ' StartDateVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ _ Public Property IsEndDateVariable() As Boolean Get IsEndDateVariable = m_isEndDateVar End Get Set(ByVal value As Boolean) If m_isEndDateVar <> value Then m_isEndDateVar = value m_endDate = String.Empty End If End Set End Property ' IsEndDateVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ Public Property EndDate() As DateTime Get Dim result As DateTime If Not String.IsNullOrEmpty(m_endDate) Then result = Convert.ToDateTime(m_endDate) End If EndDate = result End Get Set(ByVal value As DateTime) m_endDate = value.ToString() End Set End Property ' EndDate ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property EndDateVariable() As String Get EndDateVariable = m_endDate End Get Set(ByVal value As String) m_endDate = value End Set End Property ' EndDateVariable #End Region ' Properties #Region "Internals" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private ReadOnly Property ConnectionType() As String() Get ConnectionType = New String() {"SFORCE"} End Get End Property ' ConnectionType ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Sub FireError_(ByVal message As String) Dim cancel As Boolean = False Call MyBase.ComponentMetaData.FireError( _ 0, _ "Salesforce Get Updated Source", _ message, _ String.Empty, _ 0, _ cancel) End Sub ' FireError_ ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Function GetVariable_(ByVal varName As String) As Object Dim result As Object Dim vars As IDTSVariables100 = Nothing Call Me.VariableDispenser.LockOneForRead(varName, vars) Try result = vars(varName).Value Finally Call vars.Unlock() End Try GetVariable_ = result End Function ' GetVariable_ ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Function GetDate_(ByVal dateStr As String, ByVal isVar As Boolean) As DateTime Dim result As DateTime If Not String.IsNullOrEmpty(dateStr) Then If isVar Then dateStr = GetVariable_(dateStr).ToString() End If result = Convert.ToDateTime(dateStr) End If GetDate_ = result End Function ' GetDate_ #End Region ' Internals #Region "Attributes" Private m_sforceConnection As String Private m_object As String Private m_isStartDateVar As Boolean Private m_startDate As String Private m_isEndDateVar As Boolean Private m_endDate As String #End Region ' Attributes End Class ' ScriptMain ]]> {30D016F9-3734-4E33-A861-5E7D899E18F3};{F184B08F-C81C-45F6-A57F-5ABD9991F28F} Debug AnyCPU 8.0.30703 2.0 {A6F3CEB9-8E59-4102-B28D-31921954690E} Library My Project ScriptComponent_85070ac308d8484bab05193d71cf69e6 ScriptComponent_85070ac308d8484bab05193d71cf69e6 v4.0 512 Binary On On true full false .\bin\Debug\ false true true prompt 4 false true .\bin\Release\ false false true prompt 4 False C:\Program Files (x86)\Microsoft SQL Server\120\SDK\Assemblies\CozyRoc.SSISPlus.2014.dll False False False False False SSIS_SC120 ]]> _ 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 [Id]() As String Set Me(0) = Value End Set End Property Public WriteOnly Property [Id_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 Overrides ReadOnly Property StaticOutputColumns() As String() Get Return New String() {"Id"} 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 ]]> _ Public Class UserComponent Inherits ScriptComponentPlus Public Connections As New Connections(Me) Public Variables As New Variables(Me) Public OutputBuffer As OutputBuffer 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() FinishOutputs() MarkOutputsFinished() End Sub Public Overridable Sub CreateNewOutputRows() End Sub End Class Public Class Connections Dim ParentComponent As ScriptComponent _ Public Sub New(ByVal Component As ScriptComponent) ParentComponent = Component End Sub Public ReadOnly Property Connection() As IDTSConnectionManager100 Get Return ParentComponent.ComponentMetaData.RuntimeConnectionCollection("Connection").ConnectionManager End Get End Property End Class Public Class Variables Dim ParentComponent As ScriptComponent _ Public Sub New(ByVal Component As ScriptComponent) ParentComponent = Component End Sub End Class ]]> msBuild ScriptComponent_85070ac308d8484bab05193d71cf69e6 ScriptComponent_85070ac308d8484bab05193d71cf69e6 {7F4F548F-877C-4D7E-A00D-54CA7B32A422} ]]>CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus.2014, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34eaScriptComponent_85070ac308d8484bab05193d71cf69e6VisualBasic