因項(xiàng)目需要在一個(gè)應(yīng)用里從兩個(gè)數(shù)據(jù)庫取數(shù)，所以需要配置多數(shù)據(jù)源，網(wǎng)上找了好多方法才啟動(dòng)成功，整理如下。注意兩個(gè)數(shù)據(jù)源的repository文件名不能相同，即使在不同的文件夾下，否則系統(tǒng)啟動(dòng)會(huì)報(bào)錯(cuò)。

配置文件

spring.datasource.primary.url=***spring.datasource.primary.username=***spring.datasource.primary.password=***spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driverspring.datasource.second.url=***spring.datasource.second.username=***spring.datasource.second.password=***spring.datasource.second.driver-class-name=com.mysql.jdbc.Driver

通用數(shù)據(jù)源配置

import com.alibaba.druid.pool.DruidDataSource;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;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;/** * @author ruanshuai * @date 2020/5/13 */@Configurationpublic class DataSourceConfig { /** * 第一個(gè)數(shù)據(jù)連接，默認(rèn)優(yōu)先級最高 * @return */ @Primary @Bean(name = 'primaryDataSource') //數(shù)據(jù)源1配置名 @Qualifier('primaryDataSource') //數(shù)據(jù)源1配置名 @ConfigurationProperties(prefix='spring.datasource.primary') //見配置文件 public DataSource PrimaryDataSource() { return DataSourceBuilder.create().type(DruidDataSource.class).build(); } /** * 第二個(gè)數(shù)據(jù)源 * @return */ @Bean(name = 'secondDataSource') //數(shù)據(jù)源2配置名 @Qualifier('secondDataSource') //數(shù)據(jù)源2配置名 @ConfigurationProperties(prefix='spring.datasource.second') //見配置文件 public DataSource secondaryDataSource() { return DataSourceBuilder.create().type(DruidDataSource.class).build(); }}

數(shù)據(jù)源1配置

import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;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.transaction.PlatformTransactionManager;import org.springframework.transaction.annotation.EnableTransactionManagement;import javax.persistence.EntityManager;import javax.sql.DataSource;import java.util.HashMap;import java.util.Map;/** * @author ruanshuai * @date 2020/5/13 */@Configuration@EnableTransactionManagement@EnableJpaRepositories( entityManagerFactoryRef='entityManagerFactoryPrimary', transactionManagerRef='transactionManagerPrimary', basePackages= { '***此處為數(shù)據(jù)源1 repository的存放文件夾***' })public class PrimaryConfig { @Autowired @Qualifier('primaryDataSource') private DataSource primaryDataSource; @Primary @Bean(name = 'entityManagerPrimary') public EntityManager entityManager(EntityManagerFactoryBuilder builder) { return entityManagerFactoryPrimary(builder).getObject().createEntityManager(); } @Primary @Bean(name = 'entityManagerFactoryPrimary') public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary (EntityManagerFactoryBuilder builder) { return builder.dataSource(primaryDataSource).properties(getVendorProperties()).packages('***實(shí)體類所在文件夾，兩個(gè)數(shù)據(jù)源的實(shí)體類可相同***').persistenceUnit('primaryPersistenceUnit').build(); } private Map<String, String> getVendorProperties() { Map<String, String> jpaProperties = new HashMap<>(16); jpaProperties.put('hibernate.hbm2ddl.auto', 'update'); jpaProperties.put('hibernate.show_sql', System.getProperty('spring.jpa.show-sql')); jpaProperties.put('hibernate.dialect', System.getProperty('spring.jpa.properties.hibernate.dialect')); jpaProperties.put('hibernate.current_session_context_class', 'org.springframework.orm.hibernate5.SpringSessionContext'); return jpaProperties; } @Primary @Bean(name = 'transactionManagerPrimary') public PlatformTransactionManager transactionManagerPrimary(EntityManagerFactoryBuilder builder) { return new JpaTransactionManager(entityManagerFactoryPrimary(builder).getObject()); }}

數(shù)據(jù)源2配置

import org.omg.CORBA.Environment;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;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.transaction.PlatformTransactionManager;import org.springframework.transaction.annotation.EnableTransactionManagement;import javax.persistence.EntityManager;import javax.sql.DataSource;import java.util.HashMap;import java.util.Map;/** * @author ruanshuai * @date 2020/5/13 */@Configuration@EnableTransactionManagement@EnableJpaRepositories( //實(shí)體管理 entityManagerFactoryRef='entityManagerFactorySecond', //事務(wù)管理 transactionManagerRef='transactionManagerSecond', //實(shí)體掃描,設(shè)置Repository所在位置 basePackages= { '***此處為數(shù)據(jù)源1 repository的存放文件夾***' })public class SecondConfig { @Autowired @Qualifier('secondDataSource') private DataSource secondDataSource; @Bean(name = 'entityManagerSecond') public EntityManager entityManager(EntityManagerFactoryBuilder builder) { return entityManagerFactorySecond(builder).getObject().createEntityManager(); } @Bean(name = 'entityManagerFactorySecond') public LocalContainerEntityManagerFactoryBean entityManagerFactorySecond (EntityManagerFactoryBuilder builder) { return builder.dataSource(secondDataSource).properties(getVendorProperties()).packages('***實(shí)體類所在文件夾，兩個(gè)數(shù)據(jù)源的實(shí)體類可相同***').persistenceUnit('secondPersistenceUnit').build(); } private Map<String, String> getVendorProperties() { Map<String, String> jpaProperties = new HashMap<>(16); jpaProperties.put('hibernate.hbm2ddl.auto', 'update'); jpaProperties.put('hibernate.show_sql', System.getProperty('spring.jpa.show-sql')); jpaProperties.put('hibernate.dialect', System.getProperty('spring.jpa.properties.hibernate.dialect')); jpaProperties.put('hibernate.current_session_context_class', 'org.springframework.orm.hibernate5.SpringSessionContext'); return jpaProperties; } @Bean(name = 'transactionManagerSecond') PlatformTransactionManager transactionManagerSecond(EntityManagerFactoryBuilder builder) { return new JpaTransactionManager(entityManagerFactorySecond(builder).getObject()); }}

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。