Springboot连接两个数据库（以Mysql和H2数据库为例）

近期刚刚完成毕业设计，项目中必要使用两处数据库，分布是为网页提供数据的Mysql数据库和提供Corda区块链数据的H2数据库，一并连接展示于网页上。基于此本文提供一种方法。
一、项目结构

相比于原版的项目，如果必要连接两个数据库则必要创建两个文件夹，分别为config文件夹和mapper文件夹中新创立的baseMapper和testMapper文件夹，分别存放Mysql数据中的查询语句和H2的查询语句。
如果不是在Mapper中以解释的方式写查询语句，就可以在resources文件夹的xml文件中修改mapper中namespace的位置，如下图：

二、所需依靠

pom.xml文件如下

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <modelVersion>4.0.0</modelVersion>
6.     <parent>
7.         <groupId>org.springframework.boot</groupId>
8.         <artifactId>spring-boot-starter-parent</artifactId>
9.         <version>3.1.3</version>
10.     </parent>
13.     <groupId>org.example</groupId>
14.     <artifactId>big-event</artifactId>
15.     <version>1.0-SNAPSHOT</version>
16.     <packaging>jar</packaging>
18.     <name>big-event</name>
19.     <url>http://maven.apache.org</url>
21.     <properties>
22.         <maven.compiler.source>17</maven.compiler.source>
23.         <maven.compiler.target>17</maven.compiler.target>
24.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
25.     </properties>
27.     <dependencies>
28.         <!-- web-->
29.         <dependency>
30.             <groupId>org.springframework.boot</groupId>
31.             <artifactId>spring-boot-starter-web</artifactId>
32.             <version>2.5.6</version>
33.         </dependency>
35.         <dependency>
36.             <groupId>org.mybatis.spring.boot</groupId>
37.             <artifactId>mybatis-spring-boot-starter</artifactId>
38.             <version>3.0.0</version>
39.         </dependency>
41.         <dependency>
42.             <groupId>com.mysql</groupId>
43.             <artifactId>mysql-connector-j</artifactId>
44.         </dependency>
46.         <dependency>
47.             <groupId>org.projectlombok</groupId>
48.             <artifactId>lombok</artifactId>
49.         </dependency>
51.         <dependency>
52.             <groupId>org.springframework.boot</groupId>
53.             <artifactId>spring-boot-starter-validation</artifactId>
54.         </dependency>
56.         <dependency>
57.             <groupId>com.auth0</groupId>
58.             <artifactId>java-jwt</artifactId>
59.             <version>4.4.0</version>
60.         </dependency>
62.         <dependency>
63.             <groupId>org.springframework.boot</groupId>
64.             <artifactId>spring-boot-starter-test</artifactId>
65.             <version>2.5.6</version>
66.         </dependency>
68.         <dependency>
69.             <groupId>com.github.pagehelper</groupId>
70.             <artifactId>pagehelper-spring-boot-starter</artifactId>
71.             <version>1.4.6</version>
72.         </dependency>
74.         <dependency>
75.             <groupId>org.springframework.boot</groupId>
76.             <artifactId>spring-boot-starter-data-redis</artifactId>
77.         </dependency>
80.         <dependency>
81.             <groupId>com.h2database</groupId>
82.             <artifactId>h2</artifactId>
83.             <scope>runtime</scope>
84.         </dependency>
86.         <dependency>
87.             <groupId>com.alibaba</groupId>
88.             <artifactId>druid</artifactId>
89.             <version>1.1.12</version>
90.         </dependency>
92.         <dependency>
93.             <groupId>com.aliyun.oss</groupId>
94.             <artifactId>aliyun-sdk-oss</artifactId>
95.             <version>3.15.1</version>
96.         </dependency>
98.         <dependency>
99.             <groupId>javax.xml.bind</groupId>
100.             <artifactId>jaxb-api</artifactId>
101.             <version>2.3.1</version>
102.         </dependency>
103.         <dependency>
104.             <groupId>javax.activation</groupId>
105.             <artifactId>activation</artifactId>
106.             <version>1.1.1</version>
107.         </dependency>
108.         <!-- no more than 2.3.3-->
109.         <dependency>
110.             <groupId>org.glassfish.jaxb</groupId>
111.             <artifactId>jaxb-runtime</artifactId>
112.             <version>2.3.3</version>
113.         </dependency>
115. <!--        <dependency>-->
116. <!--            <groupId>org.example</groupId>-->
117. <!--            <artifactId>multipleDataConnection</artifactId>-->
118. <!--            <version>1.0-SNAPSHOT</version>-->
119. <!--        </dependency>-->
121.     </dependencies>
123.     <build>
124.         <plugins>
125.             <plugin>
126.                 <groupId>org.springframework.boot</groupId>
127.                 <artifactId>spring-boot-maven-plugin</artifactId>
128.                 <version>3.1.3</version>
129.             </plugin>
130.         </plugins>
131.     </build>
133. </project>

复制代码

三、具体配置

在config文件夹中分别创建DataSourceOneConfig和DataSourceTwo两个文件，分别存放Mysql和H2的数据库配置，此中必要根据本身项目的具体配置来改写MapperScan和getResources中的mapper路径，配置的具体代码如下。

DataSourceOneConfig：

1. package org.example.config;
4. import org.apache.ibatis.session.SqlSessionFactory;
5. import org.mybatis.spring.SqlSessionFactoryBean;
6. import org.mybatis.spring.SqlSessionTemplate;
7. import org.mybatis.spring.annotation.MapperScan;
8. import org.springframework.beans.factory.annotation.Qualifier;
9. import org.springframework.boot.context.properties.ConfigurationProperties;
10. import org.springframework.boot.jdbc.DataSourceBuilder;
11. import org.springframework.context.annotation.Bean;
12. import org.springframework.context.annotation.Configuration;
13. import org.springframework.context.annotation.Primary;
14. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
15. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
16. import org.mybatis.spring.annotation.MapperScan;
18. import javax.sql.DataSource;
20. @Configuration
21. @MapperScan(basePackages = "org.example.mapper.baseMapper", sqlSessionTemplateRef = "db1SqlSessionTemplate")
22. public class DataSourceOneConfig {
23.     @Bean
24.     @ConfigurationProperties(prefix = "spring.datasource.one")
25.     @Primary
26.     public DataSource db1DataSource() {
27.         return DataSourceBuilder.create().build();
28.     }
30.     @Bean
31.     @Primary
32.     public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
33.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
34.         bean.setDataSource(dataSource);
35.         bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:org/example/mapper/*.xml"));
36.         return bean.getObject();
37.     }
39.     @Bean
40.     @Primary
41.     public DataSourceTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
42.         return new DataSourceTransactionManager(dataSource);
43.     }
45.     @Bean
46.     @Primary
47.     public SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
48.         return new SqlSessionTemplate(sqlSessionFactory);
49.     }
50. }

复制代码

DataSourceTwoConfig：

1. package org.example.config;
3. import org.apache.ibatis.session.SqlSessionFactory;
4. import org.mybatis.spring.SqlSessionFactoryBean;
5. import org.mybatis.spring.SqlSessionTemplate;
6. import org.springframework.beans.factory.annotation.Qualifier;
7. import org.springframework.boot.context.properties.ConfigurationProperties;
8. import org.springframework.boot.jdbc.DataSourceBuilder;
9. import org.springframework.context.annotation.Bean;
10. import org.springframework.context.annotation.Configuration;
11. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
12. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
13. import org.mybatis.spring.annotation.MapperScan;
15. import javax.sql.DataSource;
17. @Configuration
18. @MapperScan(basePackages = "org.example.mapper.testMapper", sqlSessionTemplateRef = "db2SqlSessionTemplate")
19. public class DataSourceTwoConfig {
21.     @Bean
22.     @ConfigurationProperties(prefix = "spring.datasource.two")
23.     public DataSource db2DataSource() {
24.         return DataSourceBuilder.create().build();
25.     }
27.     @Bean
28.     public SqlSessionFactory db2SqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws Exception {
29.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
30.         bean.setDataSource(dataSource);
31.         //bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));
32.         return bean.getObject();
33.     }
35.     @Bean
36.     public DataSourceTransactionManager db2TransactionManager(@Qualifier("db2DataSource") DataSource dataSource) {
37.         return new DataSourceTransactionManager(dataSource);
38.     }
40.     @Bean
41.     public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
42.         return new SqlSessionTemplate(sqlSessionFactory);
43.     }
44. }

复制代码

创建好以上配置文件后，在application.yml中添加第二个数据库配置，如下：

1. spring:
2.   datasource:
3.     one:
4.       type: com.alibaba.druid.pool.DruidDataSource
5.       driver-class-name: com.mysql.cj.jdbc.Driver
6.       jdbc-url: jdbc:mysql://localhost:3306/big_event
7.       username: root
8.       password: 7777777
10.     two:
11.       type: com.alibaba.druid.pool.DruidDataSource
12.       driver-class-name: org.h2.Driver
13.       jdbc-url: jdbc:h2:tcp://localhost:10007/node
14.       username: sa
15.       password:

复制代码

完成以上步调后，在mapper中创建相应的文件夹，放入对应的Mapper接口（此处包的名称一定要和之前在config中配置的一样）：

以上步调均完成后，再调用不同包中的Mapper接口就可以实现多数据库连接了。


 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。