Spring boot配置多資料來源程式碼例項
阿新 • • 發佈:2020-07-09
因專案需要在一個應用裡從兩個資料庫取數,所以需要配置多資料來源,網上找了好多方法才啟動成功,整理如下。注意兩個資料來源的repository檔名不能相同,即使在不同的資料夾下,否則系統啟動會報錯。
配置檔案
spring.datasource.primary.url=*** spring.datasource.primary.username=*** spring.datasource.primary.password=*** spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver spring.datasource.second.url=*** spring.datasource.second.username=*** spring.datasource.second.password=*** spring.datasource.second.driver-class-name=com.mysql.jdbc.Driver
通用資料來源配置
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 */ @Configuration public class DataSourceConfig { /** * 第一個資料連線,預設優先順序最高 * @return */ @Primary @Bean(name = "primaryDataSource") //資料來源1配置名 @Qualifier("primaryDataSource") //資料來源1配置名 @ConfigurationProperties(prefix="spring.datasource.primary") //見配置檔案 public DataSource PrimaryDataSource() { return DataSourceBuilder.create().type(DruidDataSource.class).build(); } /** * 第二個資料來源 * @return */ @Bean(name = "secondDataSource") //資料來源2配置名 @Qualifier("secondDataSource") //資料來源2配置名 @ConfigurationProperties(prefix="spring.datasource.second") //見配置檔案 public DataSource secondaryDataSource() { return DataSourceBuilder.create().type(DruidDataSource.class).build(); } }
資料來源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= { "***此處為資料來源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("***實體類所在資料夾,兩個資料來源的實體類可相同***") .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()); } }
資料來源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( //實體管理 entityManagerFactoryRef="entityManagerFactorySecond",//事務管理 transactionManagerRef="transactionManagerSecond",//實體掃描,設定Repository所在位置 basePackages= { "***此處為資料來源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("***實體類所在資料夾,兩個資料來源的實體類可相同***") .persistenceUnit("secondPersistenceUnit") .build(); } private Map<String,"org.springframework.orm.hibernate5.SpringSessionContext"); return jpaProperties; } @Bean(name = "transactionManagerSecond") PlatformTransactionManager transactionManagerSecond(EntityManagerFactoryBuilder builder) { return new JpaTransactionManager(entityManagerFactorySecond(builder).getObject()); } }
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。