MySQL - 新規/更新行トリガー
新規/更新行
このトリガーは、選択したテーブルまたはビューに挿入/更新された行を取得します。 各行は個別のジョブとして処理されます。 新規/更新された行がないか、ポーリング間隔ごとに1回チェックします。
新規/更新行トリガー
| 入力フィールド | 説明 |
|---|---|
| テーブル | まず、行の処理元となるテーブル/ビューを選択します。 |
| 一意キー | 次に、行を一意に識別するための一意キー列を選択します。 この列のリストは、選択したテーブル/ビューから生成されます。 |
| ソート列 | 次に、更新された行を識別する列を選択します。 |
| WHERE条件 | 最後に、行をフィルタリングするための任意のWHERE条件を指定します。 |
新規/更新行のバッチ
このトリガーは、選択したテーブルまたはビューに挿入/更新された行を取得します。 これらの行は、各ジョブで行のバッチとして処理されます。 このバッチサイズは、トリガー入力で設定できます。 新規/更新された行がないか、ポーリング間隔ごとに1回チェックします。
新規/更新行のバッチトリガー
| 入力フィールド | 説明 |
|---|---|
| テーブル | まず、行の処理元となるテーブル/ビューを選択します。 |
| 一意キー | 次に、行を一意に識別するための一意キー列を選択します。 この列のリストは、選択したテーブル/ビューから生成されます。 |
| ソート列 | 次に、更新された行を識別する列を選択します。 |
| バッチサイズ | 次に、このレシピの各個別ジョブで処理するバッチサイズを設定します。 |
| WHERE条件 | 最後に、行をフィルタリングするための任意のWHERE条件を指定します。 |
入力
テーブル
行の処理元となるテーブル/ビューを選択します。 これは、選択リストからテーブルを選択するか、入力フィールドをテキストモードに切り替えて完全なテーブル名を入力することで実行できます。
一意キー
この選択した列の値は、選択したテーブル内の行の重複除外に使用されます。
そのため、選択した列の値がテーブル内で重複しないようにしてください。 通常、この列はテーブルの主キーです(例:ID)。 増分可能で、ソート可能である必要があります。 パフォーマンスを向上させるために、この列にインデックスを付けることもできます。
PRIMARY KEYまたはUNIQUE制約を持つ列のみ使用できます。 この要件を満たす列を確認するには、このSQLクエリを実行します。
SELECT kcu.column_name
FROM information_schema.key_column_usage kcu, information_schema.table_constraints tc
WHERE
kcu.constraint_name = tc.constraint_name and
kcu.table_name = tc.table_name and
kcu.table_schema = tc.table_schema and
tc.table_name = "table_name" and
tc.constraint_type in ("PRIMARY KEY", "UNIQUE")
ORDER BY kcu.column_nameソート列
ソート列は、テーブル内の行が更新されるたびに更新される列です。 通常、これはtimestamp列です。
行が更新されると、一意キーの値は同じままです。 ただし、最終更新時刻を反映するようにタイムスタンプが更新されている必要があります。 このロジックに従い、Workatoは、この列の値を、選択した一意キー列の値とともに追跡します。 Sort column値の変更が検出されると、更新行イベントが記録され、トリガーによって処理されます。
使用できるのは、datetimeおよびtimestamp列タイプのみです。 この要件を満たす列を確認するには、このSQLクエリを実行します。
SHOW COLUMNS FROM user WHERE Type in ('datetime','timestamp')バッチサイズ
各ジョブで返す行のバッチサイズ。 これは1から最大バッチサイズまでの任意の数値にできます。 最大バッチサイズは100で、デフォルトは100です。
任意のポーリングで、行数が設定されたバッチサイズより少ない場合、このトリガーはすべての行をより小さいバッチとして配信します。
WHERE条件
この条件は、1つ以上の列の値に基づいて行をフィルタリングするために使用されます。
role = 'admin' and created_time > '2020-05-06'選択したテーブルのすべての行を処理するには、空白のままにします。
サブクエリを含む複雑なWHERE条件も使用できます。 詳細については、WHERE条件ガイドを参照してください。
Last updated: