_ _ _ Public Class ScriptMain Inherits UserComponent ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Overrides Sub CreateNewOutputRows() ' Load RSS. Dim conn As HttpClientConnection = New HttpClientConnection( _ Me.Connections.Http.AcquireConnection(Nothing)) Dim doc As XmlDocument = New XmlDocument() Using rssStream As Stream = New MemoryStream(conn.DownloadData()) Call doc.Load(rssStream) End Using ' Push items. Dim dateString As String Dim itemsList As XmlNodeList = doc.SelectNodes("rss/channel/item") For Each item As XmlElement In itemsList Call Me.OutputBuffer.AddRow() Me.OutputBuffer.title = GetText_(item("title")) Me.OutputBuffer.link = GetText_(item("link")) Me.OutputBuffer.description = GetText_(item("description")) Me.OutputBuffer.author = GetText_(item("author")) Me.OutputBuffer.comments = GetText_(item("comments")) Me.OutputBuffer.guid = GetText_(item("guid")) ' Set pubDate dateString = GetText_(item("pubDate")) If Not String.IsNullOrEmpty(dateString) Then Me.OutputBuffer.pubDate = Convert.ToDateTime(dateString) End If ' Set source. Dim sourceElem As XmlElement = item("source") If Not sourceElem Is Nothing Then Me.OutputBuffer.source = sourceElem.GetAttribute("url") End If 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 ApplicationException("Specify HTTP connection.") 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("Http").ConnectionManagerID = Me.Connection result = True Catch ex As Exception result = False errMessage = ex.Message End Try Validate = result End Function 'Validate #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 #End Region ' Properties #Region "Internals" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private ReadOnly Property HttpConnectionType() As String() Get HttpConnectionType = New String() {"HTTP"} End Get End Property ' HttpConnectionType ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Function GetText_(ByVal element As XmlElement) As String Dim result As String If Not element Is Nothing Then result = element.InnerText If result.Length > 4000 Then ' Maximum 4000 characters are supported in data flow. result = result.Substring(0, 4000) End If End If GetText_ = result End Function ' GetText_ #End Region ' Internals #Region "Attributes" Private m_connection As String #End Region ' Attributes End Class ' ScriptMain ]]> _ 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 [title]() As String Set Me(0) = Value End Set End Property Public WriteOnly Property [title_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 WriteOnly Property [link]() As String Set Me(1) = Value End Set End Property Public WriteOnly Property [link_IsNull] As Boolean Set If (value) SetNull(1) 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 WriteOnly Property [description]() As String Set Me(2) = Value End Set End Property Public WriteOnly Property [description_IsNull] As Boolean Set If (value) SetNull(2) 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 WriteOnly Property [author]() As String Set Me(3) = Value End Set End Property Public WriteOnly Property [author_IsNull] As Boolean Set If (value) SetNull(3) 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 WriteOnly Property [comments]() As String Set Me(4) = Value End Set End Property Public WriteOnly Property [comments_IsNull] As Boolean Set If (value) SetNull(4) 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 WriteOnly Property [guid]() As String Set Me(5) = Value End Set End Property Public WriteOnly Property [guid_IsNull] As Boolean Set If (value) SetNull(5) 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 WriteOnly Property [pubDate]() As DateTime Set Me(6) = Value End Set End Property Public WriteOnly Property [pubDate_IsNull] As Boolean Set If (value) SetNull(6) 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 WriteOnly Property [source]() As String Set Me(7) = Value End Set End Property Public WriteOnly Property [source_IsNull] As Boolean Set If (value) SetNull(7) 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() {"title", "link", "description", "author", "comments", "guid", "pubDate", "source"} 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 ]]> {30D016F9-3734-4E33-A861-5E7D899E18F3};{F184B08F-C81C-45F6-A57F-5ABD9991F28F} Debug AnyCPU 8.0.30703 2.0 {96089237-9A98-4F87-93E6-03F1C369F878} Library My Project ScriptComponent_d0fb2347c68b42f3a13264adbe57442e ScriptComponent_d0fb2347c68b42f3a13264adbe57442e 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 SSIS_SC120 ]]> _ 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 Http() As IDTSConnectionManager100 Get Return ParentComponent.ComponentMetaData.RuntimeConnectionCollection("Http").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_d0fb2347c68b42f3a13264adbe57442e ScriptComponent_d0fb2347c68b42f3a13264adbe57442e {3664C07E-C5CE-4D5F-AC2C-840A9AE4381B} ]]>CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus.2014, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34eaScriptComponent_d0fb2347c68b42f3a13264adbe57442eVisualBasic