From 013e8ffc7305b706b40c45ff5e831927a5f0bc12 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Thu, 18 Jan 2024 14:41:44 +0800 Subject: [PATCH] =?UTF-8?q?oralce=E5=90=8C=E6=AD=A5=E5=88=B0influxDB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../influx/service/impl/OracleToInfluxDBServiceImpl.java | 7 +------ 1 file changed, 1 insertion(+), 6 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 afab797..22f8727 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 @@ -174,9 +174,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { jobDetailInfluxDB.setRowCount(0); } jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size*TableEnum.getMultipleByCode(tableName)); - 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()); @@ -185,9 +183,6 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService { jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); } catch (Exception exception) { exception.printStackTrace(); - if (Objects.isNull(jobDetailInfluxDB)) { - jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size*TableEnum.getMultipleByCode(tableName)); - } jobDetailInfluxDB.setState(2); jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);