当前位置： 首页 > news >正文

spring-data-jpa + Alibaba Druid多数据源案例

news 2025/7/10 11:01:10

spring-data-jpa + Alibaba Druid多数据源案例

很多情况下，应用需要连接多个数据库，基于此场景，我介绍如何使用spring-data-jpa + Alibaba Druid配置多数据源。

⚠️
代码量有点大，请耐心

假设一个场景

数据库表服务器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>
<!--数据库驱动-->
<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/testusername: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driverds2:url: jdbc:mysql://192.168.10.33:3306/trainusername: rootpassword: 123456driver-class-name: com.mysql.cj.jdbc.Driverds3:url: jdbc:mysql://192.168.10.32:3306/demousername: rootpassword: 123456driver-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;
/*** 多数据源配置* */
@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做单独的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"})@Primarypublic 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;
}

由此，就是整个多数据源配置与管理的全部核心代码

http://www.dtcms.com/a/270859.html

相关文章：

  • (5)机器学习小白入门 YOLOv：数据需求与图像不足应对策略
  • OpenCV图片操作100例：从入门到精通指南（4）
  • [C#/.NET] 内网开发中如何使用 System.Text.Json 实现 JSON 解析（无需 NuGet）
  • 树莓派vsftpd文件传输服务器的配置方法
  • Java 大视界 -- 基于 Java 的大数据分布式计算在生物信息学蛋白质 - 蛋白质相互作用预测中的应用（340）
  • 【算法深练】DFS题型拆解：沿着路径“深挖到底”、递归深入、回溯回探的算法解题思路
  • 【数据分析】多数据集网络分析：探索健康与退休研究中的变量关系
  • ESOP系统电子作业指导汽车零部件车间的数字化革命
  • 玛哈特网板矫平机：精密矫平金属开平板的利器
  • 钉钉企业应用开发技巧：查询表单实例数据新版SDK指南
  • 2023年华为杯研究生数学建模竞赛A题WLAN组网分析
  • 结构体指针：使用结构体指针访问和修改结构体成员。
  • 【网络】Linux 内核优化实战 - net.ipv4.tcp_ecn_fallback
  • softmax
  • GitHub 趋势日报 (2025年07月08日)
  • SQLZoo 练习与测试答案汇总（复杂题有最优解与其他解法分析、解题技巧）
  • 分类预测 | Matlab基于KPCA-ISSA-SVM和ISSA-SVM和SSA-SVM和SVM多模型分类预测对比
  • 打造自己的组件库（二）CSS工程化方案
  • Tensorflow的安装记录
  • 一天一道Sql题(day04)
  • 开源链动2+1模式与AI智能名片融合下的S2B2C商城小程序源码：重构大零售时代新生态
  • 华为静态路由配置
  • linux正向配置dns解析
  • 事件驱动架构
  • 汽车工业制造领域与数字孪生技术的关联性研究​
  • UI前端大数据处理性能评估与优化：基于负载测试的数据处理能力分析
  • 利用Wisdom SSH高效搭建CI/CD工作流
  • python Gui界面小白入门学习
  • # Shell 编程：从入门到实践
  • Android 系统默认代码，如何屏蔽相册分享功能