如何使用SSIS将查询结果集作为附件发送到电子邮件中？

Question

我有一个Execute SQL Task保存在System.Object变量上的查询的结果集,我想Send Mail Task使用MessageSource上的以下表达式发送此结果.

"请查找附件数据摘要\n \n"+ SUBSTRING(@ [User :: myVariable],1,3990)
+"\n \n"

Answer 1

可能你现在已经找到了问题的答案.这个答案适用于可能偶然发现这个问题的其他人.我不认为你可以在表达式中使用对象变量.您需要遍历查询结果对象并将其格式化为字符串,以便您可以在电子邮件中发送查询输出.您还可以将数据导出到文件并将文件作为附件发送.这是另一种可能的选择.此示例显示如何遍历查询结果集以形成将使用"发送电子邮件"任务通过电子邮件发送的邮件正文.

分步过程:

1. dbo.EmailData使用SQL Scripts部分下提供的脚本创建一个名为的表.

2. 屏幕截图#1显示了该示例中Execute SQL任务将在电子邮件中查询和发送的示例数据.

3. 在SSIS包上,创建5个变量,如屏幕截图#2所示.

4. 在SSIS包,请将以下任务:Execute SQL task,Foreach loop container,Script task在内部的foreach循环容器和Send Email task.

5. 配置Execute SQL task如屏幕截图#3和#4所示.

6. 配置Foreach loop container如屏幕截图#5和#6所示."变量映射"部分显示查询结果列的显示顺序以及如何将它们分配给SSIS变量.这些变量将用于在其中形成电子邮件消息Script task.

7. 在Script task,使用脚本任务代码部分下显示的代码替换代码.脚本任务具有非常简单的纯文本电子邮件格式.

8. 配置发送电子邮件任务,如屏幕截图#7所示.您需要在From和To字段中使用有效的电子邮件地址对其进行配置.

9. 配置控制流任务后,您的包应该如屏幕截图#8所示.

10. 示例包执行显示在屏幕截图#9中.

11. 包裹发送的电子邮件显示在屏幕截图#10中.某些信息已从屏幕截图中删除.您可以将屏幕截图#1中显示的表数据与此电子邮件输出进行比较,它们应该相同.

希望有所帮助.

SQL脚本: .

CREATE TABLE [dbo].[EmailData](
    [Id] [int] IDENTITY(1,1) NOT NULL,
    [ItemId] [varchar](255) NOT NULL,
    [ItemName] [varchar](255) NOT NULL,
    [ItemType] [varchar](255) NOT NULL,
    [IsProcessed] [bit] NULL,
 CONSTRAINT [PK_EmailData] PRIMARY KEY CLUSTERED ([Id] ASC)) ON [PRIMARY]
GO

脚本任务代码:

只能使用的C#代码SSIS 2008 and above..

/*Microsoft SQL Server Integration Services Script Task
   Write scripts using Microsoft Visual C# 2008.
   The ScriptMain is the entry point class of the script.
*/

using System;
using System.Data;
using Microsoft.SqlServer.Dts.Runtime;
using System.Windows.Forms;

namespace ST_7f59d09774914001b60a99a90809d5c5.csproj
{
    [System.AddIn.AddIn("ScriptMain", Version = "1.0", Publisher = "", Description = "")]
    public partial class ScriptMain : Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
    {

        #region VSTA generated code
        enum ScriptResults
        {
            Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success,
            Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
        };
        #endregion

        public void Main()
        {
            Variables varCollection = null;
            string header = string.Empty;
            string message = string.Empty;

            Dts.VariableDispenser.LockForWrite("User::EmailMessage");
            Dts.VariableDispenser.LockForWrite("User::ItemId");
            Dts.VariableDispenser.LockForWrite("User::ItemName");
            Dts.VariableDispenser.LockForWrite("User::ItemType");
            Dts.VariableDispenser.GetVariables(ref varCollection);

            //Set the header message for the query result
            if (varCollection["User::EmailMessage"].Value == string.Empty)
            {
                header = "Execute SQL task output sent using Send Email Task in SSIS:\n\n";
                header += string.Format("{0}\t{1}\t\t\t{2}\n", "Item number", "Item name", "Item type");
                varCollection["User::EmailMessage"].Value = header;
            }

            //Format the query result with tab delimiters
            message = string.Format("{0}\t{1}\t{2}",
                                        varCollection["User::ItemId"].Value,
                                        varCollection["User::ItemName"].Value,
                                        varCollection["User::ItemType"].Value);

            varCollection["User::EmailMessage"].Value = varCollection["User::EmailMessage"].Value + message;

            Dts.TaskResult = (int)ScriptResults.Success;
        }
    }
}

截图#1:

截图#2:

截图#3:

截图#4:

截图#5:

截图#6:

截图#7:

截图#8:

截图#9:

截图#10: