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 14:41:44 +08:00
parent 0abf1bdceb
commit 013e8ffc73
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -174,9 +174,7 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
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()); if (i + 1 == slice) {
jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) {
stopWatch.stop(); stopWatch.stop();
jobDetailInfluxDB.setState(1); jobDetailInfluxDB.setState(1);
jobDetailInfluxDB.setDuration(stopWatch.getTotalTimeSeconds()); jobDetailInfluxDB.setDuration(stopWatch.getTotalTimeSeconds());
@@ -185,9 +183,6 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
} catch (Exception exception) { } catch (Exception exception) {
exception.printStackTrace(); exception.printStackTrace();
if (Objects.isNull(jobDetailInfluxDB)) {
jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, size*TableEnum.getMultipleByCode(tableName));
}
jobDetailInfluxDB.setState(2); jobDetailInfluxDB.setState(2);
jobDetailInfluxDB.setUpdateTime(LocalDateTime.now()); jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());
jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB); jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);