devbox
程序代码艺术家2
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SpringBoot 2.7教程：SpringBoot 整合 mybatis 多数据源连接方法-2022年最新图文版本_springboot2.7.10对应driverclassname

作者：程序代码艺术家2 | 2024-01-30 11:53:42

赞

踩

springboot2.7.10对应driverclassname

SpringBoot 2.7教程：SpringBoot + Web 项目搭建及实践应用-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot + Web 项目搭建，异常捕获处理-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot + Mysql 项目应用-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 集成 jsp 页面开发 -2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 实现文件上传，图片上传并显示功能-2022年最新图文版本

SpringBoot 2.7教程：springboot 设置全局字符编码，解决乱码问题-2022年最新图文版

SpringBoot 2.7教程：SpringBoot mybatis 多数据源的整合方法-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 整合 RocketMQ 项目搭建-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 整合 RabbitMQ 项目搭建-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 整合 MongoDB 项目搭建-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 整合 Redisson 项目搭建-2022年最新图文版本

SpringBoot 2.7教程：SpringBoot 整合 Redis 项目搭建-2022年最新图文版本

本章学习目标：

学习 springboot-mybatis 多数据源的整合方法

项目开发过程中会遇到单个项目要连接过个数据库实例的情况，如业务需要访问 用户库 和订单库。

目录

一、项目mybatis-muilt-database最终项目结构

二、配置pom.xml文件

三、配置properties

四、配置数据源类

五、书写mapper  and  xml

六、书写service

七、书写controller

八、Mysql 数据库文件

九、测试

当前最常用的版本2.2.x、2.3.x将在2022年停止维护了。

下面我们以最新的版本2.7进行系统搭建。

一、项目mybatis-muilt-database最终项目结构

二、配置pom.xml文件

  1.  <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.boot</groupId>
  4.             <artifactId>spring-boot-starter-web</artifactId>
  5.             <version>2.7.0</version>
  6.         </dependency>
  7.         <dependency>
  8.             <groupId>org.mybatis.spring.boot</groupId>
  9.             <artifactId>mybatis-spring-boot-starter</artifactId>
  10.             <version>2.1.4</version>
  11.         </dependency>
  12.         <dependency>
  13.             <groupId>mysql</groupId>
  14.             <artifactId>mysql-connector-java</artifactId>
  15.             <version>8.0.29</version>
  16.         </dependency>
  17.         <!-- Druid 数据连接池依赖 -->
  18.         <dependency>
  19.             <groupId>com.alibaba</groupId>
  20.             <artifactId>druid</artifactId>
  21.             <version>1.1.8</version>
  22.         </dependency>
  23.  
  24.         <dependency>
  25.             <groupId>log4j</groupId>
  26.             <artifactId>log4j</artifactId>
  27.             <version>1.2.16</version>
  28.             <scope>compile</scope>
  29.         </dependency>
  30. </dependencies>

三、配置properties

  1. # 应用名称
  2. spring.application.name=mybatis-multi-datasource
  3. # 应用服务 WEB 访问端口
  4. server.port=8080
  5.  
  6. datasource.user.url=jdbc:mysql://mysql_host:3306/user?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true
  7. datasource.user.username=root
  8. datasource.user.password=password
  9. datasource.user.driverClassName=com.mysql.cj.jdbc.Driver
  10.  
  11. datasource.order.url=jdbc:mysql://mysql_host:3306/order?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true
  12. datasource.order.username=root
  13. datasource.order.password=password
  14. datasource.order.driverClassName=com.mysql.cj.jdbc.Driver
  15.  
  16. # 连接池的配置信息
  17. # 初始化大小，最小，最大
  18. spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
  19. spring.datasource.initialSize=5  
  20. spring.datasource.minIdle=5  
  21. spring.datasource.maxActive=20  
  22. # 配置获取连接等待超时的时间
  23. spring.datasource.maxWait=60000  
  24. # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
  25. spring.datasource.timeBetweenEvictionRunsMillis=60000  
  26. # 配置一个连接在池中最小生存的时间，单位是毫秒
  27. spring.datasource.minEvictableIdleTimeMillis=300000  
  28. spring.datasource.validationQuery=SELECT 1 FROM DUAL  
  29. spring.datasource.testWhileIdle=true  
  30. spring.datasource.testOnBorrow=false  
  31. spring.datasource.testOnReturn=false  
  32. # 打开PSCache，并且指定每个连接上PSCache的大小
  33. spring.datasource.poolPreparedStatements=true  
  34. spring.datasource.maxPoolPreparedStatementPerConnectionSize=20  
  35. # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
  36. spring.datasource.filters=stat,wall,log4j  
  37. # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
  38. spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000  
  39.  
  40.  
  41.  
  42. ## 打印SQL语句
  43. logging.level.com.duoduo.mybatis.mapper=debug

四、配置数据源类

user数据库连接配置类

  1. @Configuration
  2. @MapperScan(basePackages = UserDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "userSqlSessionFactory")
  3. public class UserDataSourceConfig {
  4.  
  5.     static final String PACKAGE = "com.duoduo.mybatis.mapper.user";
  6.     static final String MAPPER_LOCATION = "classpath:mapper/user/*.xml";
  7.  
  8.     @Value("${datasource.user.url}")
  9.     private String url;
  10.  
  11.     @Value("${datasource.user.username}")
  12.     private String username;
  13.  
  14.     @Value("${datasource.user.password}")
  15.     private String password;
  16.  
  17.     @Value("${datasource.user.driverClassName}")
  18.     private String driverClassName;
  19.  
  20.  
  21.  
  22.  
  23.     @Value("${spring.datasource.initialSize}")
  24.     private int initialSize;
  25.  
  26.     @Value("${spring.datasource.minIdle}")
  27.     private int minIdle;
  28.  
  29.     @Value("${spring.datasource.maxActive}")
  30.     private int maxActive;
  31.  
  32.     @Value("${spring.datasource.maxWait}")
  33.     private int maxWait;
  34.  
  35.     @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
  36.     private int timeBetweenEvictionRunsMillis;
  37.  
  38.     @Value("${spring.datasource.minEvictableIdleTimeMillis}")
  39.     private int minEvictableIdleTimeMillis;
  40.  
  41.     @Value("${spring.datasource.validationQuery}")
  42.     private String validationQuery;
  43.  
  44.     @Value("${spring.datasource.testWhileIdle}")
  45.     private boolean testWhileIdle;
  46.  
  47.     @Value("${spring.datasource.testOnBorrow}")
  48.     private boolean testOnBorrow;
  49.  
  50.     @Value("${spring.datasource.testOnReturn}")
  51.     private boolean testOnReturn;
  52.  
  53.     @Value("${spring.datasource.poolPreparedStatements}")
  54.     private boolean poolPreparedStatements;
  55.  
  56.     @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
  57.     private int maxPoolPreparedStatementPerConnectionSize;
  58.  
  59.     @Value("${spring.datasource.filters}")
  60.     private String filters;
  61.  
  62.     @Value("{spring.datasource.connectionProperties}")
  63.     private String connectionProperties;
  64.  
  65.  
  66.     @Bean(name = "userDatasource")
  67.     public DataSource userDatasource() {
  68.         DruidDataSource dataSource = new DruidDataSource();
  69.         dataSource.setUrl(url);
  70.         dataSource.setUsername(username);
  71.         dataSource.setPassword(password);
  72.         dataSource.setDriverClassName(driverClassName);
  73.  
  74.         //具体配置
  75.         dataSource.setInitialSize(initialSize);
  76.         dataSource.setMinIdle(minIdle);
  77.         dataSource.setMaxActive(maxActive);
  78.         dataSource.setMaxWait(maxWait);
  79.         dataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  80.         dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  81.         dataSource.setValidationQuery(validationQuery);
  82.         dataSource.setTestWhileIdle(testWhileIdle);
  83.         dataSource.setTestOnBorrow(testOnBorrow);
  84.         dataSource.setTestOnReturn(testOnReturn);
  85.         dataSource.setPoolPreparedStatements(poolPreparedStatements);
  86.         dataSource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
  87.         try {
  88.             dataSource.setFilters(filters);
  89.         } catch (SQLException e) {
  90.             e.printStackTrace();
  91.         }
  92.         dataSource.setConnectionProperties(connectionProperties);
  93.         return dataSource;
  94.     }
  95.  
  96.     @Bean(name = "userTransactionManager")
  97.     public DataSourceTransactionManager userTransactionManager() {
  98.         return new DataSourceTransactionManager(userDatasource());
  99.     }
  100.  
  101.     @Bean(name = "userSqlSessionFactory")
  102.     public SqlSessionFactory userSqlSessionFactory(@Qualifier("userDatasource") DataSource userDatasource)
  103.             throws Exception {
  104.         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
  105.         sessionFactory.setDataSource(userDatasource);
  106.         sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
  107.                 .getResources(UserDataSourceConfig.MAPPER_LOCATION));
  108.         return sessionFactory.getObject();
  109.     }
  110. }

order数据库连接配置类

  1. @Configuration
  2. @MapperScan(basePackages = OrderDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "orderSqlSessionFactory")
  3. public class OrderDataSourceConfig {
  4.  
  5.     static final String PACKAGE = "com.duoduo.mybatis.mapper.order";
  6.     static final String MAPPER_LOCATION = "classpath:mapper/order/*.xml";
  7.  
  8.     @Value("${datasource.order.url}")
  9.     private String url;
  10.  
  11.     @Value("${datasource.order.username}")
  12.     private String username;
  13.  
  14.     @Value("${datasource.order.password}")
  15.     private String password;
  16.  
  17.     @Value("${datasource.order.driverClassName}")
  18.     private String driverClass;
  19.  
  20.  
  21.     @Value("${spring.datasource.initialSize}")
  22.     private int initialSize;
  23.  
  24.     @Value("${spring.datasource.minIdle}")
  25.     private int minIdle;
  26.  
  27.     @Value("${spring.datasource.maxActive}")
  28.     private int maxActive;
  29.  
  30.     @Value("${spring.datasource.maxWait}")
  31.     private int maxWait;
  32.  
  33.     @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
  34.     private int timeBetweenEvictionRunsMillis;
  35.  
  36.     @Value("${spring.datasource.minEvictableIdleTimeMillis}")
  37.     private int minEvictableIdleTimeMillis;
  38.  
  39.     @Value("${spring.datasource.validationQuery}")
  40.     private String validationQuery;
  41.  
  42.     @Value("${spring.datasource.testWhileIdle}")
  43.     private boolean testWhileIdle;
  44.  
  45.     @Value("${spring.datasource.testOnBorrow}")
  46.     private boolean testOnBorrow;
  47.  
  48.     @Value("${spring.datasource.testOnReturn}")
  49.     private boolean testOnReturn;
  50.  
  51.     @Value("${spring.datasource.poolPreparedStatements}")
  52.     private boolean poolPreparedStatements;
  53.  
  54.     @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
  55.     private int maxPoolPreparedStatementPerConnectionSize;
  56.  
  57.     @Value("${spring.datasource.filters}")
  58.     private String filters;
  59.  
  60.     @Value("{spring.datasource.connectionProperties}")
  61.     private String connectionProperties;
  62.  
  63.     @Bean(name = "orderDataSource")
  64.     public DataSource orderDataSource() {
  65.  
  66.         DruidDataSource dataSource = new DruidDataSource();
  67.         dataSource.setUrl(url);
  68.         dataSource.setUsername(username);
  69.         dataSource.setPassword(password);
  70.         dataSource.setDriverClassName(driverClass);
  71.  
  72.         //具体配置
  73.         dataSource.setInitialSize(initialSize);
  74.         dataSource.setMinIdle(minIdle);
  75.         dataSource.setMaxActive(maxActive);
  76.         dataSource.setMaxWait(maxWait);
  77.         dataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  78.         dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  79.         dataSource.setValidationQuery(validationQuery);
  80.         dataSource.setTestWhileIdle(testWhileIdle);
  81.         dataSource.setTestOnBorrow(testOnBorrow);
  82.         dataSource.setTestOnReturn(testOnReturn);
  83.         dataSource.setPoolPreparedStatements(poolPreparedStatements);
  84.         dataSource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
  85.         try {
  86.             dataSource.setFilters(filters);
  87.         } catch (SQLException e) {
  88.             e.printStackTrace();
  89.         }
  90.         dataSource.setConnectionProperties(connectionProperties);
  91.         return dataSource;
  92.     }
  93.  
  94.     @Bean(name = "orderTransactionManager")
  95.     public DataSourceTransactionManager orderTransactionManager() {
  96.         return new DataSourceTransactionManager(orderDataSource());
  97.     }
  98.  
  99.     @Bean(name = "orderSqlSessionFactory")
  100.     public SqlSessionFactory orderSqlSessionFactory(@Qualifier("orderDataSource") DataSource orderDataSource)
  101.             throws Exception {
  102.         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
  103.         sessionFactory.setDataSource(orderDataSource);
  104.         sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
  105.                 .getResources(OrderDataSourceConfig.MAPPER_LOCATION));
  106.         sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(OrderDataSourceConfig.MAPPER_LOCATION));
  107.         return sessionFactory.getObject();
  108.     }
  109. }

五、书写mapper  and  xml

 com.duoduo.mybatis.mapper.user.UserMapper.java

  1. package com.duoduo.mybatis.mapper.user;
  2.  
  3. import com.duoduo.mybatis.entity.User;
  4. import org.springframework.stereotype.Repository;
  5.  
  6. /***
  7.  * @date: 2022/7/1 
  8.  * @author: 微信公众号：深入技术架构
  9.  * @description: TODO
  10.  */
  11.  
  12. @Repository
  13. public interface UserMapper {
  14.  
  15.     User findUser(int id);
  16. }

 com.duoduo.mybatis.mapper.order.OrderMapper.java

  1. package com.duoduo.mybatis.mapper.order;
  2.  
  3. import com.duoduo.mybatis.entity.Order;
  4. import org.springframework.stereotype.Repository;
  5.  
  6. /***
  7.  * @date: 2022/7/1 
  8.  * @author: 微信公众号：深入技术架构
  9.  * @description: TODO
  10.  */
  11. @Repository
  12. public interface OrderMapper {
  13.     Order findOrder(int id);
  14. }

resource/mapper/user/UserMapper.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 namespace="com.duoduo.mybatis.mapper.user.UserMapper">
  4.  
  5.     <resultMap id="BaseResultMap" type="com.duoduo.mybatis.entity.User">
  6.         <result column="id" jdbcType="INTEGER" property="id" />
  7.         <result column="userName" jdbcType="VARCHAR" property="userName" />
  8.         <result column="passWord" jdbcType="VARCHAR" property="passWord" />
  9.         <result column="realName" jdbcType="VARCHAR" property="realName" />
  10.     </resultMap>
  11.  
  12.  
  13.     <select id="findUser" resultType="com.duoduo.mybatis.entity.User">
  14.         select * from user where id = #{id}
  15.     </select>
  16.  
  17. </mapper>

resource/mapper/order/OrderMapper.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 namespace="com.duoduo.mybatis.mapper.order.OrderMapper">
  4.  
  5.     <resultMap id="BaseResultMap" type="com.duoduo.mybatis.entity.Order">
  6.         <result column="orderId" jdbcType="INTEGER" property="orderId" />
  7.         <result column="orderName" jdbcType="VARCHAR" property="orderName" />
  8.     </resultMap>
  9.  
  10.     <select id="findOrder" resultType="com.duoduo.mybatis.entity.Order">
  11.         select * from `order` where orderId = #{id}
  12.     </select>
  13.  
  14.  
  15.  </mapper>

六、书写service

com.duoduo.mybatis.service.UserService.java
  1. package com.duoduo.mybatis.service;
  2.  
  3. import com.duoduo.mybatis.entity.User;
  4. import com.duoduo.mybatis.mapper.user.UserMapper;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Service;
  7.  
  8. /***
  9.  * @date: 2022/7/1 
  10.  * @author: fenghaikuan
  11.  * @description: TODO
  12.  */
  13.  
  14. @Service
  15. public class UserService {
  16.     @Autowired
  17.     UserMapper userMapper;
  18.     public User findUser(int id){
  19.         return userMapper.findUser(id);
  20.     }
  21. }
com.duoduo.mybatis.service.OrderService.java
  1. package com.duoduo.mybatis.service;
  2.  
  3.  
  4. import com.duoduo.mybatis.entity.Order;
  5. import com.duoduo.mybatis.mapper.order.OrderMapper;
  6. import org.apache.ibatis.annotations.Mapper;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.stereotype.Service;
  9.  
  10. /***
  11.  * @date: 2022/7/1 
  12.  * @author: fenghaikuan
  13.  * @description: TODO
  14.  */
  15. @Service
  16. public class OrderService {
  17.     @Autowired
  18.     OrderMapper orderMapper;
  19.     public Order findOrder(int id){
  20.         return orderMapper.findOrder(id);
  21.     }
  22. }

七、书写controller

com.duoduo.mybatis.controller.UserController.java
  1. package com.duoduo.mybatis.controller;
  2.  
  3. import com.duoduo.mybatis.service.UserService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.web.bind.annotation.PathVariable;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  8.  
  9. /***
  10.  * @date: 2022/7/1 
  11.  * @author: fenghaikuan
  12.  * @description: TODO
  13.  */
  14. @RestController
  15. public class UserController {
  16.  
  17.     @Autowired
  18.     private UserService userService;
  19.  
  20.     @RequestMapping("/getUser/{id}")
  21.     public String getUser(@PathVariable int id){
  22.         return userService.findUser(id).toString();
  23.     }
  24. }

com.duoduo.mybatis.controller.OrderController.java

  1. package com.duoduo.mybatis.controller;
  2.  
  3. import com.duoduo.mybatis.service.OrderService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.web.bind.annotation.PathVariable;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  8.  
  9. /***
  10.  * @date: 2022/7/1 
  11.  * @author: fenghaikuan
  12.  * @description: TODO
  13.  */
  14. @RestController
  15. public class OrderController {
  16.     @Autowired
  17.     private OrderService orderService;
  18.  
  19.     @RequestMapping("getOrder/{id}")
  20.     public String getOrder(@PathVariable int id){
  21.         return orderService.findOrder(id).toString();
  22.     }
  23. }

八、Mysql 数据库文件

  1. user数据库执行：
  2.  
  3. CREATE TABLE `user` (
  4.   `id` int NOT NULL AUTO_INCREMENT,
  5.   `userName` varchar(32) NOT NULL,
  6.   `passWord` varchar(50) NOT NULL,
  7.   `realName` varchar(32) DEFAULT NULL,
  8.   PRIMARY KEY (`id`)
  9. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb3;
  10. INSERT INTO `user` VALUES (1, '张三', 'password', '小张');
  11.  
  12. order数据库执行：
  13.  
  14. CREATE TABLE `order` (
  15.   `orderId` int NOT NULL AUTO_INCREMENT,
  16.   `orderName` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL,
  17.   PRIMARY KEY (`orderId`) USING BTREE
  18. ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb3;
  19. INSERT INTO `order` VALUES (1, '订单名称');

九、测试

http://localhost:8080/getUser/1

http://localhost:8080/getOrder/1

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/article/detail/46252
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号