// 创建本地服务端
SyncServer syncServer = new DefaultSyncServer();

// 注册需要被迁移的源数据库

// 第一个源数据库
syncServer.registerDbConfig(0, "192.168.1.123:3306/mydb0", "my_user0", "my_password0");
// 第二个源数据库
syncServer.registerDbConfig(1, "192.168.1.123:3306/mydb1", "my_user1", "my_password1");
// 初始化
syncServer.init();

SyncClient syncClient = new SyncClient();
// 设置对应的服务端
syncClient.setSyncServer(syncServer);
// 设置目标数据库
syncClient.registerLocalDb(0, "127.0.0.1:3306/sample2", "root", "123456");

// 添加一个任务配置
syncClient.addTableTaskConfig(TableTaskConfig.makeSingle("my_sample_task", 0, "sample_pen", 0, "sample_pen"));

// 初始化
syncClient.init();

// 实行迁移，可调用多次
syncClient.exec("my_sample_task");

<servlet>
    <servlet-name>ServiceExporterServlet</servlet-name>
    <servlet-class>com.github.pister.dbsync.endpoint.remoting.server.ServiceExporterServlet</servlet-class>
    <load-on-startup>1</load-on-startup>
    <init-param>
        <param-name>as.server</param-name>
        <param-value>true</param-value>
    </init-param>
    <init-param>
        <param-name>app.secret</param-name>
        <param-value>appId1=secret123;appId2=secret456</param-value>
    </init-param>
    <init-param>
        <param-name>db.config</param-name>
        <param-value>0=my_user0:[email protected]:3306/mydb0;1=my_user1:[email protected]:3306/mydb1</param-value>
    </init-param>
</servlet>

<servlet-mapping>
    <servlet-name>ServiceExporterServlet</servlet-name>
    <url-pattern>sync.api</url-pattern>
</servlet-mapping>

// 创建远程服务端
RemoteSyncServerFactory factory = new RemoteSyncServerFactory();
factory.setAppId("appId1");
factory.setAppSecret("secret123");
factory.setRemotingUrl("http://192.168.1.199/sync.api");

SyncServer syncServer = factory.createSyncServer();

// 创建单表到单表同步
TableTaskConfig tableTaskConfig = TableTaskConfig.makeSingle("my_sample_task", 0, "sample_pen", 0, "sample_pen");

// 创建单表到多表同步
TableTaskConfig tableTaskConfig = TableTaskConfig.makeOneTooManyShard("sports", 0, "my_source_table", "my_dest_table_%04d", "my_route_column", 2, 4);

// 把一个字段映射到另一个字段
tableTaskConfig.mappingColumn(...)

// 只跑全量，不跑增量
tableTaskConfig.onlyFullDump(...)

// 行数据拦截修改
tableTaskConfig.rowInterceptor(...)

// 设置批量修改拦截器
tableTaskConfig.batchInterceptor(...)

// 设置更新时间字段
tableTaskConfig.setUpdatedField(...)

// 设置分库分表路由策略
tableTaskConfig.setShardStrategy(...);

// 设置数据源额外查询条件
tableTaskConfig.sourceExtCondition(...)


// 忽略检查（建议不要忽略）
syncClient.setIgnoreCheck(...)

// 创建任务
syncClient.addTableTaskConfig(tableTaskConfig);

SyncManager syncManager = new SyncManager();
syncManager.registerSourceDbConfig(...);
syncManager.registerSourceDbConfig(...);

syncManager.registerDestDbConfig(...);
syncManager.registerDestDbConfig(...);

// 一对一迁移
syncManager.addTask(TableTaskConfig.makeSingle("my_task1", 0, "qserver_user", 0, "trans_test_user")
        // 字段名修改
        .mappingColumn("nickname2", "nickname")
        // 只支持全量
        .onlyFullDump(true)
        // 额外条件
        .sourceExtCondition("deleted = 0"));

// 一对多迁移
syncManager.addTask(TableTaskConfig.makeOneTooManyShard(
       "my_task2", 0, "table_1", "dest_table_%04d", "user_id", 2, 4).batchInterceptor(myBatchInterceptor));

syncManager.init();

syncManager.runOnce();