云数据库 SelectDB 版：迁移StarRocks数据

前提条件

• 已将StarRocks实例IP添加至SelectDB的白名单。具体操作，请参见设置白名单。

• 了解什么是Catalog，以及Catalog的基本操作。更多详情，请参见湖仓一体。

示例环境

本示例为将StarRocks的数据库starRocks_db中表SR_t的数据迁移到SelectDB 数据库test_db中表test_SR2SelectDB中。在实际使用中，请根据您的实际情况修改对应参数。示例环境如下：

• 目标库：test_db

• 目标表：test_SR2SelectDB

• 源数据库：starRocks_db

• 源数据表：SR_t

源数据准备示例

登录您的源数据StarRocks，进行以下操作。

1. 创建数据库。

   CREATE DATABASE starRocks_db;

2. 创建表。

   CREATE TABLE SR_t
   (
       id int,
       name string,
       age int
   )
   DISTRIBUTED BY HASH(id) BUCKETS 4
   PROPERTIES("replication_num" = "1");

3. 插入数据。

   INSERT INTO SR_t VALUES
   (1, 'Alice', 25),
   (2, 'Bob', 30),
   (3, 'Charlie', 35),
   (4, 'David', 40),
   (5, 'Eve', 45);

操作步骤

1. 连接SelectDB实例。具体操作，请参见连接实例。

   说明

   使用DMS登录时，SWITCH指令失效。推荐使用MySQL客户端连接。

2. 创建StarRocks JDBC Catalog。更多操作，请参见JDBC数据源。

   CREATE CATALOG starrocks_catalog PROPERTIES (
       "type"="jdbc",
       "user"="root",
       "password"="123456",
       "jdbc_url" = "jdbc:mysql://127.0.0.1:3306/demo",
       "driver_url" = "mysql-connector-java-8.0.25.jar",
       "driver_class" = "com.mysql.cj.jdbc.Driver",
       "checksum" = "fdf55dcef04b09f2eaf42b75e61ccc9a"
   )

   参数说明

   参数	必选	默认值	说明
   user	是	无	StarRocks数据库的账号。
   password	是	无	StarRocks数据库的密码。
   jdbc_url	是	无	JDBC连接串。需要包含StarRocks数据库的连接地址。
   driver_url	是	无	JDBC Driver的Jar包名称。 说明 推荐使用mysql-connector-java-8.0.25.jar。 若期望使用其他Jar包，支持工单咨询。
   driver_class	是	无	JDBC Driver的Class名称。 推荐设置为com.mysql.cj.jdbc.Driver。
   lower_case_table_names （4.0版本改名为lower_case_meta_names）	否	"false"	指定是否以小写的形式同步JDBC外部数据源的库名和表名。 true：通过维护小写名称到远程系统中实际名称的映射，能够查询非小写的数据库和表。此时，库表列名都会被转换为小写。 false：不能查询非小写的数据库和表。 重要 对于SelectDB 3.0版本。 当 FE 参数的lower_case_table_names设置为1或2时， Catalog 的lower_case_table_names参数必须设置为true。 当 FE 参数的lower_case_table_names设置为0，则 Catalog 的参数可以为true或false。 对于SelectDB 4.0版本。 当 FE 的lower_case_table_names参数为0或2时，库名表名列名都不会被转换。 当 FE 的lower_case_table_names参数为1时，表名会被转换为小写，库名和列名不会被转换。
   only_specified_database	否	"false"	指定是否只同步指定的Database。 true：只同步JDBC URL中指定的数据源的 Database。 false：同步JDBC URL中所有的Database。
   include_database_list	否	""	当only_specified_database=true时，指定同步多个Database，以英文逗号分隔。Database名称大小写敏感。
   exclude_database_list	否	""	当only_specified_database=true时，指定不需要同步的多个Database，以英文逗号分隔。Database名称大小写敏感。
   meta_names_mapping	否	""	如果外部数据源存在名称相同只有大小写不同的情况，例如 DORIS 和 doris，Doris 由于歧义而在查询 Catalog 时报错，此时需要配置meta_names_mapping参数来解决冲突。 具体操作，请参见小写名称同步。 重要 此参数仅适用于SelectDB4.0版本。

3. 查看Catalog。

   SHOW CATALOGS; --查看CATALOG是否创建成功

   查询结果如下。

   +--------------+--------------+----------+-----------+-------------------------+---------------------+------------------------+
   | CatalogId    | CatalogName  | Type     | IsCurrent | CreateTime              | LastUpdateTime      | Comment                |
   +--------------+--------------+----------+-----------+-------------------------+---------------------+------------------------+
   | 436009309195 | SR_catalog | jdbc      |           | 2024-08-06 17:09:08.058 | 2024-07-19 18:04:37 |                        |
   |            0 | internal     | internal | yes       | UNRECORDED              | NULL                | Doris internal catalog |
   +--------------+--------------+----------+-----------+-------------------------+---------------------+------------------------+

4. （可选）切换至External Catalog SR_catalog目录下。

   您可以像使用Internal Catalog一样，对External Catalog SR_catalog的数据进行查看和访问。

   说明

   目前，云数据库 SelectDB 版对External Catalog中的数据只支持读操作。

   SWITCH SR_catalog;

5. （可选）切换内部的catalog internal目录下。

   如果您没有执行第4步，跳过此步骤。

   SWITCH internal;

6. （可选）创建数据。

   如果您已经创建了目标数据库，可跳过此步骤。

   CREATE database test_db;

7. 切换至目标数据库。

   USE test_db;

8. 创建表。

   如果您已经有了目标表，请检查目标列类型与StarRocks源数据列类型是否一一对应。

   如果您还没有目标表，创建表时，目标列类型需与StarRocks源数据列类型一一对应。

   列映射详情，请参见类型映射。

   CREATE TABLE test_SR2SelectDB
   (
       id int,
       name string,
       age int
   )
   DISTRIBUTED BY HASH(id) BUCKETS 4
   PROPERTIES("replication_num" = "1");

9. 迁移数据。

   INSERT INTO test_SR2SelectDB SELECT *  FROM doris_catalog.SR_db.SR_t;

10. 查看数据导入情况。

    SELECT *  FROM test_SR2SelectDB;