]]> _ _ _ 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 IDTSVariables90 = 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 ]]> ScriptComponent_85070ac308d8484bab05193d71cf69e6 true CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea