springboot + (mysql/pgsql) + jpa 多数据源（不同类数据源）

 配置文件：

spring:datasource:primary:jdbc-url: jdbc:mysql://host:3306/数据库?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&serverTimezone=Asia/Shanghai&zeroDateTimeBehavior=convertToNullusername: 账号password: 密码driver-class-name: com.mysql.cj.jdbc.Driversecondary:jdbc-url: jdbc:postgresql://host:3306/数据库username: 账号password: 密码driver-class-name: org.postgresql.Driverjpa:hibernate:primary-dialect: org.hibernate.dialect.MySQL5InnoDBDialectsecondary-dialect: org.hibernate.spatial.dialect.postgis.PostgisDialectddl-auto: updateshow-sql: trueproperties:hibernate:enable_lazy_load_no_trans: true #禁用懒加载temp:use_jdbc_metadata_defaults: falsehbm2ddl: auto: none

datasourceconfig：

import javax.sql.DataSource;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;@Configuration
public class DataSourceConfig {@Bean(name = "primaryDataSource")@Qualifier("primaryDataSource")@ConfigurationProperties(prefix = "spring.datasource.primary")@Primarypublic DataSource primaryDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "secondaryDataSource")@Qualifier("secondaryDataSource")@ConfigurationProperties(prefix = "spring.datasource.secondary")public DataSource secondaryDataSource() {return DataSourceBuilder.create().build();}}

数据源一：

import java.util.Map;
import javax.persistence.EntityManager;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
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.Database;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.annotation.EnableTransactionManagement;/*** 数据源一*/
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(entityManagerFactoryRef = "entityManagerFactoryPrimary",transactionManagerRef = "transactionManagerPrimary",basePackages = {"com.yuruo.reco.entity.repository","com.yuruo.reco.entity.mysql.repository"}) //设置Repository所在位置
public class PrimaryConfig {@Autowired@Qualifier("primaryDataSource")private DataSource primaryDataSource;@Autowiredprivate JpaProperties jpaProperties;@Primary@Bean(name = "entityManagerPrimary")public EntityManager entityManager() {return entityManagerFactoryPrimary().getObject().createEntityManager();}@Primary@Bean(name = "entityManagerFactoryPrimary")public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary() {//定义数据库类型和连接方言等主要配置（不写两个数据库方言一样会报错）HibernateJpaVendorAdapter jpaVendorAdapter = new HibernateJpaVendorAdapter();jpaVendorAdapter.setGenerateDdl(true);jpaVendorAdapter.setDatabase(Database.MYSQL);jpaVendorAdapter.setDatabasePlatform("org.hibernate.dialect.MySQL5Dialect");LocalContainerEntityManagerFactoryBean builder = new LocalContainerEntityManagerFactoryBean();builder.setDataSource(primaryDataSource);builder.setPackagesToScan("com.yuruo.reco.entity","com.yuruo.reco.entity.mysql");builder.setJpaVendorAdapter(jpaVendorAdapter);builder.setPersistenceUnitName("primaryPersistenceUnit");builder.setJpaPropertyMap(getVendorProperties());return builder;}private Map<String, String> getVendorProperties() {return jpaProperties.getProperties();}@Primary@Bean(name = "transactionManagerPrimary")public JpaTransactionManager transactionManagerPrimary() {return new JpaTransactionManager(entityManagerFactoryPrimary().getObject());}
}

数据源二：

import java.util.Map;import javax.persistence.EntityManager;
import javax.sql.DataSource;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
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.Database;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.annotation.EnableTransactionManagement;/*** 数据源二*/
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(entityManagerFactoryRef = "entityManagerFactorySecondary", transactionManagerRef = "transactionManagerSecondary", basePackages = {"com.yuruo.reco.hologres.repository" }) // 设置Repository所在位置,两个数据库对应的repository和实体类需要不同的路径
public class SecondaryConfig {@Autowired@Qualifier("secondaryDataSource")private DataSource secondaryDataSource;@Bean(name = "entityManagerSecondary")public EntityManager entityManager() {return entityManagerFactorySecondary().getObject().createEntityManager();}/*** 将配置文件中对应的配置信息注册到jpa中进行管理* * @return*/@Bean(name = "entityManagerFactorySecondary")public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary() {HibernateJpaVendorAdapter jpaVendorAdapter = new HibernateJpaVendorAdapter();jpaVendorAdapter.setGenerateDdl(true);jpaVendorAdapter.setDatabase(Database.POSTGRESQL);jpaVendorAdapter.setDatabasePlatform("org.hibernate.dialect.PostgreSQLDialect");LocalContainerEntityManagerFactoryBean builder = new LocalContainerEntityManagerFactoryBean();builder.setDataSource(secondaryDataSource);builder.setPackagesToScan("com.yuruo.reco.hologres.entity");builder.setJpaVendorAdapter(jpaVendorAdapter);builder.setPersistenceUnitName("secondaryPersistenceUnit");builder.setJpaPropertyMap(getVendorProperties());return builder;}@Autowiredprivate JpaProperties jpaProperties;private Map<String, String> getVendorProperties() {return jpaProperties.getProperties();}// 用来作为数据库事务回滚的限定词// @Transactional(rollbackFor = OAPMException.class, value =// "transactionManagerSecondary")// 事务管理器@Bean(name = "transactionManagerSecondary")public JpaTransactionManager transactionManagerSecondary() {return new JpaTransactionManager(entityManagerFactorySecondary().getObject());}
}