Spring设置多数据库（接纳数据连接池管理）

一，媒介

大家在开发过程中，如果项目大一点就会遇到一种情况，同一个项目中大概会用到很多个数据源，那么这篇文章，博主为大家分享在spring应用中怎样接纳数据库连接池的方式设置设置多数据源。
本篇文章接纳大家用的最多也是最受欢迎的HikariCP进行树模。
二，数据库连接池

数据库连接池是一个管理数据库连接的工具，它答应应用程序通过连接池来获取数据库连接，而不是每次需要时都重新创建连接。连接池通过维护一组预先创建好的数据库连接，以及管理连接的分配和释放，可以提高应用程序对数据库的访问性能和效率。
我们可以利用数据库连接池取实现连接的细节化设置。如最大连接数，最大空闲时间，最大连接等待时间等，这些方便了我们操作数据库，更可以有效制止过长等待导致程序卡死的情况。
常见的数据库连接池包罗 HikariCP、Tomcat JDBC Pool、Apache Commons DBCP、C3P0、Druid等等。
三，实际应用

1，预备数据库以及表和根本数据

本文测试多库的情况，所以我们需要创建最少两个库进行测试。数据库sql我就不提供了，各位根据本身方便手动去创建吧。我这里简单创建两个库和三张表。如下图所示

2，根本框架预备（启动类就不展示了，有需要请看博主其它文档）

2.1 pom依赖

1.     <dependency>
2.       <groupId>org.springframework.boot</groupId>
3.       <artifactId>spring-boot-starter-web</artifactId>
4.       <version>2.5.4</version>
5.       <exclusions>
6.         <exclusion>
7.           <groupId>org.springframework.boot</groupId>
8.           <artifactId>spring-boot-starter-logging</artifactId>
9.         </exclusion>
10.       </exclusions>
11.     </dependency>
13.     <dependency>
14.       <groupId>org.projectlombok</groupId>
15.       <artifactId>lombok</artifactId>
16.       <version>1.18.20</version>
17.     </dependency>
18.     <dependency>
19.       <groupId>org.apache.commons</groupId>
20.       <artifactId>commons-lang3</artifactId>
21.       <version>3.12.0</version> <!-- 这里是最新版本 -->
22.     </dependency>
23. <!--    日志框架-->
24.     <dependency>
25.       <groupId>ch.qos.logback</groupId>
26.       <artifactId>logback-classic</artifactId>
27.       <version>1.2.5</version> <!-- 你可以替换为其他版本 -->
28.     </dependency>
30.     <!-- mysql 连接 -->
31.     <dependency>
32.       <groupId>org.springframework.boot</groupId>
33.       <artifactId>spring-boot-starter-jdbc</artifactId>
34.       <version>2.5.4</version>
35.     </dependency>
37.     <dependency>
38.       <groupId>mysql</groupId>
39.       <artifactId>mysql-connector-java</artifactId>
40.       <version>8.0.17</version>
41.     </dependency>
43.     <dependency>
44.       <groupId>org.mybatis.spring.boot</groupId>
45.       <artifactId>mybatis-spring-boot-starter</artifactId>
46.       <version>2.2.0</version>
47.     </dependency>

复制代码

2.2 application.properties

这里密码接纳了加密的方式，运行时会自动解密，如果不知道怎么做的请查看SpringBoot启动自动解密加密设置项_springboot environment 设置项解密-CSDN博客

1. spring.profiles.active=dev,database
2. #mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
4. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
5. datasource1.url=jdbc:mysql://localhost:3306/rojertest?serverTimezone=Asia/Tokyo
6. datasource1.username=root
7. datasource1.password={decrypt}bGoxMDA0MDE4Mjc3
9. datasource2.url=jdbc:mysql://localhost:3306/roejrtest?serverTimezone=Asia/Tokyo
10. datasource2.username=root
11. datasource2.password={decrypt}bGoxMDA0MDE4Mjc3

复制代码

2.3 HikariCP设置

1. #HikariCP 配置信息
2. #连接超时时间，指连接数据库时最大等待时间，单位是毫秒
3. spring.datasource.hikari.connection-timeout=3000
4. #连接空闲超时时间，指连接在连接池中保持空闲状态的最大时间，超过此时间连接将被释放，单位是毫秒
5. spring.datasource.hikari.idle-timeout=3000
6. #连接池的最大连接数，指连接池中允许的最大连接数量
7. spring.datasource.hikari.maximum-pool-size=10
8. #连接池的最小空闲连接数，指连接池中保持的最小空闲连接数量。
9. spring.datasource.hikari.minimum-idle=5
10. #设置连接的事务隔离级别
11. #1,DEFAULT：使用数据库系统的默认隔离级别。
12. #2,READ_UNCOMMITTED：允许事务读取未提交的数据更改。这是最低的隔离级别，它允许事务读取未提交的更改，可能会导致脏读、不可重复读和幻读等问题。
13. #3,READ_COMMITTED：确保一个事务只能读取到已经提交的数据更改。在这个级别下，事务不会读取到其他事务未提交的更改，可以避免脏读，但仍可能存在不可重复读和幻读的问题。
14. #4,REPEATABLE_READ：确保一个事务可以多次读取相同的数据而不受其他事务的影响。在这个级别下，事务不会读取到其他事务已提交的更改，可以避免脏读和不可重复读，但仍可能存在幻读的问题。
15. #5,SERIALIZABLE：最高的隔离级别，确保事务之间完全隔离，每个事务都像是在独立运行。在这个级别下，事务不会读取到其他事务已提交或未提交的更改，可以避免脏读、不可重复读和幻读，但是会降低并发性能。
16. spring.datasource.hikari.transaction-isolation=DEFAULT
17. #连接验证超时时间，指连接在被取出后最大等待数据库验证的时间，单位是毫秒
18. spring.datasource.hikari.validation-timeout=3000
19. #用于测试连接的 SQL 查询语句
20. spring.datasource.hikari.connection-test-query=SHOW TABLES

复制代码

2.3 日志输出设置

1. <?xml version="1.0" encoding="UTF-8"?>
2. <configuration>
4.     <!-- 定义输出到控制台的日志记录器 -->
5.     <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
6.         <encoder>
7.             <!-- 设置日志输出格式 -->
8.             <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
9.         </encoder>
10.     </appender>
12.     <!--打印数据库连接池日志信息-->
13.     <logger name="com.zaxxer.hikari" level="DEBUG"/>
14.     <!--打印sql信息-->
15.     <logger name="com.luojie.dao" level="DEBUG"/>
17.     <!-- 设置根日志级别为 INFO -->
18.     <root level="INFO">
19.         <appender-ref ref="CONSOLE"/> <!-- 将日志输出到控制台 -->
20.     </root>
22. </configuration>

复制代码

2.4 datasourceConfig 编写（紧张）

1. package com.luojie.config;
3. import com.zaxxer.hikari.HikariDataSource;
4. import org.apache.ibatis.session.SqlSessionFactory;
5. import org.mybatis.spring.SqlSessionFactoryBean;
6. import org.mybatis.spring.annotation.MapperScan;
7. import org.springframework.beans.factory.annotation.Qualifier;
8. import org.springframework.beans.factory.annotation.Value;
9. import org.springframework.boot.jdbc.DataSourceBuilder;
10. import org.springframework.context.annotation.Bean;
11. import org.springframework.context.annotation.Configuration;
12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
14. import javax.sql.DataSource;
16. @Configuration
17. @MapperScan(basePackages = "com.luojie.dao.mapper1", sqlSessionFactoryRef = "sqlSessionFactory1")
18. public class DataSource1Config {
20.     @Value("${datasource1.url}")
21.     private String url;
22.     @Value("${datasource1.username}")
23.     private String username;
24.     @Value("${datasource1.password}")
25.     private String password;
27.     @Bean(name = "dataSource1")
28.     public DataSource dataSource1() {
29.         return DataSourceBuilder.create()
30.                 .url(url)
31.                 .username(username)
32.                 .password(password)
33.                 // 使用HikariCP数据连接池管理
34.                 .type(HikariDataSource.class)
35.                 .build();
36.     }
38.     @Bean(name = "sqlSessionFactory1")
39.     public SqlSessionFactory sqlSessionFactory1(@Qualifier("dataSource1") DataSource dataSource) throws Exception {
40.         SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
41.         sessionFactoryBean.setDataSource(dataSource);
42.         sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:rojerTestMapper/mapper1/*.xml"));
43.         return sessionFactoryBean.getObject();
44.     }
45. }

复制代码

1. package com.luojie.config;
3. import com.zaxxer.hikari.HikariDataSource;
4. import org.apache.ibatis.session.SqlSessionFactory;
5. import org.mybatis.spring.SqlSessionFactoryBean;
6. import org.mybatis.spring.annotation.MapperScan;
7. import org.springframework.beans.factory.annotation.Qualifier;
8. import org.springframework.beans.factory.annotation.Value;
9. import org.springframework.boot.jdbc.DataSourceBuilder;
10. import org.springframework.context.annotation.Bean;
11. import org.springframework.context.annotation.Configuration;
12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
14. import javax.sql.DataSource;
16. @Configuration
17. @MapperScan(basePackages = "com.luojie.dao.mapper2", sqlSessionFactoryRef = "sqlSessionFactory2")
18. public class DataSource2Config {
20.     @Value("${datasource2.url}")
21.     private String url;
22.     @Value("${datasource2.username}")
23.     private String username;
24.     @Value("${datasource2.password}")
25.     private String password;
27.     @Bean(name = "dataSource2")
28.     public DataSource dataSource1() {
29.         return DataSourceBuilder.create()
30.                 .url(url)
31.                 .username(username)
32.                 .password(password)
33.                 // 使用HikariCP数据连接池管理
34.                 .type(HikariDataSource.class)
35.                 .build();
36.     }
38.     @Bean(name = "sqlSessionFactory2")
39.     public SqlSessionFactory sqlSessionFactory1(@Qualifier("dataSource2") DataSource dataSource) throws Exception {
40.         SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
41.         sessionFactoryBean.setDataSource(dataSource);
42.         sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:rojerTestMapper/mapper2/*.xml"));
43.         return sessionFactoryBean.getObject();
44.     }
46. }

复制代码

3. 业务代码编写

3.1 controller 

1. package com.luojie.controller;
3. import com.luojie.controImpl.DatabaseTestImpl;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.web.bind.annotation.GetMapping;
6. import org.springframework.web.bind.annotation.RestController;
8. @RestController
9. public class DatabaseTestController {
11.     @Autowired
12.     DatabaseTestImpl test;
14.     @GetMapping("/database/test")
15.     public void test1() {
16.         test.add();
17.     }
18. }

复制代码

3.2 impl

1. package com.luojie.controImpl;
3. import com.luojie.dao.mapper1.Mapper1;
4. import com.luojie.dao.mapper2.Mapper2;
5. import com.luojie.moudle.LibraryModel;
6. import com.luojie.moudle.UserModel;
7. import org.springframework.beans.factory.annotation.Autowired;
8. import org.springframework.stereotype.Service;
10. @Service
11. public class DatabaseTestImpl {
13.     @Autowired
14.     private Mapper1 mapper1;
16.     @Autowired
17.     private Mapper2 mapper2;
19.     public void add() {
20.         UserModel userModel = new UserModel();
21.         userModel.setUsername("Rojer");
22.         userModel.setSex("男");
23.         userModel.setUserid("007");
24.         userModel.setRoles("admin,member");
25.         userModel.setMoney("10");
27.         LibraryModel libraryModel = new LibraryModel();
28.         libraryModel.setId(1);
29.         libraryModel.setAmount(1);
30.         mapper2.addLibrary(libraryModel);
31.         mapper2.addUserBalance(userModel);
32.         mapper1.addUser(userModel);
33.     }
34. }

复制代码

3.3 model文件

1. package com.luojie.moudle;
3. import lombok.Data;
5. @Data
6. public class UserModel {
8.     private String username;
10.     private String money;
12.     private String sex;
14.     private String roles;
16.     private String userid;
17. }

复制代码

1. package com.luojie.moudle;
3. import lombok.Data;
5. import java.math.BigDecimal;
7. @Data
8. public class LibraryModel {
10.     private String name;
12.     private BigDecimal price;
14.     private int amount;
16.     private int id;
17. }

复制代码

3.4 mapper接口

注意这里放的位置一定要与前面config中设置的一致

1. package com.luojie.dao.mapper1;
3. import com.luojie.moudle.UserModel;
4. import org.apache.ibatis.annotations.Mapper;
6. @Mapper
7. public interface Mapper1 {
8.     void addUser(UserModel userModel);
9. }

复制代码

1. package com.luojie.dao.mapper2;
3. import com.luojie.moudle.LibraryModel;
4. import com.luojie.moudle.UserModel;
5. import org.apache.ibatis.annotations.Mapper;
7. @Mapper
8. public interface Mapper2 {
10.     void addUserBalance(UserModel model);
12.     void addLibrary(LibraryModel model);
13. }

复制代码

3.5 mapper.xml

1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <!--<mapper> 标签用于定义 Mapper XML 文件。-->
4. <!--namespace 属性指定了该 Mapper XML 文件对应的 Mapper 接口的类路径。-->
5. <mapper namespace="com.luojie.dao.mapper1.Mapper1">
7.     <select id="addUser">
8.         insert into userpro (`userid`, `roles`, `username`) values (#{userid}, #{roles}, #{username})
9.     </select>
10. </mapper>

复制代码

1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <!--<mapper> 标签用于定义 Mapper XML 文件。-->
4. <!--namespace 属性指定了该 Mapper XML 文件对应的 Mapper 接口的类路径。-->
5. <mapper namespace="com.luojie.dao.mapper2.Mapper2">
7.     <update id="addUserBalance" parameterType="com.luojie.moudle.UserModel">
8.         update user set money = money + #{money} where userid = #{userid}
9.     </update>
11.     <update id="addLibrary" parameterType="com.luojie.moudle.LibraryModel">
12.         update library set amount = amount + #{amount} where id = #{id}
13.     </update>
14. </mapper>

复制代码

四，代码测试

sql和连接池都是正常打印日志的

整体执行ok

希望对各位大佬有资助。麻烦加个关注点个赞谢谢！


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