SpringBoot-21-Mybatis多数据源配置

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,高可用系列 2核4GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: SpringBoot-21-Mybatis多数据源配置

SpringBoot-21-Mybatis多数据源


之前我们介绍过Mybatis代码生成有两种方式:



在之前介绍JdbcTemplate和Spring-Boot-Data操作数据库的时候也分别介绍了



今天我们介绍Mybatis使用时候的多数源配置如何实现。

该测试项目的整体框架如下:

多数据源配置


在项目的application.yml中设置要链接的数据库,配置如下:

server:
  port: 8899
spring:
  datasource:
    student:
      jdbc-url: jdbc:mysql://localhost:3306/mybatis?useUnicode=true&serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
    teacher:
      jdbc-url: jdbc:mysql://localhost:3306/mysql?useUnicode=true&serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver


  • 在spring1.x和spring2.x中数据库配置链接关键字有区别:

  • 在1.x中配置的是spring.datasource.XXX.url
  • 在2.x中配置的是spring.datasource.XXX.jdbc-url


数据源的配置

主数据源的配置

在这次配置中我们将mybatis数据库作为主数据库,里面包含了student表,其主要配置如下:

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.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.core.io.support.PathMatchingResourcePatternResolver;
import javax.sql.DataSource;
@Configuration
//数据源student库接口存放目录
@MapperScan(basePackages = "com.learn.springboot.entity.student",
        sqlSessionTemplateRef = "sqlSessionTemplateStudent")
public class MybatisStudentConfig {
    /**
     * 主数据源默认使用Student
     *
     * @return
     */
    @Primary
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.student")
    public DataSource studentDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean
    public SqlSessionFactory sqlSessionFactoryStudent() throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(studentDataSource());
        //设置XML文件存放位置.注意这里student目录
        bean.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/student/*.xml")); 
        return bean.getObject();
    }
    @Bean
    public SqlSessionTemplate sqlSessionTemplateStudent() throws Exception {
        return new SqlSessionTemplate(sqlSessionFactoryStudent());
    }
}


  • 主数据源要是有**@Primary**进行表示
bean.setMapperLocations(new PathMatchingResourcePatternResolver()
        .getResources("classpath:mapper/teacher/*.xml"));用于配置xml的位置


  • 配置类上使用@MapperScan注解来是用来扫描实体类和Mapper包路径


非主数据源的配置

在这次配置中我们将mysql数据库作为非主数据库,里面包含了teacher表,其主要配置如下:

@Configuration
//数据源teacher库接口存放目录
@MapperScan(basePackages = "com.learn.springboot.entity.teacher",
        sqlSessionTemplateRef = "sqlSessionTemplateTeacher")
public class MybatisTeacherConfig {
    /**
     * 主数据源默认使用Student
     *
     * @return
     */
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.teacher")
    public DataSource teacherDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean
    public SqlSessionFactory sqlSessionFactoryTeacher() throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(teacherDataSource());
        //设置XML文件存放位置,注意这里teacher目录
        bean.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/teacher/*.xml"));
        return bean.getObject();
    }
    @Bean
    public SqlSessionTemplate sqlSessionTemplateTeacher() throws Exception {
        return new SqlSessionTemplate(sqlSessionFactoryTeacher());
    }
}


实体类的创建

本次章节的实体类分别有student和teacher两个实体类,代码如下

@Data
public class Student {
    private Long id;
    private String name;
    private String sex;
    private int age;
    private String email;
    private String mobile;
    private int isEnabled;
    private Date createDate;
    private Date updateDate;
}
@Data
public class Teacher {
    private Long id;
    private String name;
    private String sex;
    private String course;
    private int age;
    private String email;
    private String mobile;
    private int isEnabled;
    private Date createDate;
    private Date updateDate;
}


Mapper的实现

student的mapper接口的xml配置实现如下

  • studentmapper接口
public interface StudentMapper {
    Student findById(@Param("id") Long id);
    void updateStudent(Student student);
    int insertByObject(Student student);
}
  • studentmapper的xml配置如下
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.learn.springboot.entity.student.StudentMapper">
    <select id="findById" resultType="com.learn.springboot.entity.student.Student">
        SELECT * FROM STUDENT WHERE ID = #{id}
    </select>
    <insert id="insertByObject">
        INSERT INTO STUDENT(NAME, SEX,AGE,EMAIL,MOBILE) VALUES(#{name}, #{sex}, #{age}, #{email}, #{mobile})
    </insert>
    <update id="updateStudent" parameterType="com.learn.springboot.entity.student.Student">
       UPDATE STUDENT SET NAME=#{name},SEX=#{sex},AGE=#{age},EMAIL=#{email},MOBILE=#{mobile} WHERE id=#{id}
    </update>
</mapper>

teacher的mapper接口的xml配置实现如下

  • teachermapper的接口如下:
public interface TeacherService {
    Teacher updateTeacher(Teacher teacher);
    int insertByObject(Teacher teacher);
    Teacher findById(Long id);
}


  • teachermapper的xml配置如下
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.learn.springboot.entity.teacher.TeacherMapper">
    <select id="findById" resultType="com.learn.springboot.entity.teacher.Teacher">
        SELECT * FROM TEACHER WHERE ID = #{id}
    </select>
    <insert id="insertByObject">
        INSERT INTO TEACHER(NAME, SEX,AGE,EMAIL,MOBILE) VALUES(#{name}, #{sex}, #{age}, #{email}, #{mobile})
    </insert>
    <update id="updateTeacher" parameterType="com.learn.springboot.entity.teacher.Teacher">
       UPDATE TEACHER SET NAME=#{name},SEX=#{sex},AGE=#{age},EMAIL=#{email},MOBILE=#{mobile} WHERE id=#{id}
    </update>
</mapper>



Service层的实现

student的Service层实现

student的service包含studentservice接口和其实现StudentServiceimpl代码实现如下



  • StudentService接口的实现
public interface StudentService {
    Student updateStudent(Student student);
    int insertByObject(Student student);
    Student findById(Long id);
}


  • StudentServiceImpl的实现代码:
@Service
public class StudentServiceImpl implements StudentService {
    private StudentMapper studentMapper;
    @Override
    public int insertByObject(Student student){
        return  studentMapper.insertByObject(student);
    }
    @Override
    public Student updateStudent(Student student){
        studentMapper.updateStudent(student);
        return  student;
    }
    @Override
    public Student findById(Long id) {
        return studentMapper.findById(id);
    }
}



teacher的Service实现

student的service包含studentservice接口和其实现StudentServiceimpl代码实现如下:

  • StudentService接口的实现
public interface TeacherService {
    Teacher updateTeacher(Teacher teacher);
    int insertByObject(Teacher teacher);
    Teacher findById(Long id);
}


  • TeacherServiceImpl的实现代码:
@AllArgsConstructor
@Service
public class TeacherServiceImpl implements TeacherService {
    private TeacherMapper teacherMapper;
    @Override
    public int insertByObject(Teacher teacher){
        return  teacherMapper.insertByObject(teacher);
    }
    @Override
    public Teacher updateTeacher(Teacher teacher){
        teacherMapper.updateTeacher(teacher);
        return  teacher;
    }
    @Override
    public Teacher findById(Long id) {
        return teacherMapper.findById(id);
    }
}


控制层的实现

  • Student的控制层代码实现如下
@Slf4j
@RequestMapping("/student")
@RestController
@AllArgsConstructor
public class StudentController {
    /**
     * studentService注入StudentController
     */
    private StudentService studentService;
    @PostMapping("insert")
    public int insertByObject(@RequestBody Student student){
        return  studentService.insertByObject(student);
    }
    @PostMapping("update")
    public Student updateStudent(@RequestBody Student student) {
        return   studentService.updateStudent(student);
    }
    @GetMapping("/select/{id}")
    public Student findByName(@PathVariable("id") Long id) {
        return studentService.findById(id);
    }
}


  • Teacher的控制层代码实现如下
@Slf4j
@RequestMapping("/teacher")
@RestController
@AllArgsConstructor
public class TeacherController {
    /**
     * teacherService注入TeacherController
     */
    private TeacherService teacherService;
    @PostMapping("insert")
    public int insertByObject(@RequestBody Teacher teacher){
        return  teacherService.insertByObject(teacher);
    }
    @PostMapping("update")
    public Teacher updateStudent(@RequestBody Teacher teacher) {
        return   teacherService.updateTeacher(teacher);
    }
    @GetMapping("/select/{id}")
    public Teacher findByName(@PathVariable("id") Long id) {
        return teacherService.findById(id);
    }
}



测试


使用postman分别测试


http://localhost:8899/student/select/11 Get方法


http://localhost:8899/teacher/update Post方法


http://localhost:8899/teacher/select/11 Get方法


分别测试了student和teacher的方法以及Get和Post方法。


如果您觉得本文不错,欢迎关注支持,您的关注是我坚持的动力

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
目录
相关文章
|
2月前
|
XML Java 数据库连接
MyBatis的常见配置
MyBatis 常见配置包括数据库连接、类型别名、映射器等核心模块,合理配置可提升开发效率与系统性能。主要内容涵盖核心配置文件结构、关键配置项详解及配置优先级说明。
294 4
|
4月前
|
Java Spring
Spring Boot配置的优先级?
在Spring Boot项目中,配置可通过配置文件和外部配置实现。支持的配置文件包括application.properties、application.yml和application.yaml,优先级依次降低。外部配置常用方式有Java系统属性(如-Dserver.port=9001)和命令行参数(如--server.port=10010),其中命令行参数优先级高于系统属性。整体优先级顺序为:命令行参数 &gt; Java系统属性 &gt; application.properties &gt; application.yml &gt; application.yaml。
851 0
|
1月前
|
JavaScript Java Maven
【SpringBoot(二)】带你认识Yaml配置文件类型、SpringMVC的资源访问路径 和 静态资源配置的原理!
SpringBoot专栏第二章,从本章开始正式进入SpringBoot的WEB阶段开发,本章先带你认识yaml配置文件和资源的路径配置原理,以方便在后面的文章中打下基础
225 3
|
2月前
|
缓存 Java 应用服务中间件
Spring Boot配置优化:Tomcat+数据库+缓存+日志,全场景教程
本文详解Spring Boot十大核心配置优化技巧,涵盖Tomcat连接池、数据库连接池、Jackson时区、日志管理、缓存策略、异步线程池等关键配置,结合代码示例与通俗解释,助你轻松掌握高并发场景下的性能调优方法,适用于实际项目落地。
472 5
|
3月前
|
SQL XML Java
通过MyBatis的XML配置实现灵活的动态SQL查询
总结而言,通过MyBatis的XML配置实现灵活的动态SQL查询,可以让开发者以声明式的方式构建SQL语句,既保证了SQL操作的灵活性,又简化了代码的复杂度。这种方式可以显著提高数据库操作的效率和代码的可维护性。
249 18
|
2月前
|
传感器 Java 数据库
探索Spring Boot的@Conditional注解的上下文配置
Spring Boot 的 `@Conditional` 注解可根据不同条件动态控制 Bean 的加载,提升应用的灵活性与可配置性。本文深入解析其用法与优势,并结合实例展示如何通过自定义条件类实现环境适配的智能配置。
158 0
探索Spring Boot的@Conditional注解的上下文配置
|
8月前
|
Oracle 关系型数据库 Java
【YashanDB知识库】Mybatis-Plus适配崖山配置
【YashanDB知识库】Mybatis-Plus适配崖山配置
|
8月前
|
缓存 Java API
微服务——SpringBoot使用归纳——Spring Boot集成 Swagger2 展现在线接口文档——Swagger2 的配置
本文介绍了在Spring Boot中配置Swagger2的方法。通过创建一个配置类,添加`@Configuration`和`@EnableSwagger2`注解,使用Docket对象定义API文档的详细信息,包括标题、描述、版本和包路径等。配置完成后,访问`localhost:8080/swagger-ui.html`即可查看接口文档。文中还提示了可能因浏览器缓存导致的问题及解决方法。
940 0
微服务——SpringBoot使用归纳——Spring Boot集成 Swagger2 展现在线接口文档——Swagger2 的配置
|
3月前
|
安全 算法 Java
在Spring Boot中应用Jasypt以加密配置信息。
通过以上步骤,可以在Spring Boot应用中有效地利用Jasypt对配置信息进行加密,这样即使配置文件被泄露,其中的敏感信息也不会直接暴露给攻击者。这是一种在不牺牲操作复杂度的情况下提升应用安全性的简便方法。
910 10
|
8月前
|
Java 关系型数据库 数据库
微服务——SpringBoot使用归纳——Spring Boot事务配置管理——Spring Boot 事务配置
本文介绍了 Spring Boot 中的事务配置与使用方法。首先需要导入 MySQL 依赖,Spring Boot 会自动注入 `DataSourceTransactionManager`,无需额外配置即可通过 `@Transactional` 注解实现事务管理。接着通过创建一个用户插入功能的示例,展示了如何在 Service 层手动抛出异常以测试事务回滚机制。测试结果表明,数据库中未新增记录,证明事务已成功回滚。此过程简单高效,适合日常开发需求。
1084 0