Spring Boot 配置双数据源-Toy模板网

这篇具有很好参考价值的文章主要介绍了Spring Boot 配置双数据源。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

Survive by day and develop by night.
talk for import biz , show your perfect code,full busy，skip hardness,make a better result,wait for change,challenge Survive.
happy for hardess to solve denpendies.

1. 添加依赖
- 添加 Spring Boot 和数据库驱动的依赖
1. 配置数据源
- 在 application.properties 或 application.yml 中分别配置两个数据源的连接信息
1. 创建数据源配置类
- 创建两个数据源的配置类，分别配置数据源相关信息
1. 配置数据源事务管理器
- 创建两个数据源的事务管理器，并指定数据源
1. 配置 JPA 实体管理器工厂
- 创建两个 JPA 实体管理器工厂，并指定数据源和配置信息
1. 配置事务注解支持
- 启用事务注解支持，并指定事务管理器
1. 在 DAO 层使用数据源
- 使用 @Qualifier 注解指定使用的数据源
1. 测试双数据源配置
- 编写测试代码，分别使用两个数据源进行数据库操作

2.实例

在Spring Boot中配置双数据源可以使用多个方法，下面介绍其中的一种方法。

引入相关依赖

首先在pom.xml文件中引入Spring Boot和数据库连接池的依赖。例如，使用MySQL和H2数据库，可以添加以下依赖：

<dependencies>
    <!-- Spring Boot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    
    <!-- MySQL -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    
    <!-- H2 -->
    <dependency>
        <groupId>com.h2database</groupId>
        <artifactId>h2</artifactId>
        <scope>runtime</scope>
    </dependency>
</dependencies>

配置数据源

在application.properties文件中配置两个数据源的属性，例如：

# MySQL 数据源配置
spring.datasource.mysql.url=jdbc:mysql://localhost:3306/db1
spring.datasource.mysql.username=root
spring.datasource.mysql.password=123456
spring.datasource.mysql.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.mysql.tomcat.max-wait=10000

# H2 数据源配置
spring.datasource.h2.url=jdbc:h2:mem:db2
spring.datasource.h2.username=sa
spring.datasource.h2.password=
spring.datasource.h2.driver-class-name=org.h2.Driver
spring.datasource.h2.tomcat.max-wait=10000

配置数据源对象

创建两个数据源对象，用于连接数据库。可以使用@Configuration注解和@Bean注解来实现。例如：

@Configuration
public class DataSourceConfig {
    
    @Bean(name = "mysqlDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.mysql")
    public DataSource mysqlDataSource() {
        return DataSourceBuilder.create().build();
    }
    
    @Bean(name = "h2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.h2")
    public DataSource h2DataSource() {
        return DataSourceBuilder.create().build();
    }
}

配置JdbcTemplate对象

创建两个JdbcTemplate对象，用于执行SQL语句。可以使用@Autowired注解来实现。例如：

@Configuration
public class JdbcTemplateConfig {
    
    @Autowired
    @Qualifier("mysqlDataSource")
    private DataSource mysqlDataSource;
    
    @Autowired
    @Qualifier("h2DataSource")
    private DataSource h2DataSource;
    
    @Bean(name = "mysqlJdbcTemplate")
    public JdbcTemplate mysqlJdbcTemplate() {
        return new JdbcTemplate(mysqlDataSource);
    }
    
    @Bean(name = "h2JdbcTemplate")
    public JdbcTemplate h2JdbcTemplate() {
        return new JdbcTemplate(h2DataSource);
    }
}

使用JdbcTemplate对象

在代码中使用JdbcTemplate对象来执行SQL语句。可以使用@Autowired注解来实现。例如：

@RestController
public class UserController {

    @Autowired
    @Qualifier("mysqlJdbcTemplate")
    private JdbcTemplate mysqlJdbcTemplate;

    @Autowired
    @Qualifier("h2JdbcTemplate")
    private JdbcTemplate h2JdbcTemplate;

    @GetMapping("/users")
    public List<User> getUsers() {
        List<User> users = new ArrayList<>();

        // 使用mysqlJdbcTemplate执行SQL语句
        mysqlJdbcTemplate.query("SELECT * FROM users", (rs, rowNum) -> {
            User user = new User();
            user.setId(rs.getInt("id"));
            user.setName(rs.getString("name"));
            users.add(user);
            return null;
        });

        // 使用h2JdbcTemplate执行SQL语句
        h2JdbcTemplate.query("SELECT * FROM users", (rs, rowNum) -> {
            User user = new User();
            user.setId(rs.getInt("id"));
            user.setName(rs.getString("name"));
            users.add(user);
            return null;
        });

        return users;
    }
}