多数据源切换

多数据源切换

  • 1.jdbcTemplate
  • 2.使用切面
  • 3.mybatis层次的多数据源
  • 4.spring的dynamic自动注入

项目中经常会有多个数据源，那么如何处理呢
有4种方法
准备：
创建两个数据库

CREATE SCHEMA `test` DEFAULT CHARACTER SET utf8mb4 ;
CREATE SCHEMA `school` DEFAULT CHARACTER SET utf8mb4 ;

test数据库创建user表，school数据库创建student表

--
-- Table structure for table `user`
--DROP TABLE IF EXISTS `user`;
/*!40101 SET @saved_cs_client     = @@character_set_client */;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `user` (`id` int NOT NULL AUTO_INCREMENT,`username` varchar(100) NOT NULL COMMENT '用户名',`real_name` varchar(200) DEFAULT NULL COMMENT '真实姓名',`password` varchar(2000) NOT NULL COMMENT '密码',`sex` tinyint(1) NOT NULL COMMENT '性别：0-男，1-女',`birthday` date NOT NULL COMMENT '生日',`card_id` varchar(20) NOT NULL COMMENT '身份证号',`phone` varchar(20) NOT NULL COMMENT '手机号',PRIMARY KEY (`id`),UNIQUE KEY `card_id` (`card_id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='用户表';
/*!40101 SET character_set_client = @saved_cs_client */;--
-- Dumping data for table `user`
--LOCK TABLES `user` WRITE;
/*!40000 ALTER TABLE `user` DISABLE KEYS */;
INSERT INTO `user` VALUES (1,'liming','黎明','123456',1,'2000-09-09','623001200010014433','13099890032'),(3,'miaoshanshan','苗姗姗','123456',0,'2001-10-12','314002200110125523','13509327765');
/*!40000 ALTER TABLE `user` ENABLE KEYS */;
UNLOCK TABLES;--
-- Host: localhost    Database: school
-- ------------------------------------------------------
-- Server version	8.0.29--
-- Table structure for table `student`
--DROP TABLE IF EXISTS `student`;
/*!40101 SET @saved_cs_client     = @@character_set_client */;
/*!50503 SET character_set_client = utf8mb4 */;
CREATE TABLE `student` (`id` int NOT NULL AUTO_INCREMENT,`student_name` varchar(100) NOT NULL COMMENT '学生姓名',`student_no` varchar(20) DEFAULT NULL COMMENT '学号',`password` varchar(200) NOT NULL COMMENT '密码',`sex` tinyint(1) NOT NULL COMMENT '性别：0-男，1-女',`birthday` date NOT NULL COMMENT '生日',`card_id` varchar(20) NOT NULL COMMENT '身份证号',PRIMARY KEY (`id`),UNIQUE KEY `student_no` (`student_no`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='学生表';
/*!40101 SET character_set_client = @saved_cs_client */;--
-- Dumping data for table `student`
--LOCK TABLES `student` WRITE;
/*!40000 ALTER TABLE `student` DISABLE KEYS */;
INSERT INTO `student` VALUES (1,'黎明','202110010101','123456',1,'2000-09-09','623001200010014433'),(2,'李艳','202110010102','123456',1,'2000-03-19',''),(3,'苗姗姗','202110010302','123456',0,'2001-10-12','314002200110125523'),(4,'李媛','202110010301','123456',0,'2002-11-22','314002200211225523');
/*!40000 ALTER TABLE `student` ENABLE KEYS */;
UNLOCK TABLES;

1.jdbcTemplate

不需要特殊的jar，只需配置即可
pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>jdbc-test</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.5.RELEASE</version></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.3.5.RELEASE</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.29</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.24</version></dependency><dependency><groupId>com.github.xiaoymin</groupId><artifactId>knife4j-spring-boot-starter</artifactId><version>3.0.3</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.17</version></dependency></dependencies>
</project>

配置多个数据源

server:port: 10010
spring:application:name: dynamic-datasource-jdbcdatasource:master:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://localhost:3306/test?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: rootschool:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://localhost:3306/school?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: root

对数据源进行配置

package com.test.jdbc.config;import com.zaxxer.hikari.HikariDataSource;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.core.JdbcTemplate;import javax.sql.DataSource;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-09 20:51*/
@Configuration
public class DataSourceConfig {@Primary@Bean("master")@ConfigurationProperties("spring.datasource.master")public DataSource masterDataSource(){return DataSourceBuilder.create().type(HikariDataSource.class).build();}@Bean("school")@ConfigurationProperties("spring.datasource.school")public DataSource schoolDataSource(){return DataSourceBuilder.create().type(HikariDataSource.class).build();}@Bean("master")public JdbcTemplate masterTemplate(@Qualifier("master") DataSource dataSource){return new JdbcTemplate(dataSource);}@Bean("schoolTemplate")public JdbcTemplate schoolTemplate(@Qualifier("school") DataSource dataSource){return new JdbcTemplate(dataSource);}
}

启动类，因为用knife做测试，所以需要@EnableOpenApi

package com.test.jdbc;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import springfox.documentation.oas.annotations.EnableOpenApi;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-11 20:33*/
@SpringBootApplication
@EnableOpenApi
public class JdbcService {public static void main(String[] args) {SpringApplication.run(JdbcService.class,args);}
}

分别写实体，接口及实现类进行测试
实体类

package com.test.jdbc.domain;import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.fasterxml.jackson.annotation.JsonIgnore;
import lombok.Data;import java.io.Serializable;
import java.sql.Date;/*** 学生表* @TableName student*/
@Data
public class Student implements Serializable {/*** id*/@TableId(type = IdType.AUTO)private Integer id;/*** 学生姓名*/private String studentName;/*** 学号*/private String studentNo;/*** 密码*/private String password;/*** 性别：0-男，1-女*/private Boolean sex;/*** 生日*/private Date birthday;//java.sql.Date对应数据库date类型，只显示年月日/*** 身份证号*/private String cardId;/*** 手机号*/@TableField(exist = false)@JsonIgnoreprivate String phone;}package com.test.jdbc.domain;import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;import java.io.Serializable;
import java.sql.Date;/*** 用户表* @TableName user*/
@Data
public class User implements Serializable {/*** id*/@TableId(type = IdType.AUTO)private Integer id;/*** 用户名*/private String username;/*** 真实姓名*/private String realName;/*** 密码*/private String password;/*** 性别：0-男，1-女*/private Boolean sex;/*** 生日*/private Date birthday;//java.sql.Date对应数据库date类型，只显示年月日/*** 身份证号*/private String cardId;/*** 手机号*/private String phone;private static final long serialVersionUID = 1L;
}

接口

package com.test.jdbc.controller;import com.test.jdbc.domain.Student;
import com.test.jdbc.domain.User;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-11 20:31*/
@RestController
public class TestController {@Autowiredprivate JdbcTemplate masterTemplate;@Autowiredprivate JdbcTemplate schoolTemplate;@GetMapping("getUserList")public List<User> getUserList(){List<User> list = masterTemplate.query("select * from user", new BeanPropertyRowMapper<>(User.class));return list;}@GetMapping("getStudentList")public List<Student> getStudentList(){List<Student> students = schoolTemplate.query("select * from student", new BeanPropertyRowMapper<>(Student.class));return students;}@GetMapping("getStudent")public List<Student> getStudent(){String sql = "select * from student";List<Student> list = schoolTemplate.query(sql, new BeanPropertyRowMapper<>(Student.class));list.stream().forEach(student -> {if (StringUtils.isNotBlank(student.getCardId())){String phone = masterTemplate.queryForObject("select phone from user where card_id = ?",String.class);student.setPhone(phone);}});return list;}
}

浏览器输入http://localhost:10010/doc.html
在这里插入图片描述
在这里插入图片描述

2.使用切面

需要额外写注解
pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>aop-test</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.5.RELEASE</version></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.3.5.RELEASE</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.29</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.24</version></dependency><dependency><groupId>com.github.xiaoymin</groupId><artifactId>knife4j-spring-boot-starter</artifactId><version>3.0.3</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.17</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId><version>2.2.6.RELEASE</version></dependency></dependencies>
</project>

配置文件

server:port: 10011
spring:application:name: dynamic-datasource-aopdatasource:master:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://localhost:3306/test?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: rootschool:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://localhost:3306/school?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: root

启动类

package com.test.aop;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import springfox.documentation.oas.annotations.EnableOpenApi;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-09 20:37*/
@EnableOpenApi
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//排除数据源自动注入，不然会报错
public class AopSourceService {public static void main(String[] args) {SpringApplication.run(AopSourceService.class,args);}
}

自定义注解

package com.test.aop.annonation;import java.lang.annotation.*;@Target({ElementType.PARAMETER,ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataSourceSwitch {public String dataSourceName() default "";
}

自定义注解的切面实现

package com.test.aop.aop;import com.test.aop.annonation.DataSourceSwitch;
import com.test.aop.config.DynamicDataSourceHolder;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;import java.lang.reflect.Method;@Aspect
@Component
public class DataSourceAspect {@Pointcut("@annotation(com.test.aop.annonation.DataSourceSwitch)")public void pointCut(){}@Before("pointCut()")public void before(JoinPoint joinpoint){MethodSignature signature = (MethodSignature)joinpoint.getSignature();Method method = signature.getMethod();DataSourceSwitch annotation = method.getAnnotation(DataSourceSwitch.class);DynamicDataSourceHolder.setDatasourcePool(annotation.dataSourceName());}@After("pointCut()")public void after(){DynamicDataSourceHolder.removeDatasourcePool();}
}

数据源配置类

package com.test.aop.config;import com.test.aop.enums.DataSourceType;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-09 20:51*/
@Configuration
public class DataSourceConfig {@Bean("masterDataSource")@ConfigurationProperties("spring.datasource.master")public DataSource masterDataSource(){return DataSourceBuilder.create().type(HikariDataSource.class).build();}@Bean("schoolDataSource")@ConfigurationProperties("spring.datasource.school")public DataSource schoolDataSource(){return DataSourceBuilder.create().type(HikariDataSource.class).build();}@Primary@Bean("dynamicDataSource")public DynamicDataSource dynamicDataSource(){Map<Object,Object> targetDataSources = new HashMap<>();targetDataSources.put(DataSourceType.TEST.name(),masterDataSource());targetDataSources.put(DataSourceType.SCHOOL.name(),schoolDataSource());return new DynamicDataSource(masterDataSource(),targetDataSources);}/*@Bean("masterTemplate")public JdbcTemplate masterTemplate(@Qualifier("masterDataSource") DataSource dataSource){return new JdbcTemplate(dataSource);}@Bean("schoolTemplate")public JdbcTemplate schoolTemplate(@Qualifier("schoolDataSource") DataSource dataSource){return new JdbcTemplate(dataSource);}*/
}package com.test.aop.config;import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;import javax.sql.DataSource;
import java.util.Map;public class DynamicDataSource extends AbstractRoutingDataSource {public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object,Object> targetDataSource){super.setDefaultTargetDataSource(defaultTargetDataSource);super.setTargetDataSources(targetDataSource);super.afterPropertiesSet();}@Overrideprotected Object determineCurrentLookupKey() {return DynamicDataSourceHolder.getDatasourcePool();}
}package com.test.aop.config;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-09 20:54*/
public class DynamicDataSourceHolder {public static ThreadLocal<String> DATASOURCE_POOL = new ThreadLocal<>();/*** 获取数据源变量* @return*/public static String getDatasourcePool(){return DATASOURCE_POOL.get();}/*** 设置数据源变量* @param name*/public static void setDatasourcePool(String name){DATASOURCE_POOL.set(name);}public static void removeDatasourcePool(){DATASOURCE_POOL.remove();}
}

数据源类型枚举

package com.test.aop.enums;public enum DataSourceType {TEST,SCHOOL,;
}

接口或实现类使用注解

package com.test.aop.controller;import com.test.aop.annonation.DataSourceSwitch;
import com.test.aop.domain.Student;
import com.test.aop.domain.User;
import com.test.aop.service.StudentService;
import com.test.aop.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-09 20:58*/@RestController
public class TestController {@Autowiredprivate UserService userService;@Autowiredprivate StudentService studentService;@GetMapping("user/list")public List<User> userList(){return userService.list();}@GetMapping("student/list")@DataSourceSwitch(dataSourceName = "SCHOOL")public List<Student> studentList(){return studentService.list();}@PostMapping("user/save")public void saveUser(@RequestBody User user){userService.save(user);}@PostMapping("student/save")@DataSourceSwitch(dataSourceName = "SCHOOL")public void saveStudent(@RequestBody Student student){studentService.save(student);}@GetMapping("registerToUser")public void registerToUser(Integer id,String username,String phone,String cardId){userService.registerTiUser(id,username,phone,cardId);}/**** @return*/@GetMapping("list")public List<Student> list(){return studentService.getPhone();}
}

3.mybatis层次的多数据源

需要每个库写一个配置类
pom

server:port: 10012
spring:application:name: dynamic-datasource-mybatisdatasource:master:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://localhost:3306/test?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: rootschool:driver-class-name: com.mysql.cj.jdbc.Driverjdbc-url: jdbc:mysql://localhost:3306/school?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: root

启动类

package com.test.mybatis;import com.baomidou.mybatisplus.autoconfigure.MybatisPlusAutoConfiguration;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import springfox.documentation.oas.annotations.EnableOpenApi;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-11 21:06*/
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, MybatisPlusAutoConfiguration.class})
@EnableOpenApi
public class MybatisService {public static void main(String[] args) {SpringApplication.run(MybatisService.class,args);}
}

数据源配置文件

package com.test.mybatis.config;import com.sun.tracing.ProbeName;
import com.zaxxer.hikari.HikariDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;import javax.sql.DataSource;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-11 21:14*/
@Configuration
@MapperScan(basePackages = "com.test.mybatis.mapper.test",sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {@Bean@ConfigurationProperties("spring.datasource.master")public DataSource masterDatasource(){return DataSourceBuilder.create().type(HikariDataSource.class).build();}@Primary@Beanpublic SqlSessionFactory masterSqlSessionFactory()throws Exception{SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(masterDatasource());return bean.getObject();}@Primary@Beanpublic DataSourceTransactionManager masterTransactionManager(){DataSourceTransactionManager manager = new DataSourceTransactionManager();manager.setDataSource(masterDatasource());return manager;}@Beanpublic TransactionTemplate masterTemplate(){return new TransactionTemplate(masterTransactionManager());}}package com.test.mybatis.config;import com.zaxxer.hikari.HikariDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;import javax.sql.DataSource;/*** @author清梦* @site www.xiaomage.com* @company xxx公司* @create 2023-11-11 21:14*/
@Configuration
@MapperScan(basePackages = "com.test.mybatis.mapper.school",sqlSessionFactoryRef = "schoolSqlSessionFactory")
public class SchoolDataSourceConfig {@Bean@ConfigurationProperties("spring.datasource.school")public DataSource schoolDatasource(){return DataSourceBuilder.create().type(HikariDataSource.class).build();}@Beanpublic SqlSessionFactory schoolSqlSessionFactory()throws Exception{SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(schoolDatasource());return bean.getObject();}@Beanpublic DataSourceTransactionManager schoolTransactionManager(){DataSourceTransactionManager manager = new DataSourceTransactionManager();manager.setDataSource(schoolDatasource());return manager;}@Beanpublic TransactionTemplate schoolTemplate(){return new TransactionTemplate(schoolTransactionManager());}}

4.spring的dynamic自动注入

需要引入dynamic-datasource-spring-boot-starter，实现类使用注解@DS(“数据源”)即可
pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>spring-jdbc</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.5.RELEASE</version></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.3.5.RELEASE</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.29</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.24</version></dependency><dependency><groupId>com.github.xiaoymin</groupId><artifactId>knife4j-spring-boot-starter</artifactId><version>3.0.3</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>2.5.6</version></dependency></dependencies>
</project>

配置文件有点不同

server:port: 10013
spring:application:name: dynamic-datasource-springdatasource:dynamic:primary: masterdatasource:master:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/test?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: rootschool:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/school?serverTimezone=Asia/Shanghai&characterEncoding=utf-8username: rootpassword: root

启动类

@SpringBootApplication
@EnableOpenApi
public class SpringAutoService{public static void main(String[] args) {SpringApplication.run(SpringAutoService.class,args);}
}

在实现类使用注解

package com.test.spring.service.impl;import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.test.spring.domain.Student;
import com.test.spring.mapper.StudentMapper;
import com.test.spring.mapper.UserMapper;
import com.test.spring.service.StudentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;/**
*
*/
@Service
@DS("school")
public class StudentServiceImpl extends ServiceImpl<StudentMapper,Student> implements StudentService{@Autowiredprivate UserMapper userMapper;@Overridepublic List<Student> getPhone() {List<Student> list = list();list.stream().filter(student -> StringUtils.isNotBlank(student.getCardId())).forEach(student -> {String phone = userMapper.selectPhoneByCardId(student.getCardId());student.setPhone(phone);});return list;}}
package com.test.spring.service.impl;import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.test.spring.domain.Student;
import com.test.spring.domain.User;
import com.test.spring.mapper.StudentMapper;
import com.test.spring.mapper.UserMapper;
import com.test.spring.service.StudentService;
import com.test.spring.service.UserService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/**
*
*/
@Service
@DS("master")
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService{@Autowiredprivate UserMapper userMapper;@Autowiredprivate StudentMapper studentMapper;@Overridepublic void registerTiUser(Integer id, String username, String phone, String cardId) {Student student = studentMapper.selectById(id);if (null == student){throw new RuntimeException("该学生不存在");}User user = new User();user.setRealName(student.getStudentName());BeanUtils.copyProperties(student,user);user.setUsername(username);user.setPhone(phone);user.setCardId(cardId);userMapper.insert(user);}}

源码地址：https://gitee.com/qfp17393120407/dynamic-datasource-new.git

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/178767.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Power Automate-调用API

Power Automate-调用API

API:汇率查询API免费接口&#xff0c;汇率查询API接口付费定制-进制数据 在输出结果之前添加操作&#xff0c;搜索HTTP&#xff0c;点击绿色的图标 选择第一个 查看API详情对应填入到HTTP操作中&#xff0c;比如方法&#xff08;请求方法&#xff09;、URL&#xff08;接口地址…
阅读更多...
Javaweb之Vue的概述

Javaweb之Vue的概述

2.1 Vue概述 通过我们学习的htmlcssjs已经能够开发美观的页面了&#xff0c;但是开发的效率还有待提高&#xff0c;那么如何提高呢&#xff1f;我们先来分析下页面的组成。一个完整的html页面包括了视图和数据&#xff0c;数据是通过请求 从后台获取的&#xff0c;那么意味着我…
阅读更多...
[Linux] 网络文件共享服务

[Linux] 网络文件共享服务

一、存储类型 存储类型可分为三类&#xff1a;DAS&#xff08;直连式存储&#xff09;,NAS&#xff08;网络附加存储&#xff09;,SAN&#xff08;存储区域网络&#xff09;。 1.1 DAS 定义&#xff1a; DAS是指直连存储&#xff0c;即直连存储&#xff0c;可以理解为本地文…
阅读更多...
防爆五参数气象仪的科技力量

防爆五参数气象仪的科技力量

WX-FBQ2 随着科技的不断进步&#xff0c;气象监测设备也在不断升级和完善。 防爆五参数气象仪是一种可以同时监测温度、湿度、压力、风速和风向五个基本气象参数的仪器。它采用了气象监测技术&#xff0c;不仅可以实时监测气象数据&#xff0c;还可以对数据进行分析和处理。 …
阅读更多...
Neo4j数据库介绍及简单使用

Neo4j数据库介绍及简单使用

图数据库介绍 图数据库是一种专门设计用于存储和管理图形数据的数据库类型。在图数据库中&#xff0c;数据以图的形式表示&#xff0c;其中节点表示实体&#xff0c;边表示实体之间的关系。这种表示方式非常适合处理具有复杂关系的数据&#xff0c;如社交网络、推荐系统、网络…
阅读更多...
excel中vlookup用法

excel中vlookup用法

excel中vlookup用法 用法示例 参数说明 参数1&#xff1a;E1用于匹配的字段 参数2&#xff1a;E1:F4&#xff0c;匹配表格范围 参数3&#xff1a;要取的字段属于匹配表格范围的第几列 数据4&#xff1a;精确匹配
阅读更多...
【VBA】基于EXCEL生成Insert语句工具

【VBA】基于EXCEL生成Insert语句工具

前言 基于Excel生成INSERT语句工具是为了解决在数据库中插入大量数据时手动编写INSERT语句繁琐和耗时的问题而开发的辅助工具。在软件开发和数据库管理等领域&#xff0c;测试数据是非常重要的&#xff0c;它可以用于测试和验证数据库的性能、功能和准确性。 手动编写INSERT语…
阅读更多...
（Matalb时序预测）GWO-BP灰狼算法优化BP神经网络的多维时序回归预测

（Matalb时序预测）GWO-BP灰狼算法优化BP神经网络的多维时序回归预测

目录 一、程序及算法内容介绍&#xff1a; 基本内容&#xff1a; 亮点与优势&#xff1a; 二、实际运行效果&#xff1a; 三、部分代码展示&#xff1a; 四、完整代码数据说明手册下载&#xff1a; 一、程序及算法内容介绍&#xff1a; 基本内容&#xff1a; 本代码基于M…
阅读更多...
《QT从基础到进阶·二十四》按钮组QButtonGroup，单选框QRadioButton和多选框QCheckBox

《QT从基础到进阶·二十四》按钮组QButtonGroup，单选框QRadioButton和多选框QCheckBox

1、按钮组QButtonGroup 如果有多个单选按钮&#xff0c;可以统一放进一个按钮组。 图中有三个单选按钮放进了一个QGroupBox,并且设置了水平布局&#xff0c;现在要将这三个单选按钮放进一个按钮组&#xff0c;之前的想法是先把三个按钮加入按钮组&#xff0c;再把按钮组放进QG…
阅读更多...
2023年阿里云服务器购买指南，优惠云服务器性能说明

2023年阿里云服务器购买指南，优惠云服务器性能说明

云服务器作为当下互联网行业的重要基础设施之一&#xff0c;对于个人博客、企业展示型官网以及开发者来说&#xff0c;是必不可少的工具。2023年&#xff0c;阿里云金秋云创季推出了两款特惠的云服务器&#xff0c;为用户提供了更加优惠和实用的选择。 1. 轻量应用服务器2核2G…
阅读更多...
Qt 5.15.11 源码windows编译

Qt 5.15.11 源码windows编译

1.下载qt5.15.11源码 https://download.qt.io/official_releases/qt/5.15/5.15.11/single/qt-everywhere-opensource-src-5.15.11.zip 2.解码源码到桌面 3.安装cmake ,python ,perl, Visual Studio 2019 Strawberry Perl for Windows Win flex-bison download | SourceForge…
阅读更多...
医院手术麻醉信息系统（麻醉知情同意书）源码

医院手术麻醉信息系统（麻醉知情同意书）源码

手术室麻醉信息管理系统是定位于手术室和麻醉科的科室级临床信息管理系统&#xff0c;主要用于与手术麻醉相关的各项数据的记录、管理和应用&#xff0c;实现医疗信息的共享及再利用&#xff0c;提高科室的整体信息化水平。 该系统将手术室内的各种设备&#xff08;如呼吸机、麻…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023