Data Management:eコマース向けタグ付けにタスクオーケストレーション機能を使用する

SQL コンソールを開く

1. DMS コンソール V5.0 にログインします。

2. 左上隅の アイコンにポインターを合わせ、すべての機能 > SQL コンソール > SQL コンソール を選択します。

   通常モードでは、上部ナビゲーションバーから SQL コンソール > SQL コンソール を選択します。

3. まずデータベースを選択してください ダイアログボックスで、ご利用のデータベースを検索し、検索結果から選択して、確認 をクリックします。

テーブルの作成

SQL エディターで、以下の各 SQL ステートメントを 1 つずつ実行します。各ステートメントをコピー＆ペーストした後、実行 をクリックします。

activity_setting（プロモーション設定テーブル）：

CREATE TABLE `activity_setting` (
    `has_promotion` tinyint(1) NOT NULL COMMENT '割引を提供するかどうか',
    `consumption_limit` int(11) NOT NULL COMMENT '購入金額の上限',
    `quota` int(11) NOT NULL COMMENT 'クーポン割引額',
    PRIMARY KEY (`has_promotion`)
) ENGINE=InnoDB
DEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci
ROW_FORMAT=COMPACT
AVG_ROW_LENGTH=16384;

consumption_records（購入トランザクションテーブル）：

CREATE TABLE `consumption_records` (
    `id` bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 'レコード ID',
    `time` datetime NOT NULL COMMENT '購入時刻',
    `count` int(11) NOT NULL COMMENT '購入金額',
    `user_id` bigint(20) NOT NULL COMMENT 'ユーザー ID',
    PRIMARY KEY (`id`)
) ENGINE=InnoDB
DEFAULT CHARACTER SET=utf8mb4 COLLATE=utf8mb4_general_ci
COMMENT='購入レコードテーブル'
AUTO_INCREMENT=8001
ROW_FORMAT=COMPACT
AVG_ROW_LENGTH=54;

voucher_send_list（クーポン発行テーブル）：

CREATE TABLE `voucher_send_list` (
    `Id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'レコード ID',
    `user_id` int(11) NULL COMMENT 'ユーザー ID',
    `consumption_sum` int(11) NULL COMMENT '購入金額合計',
    `quota` int(11) NULL COMMENT 'クーポン割引額',
    PRIMARY KEY (`Id`)
) ENGINE=InnoDB
DEFAULT CHARACTER SET=utf8 COLLATE=utf8_general_ci
AUTO_INCREMENT=1
ROW_FORMAT=COMPACT
AVG_ROW_LENGTH=0;

データのロード

プロモーション設定を挿入します。本例では、has_promotion = 1（アクティブ）、購入しきい値を 100、クーポン割引額を 30 と設定します。

INSERT INTO activity_setting(has_promotion, consumption_limit, quota)
VALUES('1','100','30');

DMS のテストデータ生成機能を用いて、consumption_records にテスト用の購入レコードを生成します。詳細については、「テストデータの生成」をご参照ください。

以下の図は、consumption_records テーブルへのデータ生成設定の一例を示しています。

単一インスタンス向け SQL 代入ノード

このノードは、activity_setting からプロモーション設定を読み取り、各カラム値を出力変数として格納します。後続ノードでは、${variable_name} 構文でこれらの変数を参照します。

1. 単一インスタンス向け SQL 代入 ノードをダブルクリックします。

2. ドロップダウンリストから、ご利用のデータベースを検索・選択します。

3. SQL エディターに以下を入力します。

   select * from activity_setting limit 1

4. 右側ナビゲーションウィンドウで、変数設定 タブをクリックし、出力変数 タブを選択します。

5. 変数の追加 をクリックし、以下の出力変数を追加します：Quota、HasPromotion、および ConsumptionLimit。

ノード実行後、クエリ結果はこれらの 3 つの変数にマップされます。条件分岐ノードおよび単一インスタンス SQL ノードでは、それぞれ ${HasPromotion}、${Quota}、${ConsumptionLimit} として参照されます。

構成の詳細については、「SQL 代入ノードの構成」をご参照ください。

条件分岐ノード

1. 条件分岐 ノードをダブルクリックします。

2. HasPromotion がアクティブであるかを評価する条件式を構成します。

以下の図は、構成済みの条件式を示しています。

構成の詳細については、「条件分岐ノードの構成」をご参照ください。

単一インスタンス SQL ノード

1. 単一インスタンス SQL ノードをダブルクリックします。

2. SQL エディターに以下のステートメントを入力します。${Quota}、${ConsumptionLimit}、および ${bizdate} 変数を用いて、対象ユーザーを voucher_send_list に挿入します。

   INSERT INTO `voucher_send_list`(`user_id`,`consumption_sum`,`quota`)
   SELECT * FROM
   (SELECT `user_id`, sum(count) AS consumption_sum,${Quota} FROM `consumption_records`
    WHERE `time` > '${bizdate}'  GROUP BY `user_id`) `consumption_records`
   where `consumption_sum`>${ConsumptionLimit}