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

spring-data-jpa+Alibaba Druid多數(shù)據(jù)源案例實踐

 更新時間：2025年07月14日 09:47:27   作者：勤匠  
本文介紹基于Spring Data JPA與Alibaba Druid配置多數(shù)據(jù)源的方案,通過定義三個獨(dú)立數(shù)據(jù)源、分別設(shè)置JPA配置及實體/倉庫包,實現(xiàn)訂單、用戶、詳情表的分離管理

spring-data-jpa+Alibaba Druid多數(shù)據(jù)源

很多情況下，應(yīng)用需要連接多個數(shù)據(jù)庫，基于此場景，我介紹如何使用spring-data-jpa + Alibaba Druid配置多數(shù)據(jù)源。

代碼量有點(diǎn)大，請耐心：

假設(shè)一個場景

數(shù)據(jù)庫表服務(wù)器IP占用端口
testorders（訂單表）192.168.10.313306
demodetail（詳情表）192.168.10.323306
trainusers（用戶表）192.168.10.333306

pom.xml引入

<!--連接池-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.2.8</version>
</dependency>
<!--數(shù)據(jù)庫驅(qū)動-->
<dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
    <scope>runtime</scope>
</dependency>
<!--spring data jpa-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

application.yaml配置

server:
  port: 8080
spring:
  datasource:
    ds1:
      url: jdbc:mysql://192.168.10.31:3306/test
      username: root
      password: 123456
      driver-class-name: com.mysql.cj.jdbc.Driver
    ds2:
      url: jdbc:mysql://192.168.10.33:3306/train
      username: root
      password: 123456
      driver-class-name: com.mysql.cj.jdbc.Driver
    ds3:
      url: jdbc:mysql://192.168.10.32:3306/demo
      username: root
      password: 123456
      driver-class-name: com.mysql.cj.jdbc.Driver

DataSource配置

為了讓spring-data-jpa分別使用這三個庫，那么我們需要配置3個datasource

package cn.train.springdruid.config.datasource;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.sql.DataSource;
/**
 * 多數(shù)據(jù)源配置
 * */
@Configuration
public class DataSourcesConfig {
    @Bean(name = {"ds1"})
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.ds1")
    public DataSource ds1() {
        DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
        return dataSource;
    }
    @Bean(name = {"ds2"})
    @ConfigurationProperties(prefix = "spring.datasource.ds2")
    public DataSource ds2() {
        DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
        return dataSource;
    }
    @Bean(name = {"ds3"})
    @ConfigurationProperties(prefix = "spring.datasource.ds3")
    public DataSource ds3() {
        DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
        return dataSource;
    }
}

JPA配置

接下來針對每個datasource做單獨(dú)的JPA配置

ds1的JPA配置

package cn.train.springdruid.config.datasource;

import org.springframework.beans.factory.annotation.Qualifier;
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.JpaVendorAdapter;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;

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

@Configuration(value = "ds1JPAConfig")
@EnableJpaRepositories(
        basePackages = "cn.train.springdruid.repositories.ds1",//repository包位置
        entityManagerFactoryRef = "ds1EntityManagerFactory",
        transactionManagerRef = "ds1TransactionManager"
)
public class Ds1JPAConfig {
    @Bean(name = {"ds1TransactionManager"})
    public PlatformTransactionManager ds1TransactionManager(
            @Qualifier("ds1EntityManagerFactory") EntityManagerFactory emf){
        return new JpaTransactionManager(emf);
    }
    @Bean(name = {"ds1EntityManagerFactory"})
    @Primary
    public LocalContainerEntityManagerFactoryBean ds1EntityManagerFactory(
            @Qualifier(value = "ds1") DataSource dataSource,
            JpaVendorAdapter vendorAdapter) {
        LocalContainerEntityManagerFactoryBean entityManagerFactoryBean = new LocalContainerEntityManagerFactoryBean();
        entityManagerFactoryBean.setDataSource(dataSource);
        entityManagerFactoryBean.setJpaVendorAdapter(vendorAdapter);
        entityManagerFactoryBean.setPackagesToScan("cn.train.springdruid.entities.ds1");// entity包位置
        entityManagerFactoryBean.setJpaProperties(
                new Properties(){{
                    put("hibernate.hbm2ddl.auto", "update");
                    put("hibernate.show_sql", "true");
                    put("hibernate.format_sql", "true");
                }}
        );
        return entityManagerFactoryBean;
    }
}

ds2的JPA配置

package cn.train.springdruid.config.datasource;

import org.springframework.beans.factory.annotation.Qualifier;
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 org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;

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

@Configuration(value = "ds2JPAConfig")
@EnableJpaRepositories(
        basePackages = "cn.train.springdruid.repositories.ds2",//repository包位置
        entityManagerFactoryRef = "ds2EntityManagerFactory",
        transactionManagerRef = "ds2TransactionManager"
)
public class Ds2JPAConfig {
    @Bean(name = {"ds2TransactionManager"})
    public PlatformTransactionManager ds2TransactionManager(
            @Qualifier("ds2EntityManagerFactory") EntityManagerFactory emf){
        return new JpaTransactionManager(emf);
    }
    @Bean(name = {"ds2EntityManagerFactory"})
    public LocalContainerEntityManagerFactoryBean ds2EntityManagerFactory(
            @Qualifier(value = "ds2") DataSource dataSource,
            JpaVendorAdapter vendorAdapter) {
        LocalContainerEntityManagerFactoryBean entityManagerFactoryBean = new LocalContainerEntityManagerFactoryBean();
        entityManagerFactoryBean.setDataSource(dataSource);
        entityManagerFactoryBean.setJpaVendorAdapter(vendorAdapter);
        entityManagerFactoryBean.setPackagesToScan("cn.train.springdruid.entities.ds2");// entity包位置
        entityManagerFactoryBean.setJpaProperties(
                new Properties(){{
                    put("hibernate.hbm2ddl.auto", "update");
                    put("hibernate.show_sql", "true");
                    put("hibernate.format_sql", "true");
                }}
        );
        return entityManagerFactoryBean;
    }
}

ds3的JPA配置

package cn.train.springdruid.config.datasource;

import org.springframework.beans.factory.annotation.Qualifier;
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 org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;

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

@Configuration(value = "ds3JPAConfig")
@EnableJpaRepositories(
        basePackages = "cn.train.springdruid.repositories.ds3",//repository包位置
        entityManagerFactoryRef = "ds3EntityManagerFactory",
        transactionManagerRef = "ds3TransactionManager"
)
public class Ds3JPAConfig {
    @Bean(name = {"ds3TransactionManager"})
    public PlatformTransactionManager ds3TransactionManager(
            @Qualifier("ds3EntityManagerFactory") EntityManagerFactory emf){
        return new JpaTransactionManager(emf);
    }
    @Bean(name = {"ds3EntityManagerFactory"})
    public LocalContainerEntityManagerFactoryBean ds3EntityManagerFactory(
            @Qualifier(value = "ds3") DataSource dataSource,
            JpaVendorAdapter vendorAdapter) {
        LocalContainerEntityManagerFactoryBean entityManagerFactoryBean = new LocalContainerEntityManagerFactoryBean();
        entityManagerFactoryBean.setDataSource(dataSource);
        entityManagerFactoryBean.setJpaVendorAdapter(vendorAdapter);
        entityManagerFactoryBean.setPackagesToScan("cn.train.springdruid.entities.ds3");// entity包位置
        entityManagerFactoryBean.setJpaProperties(
                new Properties(){{
                    put("hibernate.hbm2ddl.auto", "update");
                    put("hibernate.show_sql", "true");
                    put("hibernate.format_sql", "true");
                }}
        );
        return entityManagerFactoryBean;
    }
}

ds1的repository包為：cn.train.springdruid.repositories.ds1，其中是OrderRepository

import cn.train.springdruid.entities.ds1.Order;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

@Repository(value = "orderRepository")
public interface OrderRepository extends JpaRepository<Order, Long> {
}

ds2的repository包為：cn.train.springdruid.repositories.ds2，其中是UserRepository

package cn.train.springdruid.repositories.ds2;

import cn.train.springdruid.entities.ds2.User;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

@Repository(value = "userRepository")
public interface UserRepository extends JpaRepository<User, Long> {
}

ds3的repository包為：cn.train.springdruid.repositories.ds3，其中是DetailRepository

package cn.train.springdruid.repositories.ds3;

import cn.train.springdruid.entities.ds3.Detail;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

@Repository(value = "detailRepository")
public interface DetailRepository extends JpaRepository<Detail, Long> {
}

entity

ds1的entity包為：cn.train.springdruid.entities.ds1，其中是Order

package cn.train.springdruid.entities.ds1;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "orders")
public class Order {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "order_name")
    private String name;

    @Column(name = "order_price")
    private Integer price;
}

ds2的entity包為：cn.train.springdruid.entities.ds2，其中是：User

package cn.train.springdruid.entities.ds2;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "users")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(name = "user_name")
    private String name;

    @Column(name = "user_age")
    private Integer age;
}

ds3的entity包為：cn.train.springdruid.entities.ds3，其中是：Detail

package cn.train.springdruid.entities.ds3;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
@Table(name = "detail")
public class Detail {
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE)
    private Long id;
    
    @Column(name = "description")
    private String description;
}

由此，就是整個多數(shù)據(jù)源配置與管理的全部核心代碼

總結(jié)

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

相關(guān)文章

  • 淺析Java如何優(yōu)雅的設(shè)計接口狀態(tài)碼和異常

    淺析Java如何優(yōu)雅的設(shè)計接口狀態(tài)碼和異常

    HTTP協(xié)議里定義了一系列的狀態(tài)碼用來表明請求的狀態(tài),如常用的200表示請求正常,404表示請求的資源不存在,所以本文就來和大家討論一下如何優(yōu)雅的設(shè)計接口狀態(tài)碼和異常,感興趣的可以了解下
    2024-03-03
  • Java中HashMap和Hashtable的區(qū)別小結(jié)

    Java中HashMap和Hashtable的區(qū)別小結(jié)

    本文主要介紹了Java中HashMap和Hashtable的區(qū)別小結(jié)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-07-07
  • 簡單了解Java程序運(yùn)行整體流程

    簡單了解Java程序運(yùn)行整體流程

    這篇文章主要介紹了簡單了解Java程序運(yùn)行整體流程,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-07-07
  • 利用Log4j將不同Package的日志輸出到不同文件的方法

    利用Log4j將不同Package的日志輸出到不同文件的方法

    日志是應(yīng)用軟件中不可缺少的部分，Apache的開源項目log4j是一個功能強(qiáng)大的日志組件,提供方便的日志記錄。這篇文章主要介紹了利用Log4j將不同Package的日志輸出到不同文件的方法,需要的朋友可以參考借鑒，下面來跟著小編一起學(xué)習(xí)學(xué)習(xí)吧。
    2017-01-01
  • Java深入探索線程安全和線程通信的特性

    Java深入探索線程安全和線程通信的特性

    這篇文章主要介紹了Java線程安全和線程通信的特性，線程安全是多線程編程時的計算機(jī)程序代碼中的一個概念。在擁有共享數(shù)據(jù)的多條線程并行執(zhí)行的程序中，線程安全的代碼會通過同步機(jī)制保證各個線程都可以正常且正確的執(zhí)行，不會出現(xiàn)數(shù)據(jù)污染等意外情況
    2022-05-05
  • SpringBoot 項目中的圖片處理策略之本地存儲與路徑映射

    SpringBoot 項目中的圖片處理策略之本地存儲與路徑映射

    在SpringBoot項目中,靜態(tài)資源存放在static目錄下,使得前端可以通過URL來訪問這些資源,我們就需要將文件系統(tǒng)的文件路徑與URL建立一個映射關(guān)系,把文件系統(tǒng)中的文件當(dāng)成我們的靜態(tài)資源即可,本文給大家介紹SpringBoot本地存儲與路徑映射的相關(guān)知識,感興趣的朋友一起看看吧
    2023-12-12
  • java獲取系統(tǒng)路徑字體、得到某個目錄下的所有文件名、獲取當(dāng)前路徑

    java獲取系統(tǒng)路徑字體、得到某個目錄下的所有文件名、獲取當(dāng)前路徑

    這篇文章主要介紹了java獲取系統(tǒng)路徑字體、得到某個目錄下的所有文件名、獲取當(dāng)前路徑,需要的朋友可以參考下
    2014-04-04
  • 基于Java代碼實現(xiàn)游戲服務(wù)器生成全局唯一ID的方法匯總

    基于Java代碼實現(xiàn)游戲服務(wù)器生成全局唯一ID的方法匯總

    我們在做服務(wù)器系統(tǒng)開發(fā)的時候，為了適應(yīng)數(shù)據(jù)大并發(fā)的請求，需要插入數(shù)據(jù)庫之前生成一個全局的唯一id，糾結(jié)全局唯一id怎么生成呢？下面小編給大家分享Java代碼實現(xiàn)游戲服務(wù)器生成全局唯一ID的方法匯總，涉及到優(yōu)劣勢方面的知識點(diǎn)，對此感興趣的朋友一起看看吧
    2016-10-10
  • JavaEE實現(xiàn)前后臺交互的文件上傳與下載

    JavaEE實現(xiàn)前后臺交互的文件上傳與下載

    這篇文章主要介紹了JavaEE實現(xiàn)前后臺交互的文件上傳與下載，分享相關(guān)技術(shù)，實現(xiàn)文件上傳下載功能，需要的朋友可以參考下
    2015-11-11
  • java UDP實現(xiàn)一個聊天工具的示例代碼

    java UDP實現(xiàn)一個聊天工具的示例代碼

    這篇文章主要介紹了java UDP實現(xiàn)一個聊天工具的示例代碼,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2021-01-01

最新評論