Spring Boot,Spring Data JPA多数据源支持
程序员文章站
2022-03-10 14:49:50
...
1 配置文件
wisely.primary.datasource.driverClassName=oracle.jdbc.OracleDriver wisely.primary.datasource.url=jdbc\:oracle\:thin\:@192.168.1.103\:1521\:xe wisely.primary.datasource.username=gis wisely.primary.datasource.password=gis wisely.secondary.datasource.driverClassName=oracle.jdbc.OracleDriver wisely.secondary.datasource.url=jdbc\:oracle\:thin\:@192.168.1.103\:1522\:xe wisely.secondary.datasource.username=gis wisely.secondary.datasource.password=gis
2 datasource配置
第一个数据源
@Configuration public class DataSourcePrimaryConfig { @Bean(name = "primaryDS") @Qualifier("primaryDS") @Primary @ConfigurationProperties(prefix="wisely.primary.datasource") public DataSource primaryDataSource(){ return DataSourceBuilder.create().build(); } }
第二个数据源
@Configuration public class DataSourceSecondaryConfig { @Bean(name = "secondaryDS") @Qualifier("secondaryDS") @ConfigurationProperties(prefix="wisely.secondary.datasource") public DataSource secondaryDataSource(){ return DataSourceBuilder.create().build(); } }
3 实体管理器及事务管理器配置
第一个数据源
@Configuration @EnableTransactionManagement @EnableJpaRepositories(entityManagerFactoryRef="entityManagerFactoryPrimary",transactionManagerRef="transactionManagerPrimary",basePackages= { "com.wisely.demo.dao.one" })//设置dao(repo)所在位置 public class RepositoryPrimaryConfig { @Autowired private JpaProperties jpaProperties; @Autowired @Qualifier("primaryDS") private DataSource primaryDS; @Bean(name = "entityManagerPrimary") @Primary public EntityManager entityManager(EntityManagerFactoryBuilder builder) { return entityManagerFactoryPrimary(builder).getObject().createEntityManager(); } @Bean(name = "entityManagerFactoryPrimary") @Primary public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary (EntityManagerFactoryBuilder builder) { return builder .dataSource(primaryDS) .properties(getVendorProperties(primaryDS)) .packages("com.wisely.demo.domain.one") //设置实体类所在位置 .persistenceUnit("primaryPersistenceUnit") .build(); } private Map<String, String> getVendorProperties(DataSource dataSource) { return jpaProperties.getHibernateProperties(dataSource); } @Bean(name = "transactionManagerPrimary") @Primary PlatformTransactionManager transactionManagerPrimary(EntityManagerFactoryBuilder builder) { return new JpaTransactionManager(entityManagerFactoryPrimary(builder).getObject()); } }
第二个数据源
@Configuration @EnableTransactionManagement @EnableJpaRepositories(entityManagerFactoryRef="entityManagerFactorySecondary",transactionManagerRef="transactionManagerSecondary",basePackages= { "com.wisely.demo.dao.two" }) public class RepositorySecondaryConfig { @Autowired private JpaProperties jpaProperties; @Autowired @Qualifier("secondaryDS") private DataSource secondaryDS; @Bean(name = "entityManagerSecondary") public EntityManager entityManager(EntityManagerFactoryBuilder builder) { return entityManagerFactorySecondary(builder).getObject().createEntityManager(); } @Bean(name = "entityManagerFactorySecondary") public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary (EntityManagerFactoryBuilder builder) { return builder .dataSource(secondaryDS) .properties(getVendorProperties(secondaryDS)) .packages("com.wisely.demo.domain.two") .persistenceUnit("secondaryPersistenceUnit") .build(); } private Map<String, String> getVendorProperties(DataSource dataSource) { return jpaProperties.getHibernateProperties(dataSource); } @Bean(name = "transactionManagerSecondary") PlatformTransactionManager transactionManagerSecondary(EntityManagerFactoryBuilder builder) { return new JpaTransactionManager(entityManagerFactorySecondary(builder).getObject()); } }
4 使用
此时来自不同数据库的dao(repo)可以任意在其它的bean里注入
@Controller public class TestController { @Autowired SysRoleRepo1 sysRoleRepo1; @Autowired SysRoleRepo2 sysRoleRepo2; @RequestMapping("/test") public @ResponseBody String test(){ System.out.println(Lists.newArrayList(sysRoleRepo1.findAll()).size()); System.out.println(Lists.newArrayList(sysRoleRepo2.findAll()).size()); return "ok"; } }
新书推荐《JavaEE开发的颠覆者: Spring Boot实战》,涵盖Spring 4.x、Spring MVC 4.x、Spring Boot企业开发实战。
京东地址:http://item.jd.com/11894632.html
当当地址:http://product.dangdang.com/23926195.html
亚马逊地址:http://www.amazon.cn/图书/dp/B01D5ZBFUK/ref=zg_bsnr_663834051_6
淘宝地址:https://item.taobao.com/item.htm?id=528426235744&ns=1&abbucket=8#detail
或自己在京东、淘宝、亚马逊、当当、互动出版社搜索自选。
上一篇: Spring Data JPA实现动态条件与范围查询
下一篇: 聊天室实现私聊第1/4页
推荐阅读
-
Spring Data JPA例子代码[基于Spring Boot、Mysql]
-
spring boot配置文件application.properties配置JPA以及数据源
-
在Spring Boot中使用Spring-data-jpa实现分页查询
-
spring boot之使用spring data jpa的自定义sql方式
-
Spring boot中Spring-Data-JPA操作MySQL数据库时遇到的错误(一)
-
Spring data jpa 配置多数据源
-
spring-boot-data-jpa
-
SpringBoot系列(四)SpringBoot 之 Spring Data Jpa 支持
-
Spring Data JPA中多数据源的配置
-
Spring Boot学习笔记(3)——加载指定配置文件&Profile多环境支持