AnalyticDB:Importar dados de um banco de dados MySQL autogerenciado

Pré-requisitos

• Você possui uma instância ECS na mesma região e VPC do seu cluster AnalyticDB for MySQL.

• Um banco de dados MySQL autogerenciado está instalado na instância ECS.

• Uma regra de entrada foi adicionada ao grupo de segurança da instância ECS para permitir o acesso ao banco de dados MySQL autogerenciado na porta 3306. Para mais informações, consulte Add a security group rule.

• Um banco de dados foi criado e os dados de teste foram preparados no MySQL autogerenciado.

  Neste exemplo, um banco de dados source chamado test_adb é criado, e uma tabela source chamada goods é criada nesse banco. O comando a seguir cria a tabela source:

  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)
  );

• Caso o cluster AnalyticDB for MySQL esteja no modo elástico, ative a opção ENI na seção Network Information da página Cluster Information.

  Importante

  Ao ativar ou desativar a ENI, as conexões com o banco de dados podem ser interrompidas por aproximadamente 2 minutos. Durante esse período, não é possível executar operações de leitura ou escrita. Tenha cuidado ao ativar ou desativar a ENI.

Procedimento

1. Conecte-se ao cluster AnalyticDB for MySQL. Para mais informações, consulte 连接集群.

2. Crie um banco de dados. Para mais informações, consulte Create a database.

   Neste exemplo, um banco de dados chamado adb_demo é criado no cluster AnalyticDB for MySQL.

3. Crie uma tabela externa.

   Execute o comando abaixo para criar uma tabela externa chamada goods_external_table no banco de dados de destino adb_demo.

   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"
     }';

   Parâmetro	Descrição
   ENGINE='mysql'	Define o mecanismo de armazenamento da tabela externa. Este exemplo utiliza MySQL.
   TABLE_PROPERTIES	Informações de conexão que o AnalyticDB for MySQL utiliza para acessar o banco de dados MySQL autogerenciado.
   url	O Primary Private IP (endereço VPC) da instância ECS e o nome do banco de dados source. Neste exemplo, o banco source é test_adb. Para visualizar o endereço IP: Faça login no ECS console e localize a instância desejada. Na página Instance Details, dentro da seção Network Information, visualize o Primary Private IP. Formato: "jdbc:mysql://mysql-vpc-address:3306/ecs-database-name". Exemplo: jdbc:mysql://192.168.128.***:3306/test_adb.
   tablename	Nome da tabela source no banco de dados MySQL autogerenciado. Neste exemplo, a tabela chama-se goods.
   username	Nome de usuário para acessar o banco de dados source na instância MySQL autogerenciada.
   password	Senha da conta.
   charset	Conjunto de caracteres do banco de dados MySQL. Valores válidos: gbk UTF8 (Padrão) utf8mb4

4. Crie uma tabela de destino.

   Execute o comando a seguir para criar uma tabela de destino chamada mysql_import_test no banco de dados adb_demo. Essa tabela armazenará os dados importados do banco MySQL autogerenciado.

   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. Importe os dados do banco MySQL autogerenciado na instância ECS para o cluster AnalyticDB for MySQL de destino.

   REPLACE INTO mysql_import_test
   SELECT * FROM goods_external_table;

Próximos passos

SELECT * FROM mysql_import_test LIMIT 100;