diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java index 39747dc..0ab3e6a 100644 --- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java +++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/mybatis/service/IReplenishMybatisService.java @@ -15,7 +15,6 @@ import java.util.List; */ public interface IReplenishMybatisService extends IService { - ServiceType getServiceType(); /*** * 当批量插入数据量过大时,可以指定尺寸交给mybatis,每次插入多少条记录 diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java deleted file mode 100644 index 0b7b7c9..0000000 --- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/ServiceExecutorStore.java +++ /dev/null @@ -1,44 +0,0 @@ -package com.njcn.oracle.service; - -import com.njcn.oracle.bo.param.ServiceType; -import com.njcn.oracle.mybatis.service.IReplenishMybatisService; -import lombok.extern.slf4j.Slf4j; -import org.apache.commons.lang3.tuple.Pair; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; - -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -/** - * Description: - * Date: 2024/1/4 13:43【需求编号】 - * - * @author clam - * @version V1.0.0 - */ -@Service -@Slf4j -public class ServiceExecutorStore { - - private final Map annotationMap = new HashMap<>(); - - @Autowired - public ServiceExecutorStore(List Services) { - for (IReplenishMybatisService executor : Services) { - annotationMap.put(executor.getServiceType().name(),executor); - } - for (ServiceType type : ServiceType.getExecutableTypes()) { - log.info("ServiceType [{}] doesn't have ServiceType executor", type); - - } - - } - - - public IReplenishMybatisService getExecutor(String serviceType) { - IReplenishMybatisService executor = annotationMap.get(serviceType); - return executor; - } -} diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java index 7f36b7e..ecad38e 100644 --- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java +++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataFlickerServiceImpl.java @@ -50,10 +50,6 @@ public class DataFlickerServiceImpl extends ReplenishMybatisServiceImpl tableNames = migrationParam.getTableNames(); tableNames.stream().forEach(temp->{ -// IReplenishMybatisService executor = (IReplenishMybatisService)SpringUtil.getBean("com.njcn.oracle.service.impl." + temp + "ServiceImpl"); - IReplenishMybatisService executor = serviceExecutorStore.getExecutor(temp); + IReplenishMybatisService executor = null; + try { + executor = (IReplenishMybatisService) SpringUtil.getBean(Class.forName("com.njcn.oracle.service.impl." + temp + "ServiceImpl")); + } catch (ClassNotFoundException e) { + throw new RuntimeException(e); + } List list = executor.queryData(migrationParam); if(CollectionUtil.isNotEmpty(list)){ executor.clearTargetData(migrationParam);