最后于 2026年10月16日 更新

MySQL 迁移到 Doris

本页使用 MySQL JDBC Catalog 把一个稳定快照导入 Doris 内部表。该方式适合一次性或周期性批量迁移，不会自动捕获后续更新、删除或 DDL。持续同步请见后面的 CDC 路线。

前提条件

已有名为 migration_source 的 MySQL 数据库，以及对示例表具有 SELECT 权限的源端账户。
每个 Doris FE/BE 都可以访问源服务。按 MySQL Catalog 和驱动部署准备 mysql-connector-j-8.3.0.jar。示例使用驱动文件名，因此 Jar 必须位于所有 FE/BE 的 jdbc_drivers_dir 中。
使用具备建 Catalog、建库、建表、读外表及写目标表权限的 Doris 账户。权限配置见授权。
以下演示在源库 migration_source 中运行，目标表必须为空。请替换示例主机、用户名和密码。

基本用法

1. 准备源表

使用具有建表和插入权限的源端账号，在源数据库中准备下面的样例；Catalog 连接使用前述源端只读账号。

CREATE TABLE migration_demo (
    id BIGINT PRIMARY KEY,
    amount DECIMAL(12,2),
    note VARCHAR(100)
);
INSERT INTO migration_demo VALUES (1, 12.50, 'first'), (2, NULL, NULL);

结果：建表成功并插入 2 行。

2. 在 Doris 中创建并检查 Catalog

CREATE CATALOG migration_mysql PROPERTIES (
    'type' = 'jdbc',
    'user' = 'migration_reader',
    'password' = '<source_password>',
    'jdbc_url' = 'jdbc:mysql://mysql-host:3306/migration_source',
    'driver_url' = 'mysql-connector-j-8.3.0.jar',
    'driver_class' = 'com.mysql.cj.jdbc.Driver'
);
DESC migration_mysql.migration_source.migration_demo;

结果应包含 id、amount、note 三列。检查实际外表类型，再创建目标表。

3. 创建目标表并迁移

CREATE DATABASE IF NOT EXISTS migration_target;
CREATE TABLE migration_target.mysql_demo (
    id BIGINT NOT NULL,
    amount DECIMAL(12,2),
    note STRING
)
DUPLICATE KEY(id)
DISTRIBUTED BY HASH(id) BUCKETS 1
PROPERTIES ('replication_num' = '1');

INSERT INTO migration_target.mysql_demo (id, amount, note)
SELECT id, amount, note FROM migration_mysql.migration_source.migration_demo;

SELECT id, amount, note FROM migration_target.mysql_demo ORDER BY id;

+------+--------+-------+
| id   | amount | note  |
+------+--------+-------+
|    1 |  12.50 | first |
|    2 |   NULL | NULL  |
+------+--------+-------+

示例使用单副本、单分桶，便于本地验证；生产环境请按可用 BE 数量和可靠性要求调整。重复执行 INSERT 会追加重复数据。

连接参数

参数	类型	是否必需 / 默认值	描述
`type`	STRING	必需，无默认值	使用 `jdbc`
`user` / `password`	STRING	必需，无默认值	源数据库凭据
`jdbc_url`	STRING	必需，无默认值	包含源数据库名的 JDBC 连接地址
`driver_url`	STRING	必需，无默认值	每个 FE/BE 可访问的 Jar；本例使用预部署文件名
`driver_class`	STRING	必需，无默认值	对应驱动的 Java 类名

连接池、名称映射及驱动路径安全规则见完整 JDBC 参数参考。

类型与版本注意事项

UNSIGNED 整数需要扩宽：例如 INT UNSIGNED 对应 BIGINT，BIGINT UNSIGNED 对应 LARGEINT，不能直接照搬有符号类型。
JDBC 的 MySQL JSON 映射为 STRING，不是自动映射为 VARIANT。TIME、ENUM、SET 也按 Catalog 映射处理；不要假设 JDBC 和 CDC 使用相同规则。
TINYINT(1) 的 JDBC 元数据受驱动设置影响；以实际 DESC 为准，不要把任意 TINYINT 都当作布尔值。
4.1 系列自 4.1.5 起，TIMESTAMP 使用 TIMESTAMPTZ，二进制类型使用 VARBINARY；DATETIME 仍是无时区的日期时间。更早版本的映射及配置不同。dev 使用当前映射。
主键模型、AUTO_INCREMENT、索引和源库约束不会因批量 INSERT 自动复制。完整类型规则见 MySQL 映射参考。

持续同步

需要源端更新、删除和全量初始化衔接时，使用 Flink CDC 同步。按 Connector 兼容矩阵选择 Flink、CDC 和 Doris Connector 版本，不要把独立版本的最低要求简单组合。

校验与错误处理

在同一快照和固定范围内，对源表 migration_mysql.migration_source.migration_demo 与目标表 migration_target.mysql_demo 分别执行 COUNT(*)、COUNT(amount)、SUM(amount)；本例结果应分别为 2、1、12.50。还应逐值检查样本、NULL、精度和时区。完整迁移的校验与切换流程见迁移概览。

连接失败时先检查所有 FE/BE 的网络、驱动文件、源账户权限及驱动路径限制。类型不兼容时先检查 DESC 并显式转换；导入失败后检查实际已写入范围，再决定重试，不要无条件重复整个 INSERT。

建议

先用本页的小表验证环境，再按稳定键或时间范围分批。持续同步选择能够处理更新、删除和重放的目标模型；批量快照表与持续镜像表应分别设计。

前提条件​

基本用法​

1. 准备源表​

2. 在 Doris 中创建并检查 Catalog​

3. 创建目标表并迁移​

连接参数​

类型与版本注意事项​

持续同步​

校验与错误处理​

建议​