springboot项目连接多种数据库该如何操作详析

更新时间：2024年08月01日 10:01:56 作者：不柔情

在Spring Boot应用中连接多个数据库或数据源可以使用多种方式,下面这篇文章主要给大家介绍了关于springboot项目连接多种数据库该如何操作的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下

前言

在项目的开发中，经常会遇到需要连接多个多种数据库的情况，mysql、oracle等等，下面详细讲解如何在一个服务中进行多种数据库的配置。

第一步：

在yml配置文件中配置多个数据源，如下，根据实际情况更改自己的配置即可。

spring:
  datasource:
    # 配置多个数据源
    primary:
      type: com.alibaba.druid.pool.DruidDataSource
      jdbc-url: jdbc:oracle:thin:@171.28.7.55:1521:example
      username: root
      password: root
      driver-class-name: oracle.jdbc.OracleDriver  #数据库链接驱动
    secondary:
      type: com.alibaba.druid.pool.DruidDataSource
      jdbc-url: jdbc:mysql://127.0.0.1:3306/exinfo?useUnicode=true&characterEncoding=utf-8
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver  #数据库链接驱动

第二步：

创建多个配置类，以配置oracle和mysql两个数据库为例，可参考代码进行延展。

1.在配置类中需要进行数据源配置

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    @Primary
    public DataSource db1DataSource() {
        return DataSourceBuilder.create().build();
    }

@ConfigurationProperties(prefix = "spring.datasource.primary")用于绑定yml中的第一个数据源配置，这些配置项会被自动映射到db1DataSource所创建的数据源实例中。通过DataSourceBuilder. create()创建一个新的数据源构建器，并调用.build()方法来完成数据源实例的创建。

如果有多个相同类型的Bean，使用@Primary注解可以标记出一个优先（默认）使用的Bean。所以使用最多的数据库可以使用@Primary注解。

2.配置MyBatis的SqlSessionFactory，它是MyBatis操作数据库的核心组件，负责创建SqlSession对象，执行SQL语句等。使用名称为db1DataSource的数据源Bean作为构造SqlSessionFactory的依赖。

    @Bean
    @Primary
    public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);//设置下划线转驼峰式
        return bean.getObject();
    }

3.配置事务管理器（DataSourceTransactionManager），它基于数据源（DataSource）的事务管理实现，专门用于JDBC事务处理。注解明确指定使用名为db1DataSource的数据源Bean。

    @Bean
    @Primary
    public DataSourceTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

4.配置SqlSessionTemplate实例，它是MyBatis与Spring集成的关键组件，提供了线程安全的SQL会话执行环境。

    @Bean
    @Primary
    public SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }

5.类注解@MapperScan

basePackages= "com.example.mapper"：指定了Mapper接口所在的包路径。Spring会扫描这个包及其子包下的所有接口，如果接口符合MyBatis Mapper的规范，Spring会自动生成代理对象来处理SQL调用。

sqlSessionTemplateRef = "db1SqlSessionTemplate"：指定了与Mapper接口绑定的sqlSessionTemplate的名称。在执行Mapper接口的方法时，Spring会使用这个指定的sqlSessionTemplate来管理SQL会话。这里的db1SqlSessionTemplate是之前通过@Bean方法定义的sqlSessionTemplate Beam的名称。

DataSourcePrimaryConfig完整代码如下：

package com.example.config;

import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.example.mapper", sqlSessionTemplateRef = "db1SqlSessionTemplate")
public class DataSourcePrimaryConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    @Primary
    public DataSource db1DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @Primary
    public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);//设置下划线转驼峰式
        return bean.getObject();
    }

    @Bean
    @Primary
    public DataSourceTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    @Primary
    public SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

DataSourceSecondaryConfig代码如下：

package com.example.config;

import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.example.mapper2", sqlSessionTemplateRef = "db2SqlSessionTemplate")
public class DataSourceSecondaryConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.secondary")
    public DataSource db2DataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    public SqlSessionFactory db2SqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);//设置下划线转驼峰式
        return bean.getObject();
    }

    @Bean
    public DataSourceTransactionManager db2TransactionManager(@Qualifier("db2DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

第三步：

根据配置文件，创建两个mapper包如下：

在不同的mapper包下进行不同数据库的交互即可。

总结

到此这篇关于springboot项目连接多种数据库该如何操作的文章就介绍到这了,更多相关springboot连接多种数据库内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

一文详解Spring是怎么读取配置Xml文件的
这篇文章主要介绍了一文详解Spring是怎么读取配置Xml文件的，文章围绕主题展开详细的内容介绍，具有一定的参考价值，感兴趣的小伙伴可以参考一下
2022-08-08
SpringBoot整合RabbitMQ消息队列的完整步骤
这篇文章主要给大家介绍了关于SpringBoot整合RabbitMQ消息队列的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-05-05
Java Spring WEB应用实例化如何实现
这篇文章主要介绍了Java Spring WEB应用实例化如何实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-12-12
mybatisplus自动填充属性值的实现步骤
MyBatis-Plus提供自动填充的功能,帮助自定设置这些字段的值,提升开发效率,本文就来介绍一下如何使用,感兴趣的可以了解一下
2023-12-12
RocketMQ 延时级别配置方式
这篇文章主要介绍了RocketMQ 延时级别配置方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-07-07
Java中的SynchronousQueue阻塞队列及使用场景解析
这篇文章主要介绍了Java中的SynchronousQueue阻塞队列及使用场景解析,SynchronousQueue 是 Java 中的一个特殊的阻塞队列,它的主要特点是它的容量为0,这意味着 SynchronousQueue不会存储任何元素,需要的朋友可以参考下
2023-12-12
java输入数字,输出倒序的实例
这篇文章主要介绍了java输入数字,输出倒序的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-08-08
用3个实例从原理到实战讲清楚Log4j史诗级漏洞
最近应该很多人都在关注着一个漏洞Apache Log4j 2远程代码执行,该漏洞一旦被攻击者利用会造成严重危害,这篇文章主要给大家介绍了关于如何用3个实例从原理到实战讲清楚Log4j史诗级漏洞的相关资料,需要的朋友可以参考下
2021-12-12
Spring中Bean创建完后打印语句的两种方法
这篇文章主要介绍了Spring中Bean创建完后打印语句的两种方法，一个是实现InitializingBean接口，另一个使用@Bean注解和initMethod属性，通过代码示例介绍的非常详细，感兴趣的小伙伴可以参考阅读
2023-07-07
Spring Cloud重试机制与各组件的重试总结
这篇文章主要给大家介绍了关于Spring Cloud中重试机制与各组件的重试的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。
2017-11-11