dongjunchuan/de
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 定时同步任务支持在历史数据变动后增量更新到doris中 #6276

Browse Source
This commit is contained in:
taojinlong 2024-01-24 12:47:29 +08:00
parent bd85d22922
commit 6d0edaebb7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core/backend/src/main/java/io/dataease/service/dataset/ExtractDataService.java
View File

@ -1299,9 +1299,9 @@ public class ExtractDataService {
List<UserDefinedJavaClassDef> definitions = new ArrayList<>();
String tmp_code = code.replace("handleWraps", handleWraps).replace("handleBinaryType", handleBinaryTypeCode.toString());
if (isSetKey) {
tmp_code.replace("handleDataease_uuid", "");
tmp_code = tmp_code.replace("handleDataease_uuid", "");
} else {
tmp_code.replace("handleDataease_uuid", handleDataease_uuid);
tmp_code = tmp_code.replace("handleDataease_uuid", handleDataease_uuid);
}
String Column_Fields;
@ -1455,7 +1455,7 @@ public class ExtractDataService {
" get(Fields.Out, filed).setValue(r, tmp);\n" +
" } \n";
private final static String handleDataease_uuid = "get(Fields.Out, \"dataease_uuid\").setValue(r, md5);";
private final static String handleDataease_uuid = "get(Fields.Out, \"dataease_uuid\").setValue(r, md5)";
private final static String handleCharset = "\tif(tmp != null && Arrays.asList(\"varcharFields\".split(\",\")).contains(filed)){\n" +
" \t\t\ttry {\n" +
"\t\t\t\tget(Fields.Out, filed).setValue(r, new String(tmp.getBytes(\"Datasource_Charset\"), \"Target_Charset\"));\n" +
@ -1502,7 +1502,7 @@ public class ExtractDataService {
" }\n" +
"\n" +
" String md5 = md5(str);\n" +
" handleDataease_uuid\n" +
" handleDataease_uuid ;\n" +
"\n" +
" putRow(data.outputRowMeta, r);\n" +
"\n" +