• springboot多数据源配置-通过SqlSessionFactory指定的数据源来操作指定目录的XML文件的方式

    前言：

    本文使用application或yml+配置类的方式，进行多数据源配置，与传统的xml方式相比，原理一致，但该方式更简便，上手难度低，避免的繁琐的xml配置，企业级开发一般使用该方式

    springboot传统的xml方式配置多数据源_链接

    以MySQL和Oracle两个数据库为例

    1、准备工作

    1.1、项目中使用的基本清单

    • springboot 2.3.7.RELEASE
    • MySQL 5.7.38
    • Oracle 19
    • mybatis-plus

    1.2、两种数据库分别新建两个测试表

    建表如下：

    1.2.1、MySQL建表及初始化数据语句

    1. CREATE TABLE `user`  (
    2.   `id` bigint(20) NOT NULL AUTO_INCREMENT,
    3.   `name` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
    4.   `age` int(11) NULL DEFAULT NULL,
    5.   PRIMARY KEY (`id`) USING BTREE
    6. ) ENGINE = InnoDB AUTO_INCREMENT = 8 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;
    7.  
    8.  
    9. INSERT INTO `user` VALUES (1, '张三', 18);
    10. INSERT INTO `user` VALUES (2, '李四', 19);
    11. INSERT INTO `user` VALUES (3, '王五', 20);
    12. INSERT INTO `user` VALUES (4, '赵六', 19);
    13. INSERT INTO `user` VALUES (5, '老七', 17);
    14. INSERT INTO `user` VALUES (6, '芈八子', 18);
    15. INSERT INTO `user` VALUES (7, '久久', 99);

    1.2.2、Oracle建表及初始化数据语句

    1. --Oracle测试表
    2. CREATE TABLE city (
    3.   id number(10)   not null,
    4.   name varchar2(40),
    5.   parent varchar2(40)
    6. );
    7.  
    8. insert into city(id,name,parent) values(1,'广州','广东');
    9. insert into city(id,name,parent) values(1,'深圳','广东');
    10. insert into city(id,name,parent) values(1,'厦门','福建');
    11. insert into city(id,name,parent) values(1,'长沙','湖南');
    12. commit;

    1.3、数据库基本信息如下

    数据库类型数据库名称账号密码
    MySQLdemorootroot
    Oracledemo2root123456

    2、搭建springboot项目

    这里我就略过了，我使用的版本为2.3.7.RELEASE

    这里附上项目所需的maven依赖，如下（注意Druid与mybatis的版本）：

    1. <dependency>
    2.     <groupId>org.springframework.bootgroupId>
    3.     <artifactId>spring-boot-starter-webartifactId>
    4. dependency>
    5. <dependency>
    6.     <groupId>com.baomidougroupId>
    7.     <artifactId>mybatis-plus-boot-starterartifactId>
    8.     <version>3.3.0version>
    9. dependency>
    11. <dependency>
    12.     <groupId>com.alibabagroupId>
    13.     <artifactId>druidartifactId>
    14.     <version>1.1.21version>
    15. dependency>
    16. <dependency>
    17.     <groupId>com.alibabagroupId>
    18.     <artifactId>fastjsonartifactId>
    19.     <version>1.2.72version>
    20. dependency>
    21. <dependency>
    22.     <groupId>com.google.code.gsongroupId>
    23.     <artifactId>gsonartifactId>
    24.     <version>2.8.5version>
    25. dependency>
    26. <dependency>
    27.     <groupId>org.apache.commonsgroupId>
    28.     <artifactId>commons-lang3artifactId>
    29.     <version>3.1version>
    30. dependency>
    32. <dependency>
    33.     <groupId>mysqlgroupId>
    34.     <artifactId>mysql-connector-javaartifactId>
    35.     <version>5.1.48version>
    36.     <scope>runtimescope>
    37. dependency>
    39. <dependency>
    40.     <groupId>com.oraclegroupId>
    41.     <artifactId>ojdbc6artifactId>
    42.     <version>11.2.0.4.0version>
    43.     <scope>runtimescope>
    44. dependency>
    45. <dependency>
    46.     <groupId>org.projectlombokgroupId>
    47.     <artifactId>lombokartifactId>
    48.     <optional>trueoptional>
    49. dependency>
    50. <dependency>
    51.     <groupId>org.springframework.bootgroupId>
    52.     <artifactId>spring-boot-starter-testartifactId>
    53.     <scope>testscope>
    54.     <exclusions>
    55.         <exclusion>
    56.             <groupId>org.junit.vintagegroupId>
    57.             <artifactId>junit-vintage-engineartifactId>
    58.         exclusion>
    59.     exclusions>
    60. dependency>

    3、配置开始

    3.1、配置两个数据源的链接信息

    在resource目录下，新建application.yml文件，并配置两个数据源的链接信息：

    如下：

    1. spring:
    2.   datasource:
    3.     #使用Druid数据源连接池
    4.     type: com.alibaba.druid.pool.DruidDataSource
    5.     #数据源01的连接信息
    6.     db1:
    7.      #存在多个 url时，必须使用jdbc-url来定义，否则连接不到数据库
    8.      jdbc-url: jdbc:mysql://127.0.0.1:3306/demo
    9.      username: root
    10.      password: root
    11.      driver-class-name: com.mysql.jdbc.Driver
    12.     #数据源02的连接信息
    13.     db2:
    14.      jdbc-url: jdbc:oracle:thin:@127.0.0.1:1521:salescdh
    15.      username: root
    16.      password: 123456
    17.      driver-class-name: oracle.jdbc.OracleDriver

    3.2、生成配置类

    在与controller同层中，新建一个包，存放两个数据源对应的配置类

    如下：

     内容如下：


    3.2.1、DataSource01配置类：

    1. package com.shuizhu.config;
    2.  
    3. import org.apache.ibatis.session.SqlSessionFactory;
    4. import org.mybatis.spring.SqlSessionFactoryBean;
    5. import org.mybatis.spring.annotation.MapperScan;
    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.context.annotation.Primary;
    12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    13.  
    14. import javax.sql.DataSource;
    15.  
    16. /**
    17.  * 数据源01的配置类
    18.  *
    19.  * @author 睡竹
    20.  * @date 2022/9/19
    21.  */
    22. @Configuration
    23. @MapperScan(basePackages = "com.shuizhu.dao.db1", sqlSessionFactoryRef = "db1SqlSessionFactory")
    24. public class DataSource01 {
    25.     @Primary
    26.     @Bean(name = "db1DataSource")
    27.     @ConfigurationProperties("spring.datasource.db1")
    28.     public DataSource db1DataSource() {
    29.         return DataSourceBuilder.create().build();
    30.     }
    31.  
    32.     @Bean(name = "db1SqlSessionFactory")
    33.     public SqlSessionFactory sqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
    34.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    35.         bean.setDataSource(dataSource);
    36.         //bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResource("classpath:mapper/db1/Demo.xml"));
    37.         PathMatchingResourcePatternResolver resource = new PathMatchingResourcePatternResolver();
    38.         bean.setMapperLocations(resource.getResources("classpath:mapper/db1/*.xml"));
    39.         return bean.getObject();
    40.     }
    41. }

    3.2.2、DataSource02配置类：

    1. package com.shuizhu.config;
    2.  
    3. import org.apache.ibatis.session.SqlSessionFactory;
    4. import org.mybatis.spring.SqlSessionFactoryBean;
    5. import org.mybatis.spring.annotation.MapperScan;
    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.context.annotation.Primary;
    12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    13.  
    14. import javax.sql.DataSource;
    15.  
    16. /**
    17.  * 数据源02的配置类
    18.  *
    19.  * @author 睡竹
    20.  * @date 2022/9/19
    21.  */
    22. @Configuration
    23. @MapperScan(basePackages = "com.shuizhu.dao.db2", sqlSessionFactoryRef = "db2SqlSessionFactory")
    24. public class DataSource02 {
    25.     @Primary
    26.     @Bean(name = "db2DataSource")
    27.     @ConfigurationProperties("spring.datasource.db2")
    28.     public DataSource db2DataSource() {
    29.         return DataSourceBuilder.create().build();
    30.     }
    31.  
    32.     @Bean(name = "db2SqlSessionFactory")
    33.     public SqlSessionFactory sqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws Exception {
    34.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    35.         bean.setDataSource(dataSource);
    36.         bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/db2/*.xml"));
    37.         return bean.getObject();
    38.     }
    39. }

    3.3、生成xml映射文件

    如图所示：

    db1文件夹表示数据源1的映射xml文件存放地；

    db2文件夹表示数据源2的映射xml文件存放地。

    分别在文件夹下新建xml映射文件：

     手写测试的SQL代码：

    Demo.xml：

    1. "1.0" encoding="UTF-8"?>
    2. mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    3. <mapper namespace="com.shuizhu.dao.db1.DemoDao">
    4.     <select id="getUsers" resultType="com.shuizhu.domain.User">
    5.         select id,name,age from user
    6.     select>
    7. mapper>

    Demo2.xml：

    1. "1.0" encoding="UTF-8"?>
    2. mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    3. <mapper namespace="com.shuizhu.dao.db2.DemoOracleDao">
    4.     <select id="getCitys" resultType="com.shuizhu.domain.City">
    5.         select id,name,parent from city
    6.     select>
    7. mapper>

    3.4、生成DAO接口层代码

    如图所示：

    测试代码如下：

    DemoDao代码：

    1. package com.shuizhu.dao.db1;
    2.  
    3. import com.shuizhu.domain.User;
    4. import org.springframework.stereotype.Repository;
    5.  
    6. import java.util.List;
    7.  
    8. /**
    9.  * MySQL数据源的dao
    10.  * @author 睡竹
    11.  * @date 2022/9/15
    12.  */
    13. @Repository
    14. public interface DemoDao {
    15.     //@Select("select id,name,age from user")
    16.     List getUsers();
    17. }

     DemoOracleDao代码：

    1. package com.shuizhu.dao.db2;
    2.  
    3. import com.shuizhu.domain.City;
    4. import org.springframework.stereotype.Repository;
    5.  
    6. import java.util.List;
    7.  
    8. /**
    9.  * Oracle数据源的dao
    10.  * @author 睡竹
    11.  * @date 2022/9/15
    12.  */
    13. @Repository
    14. public interface DemoOracleDao {
    15.     List getCitys();
    16. }

    3.5、在启动类上，添加注解属性

    如图所示：

    4、测试

     4.1、Controller层：

    1. package com.shuizhu.controller;
    2.  
    3. import com.shuizhu.domain.City;
    4. import com.shuizhu.domain.User;
    5. import com.shuizhu.service.IDemoService;
    6. import org.springframework.web.bind.annotation.RequestMapping;
    7. import org.springframework.web.bind.annotation.RestController;
    8.  
    9. import javax.annotation.Resource;
    10. import java.util.List;
    11.  
    12. /**
    13.  * @author 睡竹
    14.  * @date 2022/9/15
    15.  */
    16. @RestController
    17. public class DemoController {
    18.  
    19.     @Resource
    20.     private IDemoService service;
    21.  
    22.     /**
    23.      * 测试MySQL数据源是否生效
    24.      * @return
    25.      */
    26.     @RequestMapping("testMySQL")
    27.     public Object testMySQL(){
    28.         List users = service.getUsers();
    29.         return users;
    30.     }
    31.  
    32.     /**
    33.      * 测试Oracle数据源是否生效
    34.      * @return
    35.      */
    36.     @RequestMapping("testOracle")
    37.     public Object testOracle(){
    38.         List users = service.getCitys();
    39.         return users;
    40.     }
    41. }

    4.2、Service接口层：

    1. package com.shuizhu.service;
    2.  
    3. import com.shuizhu.domain.City;
    4. import com.shuizhu.domain.User;
    5.  
    6. import java.util.List;
    7.  
    8. /**
    9.  * @author 睡竹
    10.  * @date 2022/9/15
    11.  */
    12. public interface IDemoService {
    13.     List getUsers();
    14.     List getCitys();
    15. }

    4.3、Service接口实现层：

    1. package com.shuizhu.service.impl;
    2.  
    3. import com.shuizhu.dao.mysql.DemoDao;
    4. import com.shuizhu.dao.oracle.DemoOracleDao;
    5. import com.shuizhu.domain.City;
    6. import com.shuizhu.domain.User;
    7. import com.shuizhu.service.IDemoService;
    8. import lombok.RequiredArgsConstructor;
    9. import org.springframework.stereotype.Service;
    10.  
    11. import java.util.List;
    12.  
    13. /**
    14.  * 偷懒了，直接写入到同一个service
    15.  * @author 睡竹
    16.  * @date 2022/9/15
    17.  */
    18. @Service
    19. @RequiredArgsConstructor
    20. public class DemoService implements IDemoService {
    21.  
    22.     //MySQL的Dao构造器注入
    23.     final DemoDao dao1;
    24.     //Oracle的Dao构造器注入
    25.     final DemoOracleDao dao2;
    26.  
    27.     @Override
    28.     public List getUsers() {
    29.         List users = dao1.getUsers();
    30.         return users;
    31.     }
    32.  
    33.     @Override
    34.     public List getCitys() {
    35.         List citys = dao2.getCitys();
    36.         return citys;
    37.     }
    38. }

    4.4、Domain实体类层：

    User实体类：

    1. package com.shuizhu.domain;
    2.  
    3. import lombok.Data;
    4. import java.io.Serializable;
    5. /**
    6.  * MySQL库user表实体类
    7.  * @author 睡竹
    8.  * @date 2022/9/15
    9.  */
    10. @Data
    11. public class User implements Serializable {
    12.     private static final long serialVersionUID = 1L;
    13.  
    14.     private Integer id;
    15.     private String name;
    16.     private Integer age;
    17. }

    City实体类：

    1. package com.shuizhu.domain;
    2.  
    3. import lombok.Data;
    4. import java.io.Serializable;
    5. /**
    6.  * Oracle库city表实体类
    7.  * @author 睡竹
    8.  * @date 2022/9/16
    9.  */
    10. @Data
    11. public class City implements Serializable {
    12.     private static final long serialVersionUID = 1L;
    13.     private Integer id;
    14.     private String name;
    15.     private String parent;
    16. }

    至此，测试流程及代码都已实现

    附上整个springboot项目完整目录结构如：

     5、使用api工具测试接口

    使用api工具对接口进行测试，检验数据源是否生效

    5.1、测试MySQL数据的接口

    请求路径：http://127.0.0.1:9080/testMySQL

    5.2、 测试Oracle数据的接口

    请求路径：http://127.0.0.1:9080/testOracle

    测试成功，多数据源配置生效 

    案例代码：shuizhu-multiple-ds: 多数据源配置-通过SqlSessionFactory指定的数据源来操作指定目录的XML文件的方式https://gitee.com/ct668/shuizhu-multiple-ds

  • 相关阅读:
    [附源码]计算机毕业设计在线教育系统Springboot程序
    kafka入门教程，介绍全面
    【broadcast-service】一个轻量级Python发布订阅者框架
    illustrator插件-画板功能开发-全部页面加矩形-垂直两分-水平两分-AI插件
    基于三维GIS系统的智慧水库管理应用
    【踩坑日记】vue项目ie打不开报错SCRIPT1006:缺少‘)‘
    深入理解Redis集群模式、协议、元数据维护方式
    Vmware下的虚拟机NAT连接后仍然木有网络
    mv-lcd初始化
    PHP 数组学习资料
  • 原文地址：https://blog.csdn.net/weixin_42675423/article/details/126932977