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接口就可以实现多数据库连接了。
热门推荐
莲花的寓意和象征是什么？如何在文化中体现？
ESFP人格：特点、生活、职业、关系及短板的全方位解析
考科四需要携带哪些材料？
草红花的功效与作用的功能与主治
欧联杯淘汰赛——热刺vs阿尔克马预测分析 热刺晋级形势被动，主场翻盘需把握机会
苹果iPhone电池容量衰减严重怎么办？
新生儿Apgar评分标准及注意事项
绿色思维规划城市未来
相亲时如何有效沟通
用户运营简历模版「精选5篇」
多伦多大学三个校区详细解读
《楚乔传》收视率持续第一，特效配音问题难掩剧集魅力
宇宙中的四种基本作用力到底是如何产生的？答案或通向万物的本质
深入解析CPU天梯图：2500U性能表现及选购指南
新西兰留学住宿费用全解析
新西兰的生活成本高吗？
犹太教：犹太人的宗教信仰体系
使用ping命令检测远程主机是否可用
百桌连席 万人同饮！泰顺百家宴再上央视
房产交易违约金有哪些
发现“天使粒子”的张首晟走了，他超越物理的贡献也该被铭记
《百变小樱》角色关系深度解析：雪兔、桃矢、小樱、小狼的情感纠葛
谷歌邮箱账号申诉法律流程及注意事项
盘点全球票房最高的10部电影，漫威4部，“卡神”一人3部！
如何正确的晒太阳，才能补充维生素D？
家用沙发材质选择：真皮与布艺的优劣对比，哪种更适合你的家居风格？
浮盈加仓策略详解：实施方法与投资组合管理影响
DPI、PPI、DP、PX的详细计算方法及算法来源
深度解读哥特式建筑，黑暗美学的浪漫颂歌——艺术与历史的交汇点
汽车保险过期未购买怎么办？了解处理方法及注意事项