AnalyticDB:Tablestore データのクエリとインポート

ステップ 1：外部データベースの作成

CREATE EXTERNAL DATABASE adb_external_db;

ステップ 2：外部テーブルの作成

外部テーブルは、フィールド名、数、順序が Tablestore テーブルと一致している必要があります。また、フィールドのデータ型にも互換性が必要です。データ型のマッピングについては、「データ型マッピング」をご参照ください。

次の例では、adb_external_db データベースに person という名前のテーブルを作成します。

CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_db.person (
    id    int,
    name  string,
    age   int
)
ENGINE = 'OTS'
TABLE_PROPERTIES = '{
    "mapped_name": "person",
    "location": "https://w0****la.cn-hangzhou.vpc.tablestore.aliyuncs.com"
}';

ステップ 3：データのクエリ

外部テーブルが作成されると、AnalyticDB for MySQL は Tablestore テーブルからデータを自動的にマッピングします。次の SELECT 文を実行して、データをクエリします。

SELECT * FROM adb_external_db.person;

期待される出力：

+------+-------+------+
| id   | name  | age  |
+------+-------+------+
|    1 | james |   10 |
|    2 | bond  |   20 |
|    3 | jack  |   30 |
|    4 | lucy  |   40 |
+------+-------+------+
4 rows in set (0.35 sec)

ステップ 1：データベースの作成

CREATE DATABASE adb_demo;

ステップ 2：宛先テーブルの作成

宛先テーブルは、外部テーブルと同じフィールド数と順序を持つ必要があります。フィールドのデータ型には互換性が必要です。

CREATE TABLE IF NOT EXISTS adb_demo.adb_import_test (
    id   int,
    name string,
    age  int
)
DISTRIBUTED BY HASH(id);

ステップ 3：データの書き込み

重複するプライマリキーをどのように処理するかに基づいて、書き込みメソッドを選択します。

メソッド 1：INSERT INTO (重複をスキップ)

重複するプライマリキーを持つ行がすでに存在する場合、その行はスキップされます。

INSERT INTO adb_demo.adb_import_test
SELECT * FROM adb_external_db.person;

結果を確認します。

SELECT * FROM adb_demo.adb_import_test;

期待される出力：

+------+-------+------+
| id   | name  | age  |
+------+-------+------+
|    1 | james |   10 |
|    2 | bond  |   20 |
|    3 | jack  |   30 |
|    4 | lucy  |   40 |
+------+-------+------+

メソッド 2：INSERT OVERWRITE (重複を置き換え)

重複するプライマリキーを持つ行がすでに存在する場合、既存の行は上書きされます。

INSERT OVERWRITE adb_demo.adb_import_test
SELECT * FROM adb_external_db.person;

メソッド 3：SUBMIT JOB (非同期インポート)

ほとんどの場合、SUBMIT JOB を使用してインポートを非同期で実行します。/*+ direct_batch_load=true*/ ヒントを追加して、ジョブを高速化できます。

SUBMIT JOB
INSERT OVERWRITE adb_demo.adb_import_test
SELECT * FROM adb_external_db.person;

この文はジョブ ID を返します。

+---------------------------------------+
| job_id                                |
+---------------------------------------+
| 2020112122202917203100908203303****** |

非同期ジョブをモニターするには、「非同期でのインポートジョブの送信」をご参照ください。