SpringBoot2.X基础教程：SpringBoot整合JdbcTemplate多数据源【附源码】

浅浅的花香味﹌ 2022-09-13 04:23 210阅读 0赞

> 微信号：hzy1014211086，如果你正在学习Spring Boot，可以加入我们的Spring技术交流群，共同成长

### 文章目录 ###

*  一、引入依赖
 *  二、配置&初始化数据源
 *  三、准备测试数据
 *  四、核心代码
 *  五、源码

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

多数据源配置也算是一个常见的开发需求，Spring 和 SpringBoot 中，对此都有相应的解决方案，不过一般来说，如果有多数据源的需求，我还是建议首选分布式数据库中间件 MyCat、ShardingSphere 去解决相关问题。

# 一、引入依赖 #

<dependencies>
    	
    	<dependency>
    		<groupId>mysql</groupId>
    		<artifactId>mysql-connector-java</artifactId>
    		<scope>runtime</scope>
    	</dependency>
    	
    	
    	<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>
    </dependencies>

# 二、配置&初始化数据源 #

接下来，在 application.properties 中配置数据源，不同于上篇文章，这里的数据源需要配置两个，如下：

spring.datasource.master.jdbc-url = jdbc:mysql://139.196.20.xxx:3306/spring_boot1?useUnicode=true&characterEncoding=utf-8
    spring.datasource.master.username = root
    spring.datasource.master.password = 123456
    spring.datasource.master.driver-class-name = com.mysql.cj.jdbc.Driver
    
    spring.datasource.slave.jdbc-url = jdbc:mysql://139.196.20.xxx:3306/spring_boot2?useUnicode=true&characterEncoding=utf-8
    spring.datasource.slave.username = root
    spring.datasource.slave.password = 123456
    spring.datasource.slave.driver-class-name = com.mysql.cj.jdbc.Driver

这里通过 master 和 slave 对数据源进行了区分，但是加了 master 和 slave 之后，**这里的配置就没法被 SpringBoot 自动加载了** （因为前面的 key 变了），需要我们自己去加载 DataSource 了，此时，需要自己配置一个 DataSourceConfig，用来提供两个 DataSource Bean，如下：

@Configuration
    public class DataSourceConfiguration {
        
    
        @Primary
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource.master")
        public DataSource masterDataSource() {
        
            return DataSourceBuilder.create().build();
        }
    
        @Bean
        @ConfigurationProperties(prefix = "spring.datasource.slave")
        public DataSource slaveDataSource() {
        
            return DataSourceBuilder.create().build();
        }
    
        @Bean
        public JdbcTemplate masterJdbcTemplate(@Qualifier("masterDataSource") DataSource masterDataSource) {
        
            return new JdbcTemplate(masterDataSource);
        }
    
        @Bean
        public JdbcTemplate slaveJdbcTemplate(@Qualifier("slaveDataSource") DataSource slaveDataSource) {
        
            return new JdbcTemplate(slaveDataSource);
        }
    
    }

这里提供了两个 Bean， @ConfigurationProperties(prefix = “spring.datasource.master”) 表示使用 spring.datasource.master 前缀的数据库配置去创建一个 DataSource，这样配置之后，我们就有了两个不同的 DataSource，然后再用这两个不同的 DataSource 去创建两个不同的 JdbcTemplate。

每一个 JdbcTemplate 的创建都需要一个 DataSource，由于 Spring 容器中现在存在两个 DataSource，默认使用类型查找，会报错，因此加上 @Qualifier 注解，表示按照名称查找。这里创建了两个 JdbcTemplate 实例，分别对应了两个 DataSource。

# 三、准备测试数据 #

创建spring\_boot1、spring\_boot2两个数据库

spring\_boot1

CREATE TABLE `spring_boot1`.`article`  (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `title` varchar(255) NULL COMMENT '文章标题',
      `author` varchar(255) NULL COMMENT '作者',
      PRIMARY KEY (`id`)
    ) COMMENT = '文章表';
    
    INSERT INTO `spring_boot1`.`article`(`id`, `title`, `author`) VALUES (1, 'master', 'Java程序鱼');

spring\_boot2

CREATE TABLE `spring_boot2`.`article`  (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `title` varchar(255) NULL COMMENT '文章标题',
      `author` varchar(255) NULL COMMENT '作者',
      PRIMARY KEY (`id`)
    ) COMMENT = '文章表';
    
    INSERT INTO `spring_boot2`.`article`(`id`, `title`, `author`) VALUES (1, 'slave', 'Java程序鱼');

# 四、核心代码 #

@RestController
    public class BlogController {
        
    
      @Autowired
      public BlogService blogService;
    
      /**
       * 查询所有文章(master数据源)
       *
       * @return
       */
      @GetMapping(value = "/getAllByMasterDatabase")
      public List<Blog> getAllByMasterDatabase() {
        
        return blogService.getAllByMasterDatabase();
      }
    
      /**
       * 查询所有文章(slave数据源)
       *
       * @return
       */
      @GetMapping(value = "/getAllBySlaveDatabase")
      public List<Blog> getAllBySlaveDatabase() {
        
        return blogService.getAllBySlaveDatabase();
      }
    
    }
    
    @Service
    public class BlogServiceImpl implements BlogService {
        
    
      @Resource(name = "masterJdbcTemplate")
      JdbcTemplate masterJdbcTemplate;
    
      @Resource(name = "slaveJdbcTemplate")
      JdbcTemplate slaveJdbcTemplate;
    
      @Override
      public List<Blog> getAllByMasterDatabase() {
        
        return masterJdbcTemplate.query("select * from article", new BeanPropertyRowMapper<>(Blog.class));
      }
    
      @Override
      public List<Blog> getAllBySlaveDatabase() {
        
        return slaveJdbcTemplate.query("select * from article", new BeanPropertyRowMapper<>(Blog.class));
      }
    
    }

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBASmF2Yeeoi-W6j-mxvA_size_20_color_FFFFFF_t_70_g_se_x_16]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBASmF2Yeeoi-W6j-mxvA_size_20_color_FFFFFF_t_70_g_se_x_16 1]

# 五、源码 #

本文的相关例子可以查看下面仓库中的 **chapter5** 目录：

*  Gitee：https://gitee.com/hezhiyuan007/spring-boot-study
 *  Github：https://github.com/java-fish-0907/spring-boot-study

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBASmF2Yeeoi-W6j-mxvA_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/3239be7a5608485d874f9660430d0603.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBASmF2Yeeoi-W6j-mxvA_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/146d7c51333e4539a9bd4f00ac0f3c6c.png