From f4f71e78c49293297dcfaad62a2d8aa7693e6751 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Thu, 18 Jan 2024 08:46:18 +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    | 6 +++---
 1 file changed, 3 insertions(+), 3 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 33a4a1a..4c233a4 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
@@ -165,7 +165,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
                             }).collect(Collectors.toList());
                             //插入influxdb
                             influxDBBaseService.insertBatchBySlice(tableName, list1, 10000);
-                            size = list1.size();
+//                            size = list1.size();
                             //最后一片时修改状态
                         }
                         //手动执行GC
@@ -173,7 +173,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
                         if (i == 0) {
                             jobDetailInfluxDB.setRowCount(0);
                         }
-                        jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size* TableEnum.getMultipleByCode(tableName));
+                        jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size*TableEnum.getMultipleByCode(tableName));
                         jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());
                         jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
                         if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) {
@@ -186,7 +186,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
                     } catch (Exception exception) {
                         exception.printStackTrace();
                         if (Objects.isNull(jobDetailInfluxDB)) {
-                            jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size);
+                            jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size*TableEnum.getMultipleByCode(tableName));
                         }
                         jobDetailInfluxDB.setState(2);
                         jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());