我有一个保存在System.Object变量上的执行sql任务查询的结果集,我想使用MessageSource上的以下表达式使用发送邮件任务发送此结果.
“Please find attached data summary\n\n” + SUBSTRING( @[User::myVariable],1,3990)
+ “\n\n”
解决方法
可能你现在已经找到了问题的答案.这个答案适用于可能偶然发现这个问题的其他人.我不认为你可以在表达式中使用对象变量.您需要遍历查询结果对象并将其格式化为字符串,以便您可以在电子邮件中发送查询输出.您还可以将数据导出到文件并将文件作为附件发送.这是另一种可能的选择.此示例显示如何遍历查询结果集以形成将使用“发送电子邮件”任务通过电子邮件发送的邮件正文.
分步过程:
>使用sql Scripts部分下提供的脚本创建名为dbo.EmailData的表.
>屏幕截图#1显示了执行sql任务将在此示例中查询并通过电子邮件发送的示例数据.
>在SSIS包上,创建5个变量,如屏幕截图#2所示.
>在SSIS包上,执行以下任务:执行sql任务,Foreach循环容器,Foreach循环容器中的脚本任务和发送电子邮件任务.
>配置执行sql任务,如屏幕截图#3和#4所示.
>配置Foreach循环容器,如屏幕截图#5和#6所示. “变量映射”部分显示查询结果列的显示顺序以及如何将它们分配给SSIS变量.这些变量将用于在脚本任务中形成电子邮件消息.
>在“脚本”任务中,将代码替换为“脚本任务代码”部分下显示的代码.脚本任务具有非常简单的纯文本电子邮件格式.
>配置发送电子邮件任务,如屏幕截图#7所示.您需要在From和To字段中使用有效的电子邮件地址对其进行配置.
>配置控制流任务后,您的包应该如屏幕截图#8所示.
>示例包执行显示在屏幕截图#9中.
>软件包发送的电子邮件显示在屏幕截图#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
脚本任务代码:
只能在SSIS 2008及更高版本中使用的C#代码.
.
/*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: