Spring Boot 2 多个数据源初始化架构

# 使用Spring Boot 2实现多数据源初始化架构

properties
# 数据源1
spring.datasource.datasource1.url=jdbc:mysql://localhost:3306/db1
spring.datasource.datasource1.username=root
spring.datasource.datasource1.password=root
spring.datasource.datasource1.driver-class-name=com.mysql.cj.jdbc.Driver
# 数据源2
spring.datasource.datasource2.url=jdbc:mysql://localhost:3306/db2
spring.datasource.datasource2.username=root
spring.datasource.datasource2.password=root
spring.datasource.datasource2.driver-class-name=com.mysql.cj.jdbc.Driver

java
@Configuration
public class DataSourceConfig {
    @Primary
    @Bean(name = "datasource1")
    @ConfigurationProperties(prefix = "spring.datasource.datasource1")
    public DataSource dataSource1() {
        return DataSourceBuilder.create().build();
    }
    @Bean(name = "datasource2")
    @ConfigurationProperties(prefix = "spring.datasource.datasource2")
    public DataSource dataSource2() {
        return DataSourceBuilder.create().build();
    }
}

java
@Configuration
public class JdbcTemplateConfig {
    @Primary
    @Bean(name = "jdbcTemplate1")
    public JdbcTemplate jdbcTemplate1(@Qualifier("datasource1") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
    @Bean(name = "jdbcTemplate2")
    public JdbcTemplate jdbcTemplate2(@Qualifier("datasource2") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
}

java
@Service
public class MultiDataSourceService {
    @Autowired
    @Qualifier("jdbcTemplate1")
    private JdbcTemplate jdbcTemplate1;
    @Autowired
    @Qualifier("jdbcTemplate2")
    private JdbcTemplate jdbcTemplate2;
    public List> getDataFromDataSource1() {
        return jdbcTemplate1.queryForList("SELECT * FROM table1");
    }
    public List> getDataFromDataSource2() {
        return jdbcTemplate2.queryForList("SELECT * FROM table2");
    }
}