避坑版：springboot+JPA如何配多种数据源（postgresql+mysql）

2024-09-01 10:08
文章标签 java 多种 mysql springboot spring postgresql 数据源 避坑 database jpa

本文主要是介绍避坑版：springboot+JPA如何配多种数据源（postgresql+mysql），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

注意： JPA和mybatis是不同的持久层，各自特点独特，

与mybatis相比，JPA需要考虑对数据源的映射和操作，

通常我们设置在项目启动时，JPA就会根据设置去创建或者更新表，

因此不能像mybayis那样等到调用时再去告诉方法用哪个数据源，

JPA需要一开始就设定好repository和entity所对应的数据源，

在下列文件repository里你可以看到相关设置；

坑，请注意，网上有很多的JPA配多种数据源，但是他们都缺失一点，连方言都没有设置，有的压根不知道这回事，要知道，JPA对不同的数据库以及数据库不同版本有不同的数据方言，

此处一定要手动去设置各自不同的方言，在我的数据源设置那你可以看到手动设置方言，如果你不设置，那除非你把ddl_auto设置为none,可那样的话，项目才开始搭建，你就把JPA的特性干掉了一部分，多尴尬

application.properties数据源配置文件

#pg\u5E93
spring.pg.datasource.show-sql=true
spring.jpa.properties.hibernate.pg-dialect=org.hibernate.dialect.PostgreSQLDialect
spring.pg.datasource.hibernate.ddl-auto=update
spring.pg.datasource.platform=postgres
spring.pg.datasource.jdbc-url=jdbc:postgresql://localhost:7017/ddb
spring.pg.datasource.username=ddb_user
spring.pg.datasource.password=FSCn2qS8
spring.pg.datasource.driver-class-name=org.postgresql.Driver
#mysql
spring.mysql.datasource.show-sql=true
spring.jpa.properties.hibernate.mysql-dialect=org.hibernate.dialect.MySQL8Dialect
spring.mysql.datasource.hibernate.ddl-auto=update
spring.mysql.datasource.jdbc-url=jdbc:mysql://localhost:3306/testData?serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf8&allowPublicKeyRetrieval=true
spring.mysql.datasource.username=root
spring.mysql.datasource.password=666666
spring.mysql.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

DataSourceConfig.java 数据源实例
package com.hikvision.aries.jc.ihswfld.web.modules.dbconfig;/*** @Author: * @Description:* @Date: 2021/8/28 13:58* @Modified By：* @since v1.0.1*/
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
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 DataSourceConfig {@Bean(name = "pgDataSource")@Qualifier("pgDataSource")@ConfigurationProperties(prefix = "spring.pg.datasource")@Primarypublic DataSource pgDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "mysqlDataSource")@Qualifier("mysqlDataSource")@ConfigurationProperties(prefix = "spring.mysql.datasource")public DataSource mysqlDataSource() {return DataSourceBuilder.create().build();}}
PgConfig.java   pg数据源的配置
package com.hikvision.aries.jc.ihswfld.web.modules.dbconfig;/*** @Author: * @Description:* @Date: 2021/8/28 13:58* @Modified By：* @since v1.0.1*/
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateProperties;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateSettings;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
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.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.persistence.EntityManager;
import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;/*** 数据源一*/
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(entityManagerFactoryRef = "entityManagerFactoryPg",transactionManagerRef = "transactionManagerPg",basePackages = {"xx.xx.xx.repository"}) //设置Repository所在位置public class PgConfig {@Autowired@Qualifier("pgDataSource")private DataSource pgDataSource;//方言@Value("${spring.jpa.properties.hibernate.pg-dialect}")private String pgDialect;//表操作@Value("${spring.pg.datasource.hibernate.ddl-auto}")private String pg_ddl_auto;@Value("${spring.pg.datasource.show-sql}")private String pg_show_sql;@Primary@Bean(name = "entityManagerPg")public EntityManager entityManager(EntityManagerFactoryBuilder builder) {return entityManagerFactoryPg(builder).getObject().createEntityManager();}@Primary@Bean(name = "entityManagerFactoryPg")public LocalContainerEntityManagerFactoryBean entityManagerFactoryPg(EntityManagerFactoryBuilder builder) {LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();em.setDataSource(pgDataSource);em.setPackagesToScan(new String[] { "com.hikvision.aries.jc.ihswfld.web.modules.repository.entity" });HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();em.setJpaVendorAdapter(vendorAdapter);HashMap<String, Object> properties = new HashMap<>();properties.put("hibernate.hbm2ddl.auto",pg_ddl_auto);properties.put("hibernate.dialect",pgDialect);properties.put("hibernate.show_sql",pg_show_sql);em.setJpaPropertyMap(properties);return em;}@Primary@Bean(name = "transactionManagerPg")public PlatformTransactionManager transactionManagerPg(EntityManagerFactoryBuilder builder) {return new JpaTransactionManager(entityManagerFactoryPg(builder).getObject());}
}

MysqlConfig.java 数据源的配置
package com.hikvision.aries.jc.ihswfld.web.modules.dbconfig;/*** @Author: * @Description:* @Date: 2021/8/28 13:59* @Modified By：* @since v1.0.1*/
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateProperties;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateSettings;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
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.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.persistence.EntityManager;
import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;/*** 数据源二*/
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(entityManagerFactoryRef = "entityManagerFactoryMysql",transactionManagerRef = "transactionManagerMysql",basePackages = {"xx.xx.xx.mysqlRepository"}) //设置Repository所在位置,两个数据库对应的repository和实体类需要不同的路径
public class MysqlConfig {@Autowired@Qualifier("mysqlDataSource")private DataSource mysqlDataSource;//方言@Value("${spring.jpa.properties.hibernate.mysql-dialect}")private String mysqlDialect;//表操作@Value("${spring.mysql.datasource.hibernate.ddl-auto}")private String mysq_ddl_auto;@Value("${spring.mysql.datasource.show-sql}")private String mysql_show_sql;@Bean(name = "entityManagerMysql")public EntityManager entityManager(EntityManagerFactoryBuilder builder) {return entityManagerFactoryMysql(builder).getObject().createEntityManager();}@Bean(name = "entityManagerFactoryMysql")public LocalContainerEntityManagerFactoryBean entityManagerFactoryMysql(EntityManagerFactoryBuilder builder) {LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();em.setDataSource(mysqlDataSource);em.setPackagesToScan(new String[] { "com.hikvision.aries.jc.ihswfld.web.modules.mysqlRepository.entity" });HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();em.setJpaVendorAdapter(vendorAdapter);HashMap<String, Object> properties = new HashMap<>();properties.put("hibernate.hbm2ddl.auto",mysq_ddl_auto);properties.put("hibernate.dialect",mysqlDialect);properties.put("hibernate.show_sql",mysql_show_sql);em.setJpaPropertyMap(properties);return em;}//用来作为数据库事务回滚的限定词//@Transactional(rollbackFor = OAPMException.class, value = "transactionManagerMysql")//事务管理器@Bean(name = "transactionManagerMysql")PlatformTransactionManager transactionManagerMysql(EntityManagerFactoryBuilder builder) {return new JpaTransactionManager(entityManagerFactoryMysql(builder).getObject());}
}

这篇关于避坑版：springboot+JPA如何配多种数据源（postgresql+mysql）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1126640。

相关文章

Springboot配置文件相关语法及读取方式详解

Springboot配置文件相关语法及读取方式详解

《Springboot配置文件相关语法及读取方式详解》本文主要介绍了SpringBoot中的两种配置文件形式,即.properties文件和.yml/.yaml文件,详细讲解了这两种文件的语法和读取方... 目录配置文件的形式语法1、key-value形式2、数组形式读取方式1、通过@value注解2、通过
阅读更多...
Java 接口定义变量的示例代码

Java 接口定义变量的示例代码

《Java接口定义变量的示例代码》文章介绍了Java接口中的变量和方法,接口中的变量必须是publicstaticfinal的,用于定义常量,而方法默认是publicabstract的,必须由实现类... 在 Java 中，接口是一种抽象类型，用于定义类必须实现的方法。接口可以包含常量和方法，但不能包含实例
阅读更多...
JAVA Calendar设置上个月时,日期不存在或错误提示问题及解决

JAVA Calendar设置上个月时,日期不存在或错误提示问题及解决

《JAVACalendar设置上个月时,日期不存在或错误提示问题及解决》在使用Java的Calendar类设置上个月的日期时,如果遇到不存在的日期（如4月31日）,默认会自动调整到下个月的相应日期（... 目录Java Calendar设置上个月时,日期不存在或错误提示java进行日期计算时如果出现不存在的
阅读更多...
Mybatis对MySQL if 函数的不支持问题解读

Mybatis对MySQL if 函数的不支持问题解读

《Mybatis对MySQLif函数的不支持问题解读》接手项目后,为了实现多租户功能,引入了Mybatis-plus,发现之前运行正常的SQL语句报错,原因是Mybatis不支持MySQL的if函... 目录MyBATis对mysql if 函数的不支持问题描述经过查询网上搜索资料找到原因解决方案总结Myb
阅读更多...
Springboot的配置文件及其优先级说明

Springboot的配置文件及其优先级说明

《Springboot的配置文件及其优先级说明》文章介绍了SpringBoot的配置文件,包括application.properties和application.yml的使用,以及它们的优先级,还讨... 目录配置文件内置配置文件yml与properties的比较优先级比较外置配置文件springboot
阅读更多...
自定义注解SpringBoot防重复提交AOP方法详解

自定义注解SpringBoot防重复提交AOP方法详解

《自定义注解SpringBoot防重复提交AOP方法详解》该文章描述了一个防止重复提交的流程,通过HttpServletRequest对象获取请求信息,生成唯一标识,使用Redis分布式锁判断请求是否... 目录防重复提交流程引入依赖properties配置自定义注解切面Redis工具类controller
阅读更多...
Java利用Spire.XLS for Java自动化设置Excel的文档属性

Java利用Spire.XLS for Java自动化设置Excel的文档属性

《Java利用Spire.XLSforJava自动化设置Excel的文档属性》一个专业的Excel文件,其文档属性往往能大大提升文件的可管理性和可检索性,下面我们就来看看Java如何使用Spire... 目录Spire.XLS for Java 库介绍与安装Java 设置内置的 Excel 文档属性Java
阅读更多...
Java中的CompletableFuture核心用法和常见场景

Java中的CompletableFuture核心用法和常见场景

《Java中的CompletableFuture核心用法和常见场景》CompletableFuture是Java8引入的强大的异步编程工具,支持链式异步编程、组合、异常处理和回调,介绍其核心用法,通过... 目录1、引言2. 基本概念3. 创建 CompletableFuture3.1. 手动创建3.2.
阅读更多...
java中4种API参数传递方式统一说明

java中4种API参数传递方式统一说明

《java中4种API参数传递方式统一说明》在Java中,我们可以使用不同的方式来传递参数给方法或函数,：本文主要介绍java中4种API参数传递方式的相关资料,文中通过代码介绍的非常详细,需要的... 目录1. 概述2. 参数传递方式分类2.1 Query Parameters（查询参数）2.2 Path
阅读更多...
MySQL 筛选条件放 ON后 vs 放 WHERE 后的区别解析

MySQL 筛选条件放 ON后 vs 放 WHERE 后的区别解析

《MySQL筛选条件放ON后vs放WHERE后的区别解析》文章解释了在MySQL中,将筛选条件放在ON和WHERE中的区别,文章通过几个场景说明了ON和WHERE的区别,并总结了ON用于关... 今天我们来讲讲数据库筛选条件放 ON 后和放 WHERE 后的区别。ON 决定如何 "连接" 表，WHERE
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2