Spring Boot 中的多个 DataSource 和 JdbcTemplate ( 1.1.0)

在Spring Boot中，我们经常需要连接多个数据库，并且使用JdbcTemplate来执行SQL操作。在Spring Boot 1.1.0版本之后，我们可以更加方便地配置和使用多个数据源。

# 主数据库配置
spring.datasource.primary.url=jdbc:mysql://localhost:3306/main
spring.datasource.primary.username=root
spring.datasource.primary.password=123456
# 日志数据库配置
spring.datasource.log.url=jdbc:mysql://localhost:3306/log
spring.datasource.log.username=root
spring.datasource.log.password=123456

java
@Configuration
public class DataSourceConfig {
    // 主数据源配置
    @Bean
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }
    // 主JdbcTemplate配置
    @Bean
    @Primary
    public JdbcTemplate primaryJdbcTemplate(DataSource primaryDataSource) {
        return new JdbcTemplate(primaryDataSource);
    }
    // 日志数据源配置
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.log")
    public DataSource logDataSource() {
        return DataSourceBuilder.create().build();
    }
    // 日志JdbcTemplate配置
    @Bean
    public JdbcTemplate logJdbcTemplate(DataSource logDataSource) {
        return new JdbcTemplate(logDataSource);
    }
}

java
@Service
public class UserService {
    private final JdbcTemplate jdbcTemplate;
    @Autowired
    public UserService(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
    public void addUser(String username, String password) {
        String sql = "INSERT INTO user (username, password) VALUES (?, ?)";
        jdbcTemplate.update(sql, username, password);
    }
    // 其他操作方法...
}
@Service
public class LogService {
    private final JdbcTemplate jdbcTemplate;
    @Autowired
    public LogService(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
    public void addLog(String message) {
        String sql = "INSERT INTO log (message) VALUES (?)";
        jdbcTemplate.update(sql, message);
    }
    // 其他操作方法...
}