AnalyticDB:Ekspor data ke ApsaraDB RDS for MySQL

Langkah 1: Buat tabel tujuan di RDS

Hubungkan ke database test_adb di instans RDS Anda, lalu buat tabel tujuan:

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

Langkah 2: Hubungkan ke kluster AnalyticDB for MySQL

Hubungkan ke kluster, lalu buat database sumber. Contoh ini menggunakan database bernama adb_demo.

Langkah 3: Buat tabel sumber dan masukkan data uji

Buat tabel sumber bernama courses di database adb_demo:

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

Masukkan satu baris data uji:

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

Langkah 4: Buat tabel eksternal

Buat tabel eksternal bernama courses_external_table di database adb_demo. Tabel ini memetakan ke tabel courses di instans RDS dan berfungsi sebagai target penulisan:

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

Ganti nilai placeholder di TABLE_PROPERTIES dengan detail koneksi aktual Anda:

Langkah 5: Ekspor data

Jalankan pernyataan berikut untuk menyalin data dari tabel sumber AnalyticDB ke tabel tujuan RDS:

REPLACE INTO courses_external_table
SELECT * FROM courses;