指定变更数据的间隔

项目
05/23/2023

适用于：SQL Server Azure 数据工厂中的 SSIS Integration Runtime

在用于执行变更数据增量加载的 Integration Services 包的控制流中，第一个任务是计算变更数据的端点。这些端点是 datetime 值，将存储在包变量中以供以后在包中使用。

注意

有关设计控制流的总体过程的说明，请参阅变更数据捕获 (SSIS)。

为端点设置包变量

在配置执行 SQL 任务以计算端点之前，必须先定义用于存储端点的包变量。

设置包变量

在 SQL Server Data Tools (SSDT)中，打开新的 Integration Services 项目。
在 “变量” 窗口中创建以下变量：
1. 创建一个数据类型为 datetime 的变量以保存间隔的起始点。
  
  以下示例使用变量名 ExtractStartTime。
2. 再创建一个数据类型为 datetime 的变量以保存间隔的结束点。
  
  以下示例使用变量名 ExtractEndTime。

如果在执行多个子包的主包中计算端点，则可使用父包变量配置将这些变量的值传递给各个子包。有关详细信息，请参阅执行包任务和在子包中使用变量和参数的值。

计算变更数据的起始点和结束点

为间隔端点设置包变量之后，即可计算这些端点的实际值并将这些值映射到相应的包变量中。因为这些端点为 datetime 值，所以您必须使用可以计算或处理 datetime 值的函数。 Integration Services 表达式语言和 Transact-SQL 都具有可处理 datetime 值的函数：

Integration Services 表达式语言中可处理 datetime 值的函数

Transact-SQL 中可处理 datetime 值的函数
日期和时间数据类型及函数 (Transact-SQL)。

在使用上述任一 datetime 函数来计算端点之前，必须先确定间隔是否固定并且定期发生。通常，您会希望定期将在源表中发生的变更应用到目标表中。例如，您可能希望每小时、每天或每周应用这些变更。

在了解变更间隔是固定的还是随机的之后，即可计算端点：

计算起始日期和时间。将上一次加载的结束日期和时间作为当前的起始日期和时间。如果对增量加载使用固定间隔，则可使用 Transact-SQL 或 表达式语言的 datetime Integration Services 函数来计算此值。否则，您可能需要保持两个执行之间的端点，并使用执行 SQL 任务或脚本任务来加载上一个端点。
计算结束日期和时间。如果对增量加载使用固定间隔，则可将当前的结束日期和时间作为起始日期和时间的偏移量来计算。同样，可以使用 Transact-SQL 或 表达式语言的 datetime Integration Services 函数来计算此值。

在下面的过程中，变更间隔使用固定间隔，并假定无例外的情况下增量加载包每天运行。否则，缺失间隔的变更数据会丢失。此间隔的起始点是前天午夜，即 24 小时和 48 小时之前。此间隔的结束点是昨天午夜，即，昨天晚上，0 和 24 小时之前。

计算捕获间隔的起始点和结束点

在 设计器的 “控制流” SSIS 选项卡上，向包中添加一个执行 SQL 任务。
打开 “执行 SQL 任务编辑器”，在编辑器的 “常规” 页上，选择以下选项：
1. 对于 ResultSet，选择 “单行”。
2. 配置到源数据库的有效连接。
3. 对于 SQLSourceType，选择 “直接输入”。
4. 对于 SQLStatement，输入以下 SQL 语句：
```
SELECT DATEADD(dd,0, DATEDIFF(dd,0,GETDATE()-1)) AS ExtractStartTime,  
  DATEADD(dd,0, DATEDIFF(dd,0,GETDATE())) AS ExtractEndTime  
```
在 “执行 SQL 任务编辑器” 的 “结果集”页上，将 ExtractStartTime 结果映射到 ExtractStartTime 包变量，并将 ExtractEndTime 结果映射到 ExtractEndTime 包变量。

注意

如果使用表达式设置 Integration Services 变量的值，则每次访问该变量的值时都会计算表达式。

下一步

计算变更范围的起始点和结束点之后，下一步就是确定变更数据是否已准备就绪。

下一个主题：确定变更数据是否已准备就绪

另请参阅

在包中使用变量
 Integration Services (SSIS) 表达式
 执行 SQL 任务
 脚本任务

通过