SpringBoot 整合多数据源（MyBats + Druid）

Gorit

发布于 2021-12-08 21:16:45

3010

发布于 2021-12-08 21:16:45

文章目录

SpringBoot 整合多数据源（MyBatis + Druid）

大家在写项目的时候有没有遇到过这样的情况，当你需要你的好基友电脑上，服务器上的数据的时候，是不是就得依赖他给你的接口。这样做是不是局限性太大。假如有一种方式可以直接通过你的小伙伴的服务器上的账号密码，就可以自己定制化的操作你的小伙伴的服务器上的数据了，这样是不是很酷呢？

一、项目环境准备

MySQL 5.5 版本以上
JDK 1.8 以上
开发工具：idea 2020, maven 3.5.2 版本及以上
SpringBoot 版本 2.2.10

二、项目配置初始化

2.0 项目结构

2.1 坐标依赖

 <dependencies>
        
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-webartifactId>
        dependency>
        <dependency>
            <groupId>org.mybatis.spring.bootgroupId>
            <artifactId>mybatis-spring-boot-starterartifactId>
            <version>2.1.3version>
        dependency>
		
		
        <dependency>
            <groupId>mysqlgroupId>
            <artifactId>mysql-connector-javaartifactId>
            <version>8.0.11version>
        dependency>

        
        <dependency>
            <groupId>com.alibabagroupId>
            <artifactId>druid-spring-boot-starterartifactId>
            <version>1.1.10version>
        dependency>
    dependencies>

2.2 application.yml

因为配置了两个数据源，所以为了区分它们，我们会自定义配置，同时数据库也会创建两个

spring:
  datasource:
    druid:
      db1:
        url: jdbc:mysql://localhost:3306/dts1?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC
        driverClassName: com.mysql.cj.jdbc.Driver
        username: root
        password: root
      db2:
        url: jdbc:mysql://localhost:3306/dst2?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC
        driverClassName: com.mysql.cj.jdbc.Driver
        username: root
        password: root

2.3 创建数据库

为了简化操作，我只是保证两个数据库的名称不一致，其它的数据库名称，字段都是一致的

我们创建了一个名为 book 的表，并随机插入几条数据

DROP TABLE IF EXISTS `book`;

CREATE TABLE `book` (
  `id` tinyint(3) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL,
  `author` varchar(20) COLLATE utf8_unicode_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

/*Data for the table `book` */

insert  into `book`(`id`,`name`,`author`) values (1,'时间简史','霍金'),(2,'放学后','东野圭吾'),(3,'白白夜行','东野圭吾'),(4,'红楼梦','清 曹雪芹');

三、MVC 三层编写

3.1 mapper 编写

在 MyBatis 中，我没有使用注解开发，而是使用的 xml 方式，所以我们还需要在 SpringBoot 的 Resources 目录下创建 mapper 目录和 map1，map2 两个子目录

dao 层相关的项目结构如下，然后下面我只给出 map1 中的相关代码，map2 中只是相对应的修改

- mapper
	- map1
		- BookMapper1
	- map2
		- BookMapper2

- resources
	- mapper
		- map1
			- BookMapper1.xml
		- map2
			- BookMapper2.xml

BookMapper1代码如下：

package cn.gorit.mapper.map1;

import cn.gorit.entity.Book;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository
public interface BookMapper1 {

    List getAllBooks();
}

BookMapper1.xml 配置如下

<mapper namespace="cn.gorit.mapper.map1.BookMapper1">

    <select id="getAllBooks" resultType="cn.gorit.entity.Book">
        select * from book
    select>

mapper>

3.2 entity 实体类编写

package cn.gorit.entity;

public class Book {
    private Integer id;
    private String name;
    private String author;

	// getter 和 setter 、构造方法省略
}

3.3 config 配置类

DataSourceConfig 配置类编写

package cn.gorit.config;

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;

/**
 * DataSourceConfig 中提供了两个数据源：database1 和 database2，默认方法名即实例名
 * @ConfigurationProperties  使用不同的前缀配置文件
 */
@Configuration
public class DataSourceConfig {
	
    //  标识为第一个数据源
    @Bean("dataSource1")
    @ConfigurationProperties(prefix = "spring.datasource.druid.db1")
    DataSource database1() {
        return DruidDataSourceBuilder.create().build();
    }
	
    // 标识为第二个数据源
    @Bean("dataSource2")
    @ConfigurationProperties(prefix = "spring.datasource.druid.db2")
    DataSource database2() {
        return DruidDataSourceBuilder.create().build();
    }
}

MyBatisConfigOne 配置类（第一个数据源对应的配置类）

package cn.gorit.config;

import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import javax.sql.DataSource;

/**
* 第二个数据源同理，创建一个新的配置类，将 MapperScan 的路径改为 map2，bean 的注入也要对那个的修改
*/

@Configuration
@MapperScan(value = "cn.gorit.mapper.map1",sqlSessionFactoryRef = "sqlSessionFactoryBean1")
public class MyBatisConfigOne {

    @Autowired
    @Qualifier("dataSource1")
    DataSource db1;

    @Bean
    public SqlSessionFactory sqlSessionFactoryBean1() throws Exception {
        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(db1);
        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:./mapper/map1/*.xml"));
        return factoryBean.getObject();
    }

    @Bean
    SqlSessionTemplate sqlSessionTemplate1() throws Exception {
        return new SqlSessionTemplate(sqlSessionFactoryBean1());
    }
}

3.4 控制层 controller

package cn.gorit.controller;

import cn.gorit.mapper.map1.BookMapper1;
import cn.gorit.mapper.map2.BookMapper2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.Map;

@RestController
public class BookController {

    @Autowired
    BookMapper1 bookMapper1;

    @Autowired
    BookMapper2 bookMapper2;

    @GetMapping("/book1")
    public Map<String,Object> test1() {
        Map<String,Object> map = new HashMap<>();
        map.put("code",200);
        map.put("msg","获取成功");
        map.put("data",bookMapper1.getAllBooks());
        return map;
    }

    @GetMapping("/book2")
    public Map<String,Object> test2() {
        Map<String,Object> map = new HashMap<>();
        map.put("code",200);
        map.put("msg","获取成功");
        map.put("data",bookMapper2.getAllBooks());
        return map;
    }
}