Spring Boot 多数据源配置（JPA）

news/2024/11/14 12:46:08/

目录

前言

前置环境

pom

yml

Entity

Dao

Config

Controller

演示

前言

一般一个系统至少有一个数据源，用来持久化业务数据以及查询。单个数据源的系统很常见，在 Spring Boot 框架下配置也很简单。在约定大于配置这个思想下，只需要在配置文件中简单配置下数据库连接信息就行了。

除了单数据源系统，在实际工作中，还会遇到多数据源系统。有可能是因为业务需要，以实际中做过的资产清查相关的项目为例，数据的存储分成了两个库，一个当前库和归档库，系统就需要配置两个数据源来满足业务需求。也有可能是技术架构，比如 MySQL 数据库使用了主从复制架构来实现读写分离，然后在应用层做分流，就需要配置主库和从库数据源，并在代码中决定使用哪个库进行数据库操作。

以下是Spring Boot JPA 多数据源的配置教程

前置环境

JDK8 + SringBoot2 + MySQL8

分别创建数据库 test1 test2

分别在两个数据库中创建 user 表

create table user (
    id int auto_increment primary key,
    username varchar(255),
    password varchar(255)
);

在test1.user 表中插入数据

insert into user(username, password) values('张三', '123456');

在test2.user 表中插入数据

insert into user(username, password) values('李四', '123456');

pom

    <dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>${spring-boot.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependencies>

yml

server:port: 8888spring:datasource:primary:url: jdbc:mysql://localhost:3306/test1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=trueusername: rootpassword: mysqldriver-class-name: com.mysql.cj.jdbc.Driversecondary:url: jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=trueusername: rootpassword: mysqldriver-class-name: com.mysql.cj.jdbc.Driverjpa:primary:show-sql: trueproperties:hibernate:hbm2ddl:auto: updatedialect: org.hibernate.dialect.MySQL5InnoDBDialectsecondary:show-sql: trueproperties:hibernate:hbm2ddl:auto: updatedialect: org.hibernate.dialect.MySQL5InnoDBDialect

Entity

主库和从库的实体类需要放在不同的包下，以本文为例

主库的实体类包路径为：com.jpa.entity.primary

java">@Entity
@Table ( name = "user")
public class PrimaryUserEntity {private Integer id;private String username;private String password;@Id@GeneratedValue ( strategy = GenerationType.IDENTITY)@Column ( name = "id" )public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}@Basic@Column ( name = "username" )public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}@Basic@Column ( name = "password" )public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}}

从库的实体类包路径为：com.jpa.entity.secondary

java">@Entity
@Table ( name = "user")
public class SecondaryUserEntity {private Integer id;private String username;private String password;@Id@GeneratedValue ( strategy = GenerationType.IDENTITY)@Column ( name = "id" )public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}@Basic@Column ( name = "username" )public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}@Basic@Column ( name = "password" )public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}}

Dao

主库和从库的Dao需要放在不同的包下，以本文为例

主库的Dao包路径为：com.jpa.dao.primary

java">@Repository (value = IPrimaryUserDao.DAO_BEAN_NAME )
public interface IPrimaryUserDao extends JpaRepository<PrimaryUserEntity, Integer> {String DAO_BEAN_NAME = "primaryUserDao";
}

从库的Dao包路径为：com.jpa.dao.secondary

java">@Repository (value = ISecondaryUserDao.DAO_BEAN_NAME )
public interface ISecondaryUserDao extends JpaRepository<SecondaryUserEntity, Integer> {String DAO_BEAN_NAME = "secondaryUserDao";
}

Config

记得将类中的两个包路径修改成自己项目的包路径

REPOSITORY_PACKAGE

ENTITY_PACKAGE

主库数据源配置

java">@Configuration
@EnableTransactionManagement
@EnableJpaRepositories (basePackages = PrimaryDatasourceAndJpaConfig.REPOSITORY_PACKAGE,entityManagerFactoryRef = "primaryEntityManagerFactory",transactionManagerRef = "primaryTransactionManager"
)
public class PrimaryDatasourceAndJpaConfig {private static final String REPOSITORY_PACKAGE = "com.jpa.dao.primary";private static final String ENTITY_PACKAGE = "com.jpa.entity.primary";//--------------数据源配置-------------------/*** 扫描spring.datasource.primary开头的配置信息** @return 数据源配置信息*/@Primary@Bean(name = "primaryDataSourceProperties")@ConfigurationProperties(prefix = "spring.datasource.primary")public DataSourceProperties dataSourceProperties() {return new DataSourceProperties();}/*** 取主库数据源对象** @param dataSourceProperties 注入名为primaryDataSourceProperties的bean* @return 数据源对象*/@Primary@Bean(name = "primaryDataSource")public DataSource dataSource(@Qualifier("primaryDataSourceProperties") DataSourceProperties dataSourceProperties) {return dataSourceProperties.initializeDataSourceBuilder().build();}/*** 扫描spring.jpa.primary开头的配置信息** @return jpa配置信息*/@Primary@Bean (name = "primaryJpaProperties")@ConfigurationProperties (prefix = "spring.jpa.primary")public JpaProperties jpaProperties() {return new JpaProperties();}/*** 获取主库实体管理工厂对象** @param primaryDataSource 注入名为primaryDataSource的数据源* @param jpaProperties     注入名为primaryJpaProperties的jpa配置信息* @param builder           注入EntityManagerFactoryBuilder* @return 实体管理工厂对象*/@Primary@Bean(name = "primaryEntityManagerFactory")public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean(@Qualifier ("primaryDataSource") DataSource primaryDataSource,@Qualifier("primaryJpaProperties") JpaProperties jpaProperties,EntityManagerFactoryBuilder builder) {return builder// 设置数据源.dataSource(primaryDataSource)// 设置jpa配置.properties(jpaProperties.getProperties())// 设置实体包名.packages(ENTITY_PACKAGE)// 设置持久化单元名，用于@PersistenceContext注解获取EntityManager时指定数据源.persistenceUnit("primaryPersistenceUnit").build();}/*** 获取实体管理对象** @param factory 注入名为primaryEntityManagerFactory的bean* @return 实体管理对象*/@Primary@Bean(name = "primaryEntityManager")public EntityManager entityManager(@Qualifier("primaryEntityManagerFactory") EntityManagerFactory factory) {return factory.createEntityManager();}/*** 获取主库事务管理对象** @param factory 注入名为primaryEntityManagerFactory的bean* @return 事务管理对象*/@Primary@Bean(name = "primaryTransactionManager")public JpaTransactionManager transactionManager(@Qualifier("primaryEntityManagerFactory") EntityManagerFactory factory) {return new JpaTransactionManager(factory);}
}

从库数据源配置

java">@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = SecondaryDatasourceAndJpaConfig.REPOSITORY_PACKAGE,entityManagerFactoryRef = "secondaryEntityManagerFactory",transactionManagerRef = "secondaryTransactionManager"
)
public class SecondaryDatasourceAndJpaConfig {static final String REPOSITORY_PACKAGE = "com.jpa.dao.secondary";static final String ENTITY_PACKAGE = "com.jpa.entity.secondary";//--------------数据源配置-------------------/*** 扫描spring.datasource.secondary开头的配置信息** @return 数据源配置信息*/@Bean(name = "secondaryDataSourceProperties")@ConfigurationProperties(prefix = "spring.datasource.secondary")public DataSourceProperties dataSourceProperties() {return new DataSourceProperties();}/*** 获取次数据源对象** @param dataSourceProperties 注入名为secondaryDataSourceProperties的bean* @return 数据源对象*/@Bean("secondaryDataSource")public DataSource dataSource(@Qualifier("secondaryDataSourceProperties") DataSourceProperties dataSourceProperties) {return dataSourceProperties.initializeDataSourceBuilder().build();}/*** 扫描spring.jpa.secondary** @return jpa配置信息*/@Bean(name = "secondaryJpaProperties")@ConfigurationProperties(prefix = "spring.jpa.secondary")public JpaProperties jpaProperties() {return new JpaProperties();}/*** 获取次库实体管理工厂对象** @param secondaryDataSource 注入名为secondaryDataSource的数据源* @param jpaProperties       注入名为secondaryJpaProperties的jpa配置信息* @param builder             注入EntityManagerFactoryBuilder* @return 实体管理工厂对象*/@Bean(name = "secondaryEntityManagerFactory")public LocalContainerEntityManagerFactoryBean entityManagerFactory(@Qualifier("secondaryDataSource") DataSource secondaryDataSource,@Qualifier("secondaryJpaProperties") JpaProperties jpaProperties,EntityManagerFactoryBuilder builder) {return builder// 设置数据源.dataSource(secondaryDataSource)// 设置jpa配置.properties(jpaProperties.getProperties())// 设置实体包名.packages(ENTITY_PACKAGE)// 设置持久化单元名，用于@PersistenceContext注解获取EntityManager时指定数据源.persistenceUnit("secondaryPersistenceUnit").build();}/*** 获取实体管理对象** @param factory 注入名为secondaryEntityManagerFactory的bean* @return 实体管理对象*/@Bean(name = "secondaryEntityManager")public EntityManager entityManager(@Qualifier("secondaryEntityManagerFactory") EntityManagerFactory factory) {return factory.createEntityManager();}/*** 获取事务管理对象** @param factory 注入名为secondaryEntityManagerFactory的bean* @return 事务管理对象*/@Bean(name = "secondaryTransactionManager")public JpaTransactionManager transactionManager(@Qualifier("secondaryEntityManagerFactory") EntityManagerFactory factory) {return new JpaTransactionManager(factory);}
}

Controller

主库

java">@RestController
@RequestMapping(value = "/primary")
public class PrimaryJpaController {@Resourceprivate IPrimaryUserDao primaryUserDao;@RequestMapping(value = "/findAll", method = RequestMethod.GET)public List<PrimaryUserEntity> findAll() {return primaryUserDao.findAll();}
}

从库

java">@RestController
@RequestMapping(value = "/secondary")
public class SecondaryJpaController{@Resourceprivate ISecondaryUserDao secondaryUserDao;@RequestMapping(value = "/findAll", method = RequestMethod.GET)public List<SecondaryUserEntity> findAll() {return secondaryUserDao.findAll();}
}

演示

请求 /primary/findAll

请求 /secondary/findAll


http://www.ppmy.cn/news/1520410.html

相关文章

4. 第一个3D案例—创建3D场景

4. 第一个3D案例—创建3D场景

入门Three.js的第一步&#xff0c;就是认识场景Scene、相机Camera、渲染器Renderer三个基本概念&#xff0c;接下来&#xff0c;咱们通过三小节课&#xff0c;大家演示“第一个3D案例”完成实现过程。 学习建议&#xff1a;只要你能把第一个3D案例搞明白&#xff0c;后面学习就…
阅读更多...
Unity面向对象补全计划 之 List＜T＞与class（非基础）

Unity面向对象补全计划 之 List＜T＞与class（非基础）

C# & Unity 面向对象补全计划 泛型-CSDN博客 关于List&#xff0c;其本质就是C#封装好的一个数组&#xff0c;是一个很好用的轮子&#xff0c;所以并不需要什么特别说明 问题描述 假设我们有一个表示学生的类 Student&#xff0c;每个学生有姓名和年龄两个属性。我们需要创…
阅读更多...
缓存分布式一致性问题

缓存分布式一致性问题

缓存一致性问题发生的原因&#xff0c;是在更新数据时数据库和缓存数据的不一致。我们要做到保证缓存的最终一致性。如果数据需要强一致性建议直接查询数据库。 双写模式 双写模式为先写数据库&#xff0c;在写缓存。 进来两个请求&#xff0c;先执行“请求1”的操作写入数据…
阅读更多...
图论----最小生成树讲解与相关题解

图论----最小生成树讲解与相关题解

目前已更新系列 当前--图论----最小生成树讲解与相关题解 滑动窗口系列算法总结与题解一 算法系列----并查集总结于相关题解 图论---dfs系列 差分与前缀和总结与对应题解&#xff08;之前笔试真的很爱考&#xff09; 数论---质数判断、质因子分解、质数筛&#xff08;埃氏…
阅读更多...
Golang 小项目(3)

Golang 小项目(3)

Golang 小项目(3) 前言 本项目适合 Golang 初学者，通过简单的项目实践来加深对 Golang 的基本语法和 Web 开发的理解。 前往 torna.top 免费查阅 项目结构 D:. ├─ go.mod ├─ go.sum │ ├─cmd │ └─main │ main.go │ └─pkg├─config│ app.go│…
阅读更多...
数据库系统 第36节 数据库镜像

数据库系统 第36节 数据库镜像

数据库镜像&#xff08;Database Mirroring&#xff09;是一种在数据库系统中用于确保数据高可用性和灾难恢复的技术。在MySQL中&#xff0c;虽然它不像SQL Server那样直接支持数据库镜像&#xff0c;但可以通过复制&#xff08;Replication&#xff09;来实现类似的功能。MySQ…
阅读更多...
AUTOSAR_EXP_ARAComAPI的5章笔记（2）

AUTOSAR_EXP_ARAComAPI的5章笔记（2）

返回目录 5.3 Proxy Class Proxy Class从AutoSar元模型的服务接口描述中生成。 ara::com确实标准化了生成的Proxy Class的接口。一个AP产品供应商的工具链将生成一个代理实现类来精确地实现这个接口。 注意: 因为Proxy Class必须提供的接口是由ara::com定义的&#xff0c;所…
阅读更多...
anaconda进入环境并查看python版本

anaconda进入环境并查看python版本

conda版本&#xff0c;并新建环境 查看ancaconda有几个环境 一个conda版本可以有很多conda环境&#xff0c;每个conda环境可以安装一个版本的python&#xff0c;和所需要的包&#xff0c;每个环境的包可以不相同。
阅读更多...
最新文章

Copyright @ 2022~2023