添加多数据源

SZH

2022-06-29 00a4338443d09932ed4c56266d8c4e73ff60b46c

 safePlatfrom-out-web/src/main/java/com/gkhy/safePlatform/config/database/MyBatisConfigEmergency.java

文件名从 safePlatfrom-out-web/src/main/java/com/gkhy/safePlatform/config/database/MyBatisConfigOne.java 修改
@@ -23,26 +23,26 @@
import java.util.Arrays;

@Configuration
@MapperScan(basePackages = {"com.gkhy.safePlatform.emergency","com.gkhy.safePlatform.goalManage"},
        sqlSessionTemplateRef = "sqlTemplate1",annotationClass =
@MapperScan(basePackages = {"com.gkhy.safePlatform.emergency","com.gkhy.safePlatform.emergency"},
        sqlSessionTemplateRef = "sqlTemplateEmergency",annotationClass =
        Repository.class)
public class MyBatisConfigOne {
public class MyBatisConfigEmergency {

    @Autowired
    @Qualifier("dsOne")
    DataSource dsOne;
    @Qualifier("dsEmergency")
    DataSource dsEmergency;

    @Autowired
    private MybatisPlusInterceptor mybatisPlusInterceptor;

    @Bean(name = "datasource1")
    @ConfigurationProperties(prefix = "spring.datasource.one")
    @Bean(name = "datasourceEmergency")
    @ConfigurationProperties(prefix = "spring.datasource.emergency")
    public DruidDataSource druidDataSourceA(){
        return DruidDataSourceBuilder.create().build();
    }

    @Bean(name = "sqlFactory1")
    public SqlSessionFactory sqlSessionFactory(@Qualifier("datasource1") DruidDataSource dataSource)
    @Bean(name = "sqlFactoryEmergency")
    public SqlSessionFactory sqlSessionFactory(@Qualifier("datasourceEmergency") DruidDataSource dataSource)
            throws Exception
    {
        MybatisSqlSessionFactoryBean factoryBean = new MybatisSqlSessionFactoryBean();
@@ -51,9 +51,9 @@

        //-------------------
        Resource[] rs1 = resolver.getResources("classpath*:config/mapper/emergency/**Mapper.xml");
        Resource[] rs2 = resolver.getResources("classpath*:config/mapper/goalManage/**Mapper.xml");
//        Resource[] rs2 = resolver.getResources("classpath*:config/mapper/goalManage/**Mapper.xml");
        ArrayList<Resource> resourceArrayList = new ArrayList<>(Arrays.asList(rs1));
        resourceArrayList.addAll(new ArrayList<>(Arrays.asList(rs2)));
//        resourceArrayList.addAll(new ArrayList<>(Arrays.asList(rs2)));
        Resource[] resourceArray = new Resource[resourceArrayList.size()];
        resourceArrayList.toArray(resourceArray);
        factoryBean.setMapperLocations(resourceArray);
@@ -66,8 +66,8 @@
        return factoryBean.getObject();
    }

    @Bean(name = "sqlTemplate1")
    public SqlSessionTemplate sqlSessionTemplate(@Qualifier("sqlFactory1") SqlSessionFactory sqlSessionFactory)
    @Bean(name = "sqlTemplateEmergency")
    public SqlSessionTemplate sqlSessionTemplate(@Qualifier("sqlFactoryEmergency") SqlSessionFactory sqlSessionFactory)
    {
        return new SqlSessionTemplate(sqlSessionFactory);
    }