2022-05-29更新,使用Spring Boot 1.5.8.RELEASE即可与Spring Boot 2.x配合使用
大多数答案并未提供如何使用它们(作为数据源本身和作为事务),只提供了如何配置它们。
此外,您还应该知道如何同时提交/回滚两个数据源的事务。
您可以在https://github.com/surasint/surasint-examples/tree/master/spring-boot-jdbi/10_spring-boot-two-databases中查看可运行示例和一些解释(请参阅README.txt中的内容)
我在这里复制了一些代码。
首先,您必须像这样设置application.properties
database1.datasource.url=jdbc:mysql://localhost/testdb
database1.datasource.username=root
database1.datasource.password=root
database1.datasource.driver-class-name=com.mysql.jdbc.Driver
database2.datasource.url=jdbc:mysql://localhost/testdb2
database2.datasource.username=root
database2.datasource.password=root
database2.datasource.driver-class-name=com.mysql.jdbc.Driver
然后像这样将它们定义为提供者(@Bean):
@Bean(name = "datasource1")
@ConfigurationProperties("database1.datasource")
@Primary
public DataSource dataSource(){
return DataSourceBuilder.create().build();
}
@Bean(name = "datasource2")
@ConfigurationProperties("database2.datasource")
public DataSource dataSource2(){
return DataSourceBuilder.create().build();
}
请注意,我有 @Bean(name="datasource1")
和 @Bean(name="datasource2")
,当我们需要数据源时,您可以使用它作为 @Qualifier("datasource1")
和 @Qualifier("datasource2")
,例如。
@Qualifier("datasource1")
@Autowired
private DataSource dataSource
如果您关心事务,您需要为它们都定义DataSourceTransactionManager,像这样:
@Bean(name="tm1")
@Autowired
@Primary
DataSourceTransactionManager tm1(@Qualifier ("datasource1") DataSource datasource) {
DataSourceTransactionManager txm = new DataSourceTransactionManager(datasource);
return txm;
}
@Bean(name="tm2")
@Autowired
DataSourceTransactionManager tm2(@Qualifier ("datasource2") DataSource datasource) {
DataSourceTransactionManager txm = new DataSourceTransactionManager(datasource);
return txm;
}
然后您可以像这样使用它
@Transactional //this will use the first datasource because it is @primary
或者
@Transactional("tm2")
最重要的部分是:如果您想要一个可以提交/回滚两个数据库事务的方法,您需要为tm1和tm2使用ChainedTransactionManager,像这样:
@Bean(name = "chainedTransactionManager")
public ChainedTransactionManager getChainedTransactionManager(@Qualifier ("tm1") DataSourceTransactionManager tm1, @Qualifier ("tm2") DataSourceTransactionManager tm2){
return new ChainedTransactionManager(tm1, tm2);
}
要使用它,在方法中添加此注释:@Transactional(value ="chainedTransactionManager"),例如
@Transactional(value="chainedTransactionManager")
public void insertAll() {
UserBean test = new UserBean();
test.setUsername("username" + new Date().getTime());
userDao.insert(test);
userDao2.insert(test);
}
这应该已经足够了。请参考上面链接中的示例和细节。