异构数据库数据与结构同步工具

一、工具介绍

1、功能描述

一句话，dbswitch工具提供源端数据库向目的端数据的迁移功能，包括全量和增量方式。迁移包括：

• 结构迁移

字段类型、主键信息、建表语句等的转换，具有类似kettle的表输出组件生成建表SQL功能。

• 数据迁移。

基于JDBC的fetch-size参数分批次读取源端数据库数据，并基于insert/copy方式将数据分批次写入目的数据库。

支持有主键表的 增量变更同步 （变化数据计算Change Data Calculate）功能(千万级以上数据量慎用)

2、功能设计

3、详细功能

• 源端oracle/SqlServer/mysql/PostgreSQL向目的端为Greenplum的迁移

• 源端oracle/SqlServer/mysql/PostgreSQL向目的端为Oralce的迁移

• 源端oracle/SqlServer/mysql/PostgreSQL向目的端为SQLServer的迁移

• 源端oracle/SqlServer/mysql/PostgreSQL向目的端为PostgreSQL的迁移

• 源端oracle/SqlServer/mysql/PostgreSQL向目的端为MySQL的迁移

4、结构设计

• 模块结构设计

  

• 模块结构功能

└── dbswitch
    ├── dbswitch-common    // dbswitch通用定义模块
    ├── dbswitch-pgwriter  // PostgreSQL的二进制写入封装模块
    ├── dbswitch-dbwriter  // 数据库的通用批量Insert封装模块
    ├── dbswitch-core      // 数据库元数据抽取与建表结构语句转换模块
    ├── dbswitch-sql       // 基于calcite的DML语句转换与通用SQL拼接模块
    ├── dbswitch-dbcommon  // 数据库操作通用封装模块
    ├── dbswitch-dbchange  // 基于全量比对计算变更（变化量）数据模块
    ├── dbswitch-dbsync    // 将dbchange模块计算的变更数据同步入库模块
    ├── dbswitch-data      // 工具入口模块，读取配置文件中的参数执行异构迁移同步
    ├── dbswitch-webapi    // dbswitch-core与dbswitch-sql的RESTful接口模块
    ├── package-tool       // 基于maven-assembly-plugin插件的项目打包模块

二、编译配置

本工具纯Java语言开发，代码中的依赖全部来自于开源项目。

1、编译打包

• 环境要求:

  JDK:>=1.8

  maven:>=3.6

• 编译命令:

(1) windows下：

 双击build.cmd脚本文件即可编译打包

(2) Linux下：

git clone https://gitee.com/inrgihc/dbswitch.git
cd dbswitch/
sh ./build.sh

2、安装部署

当编译打包命令执行完成后，会在dbswitch/target/目录下生成dbswitch-relase-x.x.x.tar.gz的打包文件，将文件拷贝到已安装JRE的部署机器上解压即可。

3、配置文件

配置文件信息请见部署包中的：conf/config.properties

注意:

• （1）如果source.datasource-source.includes不为空，则按照包含表的方式来执行；

• （2）如果source.datasource-source.includes为空，则按照source.datasource-source.excludes排除表的方式来执行。

• （3）如果target.datasource-target.drop=false，target.change-data-synch=true；时会对有主键表启用增量变更方式同步

• mysql的驱动配置样例

jdbc连接地址：jdbc:mysql://172.17.2.10:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghai&nullCatalogMeansCurrent=true
jdbc驱动名称： com.mysql.cj.jdbc.Driver

• oracle的驱动配置样例

jdbc连接地址：jdbc:oracle:thin:@172.17.2.58:1521:ORCL
jdbc驱动名称：oracle.jdbc.driver.OracleDriver

• SqlServer的驱动配置样例

jdbc连接地址：jdbc:sqlserver://172.16.2.66:1433;DatabaseName=hqtest
jdbc驱动名称：com.microsoft.sqlserver.jdbc.SQLServerDriver

• PostgreSQL的驱动配置样例

jdbc连接地址：jdbc:postgresql://172.17.2.10:5432/study
jdbc驱动名称：org.postgresql.Driver

启动执行命令如下：

linux系统下：

cd dbswitch-release-X.X.X/
bin/datasync.sh

windows系统下：

切换到dbswitch-release-X.X.X/bin/目录下，双击datasync.cmd脚本文件即可启动

三、特别说明

• 1、对于向目的库为PostgreSQL/Greenplum的数据离线同步默认采用copy方式写入数据，说明如下：

  （a） 如若使用copy方式写入，配置文件中需配置为postgresql的jdbcurl和驱动类（不能为greenplum的驱动包），

  （b） 如若使用insert方式写入，需要在config.properties配置文件中设置如下参数为true:

target.writer-engine.insert=true

• 2、dbswitch离线同步工具提供各种数据库间表结构转换RESTful类型的API接口，服务启动方式如下：

cd dbswitch-release-X.X.X/
bin/startup.sh

提供swagger在线接口文档：htttp://127.0.0.1:9088/swagger-ui.html

• 3、dbswitch离线同步工具支持的数据类型包括：整型、时间、文本、二进制等常用数据类型;

• 4、Oracle的表虽然设置了主键，如果主键约束实际为DISABLED状态，那在进行结构转换时会按照没有此主键处理。

• 5、关于增量变更同步方式的使用说明

步骤A：先通过设置target.datasource-target.drop=true，target.change-data-synch=false；启动程序进行表结构和数据的全量同步;

步骤B：然后设置target.datasource-target.drop=false，target.change-data-synch=true；再启动程序对（有主键表）数据进行增量变更同步。

注：如果待同步的两端表结构已经一致或源端字段是目的端字段的子集，也可直接用步骤B配置进行变更同步

四、文档博客

（1）https://blog.csdn.net/inrgihc/article/details/103739629

（2）https://blog.csdn.net/inrgihc/article/details/104642238

（3）https://blog.csdn.net/inrgihc/article/details/103932231

（4）https://blog.csdn.net/inrgihc/article/details/103738656

五、问题反馈

如果您看到或使用了本工具，或您觉得本工具对您有价值，请为此项目点个赞，多谢！如果您在使用时遇到了bug，欢迎在issue中反馈。也可扫描下方二维码入群讨论：（加好友请注明："程序交流"）