v6.7.0 功能改进

数据同步DB导出插件改进:支持为sql语句额外指定同步条件进行全量或者定时增量导入

定时按特定条件导入数据

importBuilder.setSql("select * from batchtest1 where optime >= #[start_optime] and optime < #[end_optime]");

        importBuilder.addParam("start_optime", TimeUtil.parserDate("yyyy-MM-dd HH🇲🇲ss","2018-03-21 00:27:21"))
                .addParam("end_optime",TimeUtil.parserDate("yyyy-MM-dd HH🇲🇲ss","2019-12-30 00:27:21"));

定时按特定条件增量导入数据

importBuilder.setSql("select * from batchtest1 where optime >= #[start_optime] and optime < #[end_optime] and collecttime > #[collecttime]");
        importBuilder.setLastValueColumn("collecttime");
        importBuilder.setLastValueType(ImportIncreamentConfig.TIMESTAMP_TYPE);

        importBuilder.addParam("start_optime", TimeUtil.parserDate("yyyy-MM-dd HH🇲🇲ss","2018-03-21 00:27:21"))
                .addParam("end_optime",TimeUtil.parserDate("yyyy-MM-dd HH🇲🇲ss","2019-12-30 00:27:21"));