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

代码调整

Browse Source
This commit is contained in:
hongawen
2024-01-17 10:17:29 +08:00
parent 47d31095b9
commit 75ead46195
2 changed files with 19 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -77,6 +77,10 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
//如果该指标当前天已执行或正在执行，直接跳出循环
break;
}
if (Objects.isNull(jobDetailInfluxDB)) {
jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, 0, 0, LocalDateTime.now());
jobDetailInfluxDBService.save(jobDetailInfluxDB);
}
//程序监听
StopWatch stopWatch = new StopWatch();
stopWatch.start();
@@ -136,18 +140,12 @@ public class OracleToInfluxDBServiceImpl implements OracleToInfluxDBService {
}
//手动执行GC
System.gc();
if (Objects.nonNull(jobDetailInfluxDB)) {
if (i == 0) {
jobDetailInfluxDB.setState(0);
jobDetailInfluxDB.setRowCount(0);
}
jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size);
jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());
jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
} else {
jobDetailInfluxDB = new JobDetailInfluxDB(tableName, date, 0, size, LocalDateTime.now());
jobDetailInfluxDBService.save(jobDetailInfluxDB);
if (i == 0) {
jobDetailInfluxDB.setRowCount(0);
}
jobDetailInfluxDB.setRowCount(jobDetailInfluxDB.getRowCount() + size);
jobDetailInfluxDB.setUpdateTime(LocalDateTime.now());
jobDetailInfluxDBService.updateByMultiId(jobDetailInfluxDB);
if (i + 1 == slice && Objects.nonNull(jobDetailInfluxDB)) {
stopWatch.stop();
jobDetailInfluxDB.setState(1);

21
oracle-data/oracle-target/src/main/java/com/njcn/oracle/service/impl/OracleServiceImpl.java
View File

@@ -68,6 +68,11 @@ public class OracleServiceImpl implements IOracleService {
//如果该指标当前天已执行或正在执行，直接跳出循环
break;
}
if (Objects.isNull(jobDetail)) {
jobDetail = new JobDetail(tableName, date, 0, 0, LocalDateTime.now());
jobDetailService.save(jobDetail);
}
//程序监听
StopWatch stopWatch = new StopWatch();
stopWatch.start();
@@ -99,18 +104,12 @@ public class OracleServiceImpl implements IOracleService {
}
//手动执行GC
System.gc();
if (Objects.nonNull(jobDetail)) {
if (i == 0) {
jobDetail.setState(0);
jobDetail.setRowCount(0);
}
jobDetail.setRowCount(jobDetail.getRowCount() + size);
jobDetail.setUpdateTime(LocalDateTime.now());
jobDetailService.updateByMultiId(jobDetail);
} else {
jobDetail = new JobDetail(tableName, date, 0, size, LocalDateTime.now());
jobDetailService.save(jobDetail);
if (i == 0) {
jobDetail.setRowCount(0);
}
jobDetail.setRowCount(jobDetail.getRowCount() + size);
jobDetail.setUpdateTime(LocalDateTime.now());
jobDetailService.updateByMultiId(jobDetail);
if (i + 1 == slice && Objects.nonNull(jobDetail)) {
stopWatch.stop();
jobDetail.setState(1);