]]> _ _ _ Public Class ScriptMain Inherits UserComponent ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Overrides Sub CreateNewOutputRows() ' Get Salesforce object. Dim sobject As String = Me.SalesforceObject If Me.IsSalesforceObjectVariable Then sobject = GetVariable_(Me.SalesforceObjectVariable).ToString() End If ' Retrieve Salesforce object fields metadata. Dim dso As DescribeSObjectResult = Nothing Dim connection As ISforceConnection = CType( _ Me.Connections.Connection.AcquireConnection(Nothing), _ ISforceConnection) Try Dim service As SforceService = CType(connection.Connect(), SforceService) dso = service.describeSObject(sobject) Catch ex As Exception Call FireError_(ex.Message) Finally Call connection.Close() End Try If dso Is Nothing Then Exit Sub End If For Each field As Field In dso.fields With MyBase.OutputBuffer Call .AddRow() .autoNumber = field.autoNumber .byteLength = field.byteLength .calculated = field.calculated If Not String.IsNullOrEmpty(field.calculatedFormula) Then Call .calculatedFormula.AddBlobData(Encoding.Unicode.GetBytes(field.calculatedFormula)) End If If field.cascadeDeleteSpecified Then .cascadeDelete = field.cascadeDelete End If .caseSensitive = field.caseSensitive .controllerName = field.controllerName .createable = field.createable .custom = field.custom .defaultedOnCreate = field.defaultedOnCreate If Not String.IsNullOrEmpty(field.defaultValueFormula) Then Call .defaultValueFormula.AddBlobData(Encoding.Unicode.GetBytes(field.defaultValueFormula)) End If If field.dependentPicklistSpecified Then .dependentPicklist = field.dependentPicklist End If .deprecatedAndHidden = field.deprecatedAndHidden .digits = field.digits If field.displayLocationInDecimalSpecified Then .displayLocationInDecimal = field.displayLocationInDecimal End If If field.externalIdSpecified Then .externalId = field.externalId End If .filterable = field.filterable .groupable = field.groupable If field.htmlFormattedSpecified Then .htmlFormatted = field.htmlFormatted End If .idLookup = field.idLookup .inlineHelpText = field.inlineHelpText .label = field.label .length = field.length .name = field.name .nameField = field.nameField If field.namePointingSpecified Then .namePointing = field.namePointing End If .nillable = field.nillable .permissionable = field.permissionable Call .picklistValues.AddBlobData(Encoding.Unicode.GetBytes(GetPicklistValues_(field.picklistValues))) .precision = field.precision If Not field.referenceTo Is Nothing Then Call .referenceTo.AddBlobData(Encoding.Unicode.GetBytes(String.Join(";", field.referenceTo))) End If .relationshipName = field.relationshipName If field.relationshipOrderSpecified Then .relationshipOrder = field.relationshipOrder End If If field.restrictedDeleteSpecified Then .restrictedDelete = field.restrictedDelete End If .restrictedPicklist = field.restrictedPicklist .scale = field.scale .soapType = field.soapType.ToString() If field.sortableSpecified Then .sortable = field.sortable End If .type = field.type.ToString() .unique = field.unique .updateable = field.updateable If field.writeRequiresMasterReadSpecified Then .writeRequiresMasterRead = field.writeRequiresMasterRead End If End With Next 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 Exception("Select Salesforce Connection.") End If If String.IsNullOrEmpty(Me.SalesforceObject) Then Throw New Exception("Select Salesforce object.") 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") ' Setup dynamic. Call result.Add("IsSalesforceObjectVariable") Call result.Add(IIf( _ Me.IsSalesforceObjectVariable, _ "SalesforceObjectVariable", _ "SalesforceObject")) 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 Call result.Add(sobject.name) 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_connection End Get Set(ByVal value As String) m_connection = value End Set End Property ' Connection ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property IsSalesforceObjectVariable() As Boolean Get IsSalesforceObjectVariable = m_isObjectVar End Get Set(ByVal value As Boolean) If m_isObjectVar <> value Then m_isObjectVar = value m_object = String.Empty End If End Set End Property ' IsSalesforceObjectVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ 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 SalesforceObjectVariable() As String Get SalesforceObjectVariable = m_object End Get Set(ByVal value As String) m_object = value End Set End Property ' SalesforceObjectVariable #End Region ' Properties #Region "Internals" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private ReadOnly Property SforceConnectionType() As String() Get SforceConnectionType = New String() {"SFORCE"} End Get End Property ' SforceConnectionType ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Sub FireError_(ByVal message As String) Dim cancel As Boolean = False Call MyBase.ComponentMetaData.FireError( _ 0, _ "Salesforce Fields 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 GetPicklistValues_(ByVal picklist() As PicklistEntry) As String If picklist Is Nothing Then Return String.Empty End If Dim count As Integer = picklist.Length Dim result() As String = New String(count - 1) {} For index As Integer = 0 To count - 1 result(index) = picklist(index).value Next GetPicklistValues_ = String.Join(";", result) End Function ' GetPicklistValues_ #End Region ' Internals #Region "Attributes" Private m_connection As String Private m_isObjectVar As Boolean Private m_object As String #End Region ' Attributes End Class ' ScriptMain ]]> ScriptComponent_61c8db385ab54f948a3511404dee3f8e true CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea