Spring Boot整合持久层之JdbcTemplate多数据源

目录

• 多数据源
• JdbcTemplate 多数据源
• 1. 创建数据库
• 2.创建项目
• 3. 配置数据库连接
• 4. 配置数据源
• 5. 配置 JdbcTemplate
• 6. 创建BookController
• 7. 测试

多数据源

所谓多数据源，就是一个 Java EE 项目中采用了不同数据库实例中的多个库，或者同一个数据库实例中多个不同的库。一般来说，采用 MyCat 等分布式数据库中间件是比较好的解决方案，这样可以把数据库读写分离、分库分表、备份等操作交给中间件去做，Java 代码只需要专注于业务即可。不过这并不意味着无法使用 Java 代码解决类似的问题，在 Spring Framework 中就可以配置多数据源，Spring Boot 继承其衣钵，只不过配置方式有所变化。

JdbcTemplate 多数据源

JdbcTemplate 多数据源是比较简单的，因为一个 JdbcTemplate 对应一个 DataSource，开发者只需要手动提供多个 DataSource ，再手动配置 JdbcTemplate 即可。

1. 创建数据库

创建两个数据库：chapter05-1 和 chapter05-2.两个库中都创建 book 表，再各预设 1 条数据，脚本如下

create database `chapter05-1` default character set utf8;
CREATE TABLE `chapter05-1`.`book` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `author` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
INSERT INTO `chapter05-1`.`book`(`id`, `name`, `author`) VALUES (1, '水浒传', '施耐庵');
create database `chapter05-2` default character set utf8;
CREATE TABLE `chapter05-2`.`book` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `author` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
INSERT INTO `chapter05-2`.`book`(`id`, `name`, `author`) VALUES (1, '三国演义', '罗贯中');

2.创建项目

创建 Spring Boot Web 项目，添加如下依赖：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>druid-spring-boot-starter</artifactId>
  <version>1.1.10</version>
</dependency>
<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <scope>runtime</scope>
</dependency>

注意这里添加的数据库连接池依赖是 druid-spring-boot-starter 。druid-spring-boot-starter 可以帮助开发者在 Spring Boot 项目中轻松集成 Druid 数据库连接池和监控。

3. 配置数据库连接

在application.properties 中配置数据库连接信息

# 数据源1
spring.datasource.one.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.one.url=jdbc:mysql://localhost:3306/chapter05-1?useUnicode=true&characterEncoding=utf8&useSSL=true
spring.datasource.one.username=root
spring.datasource.one.password=root
# 数据源2
spring.datasource.two.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.two.url=jdbc:mysql://localhost:3306/chapter05-2?useUnicode=true&characterEncoding=utf8&useSSL=true
spring.datasource.two.username=root
spring.datasource.two.password=root

4. 配置数据源

创建 DataSourceConfig 配置数据源，根据 application.properties 中的配置生成两个数据源

@Configuration
public class DataSourceConfig {
    @Bean
    @ConfigurationProperties("spring.datasource.one")
    DataSource dsOne() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties("spring.datasource.two")
    DataSource dsTwo() {
        return DruidDataSourceBuilder.create().build();
    }
}

代码解释：

• DataSourceConfig 中提供了两个数据源：dsOne 和 dsTwo，默认方法名即实例名
• @ConfigurationProperties 注解表示使用不同前缀的配置文件来创建不同的 DataSource 实例

5. 配置 JdbcTemplate

在 5.1节 中得知，只要引入了 spring-jdbc 依赖，开发者没有提供 JdbcTemplate 实例时，Spring Boot 默认会提供一个 JdbcTemplate 实例。现在配置多数据源时，由开发者自己提供 JdbcTemplate 实例

@Configuration
public class JdbcTemplateConfig {
    @Bean
    JdbcTemplate jdbcTemplateOne(@Qualifier("dsOne") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
    @Bean
    JdbcTemplate jdbcTemplateTwo(@Qualifier("dsTwo") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
}

代码解释：

JdbcTemplateConfig 中提供两个 JdbcTemplate 实例。每个 JdbcTemplate 实例都需要提供 DataSource，由于Spring 容器中有两个 DataSource 实例，因此需要通过方法名查找。@Qualifier 注解表示查找不同名称的 DataSource 实例注入进来

6. 创建BookController

创建实体类 Book 和 BookController 进行测试

public class Book {
    private Integer id;
    private String name;
    private String author;
    @Override
    public String toString() {
        return "Book{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", author='" + author + '\'' +
                '}';
    }
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getAuthor() {
        return author;
    }
    public void setAuthor(String author) {
        this.author = author;
    }
}

@RestController
public class BookController {
    @Resource(name = "jdbcTemplateOne")
    JdbcTemplate jdbcTemplate;
    @Autowired
    @Qualifier("jdbcTemplateTwo")
    JdbcTemplate jdbcTemplateTwo;
    @GetMapping("/test1")
    public void test1() {
        List<Book> books1 = jdbcTemplate.query("select * from book",
                new BeanPropertyRowMapper<>(Book.class));
        List<Book> books2 = jdbcTemplateTwo.query("select * from book",
                new BeanPropertyRowMapper<>(Book.class));
        System.out.println("books1:"+books1);
        System.out.println("books2:"+books2);
    }
}

简单起见，这里没有添加 service 层，而是直接将 JdbcTemplate 注入到了 Controller 中。在Controller 中注入两个不同的 JdbcTemplate 有两种方式：一种是使用 @Resource 注解，并指明 name 属性，即按 name 进行装配，此时会根据实例名查找相应的实例注入；另一种是使用 @Autowired 注解结合 @Qualifier 注解，效果等同于使用 @Resource 注解。

7. 测试

http://localhost:8081/test1，查看打印日志

books1:[Book{id=1, name='水浒传', author='施耐庵'}]
books2:[Book{id=1, name='三国演义', author='罗贯中'}]

到此这篇关于Spring Boot整合持久层之JdbcTemplate多数据源的文章就介绍到这了,更多相关Spring Boot JdbcTemplate 内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！