触发器

Database Hub 连接器中包含的触发器，可通过轮询支持的 JDBC 数据库之间已创建的记录和已更新的记录来使用。

这些触发器通过轮询检测更改：

触发器	描述
记录已创建	将新记录添加到表格时触发。
记录已更新	修改现有记录时触发。

以下数据库支持触发器：SQL Server、Oracle、PostgreSQL、Databricks 和 Redshift。

工作方式

触发器使用轮询机制，会定期（默认情况下每五分钟）检查数据库表格是否存在更改。轮询间隔是在连接级别配置的，因此更改此间隔会影响与该连接关联的所有触发器。有关详细信息，请参阅触发器文档。

在连接上启用触发器后，连接器会使用以下两种变更跟踪方法之一自动检测哪些表格符合条件：

1. 原生更改跟踪— 如果数据库启用了内置更改跟踪（例如 SQL Server 更改跟踪或 Databricks 更改数据订阅源），则连接器会自动使用该功能。这样可以对插入与更新进行最准确的检测。
2. 基于时间戳的检测— 如果原生更改跟踪不可用，连接器会回退到表格中常见的审核时间戳列（例如UpdatedDate 、 ModifiedAt和CreatedDate ）。

如果表格支持其中任何一种方法，则该表格符合使用触发器的条件。

备注：

表格还必须定义主键，才符合触发器的条件。

数据库特定的先决条件

激活触发器的操作取决于您的数据库是否支持原生变更跟踪：

数据库	原生变更跟踪	激活触发器的操作步骤
SQL 服务器	是（推荐）	启用变更跟踪： ALTER TABLE ... ENABLE CHANGE_TRACKING 。否则，连接器将使用审核时间戳列。
Databricks	是（推荐）	启用 Deltalake 更改数据订阅源： ALTER TABLE ... SET TBLPROPERTIES (delta.enableChangeDataFeed = true) 。否则，连接器将使用审核时间戳列。
Oracle	否	添加审核时间戳列（例如ModifiedAt ）。
PostgreSQL	否	添加审核时间戳列（例如ModifiedAt ）。
红移	否	添加审核时间戳列（例如ModifiedAt ）。

筛选

配置触发器时，您可以打开“筛选器构建器” ，以缩小触发自动化的记录的范围（例如，仅限status = 'active'符合条件的记录）。

有关获得最佳结果的提示

• 启用原生变更跟踪后，可提供最可靠的检测。
• 包含主键的表格符合使用触发器的条件。
• 系统会自动识别通常命名的审核列（ UpdatedDate 、 ModifiedDate 、 CreatedDate 、 ModifiedAt ）。
• “筛选器”构建器将触发器限制为仅相关记录。

对于长时间运行的工作流，所有触发器都可以在“等待事件，然后继续”活动下自动访问。有关详细信息，请参阅使用 Integration Service 活动长时间运行的工作流。