数据库迁移实战：Oracle → MySQL → 国产化数据库完整方案

🎯 一句话定位：一篇覆盖 Oracle → MySQL → 国产化数据库的全链路迁移指南，从语法差异到灰度切流，帮你少踩 80% 的坑。

💡 核心理念：迁移不是翻译 SQL，而是重新理解业务在新引擎上的最优表达。

📖 3分钟速览版

graph LR
    A[Oracle] -->|语法转换
工具辅助| B[MySQL]
    B -->|兼容性评估
灰度切流| C{国产化数据库}
    C --> D[TiDB]
    C --> E[OceanBase]
    C --> F[达梦 DM8]
    C --> G[GaussDB]

    style A fill:#ffccbc,stroke:#333,color:#000
    style B fill:#c8e6c9,stroke:#333,color:#000
    style D fill:#bbdefb,stroke:#333,color:#000
    style E fill:#bbdefb,stroke:#333,color:#000
    style F fill:#bbdefb,stroke:#333,color:#000
    style G fill:#bbdefb,stroke:#333,color:#000

🧠 深度剖析版

1. 为什么要做数据库迁移

1.1 Oracle 迁出的驱动因素

• 授权成本高：Oracle 按 CPU 核心数收费，年维护费占总 license 的 22%，一台 16 核服务器年费可达数十万
• 供应链风险：中美技术博弈背景下，Oracle 断供风险上升
• 信创政策：党政、金融、电信等关键行业要求 2027 年前完成国产化替代

1.2 典型迁移路径

大多数企业采用 两步走 策略：

1. Oracle → MySQL：先迁到开源生态，降低成本、消除授权风险
2. MySQL → 国产化：在 MySQL 兼容基础上选择信创认证数据库

这种策略的优势在于：MySQL 生态成熟，人才储备充足，迁移工具丰富；国产化数据库大多兼容 MySQL 协议，二次迁移成本可控。

2. Oracle → MySQL 语法差异

2.1 数据类型映射

2.2 函数差异对照

2.3 序列 vs AUTO_INCREMENT

Oracle 序列：

1
2
3
4
5

-- Oracle: 创建序列
CREATE SEQUENCE seq_user_id START WITH 1 INCREMENT BY 1;

-- 使用
INSERT INTO t_user (id, name) VALUES (seq_user_id.NEXTVAL, '张三');

MySQL 自增：

1
2
3
4
5
6
7
8
9
10
11
12

-- MySQL: 自增主键
CREATE TABLE t_user (
    id BIGINT NOT NULL AUTO_INCREMENT,
    name VARCHAR(50),
    PRIMARY KEY (id)
) ENGINE=InnoDB;

-- 插入时不指定 id
INSERT INTO t_user (name) VALUES ('张三');

-- 获取最后插入的 id
SELECT LAST_INSERT_ID();

注意：如果业务代码依赖”先获取序列值再插入”的模式，需要重构为”插入后获取自增 ID”或使用分布式 ID 生成器（Snowflake、Leaf）。

2.4 空字符串与 NULL 的致命差异

这是 Oracle → MySQL 迁移中最容易出 bug 的地方：

1
2
3
4
5
6
7
8

-- Oracle：空字符串 == NULL
SELECT * FROM t_user WHERE name IS NULL;
-- 能查到 name = '' 的记录

-- MySQL：空字符串 != NULL
SELECT * FROM t_user WHERE name IS NULL;
-- 查不到 name = '' 的记录，需要：
SELECT * FROM t_user WHERE name IS NULL OR name = '';

修复策略：全面排查代码中的 IS NULL 判断，评估是否需要补充 OR column = ''。

2.5 存储过程迁移

Oracle PL/SQL 和 MySQL 存储过程语法差异大，建议优先将逻辑迁移到应用层（Java/Python）。必须保留存储过程时，主要差异：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

-- Oracle PL/SQL
CREATE OR REPLACE PROCEDURE update_salary(
    p_emp_id IN NUMBER,
    p_raise  IN NUMBER
) AS
    v_current NUMBER;
BEGIN
    SELECT salary INTO v_current FROM emp WHERE id = p_emp_id;
    UPDATE emp SET salary = v_current + p_raise WHERE id = p_emp_id;
    COMMIT;
EXCEPTION
    WHEN NO_DATA_FOUND THEN
        DBMS_OUTPUT.PUT_LINE('Employee not found');
END;
/

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

-- MySQL 存储过程
DELIMITER $$
CREATE PROCEDURE update_salary(
    IN p_emp_id BIGINT,
    IN p_raise DECIMAL(10,2)
)
BEGIN
    DECLARE v_current DECIMAL(10,2);
    DECLARE CONTINUE HANDLER FOR NOT FOUND
        SELECT 'Employee not found' AS message;

    SELECT salary INTO v_current FROM emp WHERE id = p_emp_id;
    UPDATE emp SET salary = v_current + p_raise WHERE id = p_emp_id;
    -- MySQL 默认 autocommit，无需显式 COMMIT
END$$
DELIMITER ;

3. 迁移工具与数据同步

3.1 工具选型

3.2 全量迁移流程

1
2
3
4
5
6
7
8

-- 1. 使用 ora2pg 导出 DDL（Oracle → MySQL 格式）
-- ora2pg -t TABLE -o tables.sql -c ora2pg.conf

-- 2. 手动检查并修正 DDL
-- 重点：数据类型、索引、约束

-- 3. 使用 DataX 同步数据
-- datax.py job/oracle_to_mysql.json

DataX 配置示例（Oracle → MySQL）：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

{
  "job": {
    "content": [{
      "reader": {
        "name": "oraclereader",
        "parameter": {
          "connection": [{
            "jdbcUrl": ["jdbc:oracle:thin:@//host:1521/orcl"],
            "table": ["T_USER"]
          }],
          "username": "readonly_user",
          "password": "***",
          "column": ["ID", "NAME", "STATUS", "CREATED_AT"]
        }
      },
      "writer": {
        "name": "mysqlwriter",
        "parameter": {
          "connection": [{
            "jdbcUrl": "jdbc:mysql://host:3306/mydb?useUnicode=true&characterEncoding=utf8mb4",
            "table": ["t_user"]
          }],
          "username": "write_user",
          "password": "***",
          "column": ["id", "name", "status", "created_at"],
          "writeMode": "replace"
        }
      }
    }],
    "setting": {
      "speed": { "channel": 4 }
    }
  }
}

3.3 增量同步（Canal + MQ）

迁移过程中业务不停机，需要增量同步：

graph LR
    A[MySQL 源库] -->|binlog| B[Canal Server]
    B -->|消息| C[Kafka/RocketMQ]
    C --> D[消费者：写入目标库]
    C --> E[消费者：数据校验]

    style A fill:#ffccbc,stroke:#333,color:#000
    style B fill:#c8e6c9,stroke:#333,color:#000
    style D fill:#bbdefb,stroke:#333,color:#000

Canal 核心配置：

1
2
3
4
5
6

# canal.properties
canal.instance.master.address=source-mysql:3306
canal.instance.dbUsername=canal
canal.instance.dbPassword=***
canal.instance.filter.regex=mydb\\..*
canal.mq.topic=canal_sync

4. MySQL → 国产化数据库

4.1 兼容性评估矩阵

4.2 各数据库迁移要点

TiDB（推荐 MySQL 生态项目）

优势：几乎无感迁移，修改 JDBC URL 即可。

1
2
3
4
5

# 应用配置只需改连接串
spring:
  datasource:
    url: jdbc:mysql://tidb-host:4000/mydb?useSSL=false
    driver-class-name: com.mysql.cj.jdbc.Driver

注意事项：

• 自增 ID 非连续（分布式分配），业务不能依赖 ID 连续性
• 不支持外键约束（需在应用层保证）
• SELECT ... FOR UPDATE 的锁行为与 MySQL 略有差异

OceanBase（推荐金融场景）

1
2
3
4
5

# MySQL 模式连接
spring:
  datasource:
    url: jdbc:mysql://obproxy-host:2883/mydb
    driver-class-name: com.mysql.cj.jdbc.Driver

注意：通过 OBProxy 代理连接，应用层对 MySQL 透明。

达梦 DM8（推荐政务/国企）

达梦以 Oracle 兼容为主，若源库是 MySQL 需注意：

1
2
3
4
5
6

<!-- Maven 依赖 -->
<dependency>
    <groupId>com.dameng</groupId>
    <artifactId>DmJdbcDriver18</artifactId>
    <version>8.1.2.192</version>
</dependency>

1
2
3
4

spring:
  datasource:
    url: jdbc:dm://dm-host:5236/mydb
    driver-class-name: dm.jdbc.driver.DmDriver

MyBatis 方言适配：

1
2
3
4
5

// 达梦分页不支持 LIMIT，使用 ROWNUM 或 TOP
// MyBatis Plus 已内置 DmDialect，配置即可：
mybatis-plus:
  configuration:
    database-id: dm

GaussDB（推荐华为云客户）

1
2
3
4

spring:
  datasource:
    url: jdbc:gaussdb://gauss-host:8000/mydb
    driver-class-name: com.huawei.gaussdb.jdbc.Driver

注意：GaussDB 基于 PostgreSQL 内核，SQL 方言差异较大，LIMIT 语法兼容但函数不同。

4.3 迁移策略：灰度切流

graph TD
    A[阶段1：双写] --> B[阶段2：读写分离]
    B --> C[阶段3：完全切换]
    C --> D[阶段4：老库下线]

    A --- A1[写入同时落两个库
以老库为准]
    B --- B1[写入新库
读新库为主/老库兜底]
    C --- C1[全部流量切到新库
老库只读保留 7 天]
    D --- D1[确认无异常后下线老库]

    style A fill:#ffccbc,stroke:#333,color:#000
    style B fill:#fff9c4,stroke:#333,color:#000
    style C fill:#c8e6c9,stroke:#333,color:#000
    style D fill:#bbdefb,stroke:#333,color:#000

双写模式核心代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

@Service
public class DualWriteService {

    @Autowired
    @Qualifier("mysqlJdbcTemplate")
    private JdbcTemplate mysqlTemplate;

    @Autowired
    @Qualifier("tidbJdbcTemplate")
    private JdbcTemplate tidbTemplate;

    @Transactional
    public void saveUser(User user) {
        // 主库写入（MySQL）
        mysqlTemplate.update(
            "INSERT INTO t_user (name, status) VALUES (?, ?)",
            user.getName(), user.getStatus()
        );

        // 新库写入（TiDB），异步 + 容错
        try {
            tidbTemplate.update(
                "INSERT INTO t_user (name, status) VALUES (?, ?)",
                user.getName(), user.getStatus()
            );
        } catch (Exception e) {
            // 记录差异日志，后续补偿
            log.error("TiDB 双写失败, userId={}", user.getId(), e);
            diffLogService.record("t_user", user.getId(), "INSERT");
        }
    }
}

5. 数据校验与回滚

5.1 数据一致性校验

1
2
3
4
5
6
7
8
9
10
11
12

-- 行数对比
SELECT 'mysql' AS source, COUNT(*) AS cnt FROM mysql_db.t_user
UNION ALL
SELECT 'tidb' AS source, COUNT(*) AS cnt FROM tidb_db.t_user;

-- 抽样校验（MD5 校验和）
SELECT MD5(GROUP_CONCAT(
    CONCAT_WS(',', id, name, status, created_at)
    ORDER BY id
)) AS checksum
FROM t_user
WHERE id BETWEEN 1 AND 10000;

pt-table-checksum（推荐）：

1
2
3
4
5
6

# 对比源库和目标库的数据一致性
pt-table-checksum \
    --host=mysql-source \
    --databases=mydb \
    --tables=t_user \
    --recursion-method=dsn=h=tidb-target,D=percona,t=dsns

5.2 回滚方案设计

6. 故障排查

6.1 问题：字符集乱码

症状：迁移后中文显示为 ??? 或乱码。

原因：Oracle 使用 AL32UTF8，MySQL 需要 utf8mb4。

解决：

1
2
3
4
5
6

-- 检查 MySQL 字符集
SHOW VARIABLES LIKE 'character_set%';

-- 确保数据库和表使用 utf8mb4
ALTER DATABASE mydb CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
ALTER TABLE t_user CONVERT TO CHARACTER SET utf8mb4;

6.2 问题：日期精度丢失

症状：Oracle DATE 迁移到 MySQL DATE 后，时分秒丢失。

原因：Oracle DATE 含时分秒，MySQL DATE 只含日期。

解决：Oracle DATE 应映射为 MySQL DATETIME，而非 DATE。

6.3 问题：大表迁移超时

症状：千万级表迁移时 DataX 任务超时。

解决：

1
2
3
4
5
6
7
8
9
10
11
12

{
  "setting": {
    "speed": {
      "channel": 8,
      "byte": 10485760
    },
    "errorLimit": {
      "record": 0,
      "percentage": 0
    }
  }
}

• 增加并发 channel 数
• 按主键范围分片：WHERE id BETWEEN ? AND ?
• 关闭目标库的 binlog（迁移期间）：SET sql_log_bin = 0;

💬 常见问题（FAQ）

Q1: 迁移后 SQL 性能下降怎么办？

A: Oracle 和 MySQL 的优化器策略不同，相同 SQL 的执行计划可能差异巨大。

排查步骤：

1. EXPLAIN 对比执行计划
2. 检查索引是否正确迁移（Oracle 函数索引在 MySQL 中不支持）
3. 关注 JOIN 顺序：MySQL 优化器对多表 JOIN 的处理弱于 Oracle
4. 考虑添加查询 Hint：/*+ STRAIGHT_JOIN */

Q2: Oracle 的分区表如何迁移？

A: MySQL 支持 RANGE、LIST、HASH、KEY 分区，但不支持 Oracle 的组合分区。

• RANGE 分区：直接对应
• LIST 分区：直接对应
• 组合分区：拆为单级分区 + 应用层路由
• 如果目标是 TiDB，建议用 TiDB 的 Region 分裂替代分区表

Q3: 国产数据库 JDBC 驱动从哪获取？

各数据库驱动获取方式如下：

Q4: 如何保证迁移过程中数据不丢失？

A: 采用「全量 + 增量 + 校验」三步法：

1. 全量同步：停写窗口或一致性快照导出
2. 增量同步：Canal 监听 binlog，消费写入目标库
3. 数据校验：pt-table-checksum 对比行数和校验和
4. 补偿机制：差异日志 + 定时修复任务

Q5: 达梦 DM 和 GaussDB 如何选择？

两者的核心区别在于兼容方向和目标生态：

简单判断：如果你的系统原来是 Oracle → 选达梦；如果原来是 PostgreSQL 或跑在华为云 → 选 GaussDB。

Q6: 迁移周期一般多长？

A: 视系统规模而定：

• 小型系统（< 50 张表）：2-4 周
• 中型系统（50-200 张表，含存储过程）：1-3 个月
• 大型核心系统（> 200 张表，高并发）：3-6 个月
• 其中 SQL 兼容性改造 占 40-60% 的工期

✨ 总结

核心要点

1. Oracle → MySQL 的核心难点不在数据搬迁，在 SQL 语法和隐式行为差异（尤其是空字符串/NULL、日期类型、函数差异）
2. 国产化数据库选型取决于你的源库类型和行业要求：MySQL 生态选 TiDB/OceanBase，Oracle 生态选达梦
3. 灰度切流是生命线：双写 → 读写分离 → 完全切换，每个阶段都必须有回滚方案

行动建议

今天就可以做的：

• 梳理当前系统的 Oracle 专有语法使用情况（搜索 ROWNUM、NVL、DECODE、序列）
• 评估存储过程数量和复杂度，决定是迁移还是重构到应用层

本周可以完成的：

• 使用 ora2pg 或 SQLines 做一次自动化转换评估，输出兼容性报告
• 搭建目标数据库测试环境，跑通核心业务 SQL

长期持续改进的：

• 建立 SQL 兼容性基线测试套件，CI/CD 中自动验证
• 完善数据校验和灰度切流机制，形成可复用的迁移 SOP

更新记录