diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java index 4c233a4..afab797 100644 --- a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java +++ b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java @@ -180,9 +180,9 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { stopWatch.stop(); jobDetailInfluxDB.setState(1); jobDetailInfluxDB.setDuration(stopWatch.getTotalTimeSeconds()); - jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); - jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); } + jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); + jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); } catch (Exception exception) { exception.printStackTrace(); if (Objects.isNull(jobDetailInfluxDB)) { @@ -192,7 +192,6 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); } - System.out.println("执行后总堆内存为:" + runtime.totalMemory() / (1024 * 1024) + " MB"); System.out.println("执行后已用堆内存为:" + (runtime.totalMemory() - runtime.freeMemory()) / (1024 * 1024) + " MB"); System.out.println("执行后空闲堆内存为:" + runtime.freeMemory() / (1024 * 1024) + " MB"); diff --git a/oracle-data/oracle-target/src/main/java/com/njcn/oracle/service/impl/OracleServiceImpl.java b/oracle-data/oracle-target/src/main/java/com/njcn/oracle/service/impl/OracleServiceImpl.java index 475a8a7..2c5e8bb 100644 --- a/oracle-data/oracle-target/src/main/java/com/njcn/oracle/service/impl/OracleServiceImpl.java +++ b/oracle-data/oracle-target/src/main/java/com/njcn/oracle/service/impl/OracleServiceImpl.java @@ -108,25 +108,20 @@ public class OracleServiceImpl implements IOracleService { jobDetail.setRowCount(0); } jobDetail.setRowCount(jobDetail.getRowCount() + size); - jobDetail.setUpdateTime(LocalDateTime.now()); - jobDetailService.updateByMultiId(jobDetail); - if (i + 1 == slice && Objects.nonNull(jobDetail)) { + if (i + 1 == slice) { stopWatch.stop(); jobDetail.setState(1); jobDetail.setDuration(stopWatch.getTotalTimeSeconds()); - jobDetail.setUpdateTime(LocalDateTime.now()); - jobDetailService.updateByMultiId(jobDetail); } + jobDetail.setUpdateTime(LocalDateTime.now()); + jobDetailService.updateByMultiId(jobDetail); } catch (Exception exception) { exception.printStackTrace(); - if (Objects.isNull(jobDetail)) { - jobDetail = new JobDetail(tableName, date, size); - } + jobDetail.setState(2); jobDetail.setUpdateTime(LocalDateTime.now()); jobDetailService.updateByMultiId(jobDetail); } - System.out.println("执行后总堆内存为:" + runtime.totalMemory() / (1024 * 1024) + " MB"); System.out.println("执行后已用堆内存为:" + (runtime.totalMemory() - runtime.freeMemory()) / (1024 * 1024) + " MB"); System.out.println("执行后空闲堆内存为:" + runtime.freeMemory() / (1024 * 1024) + " MB");