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

添加数据同步代码

Browse Source
This commit is contained in:
hzj
2024-01-08 11:14:27 +08:00
parent bf884343c6
commit e4eb924267
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlucServiceImpl.java
View File

@@ -1,6 +1,7 @@
package com.njcn.oracle.service.impl; package com.njcn.oracle.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam; import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType; import com.njcn.oracle.bo.param.ServiceType;
@@ -36,6 +37,7 @@ public class DataFlucServiceImpl extends ReplenishMybatisServiceImpl<DataFlucMap
@Override @Override
@DS("target")
public void clearTargetData(MigrationParam migrationParam) { public void clearTargetData(MigrationParam migrationParam) {
LambdaQueryWrapper<DataFluc> lambdaQueryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<DataFluc> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.between(DataFluc::getTimeid, migrationParam.getStartTime(), migrationParam.getEndTime()); lambdaQueryWrapper.between(DataFluc::getTimeid, migrationParam.getStartTime(), migrationParam.getEndTime());
@@ -46,6 +48,7 @@ public class DataFlucServiceImpl extends ReplenishMybatisServiceImpl<DataFlucMap
} }
@Override @Override
@DS("target")
public void insertBatchByDB(List<DataFluc> data) { public void insertBatchByDB(List<DataFluc> data) {
StopWatch stopWatch = new StopWatch(); StopWatch stopWatch = new StopWatch();
stopWatch.start(); stopWatch.start();

3
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataHarmphasicIServiceImpl.java
View File

@@ -1,6 +1,7 @@
package com.njcn.oracle.service.impl; package com.njcn.oracle.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.njcn.oracle.bo.param.MigrationParam; import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.bo.param.ServiceType; import com.njcn.oracle.bo.param.ServiceType;
@@ -35,6 +36,7 @@ public class DataHarmphasicIServiceImpl extends ReplenishMybatisServiceImpl<Data
} }
@Override @Override
@DS("target")
public void clearTargetData(MigrationParam migrationParam) { public void clearTargetData(MigrationParam migrationParam) {
LambdaQueryWrapper<DataHarmphasicI> lambdaQueryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<DataHarmphasicI> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.between(DataHarmphasicI::getTimeid, migrationParam.getStartTime(), migrationParam.getEndTime()); lambdaQueryWrapper.between(DataHarmphasicI::getTimeid, migrationParam.getStartTime(), migrationParam.getEndTime());
@@ -44,6 +46,7 @@ public class DataHarmphasicIServiceImpl extends ReplenishMybatisServiceImpl<Data
this.baseMapper.delete(lambdaQueryWrapper); this.baseMapper.delete(lambdaQueryWrapper);
} }
@Override @Override
@DS("target")
public void insertBatchByDB(List<DataHarmphasicI> data) { public void insertBatchByDB(List<DataHarmphasicI> data) {
StopWatch stopWatch = new StopWatch(); StopWatch stopWatch = new StopWatch();
stopWatch.start(); stopWatch.start();