spring-boot-route（十）多数据源切换

分手后的思念是犯贱 2021-09-18 06:00 296阅读 0赞

前面我们已经介绍了三种方式来操作数据库，在实际开发中，往往会出现一个服务连接多个数据库的需求，这时候就需要在项目中进行灵活切换数据源来完成多个数据库操作。这一章中，我们使用jdbcTemplate来学习多数据源的配置。

## 一 准备工作 ##

### 1.1 建库、建表 ###

我们新建两个库`db1`和`db2`，数据结构还是用前面演示的，分别在两个库中新建表`student`。

CREATE TABLE `student` (
       `student_id` int(30) NOT NULL AUTO_INCREMENT,
       `age` int(1) DEFAULT NULL COMMENT '年龄',
       `name` varchar(45) DEFAULT NULL COMMENT '姓名',
       `sex` int(1) DEFAULT NULL COMMENT '性别：1：男，2：女，0：未知',
       `create_time` datetime DEFAULT NULL COMMENT '创建时间',
       `status` int(1) DEFAULT NULL COMMENT '状态：1：正常，-1：删除',
       PRIMARY KEY (`student_id`)
     ) ENGINE=InnoDB CHARSET=utf8mb4 CHECKSUM=1 DELAY_KEY_WRITE=1 ROW_FORMAT=DYNAMIC COMMENT='学生表'

### 1.2 引入mysql和jdbcTemplate依赖 ###

<dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.11</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>

### 1.3 写入两个数据源配置 ###

spring:
      datasource:
        db1:
          driver-class-name: com.mysql.cj.jdbc.Driver
          jdbc-url: jdbc:mysql://localhost:3306/db1
          username: root
          password: root
        db2:
          driver-class-name: com.mysql.cj.jdbc.Driver
          jdbc-url: jdbc:mysql://localhost:3306/db2
          username: root
          password: root

## 二 多数据源配置 ##

@Configuration
    public class DataSourceConfig { 
    
        @Primary
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource.db1")
        public DataSource db1DataSource(){ 
            return DataSourceBuilder.create().build();
        }
    
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource.db2")
        public DataSource db2DataSource(){ 
            return DataSourceBuilder.create().build();
        }
    }

*  @Primary：表示主的，即出现多个bean的时候如果不指定具体的bean，则会采用这个
 *  @bean：标注为一个bean，如果不指定name属性，则会使用创建bean方法的名字做为bean的名字
 *  @ConfigurationProperties：读取配置文件

## 三 配置JdbcTemplate对象 ##

@Configuration
    public class DataSourceConfig { 
        
        @Bean
        public JdbcTemplate db1JdbcTemplate(@Qualifier("db1DataSource") DataSource dataSource){ 
            return new JdbcTemplate(dataSource);
        }
        @Primary
        @Bean
        public JdbcTemplate db2JdbcTemplate(@Qualifier("db2DataSource") DataSource dataSource){ 
            return new JdbcTemplate(dataSource);
        }
    }

*  @Qualifier：bean类型相同后，指定使用的bean的name

## 四 测试类 ##

### 4.1 测试@Primary属性 ###

不指定使用哪个JdbcTemplate对象时，会使用标注了@Primary属性的对象

@SpringBootTest
    class SpringBootDatasourceApplicationTests { 
        
        @Autowired
        private JdbcTemplate jdbcTemplate;
        
        @Test
        void testPrimary() { 
            jdbcTemplate.update("insert into student(name,age) values(?,?)",new Object[]{ "Java旅途",18});
        }
    }

### 4.2 测试多数据源 ###

@SpringBootTest
    class SpringBootDatasourceApplicationTests { 
    
    
        @Autowired
        private JdbcTemplate db1JdbcTemplate;
        @Autowired
        private JdbcTemplate db2JdbcTemplate;
    
        @Autowired
        private JdbcTemplate jdbcTemplate;
        @Test
        void contextLoads() { 
    
            db1JdbcTemplate.update("insert into student(name,age) values(?,?)",new Object[]{ "Java旅途",18});
            db2JdbcTemplate.update("insert into student(name,age) values(?,?)",new Object[]{ "Java旅途",18});
        }
        }
    }

这里分享一道面试题：**@Autowired 与@Resource有什么区别**？

@Autowired是Spring提供的，@Resource是JDK提供的；

@Autowired是根据bean的类型匹配的，@Resource是根据bean的name匹配的；

如果@Autowird想要根据name匹配应该怎么做呢？

1.  配合@Qualifier注解指定bean的name
2.  使用变量名称作为bean的id，@Autowired如果匹配到多个符合条件的对象后，会自动根据变量名称做为bean的id继续匹配。我们在**4.2**中采用的就是这种方式。

--------------------

#### 本文示例代码已上传至[github][]，点个`star`支持一下！ ####

## Spring Boot系列教程目录 ##

[spring-boot-route（一）Controller接收参数的几种方式][spring-boot-route_Controller]

[spring-boot-route（二）读取配置文件的几种方式][spring-boot-route]

[spring-boot-route（三）实现多文件上传][spring-boot-route 1]

[spring-boot-route（四）全局异常处理][spring-boot-route 2]

[spring-boot-route（五）整合swagger生成接口文档][spring-boot-route_swagger]

[spring-boot-route（六）整合JApiDocs生成接口文档][spring-boot-route_JApiDocs]

[spring-boot-route（七）整合jdbcTemplate操作数据库][spring-boot-route_jdbcTemplate]

[spring-boot-route（八）整合mybatis操作数据库][spring-boot-route_mybatis]

[spring-boot-route（九）整合JPA操作数据库][spring-boot-route_JPA]

[spring-boot-route（十）多数据源切换][spring-boot-route 3]

[spring-boot-route（十一）数据库配置信息加密][spring-boot-route 4]

[spring-boot-route（十二）整合redis做为缓存][spring-boot-route_redis]

[spring-boot-route（十三）整合RabbitMQ][spring-boot-route_RabbitMQ]

[spring-boot-route（十四）整合Kafka][spring-boot-route_Kafka]

[spring-boot-route（十五）整合RocketMQ][spring-boot-route_RocketMQ]

[spring-boot-route（十六）使用logback生产日志文件][spring-boot-route_logback]

[spring-boot-route（十七）使用aop记录操作日志][spring-boot-route_aop]

[spring-boot-route（十八）spring-boot-adtuator监控应用][spring-boot-route_spring-boot-adtuator]

[spring-boot-route（十九）spring-boot-admin监控服务][spring-boot-route_spring-boot-admin]

[spring-boot-route（二十）Spring Task实现简单定时任务][spring-boot-route_Spring Task]

[spring-boot-route（二十一）quartz实现动态定时任务][spring-boot-route_quartz]

[spring-boot-route（二十二）实现邮件发送功能][spring-boot-route 5]

[spring-boot-route（二十三）开发微信公众号][spring-boot-route 6]

[spring-boot-route（二十四）分布式session的一致性处理][spring-boot-route_session]

[spring-boot-route（二十五）两行代码实现国际化][spring-boot-route 7]

[spring-boot-route（二十六）整合webSocket][spring-boot-route_webSocket]

[github]: https://github.com/binzh303/spring-boot-route
[spring-boot-route_Controller]: https://javatip.cn/archives/66
[spring-boot-route]: https://javatip.cn/archives/72
[spring-boot-route 1]: https://javatip.cn/archives/74
[spring-boot-route 2]: https://javatip.cn/archives/79
[spring-boot-route_swagger]: https://javatip.cn/archives/90
[spring-boot-route_JApiDocs]: https://javatip.cn/archives/91
[spring-boot-route_jdbcTemplate]: https://javatip.cn/archives/92
[spring-boot-route_mybatis]: https://javatip.cn/archives/93
[spring-boot-route_JPA]: https://javatip.cn/archives/94
[spring-boot-route 3]: https://javatip.cn/archives/95
[spring-boot-route 4]: https://javatip.cn/archives/113
[spring-boot-route_redis]: https://javatip.cn/archives/114
[spring-boot-route_RabbitMQ]: https://javatip.cn/archives/115
[spring-boot-route_Kafka]: https://javatip.cn/archives/116
[spring-boot-route_RocketMQ]: https://javatip.cn/archives/117
[spring-boot-route_logback]: https://javatip.cn/archives/118
[spring-boot-route_aop]: https://javatip.cn/archives/119
[spring-boot-route_spring-boot-adtuator]: https://javatip.cn/archives/120
[spring-boot-route_spring-boot-admin]: https://javatip.cn/archives/121
[spring-boot-route_Spring Task]: https://javatip.cn/archives/122
[spring-boot-route_quartz]: https://javatip.cn/archives/123
[spring-boot-route 5]: https://javatip.cn/archives/124
[spring-boot-route 6]: https://javatip.cn/archives/125
[spring-boot-route_session]: https://javatip.cn/archives/284
[spring-boot-route 7]: https://javatip.cn/archives/256
[spring-boot-route_webSocket]: https://javatip.cn/archives/255