云原生数据仓库AnalyticDB：导出至自建MySQL

前提条件

• 已创建与AnalyticDB for MySQL集群相同地域、相同VPC的ECS实例。

• 已在ECS实例中安装自建MySQL。

• 已在ECS实例的安全组中对自建MySQL的端口3306入方向进行授权。详情请参见添加安全组规则。

• 已在ECS自建MySQL上完成创建数据库并准备好相关测试数据等操作。

  本文示例中，测试所用的ECS自建MySQL目标库名为test_adb，并在该库中创建了一张名为courses的目标表，用于存储从AnalyticDB for MySQL集群中导出的数据。建表语句如下：

  CREATE TABLE courses (
      id bigint NOT NULL,
      name varchar(32) NOT NULL,
      grade varchar(32) NOT NULL,
      submission_date  timestamp NOT NULL,
      PRIMARY KEY (id)
  );

• 如果您的AnalyticDB for MySQL集群是弹性模式，您需要在集群信息页面的网络信息区域，打开启用ENI网络的开关。

操作步骤

1. 连接目标AnalyticDB for MySQL集群。详细操作步骤，请参见连接集群。

2. 创建源数据库。详细操作步骤，请参见创建数据库。

   本示例中，AnalyticDB for MySQL集群的源库名为adb_demo。

3. 创建源表并插入源数据。

   使用以下命令在源库adb_demo中创建一张名为courses的源表，并将该表中的数据导出至自建MySQL目标库test_adb的courses表中。

   CREATE TABLE courses (
   id bigint AUTO_INCREMENT,
   name varchar NOT NULL,
   grade varchar DEFAULT '1st Grade',
   submission_date timestamp
   ) DISTRIBUTED BY HASH(id);

   使用以下命令往源表courses中插入一行数据：

   INSERT INTO courses (name,submission_date) VALUES("Jams",NOW());

4. 创建外部映射表。

   使用以下命令在源库adb_demo中创建一张名为courses_external_table的外部映射表。

    CREATE TABLE IF NOT EXISTS courses_external_table(
    id bigint NOT NULL,
    name varchar(32) NOT NULL,
    grade varchar(32) NOT NULL,
    submission_date  timestamp NOT NULL,
    PRIMARY KEY (id)
    )
   ENGINE='mysql'  
   TABLE_PROPERTIES='{  
   "url":"jdbc:mysql://mysql-vpc-address:3306/test_adb",  
   "tablename":"courses",  
   "username":"mysql-user-name",  
   "password":"mysql-user-password",
   "charset":"utf8"
   }';

   参数	说明
   ENGINE=’mysql’	外部表的存储引擎说明，本文使用的是MySQL。
   TABLE_PROPERTIES	AnalyticDB for MySQL访问自建MySQL数据库的访问方式。
   url	ECS实例的主私网IP（即VPC地址）和目标库名（本文示例中为test_adb）。查看步骤如下： 登录ECS管理控制台并找到目标实例。 在实例详情页签的网络信息区域，查看主私网IP。 格式："jdbc:mysql://mysql-vpc-address:3306/ecs-database-name"。 示例：jdbc:mysql://192.168.128.***:3306/test_adb。
   tablename	ECS自建MySQL中目标表名，本文示例中为courses。
   username	需要访问ECS自建MySQL目标库的账号。
   password	以上账号对应的密码。
   charset	MySQL字符集，取值说明： gbk utf8（默认值） utf8mb4

5. 将源AnalyticDB for MySQL集群中的数据导出至目标自建MySQL中。

   语法如下：

   REPLACE INTO courses_external_table
   SELECT * FROM courses;