记录:383
场景:使用dynamic-datasource-spring-boot-starter动态切换数据源,使用MyBatis操作数据库。提供三种示例:一,使用@DS注解作用到类上。二,使用@DS注解作用到方法上。三,不使用注解,使用DynamicDataSourceContextHolder类在方法内灵活切换不同数据源。
源码:https://github.com/baomidou
源码:https://github.com/baomidou/dynamic-datasource-spring-boot-starter
dynamic-datasource-spring-boot-starter:一个基于springboot的快速集成多数据源的启动器。
1.初始化准备
1.1创建Maven工程
使用IntelliJ IDEA创建Maven工程。
(1)微服务名称
名称:hub-example-202-dynamic-datasource
(2)微服务groupId和artifactId
groupId: com.hub
artifactId: hub-example-202-dynamic-datasource
(3)微服务核心模块版本
spring-boot 2.6.3spring-framework 5.3.15mybatis-spring-boot-starter 2.2.2mybatis-3.5.9mybatis-spring-2.0.7HikariCP-4.0.3dynamic-datasource-spring-boot-starter-3.3.2
1.1.2准备数据库
集成动态数据源,使用MyBatis操作数据库。
(1)数据库一
数据库名称:hub_exampledb
脚本:
USE mysql;CREATE DATABASE hub_exampledb DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;CREATE USER hub_example@'%' IDENTIFIED BY 'h12345678';GRANT ALL ON hub_exampledb.* TO 'hub_example'@'%' IDENTIFIED BY 'h12345678';FLUSH PRIVILEGES;
(2)数据库二
数据库名称:hub_example02db
脚本:
USE mysql;CREATE DATABASE hub_example02db DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;CREATE USER hub_example02@'%' IDENTIFIED BY 'h12345678';GRANT ALL ON hub_example02db.* TO 'hub_example02'@'%' IDENTIFIED BY 'h12345678';FLUSH PRIVILEGES;
2.修改pom.xml
修改pom.xml,引入项目依赖Jar、管理Jar包等。
2.1修改pom.xml文件
引入核心依赖包:mybatis和dynamic-datasource。
内容:
org.mybatis.spring.bootmybatis-spring-boot-starter2.2.2com.baomidoudynamic-datasource-spring-boot-starter3.3.2
解析:引入mybatis-spring-boot-starter-2.2.2,对应加载mybatis-3.5.9和mybatis-spring-2.0.7。引入dynamic-datasource-spring-boot-starter-3.3.2,加载动态数据源的依赖包。
2全量pom.xml文件
全量pom.xml文件请参考附录:12.1全量pom.xml文件
3.创建application.yml文件
在application.yml中添加各类配置。
3.1集成MyBatis的配置
(1)基础配置
内容:
mybatis:mapper-locations: classpath*:mapper/*.xmlconfiguration:log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
解析:mapper-locations属性指定MyBatis映射的SQL文件目录。
注意:属性log-impl在Java类中是logImpl,一般是驼峰命名的大写字母转换小写且在字母前加上短横线。
(2)属性类
MyBatis配置属性主要从以下两个类找到。
类:org.mybatis.spring.boot.autoconfigure.MybatisProperties
类:org.apache.ibatis.session.Configuration
3.2动态数据源配置
内容:
spring:datasource:dynamic:primary: hub_exampledbstrict: falsedatasource:hub_exampledb:url: jdbc:mysql://127.0.0.1:3306/hub_exampledbusername: hub_examplepassword: h12345678driver-class-name: com.mysql.cj.jdbc.Driverhub_example02db:url: jdbc:mysql://127.0.0.1:3306/hub_example02dbusername: hub_example02password: h12345678driver-class-name: com.mysql.cj.jdbc.Driver
解析:属性primary指定一个数据库,本例操作MySQL数据库的hub_exampledb和hub_example02db。比如要操作Oracle数据库,添加相应信息即可。
3.3其它基础配置
内容:
server:servlet:context-path: /hub-example-dsport: 18080spring:jackson:time-zone: GMT+8
解析:指定服务器端口和路径前缀。指定时区为东八区。
4.创建启动类
4.1创建包
com.hub.example.config:配置类,微服务各类自定义配置。
com.hub.example.domain:微服务使用到的VO、PO等实体类。
com.hub.example.mapper:MyBatis接口。
com.hub.example.service:服务实现类。
com.hub.example.controller:Controller类,发布Restful接口。
com.hub.example.utils:支撑工具类。
4.2启动类
包名:com.hub.example。
启动类:DynamicDatasourceExampleApplication。
(1)内容
@SpringBootApplication@ComponentScan(basePackages = {"com.hub.example.*"})@MapperScan(basePackages = "com.hub.example.**.mapper")public class DynamicDatasourceExampleApplication {public static void main(String[] args) {SpringApplication.run(DynamicDatasourceExampleApplication.class, args);}}
(2)解析
@SpringBootApplication,SpringBoot标记启动类的注解。
@ComponentScan,扫描指定的包,将组件加载到IOC容器中。
@MapperScan,是MyBatis的注解,扫描指定目录下提供给MyBatis注入的接口。
5.编写Java接口(提供给MyBatis使用)
在MyBatis的ORM(Object Relational Mapping)对象映射关系机制中,一个Java接口映射到一个MyBatis的SQL文件,一个接口方法映射到一条MyBatis的SQL语句。
5.1CityMapper接口
接口全路径:com.hub.example.mapper.CityMapper
内容:
@Repositorypublic interface CityMapper {CityDTO queryCityByCityId(String cityId);}
5.2ProvinceMapper接口
接口全路径:com.hub.example.mapper.ProvinceMapper
内容:
@Repositorypublic interface ProvinceMapper {ProvinceDTO queryProvinceByProvinceId(String cityId);}
6.编写MyBatis的SQL
一个Java接口映射到一个MyBatis的SQL文件。Java接口的一个方法映射到一个SQL。
6.1CityMapper.xml
CityMapper接口映射到CityMapper.xml。
内容:
select CITY_ID AS "cityId",CITY_NAME AS "cityName",LAND_AREA AS "landArea",POPULATIONAS "population",GROSS AS "gross",CITY_DESCRIBE AS "cityDescribe",DATA_YEAR AS "dataYear",UPDATE_TIME AS "updateTime"from t_citywhere CITY_ID = #{cityId}
6.2ProvinceMapper.xml
ProvinceMapper接口映射到ProvinceMapper.xml。
内容:
select PROVINCE_ID AS "provinceId",PROVINCE_NAME AS "provinceName",LAND_AREA AS "landArea",POPULATIONAS "population",GROSS AS "gross",PROVINCE_DESCRIBE AS "provinceDescribe",DATA_YEAR AS "dataYear",UPDATE_TIME AS "updateTime"from t_provincewhere PROVINCE_ID = #{provinceId}
7.使用DS注解作用到类上切换数据源
使用方式:在类上使用注解:@DS(“hub_exampledb”),hub_exampledb是在application.yml配置的数据源名称。
7.1编写Service层代码
在Service层注入xxMapper接口,以调用接口方式来调用MyBatis机制操作数据库。
7.1.1Service接口
(1)CityService接口
内容:
public interface CityService {CityDTO queryCityByCityId(String cityId);}
(2)ProvinceService接口
内容:
public interface ProvinceService {ProvinceDTO queryProvinceByProvinceId(String provinceId);}
7.1.2Service实现类
(1)CityServiceImpl实现类
内容:
@DS("hub_exampledb")@Servicepublic class CityServiceImpl implements CityService {@Autowiredprivate CityMapper cityMapper;@Overridepublic CityDTO queryCityByCityId(String cityId) {return cityMapper.queryCityByCityId(cityId);}}
(2)ProvinceServiceImpl实现类
内容:
@DS("hub_example02db")@Servicepublic class ProvinceServiceImpl implements ProvinceService {@Autowiredprivate ProvinceMapper provinceMapper;@Overridepublic ProvinceDTO queryProvinceByProvinceId(String provinceId) {return provinceMapper.queryProvinceByProvinceId(provinceId);}}
7.2编写Controller层代码
在Controller层注入Service接口,以调用接口方式来调用Service实现类。
@RestController@RequestMapping("/hub/example/DsOnClass/")public class DsOnClassController {@Autowiredprivate CityService cityService;@Autowiredprivate ProvinceService provinceService;@PostMapping("/query")public ResultObj query(@RequestBody IdVO idVO) {CityDTO cityDTO = cityService.queryCityByCityId(idVO.getCityId());ProvinceDTO provinceDTO = provinceService.queryProvinceByProvinceId(idVO.getProvinceId());DataVO dataVO = new DataVO();dataVO.setProvinceDTO(provinceDTO);dataVO.setCityDTO(cityDTO);return ResultObj.data(200, dataVO, "DS注解作用到类,切换数据源,执行成功");}}
8.使用DS注解作用到方法上切换数据源
使用方式:在方法上使用注解:@DS(“hub_exampledb”),hub_exampledb是在application.yml配置的数据源名称。
8.1编写Service层代码
在Service层注入xxMapper接口,以调用接口方式来调用MyBatis机制操作数据库。
8.1.1Service接口
public interface DsOnMethodService {ProvinceDTO queryProvinceByProvinceId(String provinceId);CityDTO queryCityByCityId(String cityId);}
8.1.2Service实现类
在方法上使用@DS注解。
@Servicepublic class DsOnMethodServiceImpl implements DsOnMethodService {@Autowiredprivate ProvinceMapper provinceMapper;@Autowiredprivate CityMapper cityMapper;@DS("hub_example02db")@Overridepublic ProvinceDTO queryProvinceByProvinceId(String provinceId) {return provinceMapper.queryProvinceByProvinceId(provinceId);}@DS("hub_exampledb")@Overridepublic CityDTO queryCityByCityId(String cityId) {return cityMapper.queryCityByCityId(cityId);}}
8.2编写Controller层代码
在Controller层注入Service接口,以调用接口方式来调用Service实现类。
@RestController@RequestMapping("/hub/example/DsOnMethod/")public class DsOnMethodController {@Autowiredprivate DsOnMethodService dsOnMethodService;@PostMapping("/query")public ResultObj query(@RequestBody IdVO idVO) { CityDTO cityDTO = dsOnMethodService.queryCityByCityId(idVO.getCityId()); ProvinceDTO provinceDTO = dsOnMethodService.queryProvinceByProvinceId(idVO.getProvinceId()); DataVO dataVO = new DataVO(); dataVO.setProvinceDTO(provinceDTO); dataVO.setCityDTO(cityDTO); return ResultObj.data(200, dataVO, "DS注解作用到方法,切换数据源,执行成功");}}
9.使用DynamicDataSourceContextHolder切换数据源
使用DynamicDataSourceContextHolder类在方法内灵活切换不同数据源。
9.1编写Service层代码
在Service层注入xxMapper接口,以调用接口方式来调用MyBatis机制操作数据库。
9.1.1Service接口
public interface DsUseContextHolderService {DataVO query(IdVO idVO);}
9.1.2Service实现类
在方法内灵活切换数据源。
@Servicepublic class DsUseContextHolderServiceImpl implements DsUseContextHolderService {@Autowiredprivate ProvinceMapper provinceMapper;@Autowiredprivate CityMapper cityMapper;@Overridepublic DataVO query(IdVO idVO) {// 1.读取hub_example02db的数据DynamicDataSourceContextHolder.push("hub_example02db");ProvinceDTO provinceDTO = provinceMapper.queryProvinceByProvinceId(idVO.getProvinceId());// 2.读取hub_exampledb的数据DynamicDataSourceContextHolder.poll();DynamicDataSourceContextHolder.push("hub_exampledb");CityDTO cityDTO = cityMapper.queryCityByCityId(idVO.getCityId());DataVO dataVO = new DataVO();dataVO.setProvinceDTO(provinceDTO);dataVO.setCityDTO(cityDTO);return dataVO;}}
9.2编写Controller层代码
在Controller层注入Service接口,以调用接口方式来调用Service实现类。
@RestController@RequestMapping("/hub/example/DsUseContextHolder/")public class DsUseContextHolderController {@Autowiredprivate DsUseContextHolderService dsUseContextHolderService;@PostMapping("/query")public ResultObj query(@RequestBody IdVO idVO) {DataVO dataVO = dsUseContextHolderService.query(idVO);return ResultObj.data(200,dataVO,"使用DynamicDataSourceContextHolder切换数据源,执行成功");}}
10.支撑对象
10.1CityDTO
实体对象全路径:com.hub.example.domain.CityDTO
内容:
@Datapublic class CityDTO implements Serializable {private Long cityId;private String cityName;private Double landArea;private Long population;private Double gross;private String cityDescribe;private String dataYear;@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")private Date updateTime;}
10.2ProvinceDTO
实体对象全路径:com.hub.example.domain.ProvinceDTO
内容:
@Datapublic class ProvinceDTO {private Long provinceId;private String provinceName;private Double landArea;private Long population;private Double gross;private String provinceDescribe;private String dataYear;@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")private Date updateTime;}
10.3DataVO
实体对象全路径:com.hub.example.domain.DataVO
内容:
@Datapublic class DataVO implements Serializable {private ProvinceDTO provinceDTO;private CityDTO cityDTO;}
10.4IdVO
实体对象全路径:com.hub.example.domain.IdVO
内容:
@Datapublic class IdVO implements Serializable {private String provinceId;private String cityId;}
10.5DataVO
实体对象全路径:com.hub.example.domain.ResultObj
内容:
@Datapublic class ResultObj implements Serializable {private int code;private String msg;private T data;private ResultObj(int code, T data, String msg) { this.code = code; this.data = data; this.msg = msg;}public static ResultObj data(int code, T data, String msg) { return new ResultObj(code, data, msg);}}
11.使用Postman工具测试
使用Postman工具测试。
11.1使用DS注解作用到类上切换数据源测试
请求路径:http://127.0.0.1:18080/hub-example-ds/hub/example/DsOnClass/query
请求方式:POST
入参格式:JSON
入参:
{"provinceId":"1","cityId":"1"}
11.2使用DS注解作用到方法上切换数据源测试
请求路径:http://127.0.0.1:18080/hub-example-ds/hub/example/DsOnMethod/query
请求方式:POST
入参格式:JSON
入参:
{"provinceId":"1","cityId":"1"}
11.3使用DynamicDataSourceContextHolder切换数据源测试
请求路径:http://127.0.0.1:18080/hub-example-ds/hub/example/DsUseContextHolder/query
请求方式:POST
入参格式:JSON
入参:
{"provinceId":"1","cityId":"1"}
12.附录
12.1全量pom.xml文件
4.0.0com.hubhub-example-202-dynamic-datasource1.0-SNAPSHOTorg.springframework.bootspring-boot-starter-parent2.6.3集成dynamic-datasource框架应用jar88UTF-8UTF-82.6.32.6.32.2.28.0.301.18.2430.1-jre3.3.2org.springframework.bootspring-boot-starter-parent${spring.boot.version}pomimportorg.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-jdbcmysqlmysql-connector-java${mysql-connector-java.version}org.mybatis.spring.bootmybatis-spring-boot-starter${mybatis-spring-boot-starter.version}org.projectlomboklombok${lombok.version}com.google.guavaguava${guava.version}com.baomidoudynamic-datasource-spring-boot-starter${dynamic-datasource.version}${project.artifactId}org.springframework.bootspring-boot-maven-plugin${spring.boot.maven.plugin.version}truetruerepackage
12.2建表语句与插入SQL
(1)数据库一
数据库名称:hub_exampledb
建表SQL脚本:
CREATE TABLE t_city (CITY_ID BIGINT(16) NOT NULLCOMMENT '唯一标识',CITY_NAME VARCHAR(64) COLLATE utf8_bin NOT NULL COMMENT '城市名',LAND_AREA DOUBLE DEFAULT NULL COMMENT '城市面积',POPULATION BIGINT(16) DEFAULT NULL COMMENT '城市人口',GROSS DOUBLE DEFAULT NULL COMMENT '生产总值',CITY_DESCRIBE VARCHAR(512) COLLATE utf8_bin DEFAULT NULL COMMENT '城市描述',DATA_YEAR VARCHAR(16) COLLATE utf8_bin DEFAULT NULL COMMENT '数据年份',UPDATE_TIMEDATETIME DEFAULT NULL COMMENT '更新时间') ENGINE=INNODB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='城市信息表';
插入SQL脚本:
INSERT INTO t_city (CITY_ID,CITY_NAME,LAND_AREA,POPULATION,GROSS,CITY_DESCRIBE,DATA_YEAR,UPDATE_TIME)VALUES('1','杭州','16850','1237','1.81','杭州是一个好城市','2021','2023-03-10 05:39:16'),('2','杭州','16850','1237','1.88','杭州是一个好城市','2022','2023-03-10 05:39:17'),('3','苏州','8657.32','1285','2.32','苏州是一个工业城市','2021','2023-03-10 05:39:18'),('4','苏州','8657.32','1285','2.4','苏州是一个工业城市','2022','2023-03-10 05:39:1');
(2)数据库二
数据库名称:hub_example02db
建表SQL脚本:
CREATE TABLE t_province (PROVINCE_ID BIGINT(16) NOT NULLCOMMENT '唯一标识',PROVINCE_NAME VARCHAR(64) COLLATE utf8_bin NOT NULL COMMENT '省名',LAND_AREA DOUBLE DEFAULT NULL COMMENT '省面积',POPULATION BIGINT(16) DEFAULT NULL COMMENT '全省人口',GROSS DOUBLE DEFAULT NULL COMMENT '生产总值',PROVINCE_DESCRIBE VARCHAR(512) COLLATE utf8_bin DEFAULT NULL COMMENT '省描述',DATA_YEAR VARCHAR(16) COLLATE utf8_bin DEFAULT NULL COMMENT '数据年份',UPDATE_TIMEDATETIME DEFAULT NULL COMMENT '更新时间') ENGINE=INNODB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='省信息表';
插入SQL脚本:
INSERT INTO t_province (PROVINCE_ID,PROVINCE_NAME,LAND_AREA,POPULATION,GROSS,PROVINCE_DESCRIBE,DATA_YEAR,UPDATE_TIME)VALUES('1','浙江省','105500','6577','7.77','浙江是一个好地方','2022','2023-03-11 10:55:16'),('2','江苏省','107200','8515','12.29','江苏是一个发达地区','2022','2023-03-11 10:55:17');
以上,感谢。
2023年3月11日