AnalyticDB:外部テーブルを使用して RDS for MySQL からデータをインポートする

Enterprise Edition、Basic Edition、および Data Lakehouse Edition

1. SQL エディターに移動します。

   1. AnalyticDB for MySQL コンソールにログインします。コンソールの左上隅でリージョンを選択します。左側のナビゲーションウィンドウで、クラスターリスト をクリックします。管理するクラスターを見つけて、クラスター ID をクリックします。

   2. 左側のナビゲーションウィンドウで、[ジョブ開発] > Sql開発 をクリックします。

2. XIHE エンジンとインタラクティブなリソースグループを選択します。

3. 次の文を実行して外部データベースを作成します。次のコードは例です:

   CREATE EXTERNAL DATABASE adb_external_db;

4. 次の文を実行して外部テーブルを作成します。次のコードは例です:

   説明

   • AnalyticDB for MySQL の外部テーブルは、RDS for MySQL のソーステーブルと同じ列名、列数、列の順序、およびデータの型を持つ必要があります。

   • AnalyticDB for MySQL で外部テーブルを作成するためのパラメーターの詳細については、「CREATE EXTERNAL TABLE」をご参照ください。

   CREATE EXTERNAL TABLE IF NOT EXISTS  adb_external_db.goods (
       goods_id bigint(20) NOT NULL,
       price double NOT NULL,
       class bigint(20) NOT NULL,
       name varchar(32) NOT NULL,
       update_time timestamp,
       PRIMARY KEY (goods_id)
    )ENGINE = 'MYSQL' TABLE_PROPERTIES = '{
      "url":"jdbc:mysql://mysql-address:3306/test_adb",
      "tablename":"goods",
      "username":"mysql-user-name",
      "password":"mysql-user-password",
      "charset":"utf8"
   }';

5. データをクエリします。

   外部テーブルが作成された後、AnalyticDB for MySQL で SELECT 文を実行して、RDS for MySQL の goods テーブルのデータをクエリできます。

   SELECT * FROM adb_external_db.goods;

   次の結果が返されます。

   +----------+-------+-------+------------+---------------------+
   | goods_id | price | class | name       | update_time         |
   +----------+-------+-------+------------+---------------------+
   |        2 |  80.0 |     2 | Basketball | 2024-08-08 10:00:55 |
   |       10 | 200.0 |     3 | Phone      | 2024-08-07 11:30:25 |
   |        1 |  50.0 |     1 | Book       | 2024-08-07 09:56:53 |
   |        6 |  25.0 |     4 | Tea        | 2024-08-05 09:25:30 |
   |        9 | 100.0 |     2 | Baseball   | 2024-08-08 11:35:50 |
   |        3 | 150.0 |     3 | Watch      | 2024-08-06 11:00:25 |
   |        5 |  80.0 |     2 | Football   | 2024-08-07 08:50:35 |
   |        7 |  30.0 |     4 | Coffee     | 2024-08-07 10:20:40 |
   |        8 | 300.0 |     3 | Computer   | 2024-08-06 10:55:35 |
   |        4 |  30.0 |     1 | Magazine   | 2024-08-08 12:25:55 |
   +----------+-------+-------+------------+---------------------+

6. 次の文を実行して、ターゲットデータベースを作成します。

   CREATE DATABASE adb_demo;

7. adb_demo データベースに mysql_import_test という名前のターゲットテーブルを作成するには、次の文を実行します。このテーブルは、RDS for MySQL からインポートされたデータを格納するために使用されます。

   CREATE TABLE IF NOT EXISTS  mysql_import_test (
           goods_id bigint(20) NOT NULL,
           price double NOT NULL,
           class bigint(20) NOT NULL,
           name varchar(32) NOT NULL,
           update_time timestamp,
           PRIMARY KEY (goods_id)
    )
   DISTRIBUTED BY HASH(goods_id);

8. 次の文を実行して、RDS for MySQL インスタンスからターゲットの AnalyticDB for MySQL クラスターにデータをインポートします。

   INSERT INTO mysql_import_test
   SELECT * FROM adb_external_db.goods;

9. 次の文を実行して、AnalyticDB for MySQL の mysql_import_test テーブルのデータをクエリします。

   SELECT * FROM mysql_import_test;

   次の結果が返されます。

   +----------+-------+-------+------------+---------------------+
   | goods_id | price | class | name       | update_time         |
   +----------+-------+-------+------------+---------------------+
   |        2 |  80.0 |     2 | Basketball | 2024-08-08 10:00:55 |
   |       10 | 200.0 |     3 | Phone      | 2024-08-07 11:30:25 |
   |        1 |  50.0 |     1 | Book       | 2024-08-07 09:56:53 |
   |        6 |  25.0 |     4 | Tea        | 2024-08-05 09:25:30 |
   |        9 | 100.0 |     2 | Baseball   | 2024-08-08 11:35:50 |
   |        3 | 150.0 |     3 | Watch      | 2024-08-06 11:00:25 |
   |        5 |  80.0 |     2 | Football   | 2024-08-07 08:50:35 |
   |        7 |  30.0 |     4 | Coffee     | 2024-08-07 10:20:40 |
   |        8 | 300.0 |     3 | Computer   | 2024-08-06 10:55:35 |
   |        4 |  30.0 |     1 | Magazine   | 2024-08-08 12:25:55 |
   +----------+-------+-------+------------+---------------------+

Data Warehouse Edition