背景
现阶段公司的各种基础设施都不是很完善,所以很多开发内容都打算放到一个项目里,这就涉及到连接多个数据库的问题,我们的服务之前是单数据源的,所以要改成多数据源的。
代码
修改前
现在其实将项目修改成多数据源还是很简单的,首先看一下单数据源的时候配置是啥样的:
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放到对应的文件夹下,启动就可以了。
总结
以前每次搞多数据源都整的很复杂,现在简单多了,所以记录一下。