SpringBoot和SpringJDBC多数据源
我尝试在我的SpringBoot应用程序中使用两个数据源，但无法将第二个数据源自动连接。我尝试过很多方法，但这是我最接近的方法：
我的Yaml文件：
spring:
first-datasource:
url: MyURLString1
username: User
password: Password
driver-class-name: oracle.jdbc.OracleDriver
second-datasource:
url: MyURLString2
username: User
password: Password
driver-class-name: oracle.jdbc.OracleDriver我的应用程序类：
@SpringBootApplication
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
@Bean
@Primary
@ConfigurationProperties(prefix = "spring.first-datasource")
public DataSource firstDataSource() {
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.second-datasource")
public DataSource secondDataSource() {
return DataSourceBuilder.create().build();
}
}最后是我的DAO：
@Repository
public class MyDao {
private static final String FIRST_SELECT = "select * from SomeTableInDB1";
private static final String SECOND_SELECT = "select * from AnotherTableInDB2";
@Autowired
private JdbcTemplate firstJdbcTemplate;
@Autowired
@Qualifier("secondDataSource")
private JdbcTemplate secondJdbcTemplate;
List<DB1Entity> getDB1Entity(Long id) {
return firstJdbcTemplate.query(FIRST_SELECT, new Object[] {id}, new BeanPropertyRowMapper(DB1Entity.class));
}
List<DB2Entity> getDB2Entity(Long id) {
return secondJdbcTemplate.query(SECOND_SELECT, new Object[] {id}, new BeanPropertyRowMapper(DB2Entity.class));
}
}这是我到目前为止最接近的一次。我之所以说它是最近的，是因为如果我删除@限定符，那么我的两个dao方法实际上都可以工作，假设对于我的DB1来说SECOND_SELECT语句是有效的SQL。一旦我为我的非主数据源添加了@限定符，我就会得到一个自动布线错误，因为Spring期望的是一个数据源对象，而不是一个JdbcTemplate对象。这对我来说很奇怪，因为它确实适用于主数据源。
下面是我的错误：
无法自动布线字段:私有org.springframework.jdbc.core.JdbcTemplate org.my.classpath.secondJdbcTemplate；嵌套异常为org.springframework.beans.factory.NoSuchBeanDefinitionException:找不到依赖项类型为org.springframework.jdbc.core.JdbcTemplate的限定bean :应至少有1个bean符合此依赖项的自动布线候选条件。依赖关系注释：{@org.springframework.beans.factory.annotation.Autowired(required=true)，@org.springframework.beans.factory.annotation.Qualifier(value=secondDataSource)}
回答 3
Stack Overflow用户
发布于 2016-05-19 10:23:36
理想情况下，其中一个数据源应该被标记为主要数据源，以便通过注释进行大多数默认连接。此外，我们需要分别为每个数据源创建TransactionManagers，否则Spring将不知道如何执行事务。下面是一个完整的示例，说明应该如何做到这一点
@Primary
@Bean(name = "dataSource")
@ConfigurationProperties(prefix="datasource.mysql")
public DataSource dataSource() {
return DataSourceBuilder.create().build();
}
@Primary
@Bean(name = "transactionManager")
public DataSourceTransactionManager transactionManager(@Qualifier("dataSource") DataSource dataSource) {
return new DataSourceTransactionManager();
}
@Bean(name = "postGresDataSource")
@ConfigurationProperties(prefix="datasource.postgres")
public DataSource postgresDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "postGresTransactionManager")
public DataSourceTransactionManager transactionManager(@Qualifier("postGresDataSource") DataSource dataSource) {
return new DataSourceTransactionManager();
}
@Transactional(transactionManager="postGresTransactionManager")
public void createCustomer(Customer cust) {
customerDAO.create(cust);
}
// specifying a transactionManager attribute is optional if we
// want to use the default transactionManager since we
// already marked one of the TM above with @Primary
@Transactional
public void createOrder(Order order) {
orderDAO.create(order);
}希望这能有所帮助。
Stack Overflow用户
发布于 2016-08-22 19:59:24
这里还提供了另一个让我困惑了几天的“不能工作”的情况：
当在Springboot应用程序中配置两个相同类型的数据源时，@Qualifier不能像预期的那样工作来选择正确的bean。它的行为就像Spring框架无法识别它一样。
原因是当使用包含@EnableAutoConfiguration注释的@SpringbootApplication注释时，在Springboot中，它将自动配置它为用户提供的数据源。
这将极大地影响@Qualifier的行为。
Stack Overflow用户
发布于 2019-05-16 00:49:25
在我的例子中，遵循@Aman Tuladhar的答案，是这样工作的：(Spring Boot 2.1.3.RELEASE)
@Configuration
public class JDBCConfig {
@Bean("first-datasource")
public JdbcTemplate paymentsJDBCTemplate(@Qualifier("first-db") DataSource paymentsDataSource){
return new JdbcTemplate(paymentsDataSource);
}
@Bean("second-datasource")
public JdbcTemplate parametersJDBCTemplate(@Qualifier("second-db") DataSource paramsDataSource){
return new JdbcTemplate(paramsDataSource);
}
@Bean("first-db")
public DataSource paymentsDataSource(Environment env) {
return buildDataSource(env, "first");
}
@Bean("second-db")
public DataSource paramsDataSource(Environment env) {
return buildDataSource(env, "second");
}
private DataSource buildDataSource(Environment env, String prop) {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(env.getProperty("spring."+prop+"-datasource.driver-class-name"));
dataSource.setUrl(env.getProperty("spring."+prop+"-datasource.url"));
dataSource.setUsername(env.getProperty("spring."+prop+"-datasource.username"));
dataSource.setPassword(env.getProperty("spring."+prop+"-datasource.password"));
return dataSource;
}
}..。像这样使用：
@Autowired @Qualifier("first-datasource")
private JdbcTemplate jdbcTemplate1;
@Autowired @Qualifier("second-datasource")
private JdbcTemplate jdbcTemplate2;..。application.yml：
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: ${DATABASE_1_URL}
username: ${DATABASE_1_USERNAME}
password: ${DATABASE_1_PASSWORD}
second-datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: ${DATABASE_2_URL}
username: ${DATABASE_2_USERNAME}
password: ${DATABASE_2_PASSWORD}https://stackoverflow.com/questions/37287677
复制相似问题