Spring Boot多数据源及其事务管理配置
[TOC]
准备工作
先给我们的项目添加Spring-JDBC依赖和需要访问数据库的驱动依赖。
配置文件
spring.datasource.prod.driverClassName=com.mysql.jdbc.Driver
spring.datasource.prod.url=jdbc:mysql://127.0.0.1:3306/prod
spring.datasource.prod.username=root
spring.datasource.prod.password=123456
spring.datasource.dev.driverClassName=com.mysql.jdbc.Driver
spring.datasource.dev.url=jdbc:mysql://127.0.0.1:3306/dev
spring.datasource.dev.username=root
spring.datasource.dev.password=123456
JavaConfig
首先建立Java配置类，为其添加上注解@Configuration。
@Configuration
public class JdbcConfig {
}
配置数据源
- 给其中一个数据源加上
@Primary。因为在Spring Boot Jdbc的自动配置过程中，会对于开发者透明地使用dataSource进行一些相关配置，所以当有两个Datasource实现类时，Spring Boot将无法确定使用哪一个。 - 当我们不为@Bean指定名字时，Spring会默认使用方法名作为Bean的名字，所以下面两个数据源的名字分别为
prodDataSource和devDataSource。
@Bean
@Primary
@ConfigurationProperties(prefix = "spring.datasource.prod")
public DataSource prodDataSource(){
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.dev")
public DataSource devDataSource(){
return DataSourceBuilder.create().build();
}
配置文件里的属性名是不需要写成
spring.datasource.xxx的形式的，写成a.b.c.url也没有问题，只要在配置bean时指定前缀为a.b.c
配置JdbcTemplate
- 在此我们返回的不是
JdbcTemplate的实现，而是其实现接口JdbcOperations。 - 使用
@Qualifier注解指定该注入哪个bean，默认名字为定义该bean的方法名。
@Bean
public JdbcOperations prodJdbcOperations(@Qualifier("prodDataSource") DataSource prodDataSource) {
return new JdbcTemplate(prodDataSource);
}
@Bean
public JdbcOperations devJdbcOperations(@Qualifier("devDataSource") DataSource devDataSource) {
return new JdbcTemplate(devDataSource);
}
使用
- 直接注入
JdbcOperations即可
@Autowired
private JdbcOperations devJdbcOperations;
@Autowired
private JdbcOperations prodJdbcOperations;
事务配置
开启事务管理功能
在项目入口类，添加以下注解开启事务管理功能。
@EnableTransactionManagement
配置事务管理器
@Bean
public PlatformTransactionManager prodTransactionManager(@Qualifier("prodDataSource") DataSource prodDataSource) {
return new DataSourceTransactionManager(prodDataSource);
}
@Bean
public PlatformTransactionManager devTransactionManager(@Qualifier("devDataSource") DataSource sitDataSource) {
return new DataSourceTransactionManager(sitDataSource);
}
使用
使用时只需在需要事务的方法添加注解@Transactional，并指定其value值即可。同样的，value值与相应的方法名相匹配即可。
@Transactional(value = "prodTransactionManager")
public void prod() {
prodJdbcOperations.queryForList("SELECT * FROM USER");
}
@Transactional(value = "devTransactionManager")
public void dev() {
devJdbcOperations.queryForList("SELECT * FROM USER");
}
注意，@Transactional配置事务有很多限制，如方法必须为public，同一个类中无该注解的方法调用有注解的方法事务不生效等。该注解还可以配置在接口类等地方，具体用法请参考Spring官方文档相应章节 http://docs.spring.io/spring-framework/docs/4.2.x/spring-framework-reference/html/transaction.html
