Spring Boot多数据源及其事务管理配置方法
准备工作
先给我们的项目添加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
。
bean的入参spring会自动其相符合的bean注入,所以在此我们不需要@autowired相应的bean再使用。
spring会将变量名与bean的名字做关联。在此我们入参数据源的名称和上面数据源bean的方法名相匹配,所以也不需要用@qualifier注解指定是哪个bean。
@bean public jdbcoperations prodjdbcoperations(datasource proddatasource) { return new jdbctemplate(proddatasource); } @bean public jdbcoperations devjdbcoperations(datasource devdatasource) { return new jdbctemplate(devdatasource); }
使用
直接注入jdbcoperations
即可
如上文的说明,不需要@qualifier
等的注解。
@autowired private jdbcoperations devjdbcoperations; @autowired private jdbcoperations prodjdbcoperations;
事务配置
开启事务管理功能
在项目入口类,添加以下注解开启事务管理功能。
@enabletransactionmanagement
配置事务管理器
@bean public platformtransactionmanager prodtransactionmanager(datasource proddatasource) { return new datasourcetransactionmanager(proddatasource); } @bean public platformtransactionmanager devtransactionmanager(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官方文档相应章节
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
上一篇: java抓取网页或文件中的邮箱号码