SpringBoot 配置多数据源 JPA

之前则介绍了怎样从SpringBoot源码中，摘出配置MyBatis的方法。这次，则开始摘出Jpa的配置方法。
GitHub https://github.com/oldguys/MultipleDataSourceDemo

Step1: 剔除自动配置类

package com.oldguy.example;

import org.mybatis.spring.boot.autoconfigure.MybatisAutoConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.data.jpa.JpaRepositoriesAutoConfiguration;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;


@SpringBootApplication(exclude = {
        DataSourceAutoConfiguration.class,
    //  MybatisAutoConfiguration.class,
        JpaRepositoriesAutoConfiguration.class,
        HibernateJpaAutoConfiguration.class,
})
public class MultipleDatasourceDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(MultipleDatasourceDemoApplication.class, args);
    }

}

Step2: 从SpringBoot 源码中，摘出Jpa部分配置代码，并编写成为配置类

package com.oldguy.example.modules.common.configs;

import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.JpaVendorAdapter;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;

import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;
import java.util.Map;

/**
 * @Date: 2019/1/7 0007
 * @Author: ren
 * @Description:
 */
public abstract class AbstractJpaConfiguration {


    protected JpaVendorAdapter createJpaVendorAdapter(JpaProperties properties, DataSource dataSource) {
        HibernateJpaVendorAdapter adapter = new HibernateJpaVendorAdapter();
        adapter.setShowSql(properties.isShowSql());
        adapter.setDatabase(properties.determineDatabase(dataSource));
        adapter.setDatabasePlatform(properties.getDatabasePlatform());
        adapter.setGenerateDdl(properties.isGenerateDdl());
        return adapter;
    }


    protected EntityManagerFactory createEntityManagerFactory(
            DataSource dataSource,
            JpaProperties jpaProperties,
            JpaVendorAdapter jpaVendorAdapter,
            String entitiesPackage) {

        Map<String, String> map = jpaProperties.getHibernateProperties(dataSource);

        LocalContainerEntityManagerFactoryBean bean = new LocalContainerEntityManagerFactoryBean();
        bean.setDataSource(dataSource);
        bean.setJpaVendorAdapter(jpaVendorAdapter);
        bean.setPackagesToScan(entitiesPackage);
        bean.setJpaPropertyMap(map);


        // 进行配置
        bean.afterPropertiesSet();

        return bean.getObject();
    }


    protected JpaTransactionManager createTransactionManager(EntityManagerFactory entityManagerFactory) {

        JpaTransactionManager manager = new JpaTransactionManager();
        manager.setEntityManagerFactory(entityManagerFactory);
        return manager;
    }
}

Step3: 编写实现类

数据源3

package com.oldguy.example.configs;

import com.alibaba.druid.pool.DruidDataSource;
import com.oldguy.example.modules.common.configs.AbstractJpaConfiguration;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.JpaVendorAdapter;


import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;

/**
 * @Date: 2019/1/7 0007
 * @Author: ren
 * @Description:
 */
@Configuration
@EnableJpaRepositories(entityManagerFactoryRef = "test3EntityManagerFactory",
        basePackages = "com.oldguy.example.modules.test3.dao.jpas",
        transactionManagerRef = "test3TransactionManager")
public class Test3DataSourceConfiguration extends AbstractJpaConfiguration {

    @Value("${test3.jpa.base-package}")
    private String entitiesPackage;

    @Bean(name = "test3DataSource")
    @ConfigurationProperties(prefix = "test3.datasource")
    public DataSource test3DataSource() {
        return new DruidDataSource();
    }

    @Bean(name = "test3JpaProperties")
    @ConfigurationProperties(prefix = "test3.jpa")
    public JpaProperties jpaProperties() {
        return new JpaProperties();
    }


    @Bean(name = "test3JpaVendorAdapter")
    public JpaVendorAdapter createJpaVendorAdapter(@Qualifier("test3JpaProperties") JpaProperties properties, @Qualifier("test3DataSource") DataSource dataSource) {

        return super.createJpaVendorAdapter(properties, dataSource);
    }


    @Bean(name = "test3EntityManagerFactory")
    public EntityManagerFactory LocalContainerEntityManagerFactoryBean(
            @Qualifier("test3DataSource") DataSource dataSource,
            @Qualifier("test3JpaProperties") JpaProperties jpaProperties,
            @Qualifier("test3JpaVendorAdapter") JpaVendorAdapter jpaVendorAdapter) {


        return super.createEntityManagerFactory(dataSource, jpaProperties, jpaVendorAdapter, entitiesPackage);
    }


    @Bean(name = "test3TransactionManager")
    public JpaTransactionManager createTransactionManager(@Qualifier("test3EntityManagerFactory") EntityManagerFactory entityManagerFactory) {

        return super.createTransactionManager(entityManagerFactory);
    }


}

数据源4

package com.oldguy.example.configs;

import com.alibaba.druid.pool.DruidDataSource;
import com.oldguy.example.modules.common.configs.AbstractJpaConfiguration;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.JpaVendorAdapter;

import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;

/**
 * @Date: 2019/1/7 0007
 * @Author: ren
 * @Description:
 */
@Configuration
@EnableJpaRepositories(entityManagerFactoryRef = "test4EntityManagerFactory",
        basePackages = "com.oldguy.example.modules.test4.dao.jpas",
        transactionManagerRef = "test4TransactionManager")
public class Test4DataSourceConfiguration extends AbstractJpaConfiguration{


    @Value("${test4.jpa.base-package}")
    private String entitiesPackage;

    @Bean(name = "test4DataSource")
    @ConfigurationProperties(prefix = "test4.datasource")
    public DataSource test4DataSource() {
        return new DruidDataSource();
    }

    @Bean(name = "test4JpaProperties")
    @ConfigurationProperties(prefix = "test4.jpa")
    public JpaProperties jpaProperties() {
        return new JpaProperties();
    }


    @Bean(name = "test4JpaVendorAdapter")
    public JpaVendorAdapter createJpaVendorAdapter(@Qualifier("test4JpaProperties") JpaProperties properties, @Qualifier("test4DataSource") DataSource dataSource) {

        return super.createJpaVendorAdapter(properties, dataSource);
    }


    @Bean(name = "test4EntityManagerFactory")
    public EntityManagerFactory LocalContainerEntityManagerFactoryBean(
            @Qualifier("test4DataSource") DataSource dataSource,
            @Qualifier("test4JpaProperties") JpaProperties jpaProperties,
            @Qualifier("test4JpaVendorAdapter") JpaVendorAdapter jpaVendorAdapter) {


        return super.createEntityManagerFactory(dataSource, jpaProperties, jpaVendorAdapter, entitiesPackage);
    }


    @Bean(name = "test4TransactionManager")
    public JpaTransactionManager createTransactionManager(@Qualifier("test4EntityManagerFactory") EntityManagerFactory entityManagerFactory) {

        return super.createTransactionManager(entityManagerFactory);
    }

}

Step4:编写配置文件


test3:
  jpa:
    show-sql: true
    hibernate:
      ddl-auto: update
    base-package: com.oldguy.example.modules.test3.dao.entities
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/multiple_datasource3?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver
    type: org.apache.tomcat.jdbc.pool.DataSource

test4:
  jpa:
    show-sql: true
    hibernate:
      ddl-auto: update
    base-package: com.oldguy.example.modules.test4.dao.entities
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/multiple_datasource4?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true
    username: root
    password: root
    driver-class-name: com.mysql.jdbc.Driver
    type: org.apache.tomcat.jdbc.pool.DataSource

到此就完成了多重数据源配置。

MyBatis 测试结果：

package com.oldguy.example.modules.controllers;

import com.oldguy.example.modules.test1.dao.jpas.TestEntity1Mapper;
import com.oldguy.example.modules.test2.dao.jpas.TestEntity2Mapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created by Administrator on 2018/12/20 0020.
 */
@RestController
public class TestController {

    /**
     *  MyBatis 数据库2
     */
    @Autowired
    private TestEntity2Mapper testEntity2Mapper;
    /**
     *  MyBatis 数据库1
     */
    @Autowired
    private TestEntity1Mapper testEntity1Mapper;

    @GetMapping("test1")
    public Object test1(){
        return testEntity1Mapper.findAllByStatus(null);
    }

    @GetMapping("test2")
    public Object test2(){
        return testEntity2Mapper.findAllByStatus(null);
    }
}

图片结果：

1.png

2.png

Jpa 测试结果：

数据源3

package com.oldguy.example.modules.test3.controllers;

import com.oldguy.example.modules.test3.dao.jpas.TestUserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Date: 2019/1/7 0007
 * @Author: ren
 * @Description:
 */
@RestController
@RequestMapping("TestUser")
public class TestUserController {

    @Autowired
    private TestUserRepository testUserRepository;


    @GetMapping("list")
    public Object getList(){
        return testUserRepository.findAll();
    }
}

数据源4

package com.oldguy.example.modules.test4.controllers;

import com.oldguy.example.modules.test4.dao.jpas.RemarkRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Date: 2019/1/7 0007
 * @Author: ren
 * @Description:
 */
@RestController
@RequestMapping("Test4")
public class Test4Controller {


    @Autowired
    private RemarkRepository remarkRepository;

    @GetMapping("message")
    public Object getMessage(String message){
        return remarkRepository.findByMessage(message);
    }

    @GetMapping("list")
    public Object getList(){
        return remarkRepository.findAll();
    }
}

图片结果：

3.png

4.png

以上就完成了SpringBoot 同时使用MyBatis 和 Jpa 配置双方多重数据源。
代码可以参考 GitHub https://github.com/oldguys/MultipleDataSourceDemo

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,098评论 5赞 476
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,213评论 2赞 380
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 149,960评论 0赞 336
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,519评论 1赞 273
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,512评论 5赞 364
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,533评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,914评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,574评论 0赞 256
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,804评论 1赞 296
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,563评论 2赞 319
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,644评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,350评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,933评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,908评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,146评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,847评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,361评论 2赞 342

SpringBoot 配置多数据源 JPA

推荐阅读更多精彩内容