Other/data-migration
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

oralce同步到influxDB

Browse Source
This commit is contained in:
hzj
2024-01-18 08:46:18 +08:00
parent c45ff6d110
commit f4f71e78c4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleToInfluxDBServiceImpl.java
View File

@@ -165,7 +165,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
}).collect(Collectors.toList()); }).collect(Collectors.toList());
//插入influxdb //插入influxdb
influxDBBaseService.insertBatchBySlice(tableName, list1, 10000); influxDBBaseService.insertBatchBySlice(tableName, list1, 10000);
size = list1.size(); // size = list1.size();
//最后一片时修改状态 //最后一片时修改状态
} }
//手动执行GC //手动执行GC
@@ -173,7 +173,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
if (i == 0) { if (i == 0) {
jobDetailInfluxDB.setRowCount(0); jobDetailInfluxDB.setRowCount(0);
} }
jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size* TableEnum.getMultipleByCode(tableName)); jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size*TableEnum.getMultipleByCode(tableName));
jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());
jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) { if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) {
@@ -186,7 +186,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
} catch (Exception exception) { } catch (Exception exception) {
exception.printStackTrace(); exception.printStackTrace();
if (Objects.isNull(jobDetailInfluxDB)) { if (Objects.isNull(jobDetailInfluxDB)) {
jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size); jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size*TableEnum.getMultipleByCode(tableName));
} }
jobDetailInfluxDB.setState(2); jobDetailInfluxDB.setState(2);
jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());