SeaTunnel实现Oracle到MySQL实时同步的配置完整步骤：

一、环境准备

1、安装SeaTunnel
下载并解压SeaTunnel二进制包，版本建议≥2.3.314：

export version="2.3.9"
wget "https://archive.apache.org/dist/seatunnel/${version}/apache-seatunnel-${version}-bin.tar.gz"
tar -xzvf "apache-seatunnel-${version}-bin.tar.gz"

2、依赖驱动配置

将Oracle JDBC驱动（如ojdbc8.jar）和MySQL驱动（如
mysql-connector-java-8.0.28.jar）放入lib/目录。

二、配置文件编写

创建config/oracle_to_mysql.conf，配置分为以下部分：

1、基础环境设置

env {
  execution.parallelism = 4
  job.mode = "STREAMING"  # 实时同步模式:ml-citation{ref="4" data="citationList"}
  checkpoint.interval = 10000  # 检查点间隔10秒:ml-citation{ref="2" data="citationList"}
}

2、Oracle源配置（CDC模式）

source {
  Jdbc {
    url = "jdbc:oracle:thin:@10.40.12.219:1521:sharedb"
    driver = "oracle.jdbc.OracleDriver"
    user = "system"
    password = "xxxx"
    table-name = "scott.emp"  # 需同步的表:ml-citation{ref="1" data="citationList"}
    
    # CDC增量配置
    cdc {
      startup.mode = "initial"  # 首次全量+增量
      debezium.properties = {
        "database.history.kafka.bootstrap.servers" = "localhost:9092"
        "snapshot.mode" = "schema_only"
      }
    }
  }
}

3、MySQL目标配置

sink {
  Jdbc {
    url = "jdbc:mysql://10.40.13.75:3306/ceshi?useUnicode=true&characterEncoding=UTF-8"
    driver = "com.mysql.cj.jdbc.Driver"
    user = "root"
    password = "xxxx"
    table = "emp"  # 目标表名:ml-citation{ref="1" data="citationList"}
    generate-sink-sql = true  # 自动建表:ml-citation{ref="1" data="citationList"}
  }
}

三、实时同步验证

1、启动任务

./bin/seatunnel.sh --config ./config/oracle_to_mysql.conf -e local

2、监控与校验

• 通过日志观察数据同步状态
• 使用SELECT COUNT(*)比对源库与目标库数据量

四、注意事项

1、Oracle CDC前置条件

• 需开启归档日志：ALTER DATABASE ADD SUPPLEMENTAL LOG DATA
• 授予用户LOGMINING权限

2、性能调优

• 增大parallelism值提升吞吐量
• 调整checkpoint.interval平衡实时性与资源消耗

3、故障恢复

• 任务中断后会自动从上次检查点恢复
• 全量阶段失败需手动清理目标表后重试

替代方案对比

若SeaTunnel配置复杂，可考虑：

• Tapdata Cloud：图形化配置Oracle→MySQL同步，支持全量+增量模式
• GoldenGate：企业级高可用方案，但部署成本较高