文档章节

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

liululee
 liululee
发布于 2018/10/24 14:25
字数 824
阅读 95
收藏 4

刚更新了一篇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

© 著作权归作者所有

liululee
粉丝 127
博文 73
码字总数 104582
作品 0
杭州
程序员
私信 提问
spring3 ,spring3 mvc 配置文件整合问题,哪种配置更好?

正常的整合是要在web.xml里面配置spring监听器,spring mvc的dispath servlet,代码如下: Java代码 org.springframework.web.context.ContextLoaderListener contextConfigLocation /WEB-I......

_凤求凰_
2014/01/07
2.4K
3
SpringBoot | 第三十章:Spring-data-jpa的集成和使用

前言 在前面的第九章:Mybatis-plus的集成和使用章节中,介绍了使用框架进行数据库的访问。今天,我们来简单学习下如何使用进行数据库的访问。由于本人未使用过,也是趁着写博文的机会查阅了...

oKong
2018/10/31
278
0
spring-boot和JPA多数据源整合

今天弄一下spring-boot和jpa的多数据源整合 Jpa(Java Persistence API)Java持久化API,它是一套ORM规范 只是一套规范 Spring Boot中使用的Jpa实际上是Spring Data Jpa,Spring Data是Sprin...

咸鱼-李y
06/01
107
0
Spring Boot入门资料整理

Spring Boot 初识 SpringBoot前世今生 本文主要讲述spring boot的由来,即其它诞生的背景,初衷,现状,及对未来的展望。 Spring Boot参考指南中文版--Chapter1.Spring Boot中文文档 本节提供...

小致dad
2017/11/07
537
0
springboot从入门到精通教程分享, 深度掌握Springboot实践技术教程

深度掌握Springboot实践技术教程,共22个课时,需要的可回复邮箱。 课程简介 day1 01springboot简介-曾经开发中的问题 02springboot解决的问题-优势以及弊端 03springboot环境准备 04spring...

小小倾听
2018/12/06
736
19

没有更多内容

加载失败,请刷新页面

加载更多

一起来学Java8(四)——复合Lambda

在一起来学Java8(二)——Lambda表达式中我们学习了Lambda表达式的基本用法,现在来了解下复合Lambda。 Lambda表达式的的书写离不开函数式接口,复合Lambda的意思是在使用Lambda表达式实现函...

猿敲月下码
9分钟前
0
0
debian10使用putty配置交换机console口

前言:Linux的推广普及,需要配合解决实际应用方能有成效! 最近强迫自己用linux进行实际工作,过程很痛苦,还好通过网络一一解决,感谢各位无私网友博客的帮助! 系统:debian10 桌面:xfc...

W_Lu
41分钟前
10
0
aelf Enterprise 0.8.0 beta有奖公测,“Bug奖金计划”重磅开启

2019年9月30日,aelf Enterprise 0.8.0 beta版正式发布。aelf Enterprise 0.8.0 beta是一个完备的区块链系统, 包含完备的区块链系统、开发套件、开发文档、以及配套的基础应用和基础服务。 ...

AELF开发者社区
42分钟前
8
0
oracle 初始化数据库脚本

create user lpf identified by 123456; create tablespace lpf_ts_cms datafile '/opt/app/oracle/product/11.2.0/lpf.dbf' size 200M; alter user lpf default tablespace lpf_ts_cms; sel......

internetafei
46分钟前
7
0
深入了解Redis底层数据结构

说明 说到Redis的数据结构,我们大概会很快想到Redis的5种常见数据结构:字符串(String)、列表(List)、散列(Hash)、集合(Set)、有序集合(Sorted Set),以及他们的特点和运用场景。不过它们是...

TurboSanil
47分钟前
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部