欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot項目中的多數據源支持的方法

 更新時間：2017年10月23日 10:08:13   作者：QiHaiYan  
本篇文章主要介紹了SpringBoot項目中的多數據源支持的方法，主要介紹在SpringBoot項目中利用SpringDataJpa技術如何支持多個數據庫的數據源，有興趣的可以了解一下

1.概述

項目中經常會遇到一個應用需要訪問多個數據源的情況，本文介紹在SpringBoot項目中利用SpringDataJpa技術如何支持多個數據庫的數據源。

具體的代碼參照該 示例項目

2.建立實體類（Entity）

首先，我們創(chuàng)建兩個簡單的實體類，分別屬于兩個不同的數據源，用于演示多數據源數據的保存和查詢。

Test實體類：

package com.example.demo.test.data;

import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name = "test")
public class Test {

  @Id
  private Integer id;

  public Test(){

  }

  public Integer getId() {
    return this.id;
  }

  public void setId(Integer id){
    this.id = id;
  }
}

Other實體類：

package com.example.demo.other.data;

import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name = "other")
public class Other {

  @Id
  private Integer id;

  public Integer getId() {
    return this.id;
  }

  public void setId(Integer id){
    this.id = id;
  }
}

需要注意的是，這兩個實體類分屬于不同的package，這一點極為重要，spring會根據實體類所屬的package來決定用那一個數據源進行操作。

3.建立Repository

分別建立兩個實體類對應的Repository，用于進行數據操作。

TestRepository:

package com.example.demo.test.data;

import org.springframework.data.jpa.repository.JpaRepository;

public interface TestRepository extends JpaRepository<Test, Integer> {
}

OtherRepository:

package com.example.demo.other.data;

import org.springframework.data.jpa.repository.JpaRepository;

public interface OtherRepository extends JpaRepository<Other, Integer> {
}

得益于spring-data-jpa優(yōu)秀的封裝，我們只需創(chuàng)建一個接口，就擁有了對實體類的操作能力。

3.對多數據源進行配置

分別對Test和Other兩個實體類配置對應的數據源。配置的內容主要包含三個要素：

  1. dataSource，數據源的連接信息
  2. entityManagerFactory，數據處理
  3. transactionManager，事務管理

Test實體類的數據源配置 TestDataConfig：

package com.example.demo.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

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

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
    entityManagerFactoryRef = "entityManagerFactory",
    basePackages = {"com.example.demo.test.data"}
)
public class TestDataConfig {

  @Autowired
  private JpaProperties jpaProperties;

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

  @Primary
  @Bean(name = "entityManagerFactory")
  public LocalContainerEntityManagerFactoryBean entityManagerFactory(
      EntityManagerFactoryBuilder builder,
      @Qualifier("dataSource") DataSource dataSource) {
    return builder
        .dataSource(dataSource)
        .packages("com.example.demo.test.data")
        .properties(jpaProperties.getHibernateProperties(dataSource))
        .persistenceUnit("test")
        .build();
  }

  @Primary
  @Bean(name = "transactionManager")
  public PlatformTransactionManager transactionManager(
      @Qualifier("entityManagerFactory") EntityManagerFactory entityManagerFactory) {
    return new JpaTransactionManager(entityManagerFactory);
  }

}

代碼中的Primary注解表示這是默認數據源。

Other實體類的數據源配置 OtherDataConfig：

package com.example.demo.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
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.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

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

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
    entityManagerFactoryRef = "otherEntityManagerFactory",
    transactionManagerRef = "otherTransactionManager",
    basePackages = {"com.example.demo.other.data"}
)
public class OtherDataConfig {

  @Autowired
  private JpaProperties jpaProperties;

  @Bean(name = "otherDataSource")
  @ConfigurationProperties(prefix = "other.datasource")
  public DataSource otherDataSource() {
    return DataSourceBuilder.create().build();
  }

  @Bean(name = "otherEntityManagerFactory")
  public LocalContainerEntityManagerFactoryBean otherEntityManagerFactory(
      EntityManagerFactoryBuilder builder,
      @Qualifier("otherDataSource") DataSource otherDataSource) {
    return builder
        .dataSource(otherDataSource)
        .packages("com.example.demo.other.data")
        .properties(jpaProperties.getHibernateProperties(otherDataSource))
        .persistenceUnit("other")
        .build();
  }

  @Bean(name = "otherTransactionManager")
  public PlatformTransactionManager otherTransactionManager(
      @Qualifier("otherEntityManagerFactory") EntityManagerFactory otherEntityManagerFactory) {
    return new JpaTransactionManager(otherEntityManagerFactory);
  }

}

3.數據操作

我們創(chuàng)建一個Service類TestService來分別對兩個數據源進行數據的操作。

package com.example.demo.service;

import com.example.demo.other.data.Other;
import com.example.demo.other.data.OtherRepository;
import com.example.demo.test.data.Test;
import com.example.demo.test.data.TestRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class TestService {

  @Autowired
  private TestRepository testRepository;

  @Autowired
  private OtherRepository otherRepository;

  @Value("${name:World}")
  private String name;

  public String getHelloMessage() {
    Test test = new Test();
    test.setId(1);
    test = testRepository.save(test);

    Other other = new Other();
    other.setId(2);
    other = otherRepository.save(other);

    return "Hello " + this.name + " : test's value = " + test.getId() + " , other's value = " + other.getId();

  }

}

對Test和Other分別進行數據插入和讀取操作，程序運行后會打印出兩個數據源各自的數據。 數據庫采用的mysql，連接信息在application.yml進行配置。

spring:
 datasource:
  url: jdbc:mysql://localhost:3306/test?characterEncoding=utf-8&useSSL=false
  testWhileIdle: true
  validationQuery: SELECT 1 from dual
  username: test
  password: 11111111
  driverClassName: com.mysql.jdbc.Driver
 jpa:
  database: MYSQL
  show-sql: true
  hibernate:
   show-sql: true
   ddl-auto: create
   naming-strategy: org.hibernate.cfg.ImprovedNamingStrategy
  properties:
   hibernate.dialect: org.hibernate.dialect.MySQL5Dialect
other:
 datasource:
  url: jdbc:mysql://localhost:3306/other?characterEncoding=utf-8&useSSL=false
  testWhileIdle: true
  validationQuery: SELECT 1
  username: other
  password: 11111111
  driverClassName: com.mysql.jdbc.Driver
 jpa:
  database: MYSQL
  show-sql: true
  hibernate:
   show-sql: true
   ddl-auto: create
   naming-strategy: org.hibernate.cfg.ImprovedNamingStrategy
  properties:
   hibernate.dialect: org.hibernate.dialect.MySQL5Dialect

Test實體對應的是主數據源，采用了spring-boot的默認數據源配置項，Other實體單獨配置數據源連接。具體應該讀取哪一段配置內容，是在配置類OtherDataConfig中這行代碼指定的。

@ConfigurationProperties(prefix = "other.datasource")

本示例需要建立的數據庫用戶和庫可以通過以下命令處理：

CREATE USER 'test'@'localhost' IDENTIFIED BY '11111111';
GRANT ALL PRIVILEGES ON *.* TO 'test'@'localhost';
CREATE USER 'other'@'localhost' IDENTIFIED BY '11111111';
GRANT ALL PRIVILEGES ON *.* TO 'other'@'localhost';
create database test;
create database other;

4.總結

spring-data-jpa極大的簡化了數據庫操作，對于多數據源的支持，也只是需要增加一下配置文件和配置類而已。其中的關鍵內容有3點：

  1. 配置文件中數據源的配置
  2. 配置類的編寫
  3. 實體類所在的package必須與配置類中指定的package一致，如OtherDataConfig中指定的basePackages = {"com.example.demo.other.data"}

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

相關文章

  • SpringBoot使用@Cacheable出現預覽工具亂碼的解決方法

    SpringBoot使用@Cacheable出現預覽工具亂碼的解決方法

    直接使用注解進行緩存數據,我們再使用工具去預覽存儲的數據時發(fā)現是亂碼,這是由于默認序列化的問題,所以接下來將給大家介紹一下SpringBoot使用@Cacheable出現預覽工具亂碼的解決方法,需要的朋友可以參考下
    2023-10-10
  • java實現后臺圖片跨域上傳功能

    java實現后臺圖片跨域上傳功能

    這篇文章主要給大家介紹了關于java實現后臺圖片跨域上傳功能的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用java具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
    2019-07-07
  • Java中SpringSecurity密碼錯誤5次鎖定用戶的實現方法

    Java中SpringSecurity密碼錯誤5次鎖定用戶的實現方法

    這篇文章主要介紹了Java中SpringSecurity密碼錯誤5次鎖定用戶的實現方法,非常不錯，具有參考借鑒價值，需要的朋友可以參考下
    2017-03-03
  • 詳解Java并發(fā)編程之原子類

    詳解Java并發(fā)編程之原子類

    這篇文章主要為大家介紹了Java并發(fā)編程之原子類介紹，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
    2023-04-04
  • SpringBoot應用War包形式部署到外部Tomcat的方法

    SpringBoot應用War包形式部署到外部Tomcat的方法

    這篇文章主要介紹了SpringBoot應用War包形式部署到外部Tomcat的方法，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2018-08-08
  • 基于Java語言的遞歸運算例題詳解

    基于Java語言的遞歸運算例題詳解

    一個方法在執(zhí)行過程中調用自身, 就稱為 "遞歸"。本文將通過幾個例題帶大家深入了解一下Java語言中的遞歸運算，感興趣的可以了解一下
    2022-08-08
  • IntelliJ IDEA 使用經驗總結(推薦)

    IntelliJ IDEA 使用經驗總結(推薦)

    這篇文章主要介紹了IntelliJ IDEA 使用經驗總結，非常不錯，具有參考價值,需要的朋友可以參考下
    2018-02-02
  • Java 調用Restful API接口的幾種方式(HTTPS)

    Java 調用Restful API接口的幾種方式(HTTPS)

    這篇文章主要介紹了Java 調用Restful API接口的幾種方式(HTTPS)，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2018-02-02
  • SpringBoot項目如何把接口參數中的空白值替換為null值(推薦)

    SpringBoot項目如何把接口參數中的空白值替換為null值(推薦)

    這篇文章主要介紹了SpringBoot項目如何把接口參數中的空白值替換為null值(推薦),本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2021-01-01
  • Java基于Tcp協議的socket編程實例

    Java基于Tcp協議的socket編程實例

    這篇文章主要介紹了Java基于Tcp協議的socket編程實例,較為詳細的分析了socket編程客戶端與服務器端的具體實現步驟與使用技巧,具有一定的參考借鑒價值,需要的朋友可以參考下
    2014-12-12

最新評論