Spring Boot连接两个数据库（以MySQL和H2数据库为例）
创作时间:
作者:
@小白创作中心
Spring Boot连接两个数据库（以MySQL和H2数据库为例）
引用
CSDN
1.
https://blog.csdn.net/weixin_56213139/article/details/140008729
在Spring Boot项目中，有时需要连接多个数据库来处理不同类型的数据。本文以MySQL和H2数据库为例，详细介绍如何在Spring Boot项目中配置和使用两个数据源。
一、项目结构
相比于原版的项目，如果需要连接两个数据库则需要创建两个文件夹，分别为config文件夹和mapper文件夹中新创立的baseMapper和testMapper文件夹，分别存放Mysql数据中的查询语句和H2的查询语句。
如果不是在Mapper中以注释的方式写查询语句，就可以在resources文件夹的xml文件中修改mapper中namespace的位置，如下图：
二、所需依赖
在pom.xml文件中添加以下依赖：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.1.3</version>
</parent>
<groupId>org.example</groupId>
<artifactId>big-event</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<name>big-event</name>
<url>http://maven.apache.org</url>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>2.5.6</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>3.0.0</version>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
</dependency>
<dependency>
<groupId>com.auth0</groupId>
<artifactId>java-jwt</artifactId>
<version>4.4.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>2.5.6</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.4.6</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.12</version>
</dependency>
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.15.1</version>
</dependency>
<dependency>
<groupId>javax.xml.bind</groupId>
<artifactId>jaxb-api</artifactId>
<version>2.3.1</version>
</dependency>
<dependency>
<groupId>javax.activation</groupId>
<artifactId>activation</artifactId>
<version>1.1.1</version>
</dependency>
<!-- no more than 2.3.3-->
<dependency>
<groupId>org.glassfish.jaxb</groupId>
<artifactId>jaxb-runtime</artifactId>
<version>2.3.3</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.example</groupId>-->
<!-- <artifactId>multipleDataConnection</artifactId>-->
<!-- <version>1.0-SNAPSHOT</version>-->
<!-- </dependency>-->
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>3.1.3</version>
</plugin>
</plugins>
</build>
</project>
三、具体配置
在config文件夹中分别创建DataSourceOneConfig和DataSourceTwo两个文件，分别存放MySQL和H2的数据库配置，其中需要根据自己项目的具体配置来改写MapperScan和getResources中的mapper路径，配置的具体代码如下。
DataSourceOneConfig：
package org.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.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.mybatis.spring.annotation.MapperScan;
import javax.sql.DataSource;
@Configuration
@MapperScan(basePackages = "org.example.mapper.baseMapper", sqlSessionTemplateRef = "db1SqlSessionTemplate")
public class DataSourceOneConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.one")
@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.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:org/example/mapper/*.xml"));
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) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
DataSourceTwoConfig：
package org.example.config;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
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.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.mybatis.spring.annotation.MapperScan;
import javax.sql.DataSource;
@Configuration
@MapperScan(basePackages = "org.example.mapper.testMapper", sqlSessionTemplateRef = "db2SqlSessionTemplate")
public class DataSourceTwoConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.two")
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.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));
return bean.getObject();
}
@Bean
public DataSourceTransactionManager db2TransactionManager(@Qualifier("db2DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean
public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
创建好以上配置文件后，在application.yml中添加第二个数据库配置，如下：
spring:
datasource:
one:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://localhost:3306/big_event
username: root
password: 7777777
two:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: org.h2.Driver
jdbc-url: jdbc:h2:tcp://localhost:10007/node
username: sa
password:
完成以上步骤后，在mapper中创建相应的文件夹，放入对应的Mapper接口（此处包的名称一定要和之前在config中配置的一样）：
以上步骤均完成后，再调用不同包中的Mapper接口就可以实现多数据库连接了。
热门推荐
我国“基民”超1亿！公募基金20多年来创造近6万亿元回报，你赚到钱了吗
【2025两会看重庆】巫溪老鹰茶：生态“绿叶”变富民“金叶”
域名泛解析是什么？如何设置？
樱桃萝卜生长过程详解：从播种到收获的全程指南
日本工厂品质管理如何
052E型驱逐舰再升级，中国海军战备新王牌，强悍到令人窒息
普通人怎么理财
Kotlin的优势：现代编程语言的卓越选择
打卡江苏“小而美”博物馆③｜中国珠算博物馆里，有趣故事知多少？
中国珠算博物馆：传承千年的计算智慧
5个实用方法缓解脚后跟疼痛
十部必看的中国动漫电影：笑声与感动齐飞
家庭院落栽什么树好（家中有院子，就栽这6种吉祥树）
隋唐帝国｜盛世遗风：唐朝对全球文化的影响与「唐人街」名称的由来
探讨在服务器布线中如何有效应对长距离传输与信号衰减的问题
优化人力资源管理体系，提高企业管理效率和员工福利
吃什么能缓解疲劳乏力
3种方法来判断鱼肉是否变质
如何高效制定工作任务分配方案？
黄果树瀑布旅游攻略
普洱茶中是否含有黄曲霉菌：检测方法、预防措施及安全性分析
老年人预防呛咳注意控制“一口”的量
被忽视的内感觉：从心理学到筋膜医学
猪蓝耳病检测卡的诊断与分析
碳纤维复合材料模具的优势有哪些？
企业故事的力量：纪录片在品牌传播中的角色
油炸小吃有哪些品种 油炸小吃的做法
数据库连接超时异常的全面解析与解决方案
2025年初中地理中考必考知识点梳理及复习指南
武汉龙泉山风景区：九座王陵与武昌鱼的完美邂逅