From 071c3a4b07031b58d709b1cd882e7f6ae5c0982e Mon Sep 17 00:00:00 2001 From: hongawen <83944980@qq.com> Date: Thu, 18 Jan 2024 09:13:02 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/OracleToInfluxDBServiceImpl.java | 12 +++--------- .../njcn/oracle/service/impl/OracleServiceImpl.java | 13 ++++--------- 2 files changed, 7 insertions(+), 18 deletions(-) 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 cc66598..d7bce56 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 @@ -144,25 +144,19 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { jobDetailInfluxDB.setRowCount(0); } jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size); - jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); - jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); - if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) { + if (i + 1 == slice) { 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)) { - jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size); - } jobDetailInfluxDB.setState(2); 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");