Spring?Boot整合持久層之JPA多數(shù)據(jù)源

更新時間：2022年08月13日 11:15:29 作者：一只小熊貓呀

JPA（Java Persistence API）Java 持久化 API，是 Java 持久化的標準規(guī)范，Hibernate 是持久化規(guī)范的技術實現(xiàn)，而 Spring Data JPA 是在 Hibernate 基礎上封裝的一款框架

JPA 多數(shù)據(jù)源

JPA 和 MyBatis 配置多數(shù)據(jù)源類似，不同的是，JPA 配置時主要提供不同的 LocalContainerEntityManagerFactoryBean 以及事務管理器。

項目目錄結構如下：

準備工作

創(chuàng)建 Spring Boot Web 項目，添加如下依賴：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>druid-spring-boot-starter</artifactId>
  <version>1.1.10</version>
</dependency>
<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <scope>runtime</scope>
</dependency>

application.properties 配置

注意：這里的配置與配置單獨的 JPA 有區(qū)別，因為在后文的配置中要從 JpaProperties 中的 getProperties 方法中獲取所有的 JPA 相關配置，因此這里的屬性前綴都是 spring.jpa.properties。

server.port=8081
# 數(shù)據(jù)源1
spring.datasource.one.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.one.url=jdbc:mysql://localhost:3306/chapter05-1
spring.datasource.one.username=root
spring.datasource.one.password=root
# 數(shù)據(jù)源2
spring.datasource.two.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.two.url=jdbc:mysql://localhost:3306/chapter05-2
spring.datasource.two.username=root
spring.datasource.two.password=root
# JPA 配置
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL57InnoDBDialect
spring.jpa.properties.database=mysql
spring.jpa.properties.hibernate.hbm2ddl.auto=update
spring.jpa.properties.show-sql= true

數(shù)據(jù)源配置 DataSourceConfig

@Configuration
public class DataSourceConfig {
    @Bean
    @ConfigurationProperties("spring.datasource.one")
    @Primary
    DataSource dsOne() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties("spring.datasource.two")
    DataSource dsTwo() {
        return DruidDataSourceBuilder.create().build();
    }
}

實體類 User

@Entity(name = "t_user")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;
    private String name;
    private String gender;
    private Integer age;
    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", gender='" + gender + '\'' +
                ", age=" + age +
                '}';
    }
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getGender() {
        return gender;
    }
    public void setGender(String gender) {
        this.gender = gender;
    }
    public Integer getAge() {
        return age;
    }
    public void setAge(Integer age) {
        this.age = age;
    }
}

創(chuàng)建 JPA 配置

接下來是核心配置，根據(jù)兩個配置好的數(shù)據(jù)源創(chuàng)建兩個不同的 JPA 配置

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "com.sang.dao1",
        entityManagerFactoryRef = "entityManagerFactoryBeanOne",
        transactionManagerRef = "platformTransactionManagerOne")
public class JpaConfigOne {
    @Resource(name = "dsOne")
    DataSource dsOne;
    @Autowired
    JpaProperties jpaProperties;
    @Bean
    @Primary
    LocalContainerEntityManagerFactoryBean entityManagerFactoryBeanOne(
            EntityManagerFactoryBuilder builder) {
        return builder.dataSource(dsOne)
                .properties(jpaProperties.getProperties())
                .packages("com.sang.model")
                .persistenceUnit("pu1")
                .build();
    }
    @Bean
    PlatformTransactionManager platformTransactionManagerOne(
            EntityManagerFactoryBuilder builder) {
        LocalContainerEntityManagerFactoryBean factoryOne = entityManagerFactoryBeanOne(builder);
        return new JpaTransactionManager(factoryOne.getObject());
    }
}

代碼解釋：

使用 @EnableJpaRepositories 注解進行 JPA 配置，該注解中主要配置三個屬性：basePackages、entityManagerFactoryRef、transactionManagerRef。其中 basePackages 用來指定 Repository 所在的位置，entityManagerFactoryRef 用來指定實體類管理工廠 Bean 的名稱，transactionManagerRef 用來指定事務管理器的引用名稱，這里的引用名稱就是 JpaConfigOne 類中注冊的 Bean 的名稱（默認的 Bean 名稱為方法名）
創(chuàng)建 LocalContainerEntityManagerFactoryBean ，該 Bean 將用來提供 EntityManager 實例，在該類的創(chuàng)建過程中，首先配置數(shù)據(jù)源，然后設置 JPA 相關配置（JpaProperties 由系統(tǒng)自動加載），再設置實體類所在的位置，最后配置持久化單位名，若項目中只有一個 EntityManagerFactory，則 persistenceUnit 可以省略掉，若有多個，則必須明確指定持久化單元名
由于項目中會提供兩個 LocalContainerEntityManagerFactoryBean 實例，@Primary 注解表示當存在多個 LocalContainerEntityManagerFactoryBean 實例時，該實例將被優(yōu)先使用
platformTransactionManagerOne() 方法表示創(chuàng)建一個事務管理器。JpaTransactionManager 提供對單個 EntityManagerFactory 的事務支持，專門用于解決 JPA 中的事務管理

以下是第二個 JPA 配置

注意：LocalContainerEntityManagerFactoryBean 實例不需要添加 @Primary 注解

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "com.sang.dao2",
entityManagerFactoryRef = "entityManagerFactoryBeanTwo",
transactionManagerRef = "platformTransactionManagerTwo")
public class JpaConfigTwo {
    @Resource(name = "dsTwo")
    DataSource dsTwo;
    @Autowired
    JpaProperties jpaProperties;
    @Bean
    LocalContainerEntityManagerFactoryBean entityManagerFactoryBeanTwo(
            EntityManagerFactoryBuilder builder) {
        return builder.dataSource(dsTwo)
                .properties(jpaProperties.getProperties())
                .packages("com.sang.model")
                .persistenceUnit("pu2")
                .build();
    }
    @Bean
    PlatformTransactionManager platformTransactionManagerTwo(
            EntityManagerFactoryBuilder builder) {
        LocalContainerEntityManagerFactoryBean factoryTwo = entityManagerFactoryBeanTwo(builder);
        return new JpaTransactionManager(factoryTwo.getObject());
    }
}

創(chuàng)建 Repository

分別在 com.sang.dao1 和 com.sang.dao2 包下創(chuàng)建兩個 Repository

UserDao

public interface UserDao extends JpaRepository<User,Integer> {
}

UserDao2

public interface UserDao2 extends JpaRepository<User,Integer> {
}

創(chuàng)建 Controller

簡便起見，這里省略掉 Service 層，將 UserDao 直接注入 Controller 中

@RestController
public class UserController {
    @Autowired
    UserDao userDao;
    @Autowired
    UserDao2 userDao2;
    @GetMapping("/test1")
    public void test1() {
        User u1 = new User();
        u1.setAge(55);
        u1.setName("魯迅");
        u1.setGender("男");
        userDao.save(u1);
        User u2 = new User();
        u2.setAge(80);
        u2.setName("泰戈爾");
        u2.setGender("男");
        userDao2.save(u2);
    }
}

http://localhost:8081/test1，查看數(shù)據(jù)庫，即可看到數(shù)據(jù)庫中的表和數(shù)據(jù)都已經存在了，如下

到此這篇關于Spring Boot整合持久層之JPA多數(shù)據(jù)源的文章就介紹到這了,更多相關Spring Boot JPA多數(shù)據(jù)源內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Java實現(xiàn)添加條形碼到PDF表格的方法詳解
條碼的應用已深入生活和工作的方方面面。本文以操作PDF文件為例，介紹如何利用Java語言在編輯表格時，向單元格中添加條形碼，感興趣的可以學習一下
2022-06-06
Java日常練習題,每天進步一點點(51)
下面小編就為大家?guī)硪黄狫ava基礎的幾道練習題(分享)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧，希望可以幫到你
2021-08-08
Java技能點之SimpleDateFormat進行日期格式化問題
這篇文章主要介紹了Java技能點之SimpleDateFormat進行日期格式化問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-04-04
springboot使用spring-data-jpa操作MySQL數(shù)據(jù)庫
這篇文章主要介紹了springboot使用spring-data-jpa操作MySQL數(shù)據(jù)庫，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2018-07-07
mybatis中映射文件(mapper)中的使用規(guī)則
這篇文章主要介紹了mybatis中映射文件(mapper)中的使用規(guī)則，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2021-11-11
Java實現(xiàn)XML文件學生通訊錄
這篇文章主要為大家詳細介紹了Java實現(xiàn)XML文件學生通訊錄，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2018-02-02
spring-mybatis獲取mapper的四種方式匯總
這篇文章主要介紹了spring-mybatis獲取mapper的四種方式匯總，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-03-03
Java實現(xiàn)HDFS文件上傳下載
這篇文章主要為大家詳細介紹了Java實現(xiàn)HDFS文件上傳下載，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2022-06-06
jdk源碼閱讀Collection詳解
這篇文章主要介紹了jdk源碼閱讀Collection詳解，具有一定借鑒價值,需要的朋友可以參考下
2017-12-12
Spring P標簽的使用詳解
這篇文章主要介紹了Spring P標簽的使用詳解，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2021-08-08