这篇文章主要介绍“SpringBoot+Jpa项目配置双数据源怎么实现”，在日常操作中，相信很多人在SpringBoot+Jpa项目配置双数据源怎么实现问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”SpringBoot+Jpa项目配置双数据源怎么实现”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
配置yml文件
server: port: 8080spring: profiles: active: dev jackson: time-zone: GMT+8 # 这里是我们的数据库配置地方 datasource: data1: #这里是数据库一 driverClassName: com.mysql.cj.jdbc.Driver url: jdbc:mysql://192.168.0.77:3306/test1?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true&failOverReadOnly=false&rewriteBatchedStatements=true username: root password: 123 type: com.alibaba.druid.pool.DruidDataSource data2: #这里是数据库二 driverClassName: com.mysql.cj.jdbc.Driver url: jdbc:mysql://192.168.0.88:3306/test2?characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true&failOverReadOnly=false&rewriteBatchedStatements=true username: root password: 123 type: com.alibaba.druid.pool.DruidDataSource当然到这里肯定是没有结束的，需要配置一些参数，否则启动会报错
创建数据源配置类
我们创建一个数据源的类，我们就给他取名为DataSourceConfig(这个名字自定义)，在项目下创建一个包，方便管理
package com.eman.cdn.common.dataSource;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.autoconfigure.ImportAutoConfiguration;import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;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;@Configurationpublic class DataSourceConfig { # 这里是我们在yml文件配置的位置 private final static String DB_TEST1 = "spring.datasource.test1"; private final static String DB_TEST2= "spring.datasource.test1"; # 这个Bean名字子自定义只要不是重复的Bean名字就行了 @Bean(name = "test1Properties") @Qualifier("test1Properties") @Primary @ConfigurationProperties(DB_TEST1) public DataSourceProperties test1Properties() { return new DataSourceProperties(); } @Bean(name = "test1DataSource") @Qualifier("test1DataSource") @Primary @ConfigurationProperties(prefix = DB_TEST1) public DataSource test1DataSource() { return test1Properties().initializeDataSourceBuilder().build(); } @Bean(name = "test2Properties") @Qualifier("test2Properties") @ConfigurationProperties(DB_TEST2) public DataSourceProperties test2Properties() { return new DataSourceProperties(); } @Bean(name = "test2DataSource") @Qualifier("test2DataSource") @ConfigurationProperties(prefix = DB_ANALYSIS) public DataSource test2DataSource() { return test2Properties().initializeDataSourceBuilder().build(); }}为每个数据库创建配置类
由于需要用到Mybaitis-plus所以你得先导入Mybaitis-Plus的依赖
<!--mybatis-plus--> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.1.0</version> </dependency>package com.eman.xx.xxx.xx;import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.SqlSessionTemplate;import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;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.core.io.support.PathMatchingResourcePatternResolver;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.sql.DataSource;import java.util.Objects;@Configuration@EnableTransactionManagement@EnableJpaRepositories( // 配置连接工厂 entityManagerFactoryRef = "tes1Factory", // 配置事物管理器 transactionManagerRef = "tes1Transaction", // 设置Jpa 的 repository所在位置 basePackages = {"com.xx.xx.xx.**.repository"})// 设置扫描的mapper@MapperScan(basePackages ="xx.xx.xx.test1.**.mapper", sqlSessionTemplateRef = "tes1SqlSessionTemplate")public class AnalysisDataBaseConfig { @Autowired @Qualifier("tes1DataSource") private DataSource analysisDataSource; @Autowired private JpaProperties jpaProperties; @Autowired private HibernateProperties properties; // 以下是jpa的配置 @Bean(name = "tes1Factory") public LocalContainerEntityManagerFactoryBean tes1Factory(EntityManagerFactoryBuilder builder) { return builder // 设置数据源 .dataSource(analysisDataSource) //设置实体类所在位置.扫描所有带有 @Entity 注解的类 .packages("xx.xx.xx.tes1.**.entity") // Spring会将EntityManagerFactory注入到Repository之中.有了 EntityManagerFactory之后, // Repository就能用它来创建 EntityManager 了,然后 EntityManager 就可以针对数据库执行操作 .persistenceUnit("tes1") // 为了加载yml中jpa下hibernate的相关配置 .properties(properties.determineHibernateProperties(jpaProperties.getProperties(), new HibernateSettings())) .build(); } @Bean(name = "tes1Transaction") PlatformTransactionManager tes1Transaction(EntityManagerFactoryBuilder builder) { return new JpaTransactionManager(Objects.requireNonNull(analysisFactory(builder).getObject())); } // 以下是mybatis的配置 @Bean("tes1SqlSessionFactory") public SqlSessionFactory tes1SqlSessionFactory() throws Exception { MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean(); sqlSessionFactory.setDataSource(analysisDataSource); sqlSessionFactory.setMapperLocations(new //这里填写你mybaits的xml文件存放的路径 PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper @Bean(name = "tes1SqlSessionTemplate") public SqlSessionTemplate tes1SqlSessionTemplate() throws Exception { return new SqlSessionTemplate(tes1SqlSessionFactory()); }}以此类推之后每增加一个数据库源就循环上面的方法
注意！！！！包一定要放对你配置的位置，否则不识别就会报错！！！！！！
到此，关于“SpringBoot+Jpa项目配置双数据源怎么实现”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程网网站，小编会继续努力为大家带来更多实用的文章！
