1. 迁移前准备
– 停止业务写入
– 备份源库数据
– 检查目标库环境
– 准备迁移工具

2. 结构迁移
$ obclient -h192.168.1.101 -P2881 -uroot@fgedu_tenant -p -e ”
— 创建目标表
CREATE TABLE fgedudb.fgedu_order (
order_id BIGINT PRIMARY KEY,
user_id BIGINT,
amount DECIMAL(18,2),
order_status TINYINT,学习交流加群风哥QQ113257174。
create_time TIMESTAMP,
INDEX idx_user_id (user_id),
INDEX idx_create_time (create_time)
) PARTITION BY HASH(order_id) PARTITIONS 16;
”

3. 数据导出
$ mysqldump -h192.168.1.100 -P3306 -uroot -p fgedudb fgedu_order \
–no-create-info –extended-insert > /backup/orders.sql

# 或使用SELECT INTO OUTFILE
$ mysql -e “SELECT * INTO OUTFILE ‘/tmp/orders.csv’
FIELDS TERMINATED BY ‘,’
FROM fgedudb.fgedu_order;”

4. 数据导入
$ obclient -h192.168.1.101 -P2881 -uroot@fgedu_tenant -p < /backup/orders.sql # 或使用LOAD DATA $ obclient -e "LOAD DATA INFILE '/tmp/orders.csv' INTO TABLE fgedudb.fgedu_order FIELDS TERMINATED BY ',';" 5. 数据校验 $ obclient -e " SELECT COUNT(*) FROM fgedudb.fgedu_order; SELECT SUM(order_id) FROM fgedudb.fgedu_order; " 6. 启动业务 - 验证数据完整性 - 切换业务连接 - 监控业务运行

1. OMS部署
# 安装OMS
$ cd /ob/app/oms
$ ./install.sh

# 启动OMS
$ ./bin/oms.sh start

# 访问OMS控制台
http://192.168.1.200:8080

2. 创建迁移项目
– 登录OMS控制台
– 创建数据源（MySQL）
– 创建目标库（OceanBase）
– 创建迁移项目

3. 配置迁移任务
┌─────────────────────────────────────────────────────────────┐
│ 迁移配置 │
├─────────────────────────────────────────────────────────────┤
│ 源库：MySQL 192.168.1.100:3306 │
│ 目标库：OceanBase 192.168.1.101:2881 │
│ 迁移对象：fgedudb.* │
│ 迁移类型：结构+全量+增量 │
│ 并发度：16 │
│ 限速：100MB/s │
└─────────────────────────────────────────────────────────────┘

4. 启动迁移
# 在OMS控制台启动迁移任务
# 监控迁移进度

5. 数据校验
# OMS自动校验
# 或手动校验
$ obclient -e ”
SELECT
(SELECT COUNT(*) FROM fgedudb.fgedu_order) as target_count,
(SELECT COUNT(*) FROM mysql.fgedu_order) as source_count;更多学习教程公众号风哥教程itpux_com。
”

6. 业务切流
– 停止源库写入
– 等待增量同步完成
– 切换业务连接到目标库
– 启动业务

1. OMS增量同步配置
# 在OMS控制台配置
– 启用增量同步
– 配置同步对象
– 设置过滤规则
– 配置冲突处理

2. Canal增量同步
# 部署Canal
$ cd /ob/app/canal
$ ./bin/startup.sh

# 配置Canal
$ cat conf/example/instance.properties
canal.instance.master.address=192.168.1.100:3306
canal.instance.dbUsername=canal，from DB视频:www.itpux.com。
canal.instance.dbPassword=canal
canal.instance.connectionCharset=UTF-8
canal.instance.tsdb.enable=true

# 启动Canal实例
$ ./bin/startup.sh example

3. 消费增量数据
“`java
// Java代码消费Canal数据
CanalConnector connector = CanalConnectors.newSingleConnector(
new InetSocketAddress(“192.168.1.200”, 11111), “example”, “”, “”);

connector.connect();
connector.subscribe(“fgedudb\\..*”);

while (running) {
Message message = connector.getWithoutAck(100);
long batchId = message.getId();

for (Entry entry : message.getEntries()) {
// 解析binlog
RowChange rowChange = RowChange.parseFrom(entry.getStoreValue());

for (RowData rowData : rowChange.getRowDatasList()) {
// 同步到OceanBase
syncToOceanBase(rowData);
}
}

connector.ack(batchId);
}
“`

4. 增量同步监控
#!/bin/bash
# sync_monitor.sh
# from:www.itpux.com.qq113257174.wx:itpux-com

echo “=== Incremental Sync Monitor ===”

# 检查延迟
obclient -e ”
SELECT
source_position,
target_position,
delay_seconds
FROM oceanbase.__all_virtual_cdc_sync_stat;
”

# 检查同步速率
obclient -e ”
SELECT
sync_rate_tps,
sync_rate_mbps
FROM oceanbase.__all_virtual_cdc_sync_stat;
”

echo “==================================”