springbootjpa整合多数据源(springboot怎么配置多个数据源)

• 攻略

技术SpringBoot+Jpa项目配置双数据源怎么实现这篇文章主要介绍“SpringBoot+Jpa项目配置双数据源怎么实现”，在日常操作中，相信很多人在SpringBoot+Jpa项目配置双数据源怎么实现问题上存在疑

这篇文章主要介绍“SpringBoot Jpa项目配置双数据源怎么实现",在日常操作中，相信很多人在SpringBoot Jpa项目配置双数据源怎么实现问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答“SpringBoot Jpa项目配置双数据源怎么实现"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

配置yml文件

服务器：

端口：8080

弹簧：

profiles:

active:dev

千斤顶：

时区：GMT 8

#这里是我们的数据库配置地方

数据源：

数据1:#这里是数据库一

驱动程序rclassname : com。MySQL。CJ。JDBC。驾驶员

网址： JDBC :我的SQL ://192。168 .0 .77:3306/test1？字符编码=UTF-8服务器时区=亚洲/上海自动重新连接=true faileoverreadonly=false writebatchestatements=true

用户名：root

密码：123

键入： com。阿里巴巴。德鲁伊。游泳池。德鲁伊数据源

数据2:#这里是数据库二

驱动程序rclassname : com。MySQL。CJ。JDBC。驾驶员

网址： JDBC :我的SQL ://192。168 .0 .88:3306/test2？字符编码=UTF-8服务器时区=亚洲/上海自动重新连接=true faileoverreadonly=false writebatchestatements=true

用户名：root

密码：123

键入： com。阿里巴巴。德鲁伊。游泳池。德鲁伊数据源当然到这里肯定是没有结束的，需要配置一些参数，否则启动会报错

创建数据源配置类

我们创建一个数据源的类，我们就给他取名为数据源图（这个名字自定义),在项目下创建一个包，方便管理

SpringBoot+Jpa项目配置双数据源怎么实现

打包。伊曼。cdn。常见。数据源；

导入组织。弹簧框架。豆子。工厂。注释。限定词；

导入组织。弹簧框架。靴子。自动配置。导入自动配置；

导入组织。弹簧框架。靴子。自动配置。JDBC。数据源属性；

导入组织。弹簧框架。靴子。语境。属性。配置属性；

导入组织。弹簧框架。语境。注释。豆子；

importorg.springfra

mework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.sql.DataSource;

/**
 * @author https://blog.csdn.net/weixin_42782429?spm=1000.2115.3001.5343
 * @date 2021/12/21 11:35
 * <p>
 * description 数据源配置
 */
@Configuration
public 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;

/**
 * @author tongJie
 * @date 2021/12/21 11:59
 * <p>
 * description  日志处理端数据库配置
 */
@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的配置

    /**
     * 连接工厂
     * @param builder 创建工具
     * @return 结果
     */
    @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();

    }

    /**
     * 配置事物管理器
     *
     * @param builder 创建工具
     * @return 结果
     */
    @Bean(name = "tes1Transaction")
    PlatformTransactionManager tes1Transaction(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(Objects.requireNonNull(analysisFactory(builder).getObject()));
    }

    // 以下是mybatis的配置

    /**
     * 配置sqlSessionFactory
     * @return 结果
     * @throws Exception 异常
     */
    @Bean("tes1SqlSessionFactory")
    public SqlSessionFactory tes1SqlSessionFactory() throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(analysisDataSource);
        sqlSessionFactory.setMapperLocations(new 
        //这里填写你mybaits的xml文件存放的路径
        PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/*.xml"));
        return sqlSessionFactory.getObject();
    }

    /**
     * 配置sqlSessionTemplate
     * @return 结果
     */
    @Bean(name = "tes1SqlSessionTemplate")
    public SqlSessionTemplate tes1SqlSessionTemplate() throws Exception {
        return new SqlSessionTemplate(tes1SqlSessionFactory());
    }
}

以此类推之后每增加一个数据库源就循环上面的方法
注意！！！！包一定要放对你配置的位置，否则不识别就会报错！！！！！！

到此，关于“SpringBoot+Jpa项目配置双数据源怎么实现”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！

内容来源网络，如有侵权，联系删除，本文地址：https://www.230890.com/zhan/156064.html

赞 (0)

相关推荐

  • vue echarts使用总结

    技术vue echarts使用总结 vue echarts使用总结option = {tooltip: {//提示框组件，也就是我们平时经常看见的鼠标移入后会有一个框框，显示你当前移入的参数名称和数据t

    礼包 2021年11月4日

  • 眉间痣,痣，长在脸上哪些部位算是美女

    技术眉间痣,痣，长在脸上哪些部位算是美女有人认为眉间痣，长在眉心和嘴角的痣是美人痣。其实不然，长在眼睑旁边和下方肤色较淡部位的明亮之痣，才会让人增色和增运。少数痣的确能够使人更美，但并不是每个人都是美人胚子，关于“美人痣

    生活 2021年10月26日

  • C++11有作用域的enum举例分析

    技术C++11有作用域的enum举例分析本篇内容介绍了“C++11有作用域的enum举例分析”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅

    攻略 2021年11月25日

  • 日历工具BusyCal mac版减速了该怎么解决

    技术日历工具BusyCal mac版减速了该怎么解决今天就跟大家聊聊有关日历工具BusyCal mac版减速了该怎么解决，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收

    攻略 2021年12月8日

  • mybatis日常语法有哪些

    技术mybatis日常语法有哪些mybatis日常语法有哪些，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。mybatis中的#和$的区别? #方式能够很大程

    攻略 2021年10月20日

  • 7.数组和正则

    技术7.数组和正则 7.数组和正则1.数组数据结构
    1.1什么是数组
    数组的英文是array , 可以存入多个不同类型的数据，是一个复合数据类型。
    1.2定义数组
    $a1 = array(1 , 1.5

    礼包 2021年12月23日