datax-web ExecutorJobHandler如何修改源碼解決sqlserver時間格式不識別時間字符串中的%

今天就跟大家聊聊有關datax-web ExecutorJobHandler如何修改源碼解決sqlserver時間格式不識別時間字符串中的%，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

問題：

select * from dbo.SKJJGWFGXX where (i_time >= '1980-01-01%00:00:00' and i_time < '2020-12-15%15:25:40') 具體錯誤信息為：com.microsoft.sqlserver.jdbc.SQLServerException: 從字符串轉換日期和/或時間時，轉換失敗。

時間字符串中帶%，mysql數據庫能識別并正確執(zhí)行，而sqlserver數據庫（2008）不能識別，造成查詢失敗。

如果此問題不解決，那么從sqlserver到mysql的數據同步中，無法采用時間增量方式進行數據實時同步。

在java中和python中都嘗試把“%”換成空格，最后的結果都是無法運行。估計是在命令行中做為參數傳入時，空格本身是特殊符號，用于分開命令和參數的，強行替換，最后導致時間字符串被分成兩段接收。

解決方案：

修改ExecutorJobHandler,生成job臨時文件時，把臨時文件中的變量用具體值進行替換。

定義了一個新的處理方法：replaceJobJsonParams

// zhuangxl 2020.12.15 替換開始

String jobJson = new String(trigger.getJobJson());

jobJson = replaceJobJsonParams(jobJson, trigger);

tmpFilePath = generateTemJsonFile(jobJson);

// zhuangxl 2020.12.15 替換結束

/**

 * 替換job文件參數

 * @author zhuangxl

 * @param jobJson

 * @return

 */

private String replaceJobJsonParams(String jobJson, TriggerParam trigger) {

    if (IncrementTypeEnum.TIME.getCode() == trigger.getIncrementType()) {

        String replaceParamType = trigger.getReplaceParamType();

        //類別：時間自增，只操作指定了具體的時間格式的類型

        if (StringUtils.isNotBlank(replaceParamType) && !replaceParamType.equals("Timestamp")) {

            //格式化時間字符串

            SimpleDateFormat sdf = new SimpleDateFormat(replaceParamType);

            String endTime_ = sdf.format(trigger.getTriggerTime());

            String startTime_ = sdf.format(trigger.getStartTime());

            //識別要替換的時間變量名稱

            String[] replaceParams = trigger.getReplaceParam().split(" ");

            String startTimeStr = replaceParams[0].substring(replaceParams[0].indexOf("D")+1, replaceParams[0].indexOf("="));

            String endTimeStr = replaceParams[1].substring(replaceParams[1].indexOf("D")+1, replaceParams[1].indexOf("="));

            //執(zhí)行變量替換

            jobJson = jobJson.replace("${"+startTimeStr+"}", "'"+startTime_+"'");

            jobJson = jobJson.replace("${"+endTimeStr+"}", "'"+endTime_+"'");

        }

    }

    return jobJson;

}

看完上述內容，你們對datax-web ExecutorJobHandler如何修改源碼解決sqlserver時間格式不識別時間字符串中的%有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業(yè)資訊頻道，感謝大家的支持。