JdbcTemplate多数据源详解

妖狐艹你老母 2022-12-27 11:17 213阅读 0赞

### 创建数据库： ###

创建两个数据库用来测试，分别为database1和database2。在两个数据库中都创建一张book表。

![20201210170847194.PNG][]

### 添加依赖： ###

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
                <version>2.4.0</version>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>1.2.3</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.20</version>
            </dependency>

*  druid-spring-boot-starter：数据库连接池依赖，帮助开发者在spring boot项目中轻松集成Druid数据库连接池和监控

### 配置数据库连接： ###

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

*  配置两个数据源，数据库不同，其他相同

### 配置数据源： ###

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import javax.sql.DataSource;
    
    @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();
        }
    }

**代码解释：**

*  @Configuration：@Configuration注解的使用
 *  @ConfigurationProperties：将配置文件(application.yaml)的每个属性值，映射到这个组件中。告诉Springboot将本类中的所有属性和配置文件中的配置进行绑定。此处表示使用不同前缀的配置文件来创建不同的DataSource实例
 *  @Bean：此注解用于告诉方法，产生一个Bean对象，然后这个Bean对象交给Spring管理。产生这个Bean对象的方法会调用一次，随后这个Spring将会将这个Bean对象放在自己的IOC容器中。SpringIOC容器管理一个或多个bean，这些bean都需要在@Configuration注解下进行创建，在一个方法上使用@Bean注解就表明这个方法需要交给Spring进行管理

### 实体类： ###

import lombok.Data;
    
    @Data
    public class Book {
        private Integer id;
        private String name;
        private String author;
    }

### 配置JdbcTemplate： ###

在配置多数据源时，需要自己提供JdbcTemplate实例：

import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.jdbc.core.JdbcTemplate;
    
    import javax.sql.DataSource;
    
    @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实例注入进来

### Controller层： ###

import com.example.demo.domain.Book;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.jdbc.core.BeanPropertyRowMapper;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    import java.util.List;
    
    @RestController
    public class BookController {
        @Resource(name = "jdbcTemplateOne")
        JdbcTemplate jdbcTemplateOne;
        @Autowired
        @Qualifier("jdbcTemplateTwo")
        JdbcTemplate jdbcTemplateTwo;
    
        @GetMapping("/test1")
        public void test1(){
            List<Book> book1 = jdbcTemplateOne.query("select * from book",new BeanPropertyRowMapper<>(Book.class));
    
            List<Book> book2 = jdbcTemplateTwo.query("select * from book",new BeanPropertyRowMapper<>(Book.class));
    
            System.out.println("book1:"+book1);
            System.out.println("book2:"+book2);
        }
    }

在Controller中注入两个不同的JdbcTemplate有两种方式：一是使用@Resource注解，并指明name属性，即按name进行装配，此时会根据实例名查找相应的实例注入；另一种时使用@Autowored注解结合@Qualifiler注解，效果等同于使用@Resource注解。

### 测试： ###

**启动系统，访问地址：**

http://127.0.0.1:8080/test1

**控制台输出：**

book1:[Book(id=1, name=水浒传, author=施耐庵)]
    book2:[Book(id=1, name=三国演义, author=罗贯中)]

[20201210170847194.PNG]: /images/20221120/1a37e40418e24617bd3d349ba4c714b0.png