_ 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 End Class Public Class Variables Dim ParentComponent As ScriptComponent _ Public Sub New(ByVal Component As ScriptComponent) ParentComponent = Component End Sub End Class ]]> _ 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 WriteOnly Property [SentDate]() As DateTime Set Me(1) = Value End Set End Property Public WriteOnly Property [SentDate_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 [ReceivedDate]() As DateTime Set Me(2) = Value End Set End Property Public WriteOnly Property [ReceivedDate_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 [Size]() As Int64 Set Me(3) = Value End Set End Property Public WriteOnly Property [Size_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 [From]() As String Set Me(4) = Value End Set End Property Public WriteOnly Property [From_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 [To]() As String Set Me(5) = Value End Set End Property Public WriteOnly Property [To_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 [CC]() As String Set Me(6) = Value End Set End Property Public WriteOnly Property [CC_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 [ReplyTo]() As String Set Me(7) = Value End Set End Property Public WriteOnly Property [ReplyTo_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 WriteOnly Property [Subject]() As String Set Me(8) = Value End Set End Property Public WriteOnly Property [Subject_IsNull] As Boolean Set If (value) SetNull(8) 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 ReadOnly Property [BodyText]() As BlobColumn Get Return CType(Me(9), BlobColumn) End Get End Property Public ReadOnly Property [BodyText_IsNull] As Boolean Get Return IsNull(9) End Get End Property Public ReadOnly Property [BodyHtml]() As BlobColumn Get Return CType(Me(10), BlobColumn) End Get End Property Public ReadOnly Property [BodyHtml_IsNull] As Boolean Get Return IsNull(10) End Get End Property Public Overrides ReadOnly Property StaticOutputColumns() As String() Get Return New String() {"ID", "SentDate", "ReceivedDate", "Size", "From", "To", "CC", "ReplyTo", "Subject", "BodyText", "BodyHtml"} 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 ScriptMain Inherits UserComponent ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Overrides Sub CreateNewOutputRows() ' Get mails list. Dim mailsList() As Object Dim vars As IDTSVariables100 = Nothing Call Me.VariableDispenser.LockOneForRead(Me.MailsVariable, vars) Try mailsList = CType(vars(Me.MailsVariable).Value, Object()) Finally Call vars.Unlock() End Try Dim attachmentsFolder As String = GetAttachmentsFolder_() ' Populate output buffer. For Each mi As IMailInfo In mailsList Try With Me.OutputBuffer Call .AddRow() .ID = mi.ID Try .SentDate = mi.SentDate Catch ex As Exception ' Some mail doesn't include origination date. End Try .ReceivedDate = mi.ReceivedDate .Size = mi.Size .From = mi.From .To = mi.To .CC = mi.CC .ReplyTo = mi.ReplyTo .Subject = mi.Subject .BodyText.AddBlobData(Encoding.Unicode.GetBytes(mi.BodyText)) .BodyHtml.AddBlobData(Encoding.Unicode.GetBytes(mi.BodyHtml)) If Not String.IsNullOrEmpty(attachmentsFolder) AndAlso mi.HasAttachments Then ' Download mail attachments. Dim destFolder As String = Path.Combine(attachmentsFolder, mi.ID) If Not Directory.Exists(destFolder) Then Call Directory.CreateDirectory(destFolder) End If Call mi.GetAttachments(destFolder, True) End If End With Catch ex As Exception Call FireError_(String.Format("Failed to process mail info. {0}", ex.ToString())) End Try Next Call Me.OutputBuffer.SetEndOfRowset() End Sub ' CreateNewOutputRows ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Public Function Validate(ByRef errMessage As String) As Boolean Dim result As Boolean = True Try If String.IsNullOrEmpty(Me.MailsVariable) Then Throw New Exception("Select mails list variable.") End If 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 ' Base properties. Call result.Add("MailsVariable") Call result.Add("IsAttachmentsFolderVariable") Call result.Add(IIf(Me.IsAttachmentsFolderVariable, "AttachmentsFolderVariable", "AttachmentsFolder")) Return CType(result.ToArray(GetType(String)), String()) End Function ' GetProperties #Region "Properties" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property MailsVariable() As String Get MailsVariable = m_mailsVariable End Get Set(ByVal value As String) m_mailsVariable = value End Set End Property ' MailsVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property IsAttachmentsFolderVariable() As Boolean Get IsAttachmentsFolderVariable = m_isAttachmentsFolderVariable End Get Set(ByVal value As Boolean) If m_isAttachmentsFolderVariable <> value Then m_isAttachmentsFolderVariable = value m_attachmentsFolder = String.Empty End If End Set End Property ' IsAttachmentsFolderVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property AttachmentsFolderVariable() As String Get AttachmentsFolderVariable = m_attachmentsFolder End Get Set(ByVal value As String) m_attachmentsFolder = value End Set End Property ' AttachmentsFolderVariable ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' _ _ _ Public Property AttachmentsFolder() As String Get AttachmentsFolder = m_attachmentsFolder End Get Set(ByVal value As String) m_attachmentsFolder = value End Set End Property ' AttachmentsFolder #End Region ' Properties #Region "Internals" ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Sub FireError_(ByVal message As String) Dim cancel As Boolean = False Call MyBase.ComponentMetaData.FireError( _ 0, _ "Mail Info Source", _ message, _ String.Empty, _ 0, _ cancel) End Sub ' FireError_ ''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' Private Function GetAttachmentsFolder_() As String Dim result As String = String.Empty If Me.IsAttachmentsFolderVariable Then ' Get attachments folder from variable. If Not String.IsNullOrEmpty(Me.AttachmentsFolderVariable) Then Dim vars As IDTSVariables100 = Nothing Call MyBase.VariableDispenser.LockOneForRead(Me.AttachmentsFolderVariable, vars) Try result = vars(Me.AttachmentsFolderVariable).Value.ToString() Finally Call vars.Unlock() End Try End If Else result = Me.AttachmentsFolder End If GetAttachmentsFolder_ = result End Function ' GetAttachmentsFolder_ #End Region ' Internals #Region "Attributes" Private m_mailsVariable As String Private m_isAttachmentsFolderVariable As Boolean Private m_attachmentsFolder As String #End Region ' Attributes End Class ' ScriptMain ]]> msBuild ScriptComponent_ba22ece778b94eb9a89fc680016926b9 ScriptComponent_ba22ece778b94eb9a89fc680016926b9 {8D3D1B01-677C-4E1A-BBA0-C7B0C94D5D22} ]]> {30D016F9-3734-4E33-A861-5E7D899E18F3};{F184B08F-C81C-45F6-A57F-5ABD9991F28F} Debug AnyCPU 8.0.30703 2.0 {71842DCE-2A92-4E99-8340-87BAF404444F} Library My Project ScriptComponent_ba22ece778b94eb9a89fc680016926b9 ScriptComponent_ba22ece778b94eb9a89fc680016926b9 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 ]]>CozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus.2014, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34eaScriptComponent_ba22ece778b94eb9a89fc680016926b9VisualBasic