Merge pull request #7036 from dataease/pr@dev@fixSql

fix: 没有已完成的同步任务,无法进行增量同步
This commit is contained in:
taojinlong 2023-12-05 23:53:21 -06:00 committed by GitHub
commit 203352bddc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -362,13 +362,14 @@ public class ExtractDataService {
case add_scope: // 增量更新
try {
if (datasetTable.getLastUpdateTime() == null || datasetTable.getLastUpdateTime() == 0) {
throw new Exception("未进行全量同步");
}
if (datasource.getType().equalsIgnoreCase(DatasourceTypes.api.name())) {
extractData(datasetTable, datasource, datasetTableFields, "incremental_add", null);
} else {
DatasetTableIncrementalConfig datasetTableIncrementalConfig = dataSetTableService.incrementalConfig(datasetTableId);
if (datasetTable.getLastUpdateTime() == null || datasetTable.getLastUpdateTime() == 0) {
throw new Exception("未进行全量同步");
}
execTime = System.currentTimeMillis();
if (datasetTableIncrementalConfig != null && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd()) && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd().replace(" ", ""))) {// 增量添加