springboot连接两个数据库

素颜马尾好姑娘i 2023-10-05 23:41 40阅读 0赞

### springboot连接两个数据库 ###

一、启动类  
1.启动类需要不用加mybatis的@MapperScan注解

@SpringBootApplication
    public class AppPush {
        
        public static void main(String[] args) {
        
            SpringApplication.run(AppPush.class,args);
        }
    }

二、application.yml文件  
配置俩个或多个数据库连接

spring:
      datasource:
         driver-class-name: com.mysql.jdbc.Driver
         url: jdbc:postgresql://127.0.0.1/aaa
         username: root
         password: root
          one:
            driver-class-name: com.mysql.jdbc.Driver
            url: jdbc:mysql://127.0.0.1/aaa
            username: root
            password: root
          two:
            driver-class-name: org.postgresql.Driver
            url: jdbc:mysql://127.0.0.1/bbb
            username: root
            password: root

三、创建配置类  
1.注意：@MapperScan 的basePackages就是你包的路径 ，  
sqlSessionFactoryRef 可以随便起名 但是着两个类不能重复！

One配置类

/**
     * @program:  
     * @description: 数据库配置1
     * @author: 
     * @create: 
     **/
    @Configuration
    @MapperScan(basePackages = "com.wys.mapper.**", sqlSessionFactoryRef = "oneSqlSessionFactory")
    public class OneDataSourceConfig {
        
        @Value("${spring.datasource.one.driver-class-name}")
        String driverClass;
        @Value("${spring.datasource.one.url}")
        String url;
        @Value("${spring.datasource.one.username}")
        String userName;
        @Value("${spring.datasource.one.password}")
        String passWord;
    
        @Primary
        @Bean(name = "oneDataSource")
        @ConfigurationProperties("spring.datasource.one")
        public DataSource masterDataSource() {
        
            DriverManagerDataSource dataSource = new DriverManagerDataSource();
            dataSource.setDriverClassName(driverClass);
            dataSource.setUrl(url);
            dataSource.setUsername(userName);
            dataSource.setPassword(passWord);
            return dataSource;
        }
    
        @Bean(name = "oneSqlSessionFactory")
        public SqlSessionFactory sqlSessionFactory(@Qualifier("oneDataSource") DataSource dataSource) throws Exception {
        
            SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
            sessionFactoryBean.setDataSource(dataSource);
            sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                    .getResources("classpath:mybatis/mapper-postgre/*.xml"));
            
            return sessionFactoryBean.getObject();
        }
        @Bean(name = "oneSqlSessionTemplate")
        public SqlSessionTemplate sqlSessionFactoryTemplate(@Qualifier("oneSqlSessionFactory")SqlSessionFactory sqlSessionFactory ) throws Exception {
        
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

Two配置类

/**
     * @program:  
     * @description: 数据库配置2
     * @author: 
     * @create: 
     **/
    @Configuration
    @MapperScan(basePackages = "com.wys.mappers",sqlSessionFactoryRef = "twoSqlSessionFactory")
    public class TwoDataSourceConfig {
        
    
        @Value("${spring.datasource.two.driver-class-name}")
        String driverClass;
        @Value("${spring.datasource.two.url}")
        String url;
        @Value("${spring.datasource.two.username}")
        String userName;
        @Value("${spring.datasource.two.password}")
        String passWord;
        
        @Bean(name = "twoDataSource")
        @ConfigurationProperties("spring.datasource.two")
        public DataSource masterDataSource(){
        
            DriverManagerDataSource dataSource = new DriverManagerDataSource();
            dataSource.setDriverClassName(driverClass);
            dataSource.setUrl(url);
            dataSource.setUsername(userName);
            dataSource.setPassword(passWord);
            return dataSource;
        }
    
        @Bean(name = "twoSqlSessionFactory")
        public SqlSessionFactory sqlSessionFactory(@Qualifier("twoDataSource") DataSource dataSource) throws Exception {
        
            SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
            sessionFactoryBean.setDataSource(dataSource);
            sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
                    .getResources("classpath:mybatis/mapper-postgres/*.xml"));
             
            return sessionFactoryBean.getObject();
        }
        
        @Bean(name = "twoSqlSessionTemplate")
        public SqlSessionTemplate sqlSessionFactoryTemplate(@Qualifier("twoSqlSessionFactory")SqlSessionFactory sqlSessionFactory ) throws Exception {
        
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

四 、结构  
可能有人不清楚项目的结构，我在下面放了一张类结构图，能更清晰和方便理解。  
注意：和之前的项目的主要区别就是 mapper包多了一个，mapper的xml包也多了一个，不同的数据库mapper放到不同的包内就可以了。  
![在这里插入图片描述][98ac505e6e664c6abee555406b9642b3.jpeg_pic_center]

[98ac505e6e664c6abee555406b9642b3.jpeg_pic_center]: https://img-blog.csdnimg.cn/98ac505e6e664c6abee555406b9642b3.jpeg#pic_center