トリガー

Database Hub コネクタに含まれるトリガー。サポートされている JDBC データベース全体でレコードの作成時およびレコードの更新時の変更のポーリングを介して利用可能です。

以下のトリガーはポーリングを介して変更を検出します。

トリガー	説明
レコードの作成時	新しいレコードがテーブルに追加された際にトリガーされます。
レコードの更新時	既存のレコードが変更された際にトリガーされます。

トリガーがサポートされているデータベースは、SQL Server、Oracle、PostgreSQL、Databricks、Redshift です。

動作のしくみ

トリガーはポーリング メカニズムを使用し、データベース テーブルの変更を定期的に (既定では 5 分ごと) チェックします。ポーリング間隔は接続レベルで設定されるため、変更すると、その接続に関連付けられているすべてのトリガーに影響します。詳しくは、 トリガー に関するこちらのページをご覧ください。

コネクションでトリガーを有効化すると、コネクタは、次の 2 つの変更追跡方法のいずれかを使用して、適切なテーブルを自動的に検出します。

1. ネイティブの変更追跡 — データベースで組み込みの変更追跡 (SQL Server 変更履歴管理や Databricks 変更データ フィードなど) が有効化されている場合、コネクタによって自動的に使用されます。これにより、挿入と更新を最も正確に検出できます。
2. タイムスタンプベースの検出 — ネイティブの変更追跡が利用できない場合、コネクタはテーブル内の一般的な監査タイムスタンプ列 ( UpdatedDate、 ModifiedAt、 CreatedDateなど) にフォールバックします。

テーブルは、これらのメソッド のいずれか をサポートしている場合にトリガーの対象となります。

注:

また、テーブルには、トリガーの対象となる主 キー が定義されている必要があります。

データベース固有の前提条件

トリガーをアクティブ化する方法は、データベースがネイティブの変更追跡をサポートしているかどうかによって異なります。

データベース	ネイティブの変更追跡	トリガーをアクティブ化する手順
SQL Server	はい (推奨)	変更履歴の追跡を有効化します。 ALTER TABLE ... ENABLE CHANGE_TRACKING。それ以外の場合は、監査のタイムスタンプ列が使用されます。
Databricks	はい (推奨)	Delta Lake 変更データ フィードを有効にする: ALTER TABLE ... SET TBLPROPERTIES (delta.enableChangeDataFeed = true)。それ以外の場合は、監査のタイムスタンプ列が使用されます。
Oracle	いいえ	監査のタイムスタンプ列を追加します (例: ModifiedAt)。
PostgreSQL	いいえ	監査のタイムスタンプ列を追加します (例: ModifiedAt)。
赤方偏移	いいえ	監査のタイムスタンプ列を追加します (例: ModifiedAt)。

フィルター処理

トリガーを設定するときに、 フィルター ビルダー を開いて、オートメーションをトリガーするレコードを絞り込むことができます (たとえば、 が status = 'active'レコードのみ)。

最良の結果を得るためのヒント

• ネイティブの変更追跡を有効化すると、最も信頼性の高い検出機能を提供します。
• 主キーを持つテーブルはトリガーの対象となります。
• 一般に名前が付けられた監査列 (UpdatedDate、 ModifiedDate、 CreatedDate、 ModifiedAt) は自動的に認識されます。
• フィルター ビルダーは、トリガーを関連するレコードのみに制限します。

すべてのトリガーには、長期実行のワークフローの [ イベントを待機し再開 ] アクティビティで自動的にアクセスできます。詳しくは、「 Integration Service アクティビティを使用した長期実行のワークフロー」をご覧ください。