15

在执行我的包之前，我正在尝试首先检查是否有任何新记录要处理。我在 SQL Server 2008 R2 表中有一个名为“已处理”的位字段，如果已处理，则其值为 1，否则为 0。

我想这样查询它：

select count(processed) from dbo.AR_Sale where processed = 0

如果结果为 0，我想发送一封电子邮件，说明记录不存在。如果大于零，我想继续执行包。我是 SSIS 新手，似乎不知道要使用什么工具。

我的包有一个数据流项，其中包含与数据库的 OLE DB 连接。该连接使用查询来返回记录。不幸的是，即使没有要处理的记录，查询也会成功完成（应该如此）。这是查询：

Select * from dbo.AR_Sale where processed = 0

我将这些记录复制到数据仓库，然后运行另一个查询，通过将已处理的字段从 0 更改为 1 来更新源表。
任何帮助将不胜感激。

4

2 回答 2

66

一种选择是将优先约束与执行 SQL 任务结合使用来实现此功能。这是一个如何在SSIS 2008 R2.

我根据问题中提供的信息创建了一个简单的表格。

创建表脚本：

CREATE TABLE dbo.AR_Sale(
    Id int NOT NULL IDENTITY PRIMARY KEY,
    Item varchar(30) NOT NULL,
    Price numeric(10, 2) NOT NULL,
    Processed bit NOT NULL
) 
GO

然后用一些示例数据填充新表。您可以看到其中一行已将已处理标志设置为零。

填充表脚本：

INSERT INTO dbo.AR_Sale (Item, Price, Processed) VALUES
    ('Item 1', 23.84, 1),
    ('Item 2', 72.19, 0),
    ('Item 3', 45.73, 1);

在 SSIS 包上，创建以下两个变量。

  • Processed数据类型Int32
  • SQLFetchCount数据类型String的值设置为SELECT COUNT(Id) ProcessedCount FROM dbo.AR_Sale WHERE Processed = 0

变量

在 SSIS 项目上，创建一个指向您选择的数据库的 OLE DB 数据源。将数据源添加到包的连接管理器。在此示例中，我使用将数据源命名为Practice.

在包的Control Flow选项卡上，从工具箱中拖放执行 SQL 任务。

配置Execute SQL Task的General页面，如下图：

  • 给一个合适的名字，说Check pre-execution
  • 将ResultSet更改为，Single row因为查询返回标量值
  • 设置连接到 OLE DB 数据源，在本例中Practice
  • 将SQLSourceType设置为，Variable因为我们将使用存储在变量中的查询
  • 将SourceVariable设置为User::SQLFetchCount
  • 点击Result Set左侧页面

执行 SQL 任务 - 常规

配置Execute SQL Task的Result Set页面，如下图：

  • 单击添加按钮添加一个新变量，该变量将存储查询返回的计数值
  • 更改结果名称以0指示查询返回的第一列值
  • 将变量名称设置为User::Processed
  • 点击OK

执行 SQL 任务 - 结果集

在包的Control Flow选项卡上，从工具箱中拖放发送邮件任务和数据流任务。控制流选项卡应如下所示：

控制流选项卡

右键单击连接执行 SQL 任务和发送邮件任务的绿色箭头。单击 Edit... 绿色箭头称为 Precedence Constraint。

右键单击约束 1

在 Precedence Constraint Editor 上，执行以下步骤：

  • 将评估操作设置为Expression
  • 将表达式设置为@[User::Processed] == 0。这意味着仅当变量 Processed 设置为零时才采用此路径。
  • 点击确定

等于零

右键单击连接执行 SQL 任务和数据流任务的绿色箭头。单击 Edit... 在 Precedence Constraint Editor 上，执行以下步骤：

  • 将评估操作设置为Expression
  • 将表达式设置为@[User::Processed] != 0。这意味着仅当变量 Processed 未设置为零时才采用此路径。
  • 点击确定

不等于零

控制流选项卡看起来像这样。您可以根据需要配置发送邮件任务发送电子邮件和数据流任务更新数据。

控制流最终

当我根据填充表脚本使用数据集执行包时，包将执行数据流任务，因为有一行未处理。

数据流任务逻辑

当我使用脚本在表中的所有行上将 Processed 标志设置为 1 后执行包时UPDATE dbo.AR_Sale SET Processed = 1，包将执行发送邮件任务。

发送邮件任务逻辑

希望有帮助。

于 2012-10-18T17:42:41.420 回答
4

你的 SSIS 设计应该是

源：

Select count(processed) Cnt from dbo.AR_Sale where processed = 0

条件拆分阶段[在数据流转换下]：

output1: Order 1, Name - EmailCnt, Condition - Cnt = 0
output2: Order 2, Name - ProcessRows, Condition - Cnt > 0

输出链接：

EmailCnt Link: Send email

ProcessRowsLink: DataFlowTask
于 2012-10-18T15:48:14.770 回答