手动目录 SpringBoot 整合多数据源 （MyBatis + Druid） 一、项目环境准备 二、项目配置初始化 2.0 项目结构 2.1 坐标依赖 2.2 application.yml 2.3 创建数据库 三、MVC 三层编写 3.1 mapper 编写 3.2 entity 实体类编写 3.3 config 配置类 3.4 控制层 controller 四、测试运行
大家在写项目的时候有没有遇到过这样的情况，当你需要你的好基友电脑上，服务器上的数据的时候，是不是就得依赖他给你的接口。这样做是不是局限性太大。假如有一种方式可以直接通过你的小伙伴的服务器上的账号密码，就可以自己定制化的操作你的小伙伴的服务器上的数据了，这样是不是很酷呢？
一、项目环境准备- MySQL 5.5 版本以上
- JDK 1.8 以上
- 开发工具：idea 2020, maven 3.5.2 版本及以上
- SpringBoot 版本 2.2.10
org.springframework.boot
spring-boot-starter-web
org.mybatis.spring.boot
mybatis-spring-boot-starter
2.1.3
mysql
mysql-connector-java
8.0.11
com.alibaba
druid-spring-boot-starter
1.1.10
因为配置了两个数据源，所以为了区分它们，我们会自定义配置，同时数据库也会创建两个
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
为了简化操作，我只是保证两个数据库的名称不一致，其它的数据库名称，字段都是一致的
我们创建了一个名为 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;
insert into `book`(`id`,`name`,`author`) values (1,'时间简史','霍金'),(2,'放学后','东野圭吾'),(3,'白白夜行','东野圭吾'),(4,'红楼梦','清 曹雪芹');
在 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 配置如下
package cn.gorit.entity;
public class Book {
private Integer id;
private String name;
private String author;
// getter 和 setter 、构造方法省略
}
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;
@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;
@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());
}
}
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 test1() {
Map map = new HashMap<>();
map.put("code",200);
map.put("msg","获取成功");
map.put("data",bookMapper1.getAllBooks());
return map;
}
@GetMapping("/book2")
public Map test2() {
Map map = new HashMap<>();
map.put("code",200);
map.put("msg","获取成功");
map.put("data",bookMapper2.getAllBooks());
return map;
}
}
