springboot多数据源配置

Posted 2022-04-09 盖丽男

背景

现阶段公司的各种基础设施都不是很完善，所以很多开发内容都打算放到一个项目里，这就涉及到连接多个数据库的问题，我们的服务之前是单数据源的，所以要改成多数据源的。

代码

修改前

现在其实将项目修改成多数据源还是很简单的，首先看一下单数据源的时候配置是啥样的：

spring:
  datasource:
    username: db_username
    password: WXx9sisvzqfbU
    url: jdbc:mysql://localhost:3306/db_name?useUnicode=true&characterEncoding=utf-8&useSSL=false&zeroDateTimeBehavior=CONVERT_TO_NULL
    hikari:
      minimum-idle: 5 #最小连接数
      maximum-pool-size: 10  #池中最大连接数
      connection-timeout: 20000 #连接超时时间
      idle-timeout: 30000 # 空闲等待时间 ms
      auto-commit: true #
      max-lifetime: 1800000 #30分

一般来说，但数据源不需要我们另外写代码去配置啥了，直接在启动类上加上mapperScan就可以啦。

修改后

多数据源的时候，首先我们是有多个database的配置的，如下：

spring:
  datasource:
    db1:
      username: db_username
      password: DHofwWXx9sisvzqfbU16
      jdbc-url: jdbc:mysql://localhost:3306/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&zeroDateTimeBehavior=CONVERT_TO_NULL
      hikari:
        minimum-idle: 5 #最小连接数
        maximum-pool-size: 10  #池中最大连接数
        connection-timeout: 20000 #连接超时时间
        idle-timeout: 30000 # 空闲等待时间 ms
        auto-commit: true #
        max-lifetime: 1800000 #30分钟
    db2:
      username: db_username
      password: 71vFADHofwWXx9
      jdbc-url: jdbc:mysql://localhost:3306/db2?useUnicode=true&characterEncoding=utf-8&useSSL=false&zeroDateTimeBehavior=CONVERT_TO_NULL
      hikari:
        minimum-idle: 5 #最小连接数
        maximum-pool-size: 10  #池中最大连接数
        connection-timeout: 20000 #连接超时时间
        idle-timeout: 30000 # 空闲等待时间 ms
        auto-commit: true #
        max-lifetime: 1800000 #30分钟

此处注意一下，url变成了jdbc-url，如果配置了driverClassName的话，也要改成driver-class-name。
配置文件改好之后，还需要对应的代码配置，两个文件如下：

@Configuration
public class DataSourceConfig 

    @Primary
    @Bean(name = "db1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    public DataSource db1DataSource()
        return DataSourceBuilder.create().build();
    

    @Bean(name = "db2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.db2")
    public DataSource db2DataSource()
        return DataSourceBuilder.create().build();
    

另一个给一个db1的例子，db2照着抄一个就可以：

@Configuration
@MapperScan(basePackages = "com.test.dao.db1",sqlSessionFactoryRef = "db1SqlSessionFactory")
public class DB1Config 

    @Resource(name = "db1DataSource")
    private DataSource dataSource;

    @Bean
    public SqlSessionFactory db1SqlSessionFactory() throws Exception
        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/db1/*.xml"));
        return factoryBean.getObject();
    
    @Bean
    public SqlSessionTemplate sqlSessionTemplateGk() throws Exception 
        return new SqlSessionTemplate(db1SqlSessionFactory());
    

然后记得把自己的mapper.xml和mapper.java放到对应的文件夹下，启动就可以了。

总结

以前每次搞多数据源都整的很复杂，现在简单多了，所以记录一下。