ToB企服应用市场:ToB评测及商务社交产业平台

标题: Springboot连接两个数据库（以Mysql和H2数据库为例） [打印本页]
作者: 科技颠覆者    时间: 前天 13:26
标题: 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企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4