精通SpringBoot —— 第十四篇:整合mybatis和jpa的多数据源

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: springboot 整合mybatis + jpa多数据源

刚更新了一篇SpringBoot整合mybatis。突然想mybatis虽然功能强大,但是对sql的要求还是算高的。Spring Data Jpa对于某些用户来说 ,还是个比较简单的选择。毕竟不用写较复杂的sql语句,于是就想,来一个SpringBoot+mybatis + jpa的大杂烩。
说到底,多数据源整合其实就是要保证项目中有且仅有一个primaryDataSource,即主数据源,它是无可替代的。
先看application.yml 有多少个数据源就的配置多少个数据库链接

spring:
  ## multipart datasource configuration ##
  datasource:
    primary:
      jdbc-url: jdbc:mysql://localhost:3306/javashop
      username: root
      password: 123456
      driver-class-name: com.mysql.jdbc.Driver
      type: com.alibaba.druid.pool.DruidDataSource
    secondary:
      jdbc-url: jdbc:mysql://localhost:3306/test
      username: root
      password: 123456
      driver-class-name: com.mysql.jdbc.Driver
      type: com.alibaba.druid.pool.DruidDataSource
    master:
      jdbc-url: jdbc:mysql://localhost:3306/javashop
      username: root
      password: 123456
      driver-class-name: com.mysql.jdbc.Driver
      type: com.alibaba.druid.pool.DruidDataSource
    cluster:
      jdbc-url: jdbc:mysql://localhost:3306/test
      username: root
      password: 123456
      driver-class-name: com.mysql.jdbc.Driver
      type: com.alibaba.druid.pool.DruidDataSource

  jpa:
    hibernate:
      ddl-auto: update
      naming:
        physical-strategy: org.springframework.boot.orm.jpa.hibernate.SpringPhysicalNamingStrategy
    show-sql: true
    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect

项目结构图

└─src
    ├─main
    │  ├─java
    │  │  └─com
    │  │      └─developlee
    │  │          └─multipartdatasource
    │  │              │  MultipartDatasourceApplication.java
    │  │              │  
    │  │              ├─config
    │  │              │  ├─jpa
    │  │              │  │      DataSourceConfig.java
    │  │              │  │      PrimaryDataSourceConfig.java
    │  │              │  │      SecondaryDataSourceConfig.java
    │  │              │  │      
    │  │              │  └─mybatis
    │  │              │          ClusterDataSourceConfig.java
    │  │              │          MasterDataSourceConfig.java
    │  │              │          
    │  │              ├─dao
    │  │              │  ├─jpa
    │  │              │  │  ├─primary
    │  │              │  │  │      UserRepository.java
    │  │              │  │  │      
    │  │              │  │  └─secondary
    │  │              │  │          CityRepository.java
    │  │              │  │          
    │  │              │  └─mybatis
    │  │              │      ├─cluster
    │  │              │      │      CityDao.java
    │  │              │      │      
    │  │              │      └─master
    │  │              │              UserDao.java
    │  │              │              
    │  │              ├─entity
    │  │              │  ├─jpa
    │  │              │  │  ├─primary
    │  │              │  │  │      UserEntity.java
    │  │              │  │  │      
    │  │              │  │  └─secondary
    │  │              │  │          CityEntity.java
    │  │              │  │          
    │  │              │  └─mybatis
    │  │              │      ├─cluster
    │  │              │      │      MybatisCityEntity.java
    │  │              │      │      
    │  │              │      └─master
    │  │              │              MybatisUserEntity.java
    │  │              │              
    │  │              └─service
    │  │                  │  CityService.java
    │  │                  │  UserService.java
    │  │                  │  
    │  │                  └─impl
    │  │                          CityServiceImpl.java
    │  │                          UserServiceImpl.java
    │  │                          
    │  └─resources
    │      │  application.yml
    │      │  
    │      ├─mapper
    │      │  ├─cluster
    │      │  │      city.xml
    │      │  │      
    │      │  └─master
    │      │          user.xml
    │      │          
    │      ├─static
    │      └─templates
    └─test
        └─java
            └─com
                └─developlee
                    └─multipartdatasource
                            MultipartDatasourceApplicationTests.java
                    

从文件树可以看到,对每个数据源要操作的实体类和数据接口都进行隔离。

jpa数据源配置

@Configuration
public class DataSourceConfig {

    @Bean(name = "primaryDataSource")
    @Qualifier("primaryDataSource")
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "secondaryDataSource")
    @Qualifier("secondaryDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.secondary")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }

}
JPA-primary主数据源配置
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "primaryEntityManagerFactory",
        transactionManagerRef = "primaryTransactionManager",
        basePackages = { PrimaryDataSourceConfig.REPO_PACKAGE } // 设置 Repository 所在位置
        )
public class PrimaryDataSourceConfig {

    static final String REPO_PACKAGE = "com.developlee.multipartdatasource.dao.jpa.primary";
    static final String ENTITY_PACKAGE = "com.developlee.multipartdatasource.entity.jpa.primary";

    @Resource
    @Qualifier("primaryDataSource")
    private DataSource primaryDataSource;

    @Resource
    private JpaProperties jpaProperties;

    @Primary
    @Bean(name = "primaryEntityManager")
    public EntityManager primaryEntityManager(EntityManagerFactoryBuilder builder) {
       return primaryEntityManagerFactory(builder).getObject().createEntityManager();
    }

    @Primary
    @Bean(name = "primaryEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean primaryEntityManagerFactory(EntityManagerFactoryBuilder builder) {
        return builder.dataSource(primaryDataSource)
                .properties(jpaProperties.getHibernateProperties(new HibernateSettings()))
                .persistenceUnit("primaryPersistenceUnit")
                .packages(ENTITY_PACKAGE)
                .build();
    }

    @Primary
    @Bean(name = "primaryTransactionManager")
    public PlatformTransactionManager primaryTransactionManager(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(primaryEntityManagerFactory(builder).getObject());
    }
}

jpa-secondary的从数据源与此类似。

mybatis-master数据源配置
@Configuration
@MapperScan(basePackages = MasterDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {
    // 精确到master目录和其他数据源隔离
    static final String PACKAGE = "com.developlee.multipartdatasource.dao.mybatis.master";
    static final String MAPPER_LOCATION = "classpath:mapper/master/*.xml";

    @Value("${spring.datasource.master.jdbc-url}")
    private String url;

    @Value("${spring.datasource.master.username}")
    private String user;

    @Value("${spring.datasource.master.password}")
    private String password;

    @Value("${spring.datasource.master.driver-class-name}")
    private String driverClass;

    @Bean(name = "masterDataSource")
    public DataSource masterDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driverClass);
        dataSource.setUrl(url);
        dataSource.setUsername(user);
        dataSource.setPassword(password);
        return dataSource;
    }

    @Bean(name = "masterTransactionManager")
    @Primary
    public DataSourceTransactionManager masterTransactionManager() {
        return new DataSourceTransactionManager(masterDataSource());
    }

    @Bean(name = "masterSqlSessionFactory")
    @Primary
    public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource masterDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(masterDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(MasterDataSourceConfig.MAPPER_LOCATION));
        return sessionFactory.getObject();
    }
}

mybatis-cluster数据源配置与此类似。

测试

说明下,业务逻辑代码就不贴了,可在我的github中找到。

@RunWith(SpringRunner.class)
@SpringBootTest
public class MultipartDatasourceApplicationTests {

    @Autowired
    UserServiceImpl userService;

    @Autowired
    CityServiceImpl cityService;


    @Test
    public void contextLoads() {
        UserEntity userEntity = new UserEntity();
        userEntity.setUsername("JPA-Lensen");
        userEntity.setPwd("123456");
        userEntity.setMobile("137****8661");

        CityEntity cityEntity = new CityEntity();
        cityEntity.setUserId(1024L);
        cityEntity.setDescription("JPA-Lensen-Desc");

        MybatisUserEntity mybatisUserEntity = new MybatisUserEntity();
        mybatisUserEntity.setUsername("Mybatis-Lensen");
        mybatisUserEntity.setPwd("654321");
        mybatisUserEntity.setMobile("137****1024");

        MybatisCityEntity mybatisCityEntity = new MybatisCityEntity();
        mybatisCityEntity.setDesc("MyBatis-Lensen-Desc");
        mybatisCityEntity.setUserId(2048L);
        mybatisCityEntity.setId(10L);

        userService.saveUserByJpa(userEntity);
        cityService.saveCityByJpa(cityEntity);
        userService.saveUserByMybatis(mybatisUserEntity);
        cityService.saveCityByMybatis(mybatisCityEntity);

    }

}

截图看看效果
image

看看数据库的数据
tb_user表
image
tb_city表
image
最后: 此项目代码可在我的github.com中找到。
我的个人公众号:developlee的潇洒人生。
关注了也不一定更新,更新就不得了了。
image

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
24天前
|
Java 数据库连接 Maven
mybatis使用一:springboot整合mybatis、mybatis generator,使用逆向工程生成java代码。
这篇文章介绍了如何在Spring Boot项目中整合MyBatis和MyBatis Generator,使用逆向工程来自动生成Java代码,包括实体类、Mapper文件和Example文件,以提高开发效率。
70 2
mybatis使用一:springboot整合mybatis、mybatis generator,使用逆向工程生成java代码。
|
24天前
|
SQL JSON Java
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
这篇文章介绍了如何在Spring Boot项目中整合MyBatis和PageHelper进行分页操作,并且集成Swagger2来生成API文档,同时定义了统一的数据返回格式和请求模块。
39 1
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
|
1月前
|
前端开发 Java Apache
Springboot整合shiro,带你学会shiro,入门级别教程,由浅入深,完整代码案例,各位项目想加这个模块的人也可以看这个,又或者不会mybatis-plus的也可以看这个
本文详细讲解了如何整合Apache Shiro与Spring Boot项目,包括数据库准备、项目配置、实体类、Mapper、Service、Controller的创建和配置,以及Shiro的配置和使用。
212 1
Springboot整合shiro,带你学会shiro,入门级别教程,由浅入深,完整代码案例,各位项目想加这个模块的人也可以看这个,又或者不会mybatis-plus的也可以看这个
|
23天前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
35 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库
|
24天前
|
SQL Java 数据库连接
mybatis使用二:springboot 整合 mybatis,创建开发环境
这篇文章介绍了如何在SpringBoot项目中整合Mybatis和MybatisGenerator,包括添加依赖、配置数据源、修改启动主类、编写Java代码,以及使用Postman进行接口测试。
14 0
mybatis使用二:springboot 整合 mybatis,创建开发环境
|
25天前
|
Java 数据库连接 API
springBoot:后端解决跨域&Mybatis-Plus&SwaggerUI&代码生成器 (四)
本文介绍了后端解决跨域问题的方法及Mybatis-Plus的配置与使用。首先通过创建`CorsConfig`类并设置相关参数来实现跨域请求处理。接着,详细描述了如何引入Mybatis-Plus插件,包括配置`MybatisPlusConfig`类、定义Mapper接口以及Service层。此外,还展示了如何配置分页查询功能,并引入SwaggerUI进行API文档生成。最后,提供了代码生成器的配置示例,帮助快速生成项目所需的基础代码。
|
29天前
|
SQL Java 关系型数据库
Springboot引入jpa来管理数据库
Springboot引入jpa来管理数据库
26 0
Springboot引入jpa来管理数据库
|
1月前
|
前端开发 Java 数据库连接
表白墙/留言墙 —— 中级SpringBoot项目,MyBatis技术栈MySQL数据库开发,练手项目前后端开发(带完整源码) 全方位全步骤手把手教学
本文是一份全面的表白墙/留言墙项目教程,使用SpringBoot + MyBatis技术栈和MySQL数据库开发,涵盖了项目前后端开发、数据库配置、代码实现和运行的详细步骤。
35 0
表白墙/留言墙 —— 中级SpringBoot项目,MyBatis技术栈MySQL数据库开发,练手项目前后端开发(带完整源码) 全方位全步骤手把手教学
|
27天前
|
Java 数据库连接 Maven
Spring整合Mybatis
Spring整合Mybatis
|
28天前
|
SQL Java 数据库连接
springBoot+Jpa(hibernate)数据库基本操作
springBoot+Jpa(hibernate)数据库基本操作
30 0