AnalyticDB：通過外表匯入至數倉版

前提條件

• RDS MySQL執行個體需與AnalyticDB MySQL叢集位於同一個VPC，即所在專用網路的VPC ID相同。

  說明

  • 登入RDS控制台，單擊執行個體ID，在資料庫連接頁面的網路類型位置，查看RDS MySQL執行個體所在的VPC ID。

  • 登入AnalyticDB MySQL控制台，在數倉版頁簽單擊叢集ID，在集群資訊頁面的網路資訊位置，查看AnalyticDB MySQL叢集所在的VPC ID。

• 已將AnalyticDB MySQL叢集的VPC網段加入RDS MySQL執行個體的白名單中。詳細操作步驟，請參見設定RDS的IP白名單。

• 需在RDS MySQL執行個體上完成建立資料庫和串連執行個體等操作，並準備好相關測試資料。詳細操作步驟，請參見建立資料庫和帳號和串連RDS MySQL執行個體。

  本文樣本中，測試所用的RDS MySQL源庫名為test_adb，並在該庫中建立了一張名為goods的源表，建表語句如下：

  CREATE TABLE goods (
  goods_id bigint(20) NOT NULL,
  price double NOT NULL,
  class bigint(20) NOT NULL,
  name varchar(32) NOT NULL,
  update_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (goods_id)
  );

• 如果您的AnalyticDB MySQL叢集是彈性模式，您需要在集群資訊頁面的網路資訊地區，開啟啟用ENI網絡的開關。

操作步驟

1. 串連目標AnalyticDB MySQL叢集。詳細操作步驟，請參見串連叢集。

2. 建立目標資料庫。詳細操作步驟，請參見建立資料庫。

   本樣本中，AnalyticDB MySQL叢集的目標庫名為adb_demo。

3. 建立外表。

   使用以下命令在目標庫adb_demo中建立一張名為goods_external_table的外表。

   CREATE TABLE IF NOT EXISTS goods_external_table (
           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-vpc-address:3306/test_adb",  
           "tablename":"goods",  
           "username":"mysql-user-name",  
           "password":"mysql-user-password",
           "charset":"utf8"
     }';

   參數	說明
   ENGINE='mysql'	外部表格的儲存引擎說明，本文使用的是MySQL。
   TABLE_PROPERTIES	AnalyticDB MySQL訪問RDS MySQL資料的訪問方式。
   url	RDS MySQL執行個體中的內網地址（即VPC串連地址）和源庫名（本文樣本中為test_adb）。RDS地址資訊的查看方法，請參見查看或修改內外網地址和連接埠。 格式："jdbc:mysql://mysql-vpc-address:3306/rds-database-name"。 樣本：jdbc:mysql://rm-bp1hem632****.mysql.rds.aliyuncs.com:3306/test_adb。
   tablename	RDS MySQL中源表名，本文樣本中為goods。
   username	需要訪問RDS MySQL源庫的帳號。
   password	以上帳號對應的密碼。
   charset	MySQL字元集，取值說明： gbk utf8（預設值） utf8mb4

4. 建立目標表。

   使用以下命令在目標資料庫adb_demo中建立一張名為mysql_import_test的目標表，用於儲存從RDS 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);

5. 將源RDS MySQL執行個體中的資料匯入至目標AnalyticDB MySQL叢集中。

   REPLACE INTO mysql_import_test
   SELECT * FROM goods_external_table;