• Springboot项目的多数据源配置

    spring boot项目配置多个数据源很常见！

    话不多说，上代码。

    首先先在system账号下创建了一个用户test1,并授予权限

    1. create user test1 identified by 123456;
    2. grant connect,resource to test1;

    接下来登录test1用户，创建一个表student

    1. create table student
    2. (
    3.   id number primary key,
    4.   name varchar2(30),
    5.   address varchar2(100)
    6. );

    项目目录如下：

    修改之前的配置文件

    1. spring:
    2.   datasource:
    3.     driver-class-name: oracle.jdbc.driver.OracleDriver
    4.     url: jdbc:oracle:thin:@localhost:1521:ORCL
    5.     username: test
    6.     password: 123456

    调整后多个数据源后的配置

    1. spring:
    2.   datasource:
    3.     main:
    4.       driver-class-name: oracle.jdbc.driver.OracleDriver
    5.       jdbc-url: jdbc:oracle:thin:@localhost:1521:ORCL
    6.       username: test
    7.       password: 123456
    8.     ext:
    9.       driver-class-name: oracle.jdbc.driver.OracleDriver
    10.       jdbc-url: jdbc:oracle:thin:@localhost:1521:ORCL
    11.       username: test1
    12.       password: 123456

    主数据源配置：

    1. import org.springframework.boot.context.properties.ConfigurationProperties;
    2. import org.springframework.boot.jdbc.DataSourceBuilder;
    3. import org.springframework.context.annotation.Bean;
    4. import org.springframework.context.annotation.Configuration;
    5. import org.springframework.context.annotation.Primary;
    6. import javax.sql.DataSource;
    7.  
    8. /**
    9.  * 主数据源配置
    10.  */
    11. @Configuration
    12. public class MainDataSource {
    13.  
    14.     @Bean(name = "mainDataSources")
    15.     @Primary
    16.     @ConfigurationProperties(prefix = "spring.datasource.main")
    17.     public DataSource mainDataSource() {
    18.         return DataSourceBuilder.create().build();
    19.     }
    20. }

    主数据源的mybatis配置

    1. import org.apache.ibatis.session.SqlSessionFactory;
    2. import org.mybatis.spring.SqlSessionFactoryBean;
    3. import org.mybatis.spring.SqlSessionTemplate;
    4. import org.mybatis.spring.annotation.MapperScan;
    5. import org.springframework.beans.factory.annotation.Autowired;
    6. import org.springframework.beans.factory.annotation.Qualifier;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Configuration;
    9. import org.springframework.context.annotation.Primary;
    10. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    11. import org.springframework.transaction.PlatformTransactionManager;
    12. import javax.sql.DataSource;
    13.  
    14. /**
    15.  * 主数据源的mybatis配置
    16.  */
    17. @Configuration
    18. @MapperScan(basePackages = "com.example.demo.mapper", sqlSessionFactoryRef = "mainSqlSessionFactory", sqlSessionTemplateRef = "mainSqlSessionTemplate")
    19. public class MainMybatisConfig {
    20.  
    21.     @Autowired
    22.     private DataSource mainDataSources;
    23.  
    24.     @Bean(name = "mainSqlSessionFactory")
    25.     @Primary
    26.     public SqlSessionFactory mainSqlSessionFactory() throws Exception {
    27.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    28.         bean.setDataSource(mainDataSources);
    29. //        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));
    30.         return bean.getObject();
    31.     }
    32.  
    33.     //配置声明式事务管理器
    34.     @Bean(name = "mainTransactionManager")
    35.     @Primary
    36.     public PlatformTransactionManager mainTransactionManager() {
    37.         return new DataSourceTransactionManager(mainDataSources);
    38.     }
    39.  
    40.     @Bean(name = "mainSqlSessionTemplate")
    41.     @Primary
    42.     public SqlSessionTemplate mainSqlSessionTemplate(
    43.             @Qualifier("mainSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    44.         return new SqlSessionTemplate(sqlSessionFactory);
    45.     }
    46. }

    副数据源配置：

    1. import org.springframework.beans.factory.annotation.Qualifier;
    2. import org.springframework.boot.context.properties.ConfigurationProperties;
    3. import org.springframework.boot.jdbc.DataSourceBuilder;
    4. import org.springframework.context.annotation.Bean;
    5. import org.springframework.context.annotation.Configuration;
    6. import javax.sql.DataSource;
    7.  
    8. /**
    9.  * 副数据源配置
    10.  */
    11. @Configuration
    12. public class ExtDataSource {
    13.  
    14.     @Bean(name = "extDataSources")
    15.     @Qualifier(value = "extDataSources")
    16.     @ConfigurationProperties(prefix = "spring.datasource.ext")
    17.     public DataSource extDataSource() {
    18.         return DataSourceBuilder.create().build();
    19.     }
    20. }

    副数据源的mybatis配置：

    1. import org.apache.ibatis.session.SqlSessionFactory;
    2. import org.mybatis.spring.SqlSessionFactoryBean;
    3. import org.mybatis.spring.SqlSessionTemplate;
    4. import org.mybatis.spring.annotation.MapperScan;
    5. import org.springframework.beans.factory.annotation.Autowired;
    6. import org.springframework.beans.factory.annotation.Qualifier;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Configuration;
    9. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    10. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    11. import org.springframework.transaction.PlatformTransactionManager;
    12. import javax.sql.DataSource;
    13.  
    14.  
    15. /**
    16.  * 副数据源的mybatis配置
    17.  */
    18. @Configuration
    19. @MapperScan(basePackages = "com.example.demo.extMapper", sqlSessionFactoryRef = "extSqlSessionFactory", sqlSessionTemplateRef = "extSqlSessionTemplate")
    20. public class ExtMybatisConfig {
    21.  
    22.     @Autowired
    23.     @Qualifier(value = "extDataSources")
    24.     private DataSource extDataSource;
    25.  
    26.     @Bean(name = "extSqlSessionFactory")
    27.     public SqlSessionFactory extSqlSessionFactory() throws Exception {
    28.         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    29.         bean.setDataSource(extDataSource);
    30. //        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:extMapper/*.xml"));
    31.         return bean.getObject();
    32.     }
    33.  
    34.     //配置声明式事务管理器
    35.     @Bean(name = "extTransactionManager")
    36.     public PlatformTransactionManager extTransactionManager() {
    37.         return new DataSourceTransactionManager(extDataSource);
    38.     }
    39.  
    40.     @Bean(name = "extSqlSessionTemplate")
    41.     public SqlSessionTemplate extSqlSessionTemplate(
    42.             @Qualifier("extSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    43.         return new SqlSessionTemplate(sqlSessionFactory);
    44.     }
    45. }

    StudentMapper类

    1. import com.example.demo.entity.Student;
    2. import org.apache.ibatis.annotations.Mapper;
    3. import java.util.List;
    4.  
    5. @Mapper
    6. public interface StudentMapper {
    7.  
    8.     List queryList();
    9. }

    StudentMapper.xml文件

    1. "1.0" encoding="utf-8"?>
    2. mapper
    3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    5. <mapper namespace="com.example.demo.extMapper.StudentMapper">
    6.     <resultMap type="com.example.demo.entity.Student" id="Result">
    7.         <result property="id" 			column="id"/>
    8.         <result property="name" 		column="name"/>
    9.         <result property="address"		column="address"/>
    10.     resultMap>
    11.     <select id="queryList" resultMap="Result">
    12.         select  id,name,address  from  student
    13.     select>
    14. mapper>

    UserMapper文件

    1. import com.example.demo.entity.User;
    2. import java.util.List;
    3. import org.apache.ibatis.annotations.Mapper;
    4.  
    5. @Mapper
    6. public interface UserMapper {
    7.  
    8.     List queryList();
    9. }

    UserMapper.xml

    1. "1.0" encoding="utf-8"?>
    2. mapper
    3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    5. <mapper namespace="com.example.demo.mapper.UserMapper">
    6.     <resultMap type="com.example.demo.entity.User" id="userResult">
    7.         <result property="id" 			column="id"/>
    8.         <result property="name" 		column="name"/>
    9.         <result property="age"		column="age"/>
    10.     resultMap>
    11.  
    12.     <select id="queryList" resultMap="userResult">
    13.         select  id,name,age  from  "USER"
    14.     select>
    15. mapper>

    controller类：

    1. import com.example.demo.entity.Student;
    2. import com.example.demo.entity.User;
    3. import com.example.demo.extMapper.StudentMapper;
    4. import com.example.demo.mapper.UserMapper;
    5. import org.slf4j.Logger;
    6. import org.slf4j.LoggerFactory;
    7. import org.springframework.beans.factory.annotation.Autowired;
    8. import org.springframework.web.bind.annotation.PostMapping;
    9. import org.springframework.web.bind.annotation.RequestBody;
    10. import org.springframework.web.bind.annotation.RequestMapping;
    11. import org.springframework.web.bind.annotation.RestController;
    12.  
    13. import java.util.List;
    14.  
    15. @RestController
    16. @RequestMapping("/user")
    17. public class UserController {
    18.  
    19.     private static final Logger logger = LoggerFactory.getLogger(UserController.class);
    20.  
    21.     @Autowired
    22.     private UserMapper userMapper;
    23.  
    24.     @Autowired
    25.     private StudentMapper studentMapper;
    26.  
    27.     @PostMapping("/queryUserList")
    28.     public List queryUserList() {
    29.         return userMapper.queryList();
    30.     }
    31.  
    32.     @PostMapping("/queryStudentList")
    33.     public List queryStudentList() {
    34.         return studentMapper.queryList();
    35.     }
    36.  
    37. }

    此时查询结果：

    副数据源：

        主数据源：

     若将副数据源的xml文件放到resources目录下

     此时 需要将副数据源的mybatis配置修改下：

  • 相关阅读:
    架构学习——Redis内存数据库学习要点
    LeetCode-解数独（C++）
    2023.10.17
    深入解析Linux Bridge：原理、架构、操作与持久化配置
    logback1.3.x配置详解与实践
    第十八课、Qt 下载、安装与配置
    Jmeter性能测试指南
    Docker常用命令
    [C/C++]数据结构 深入挖掘环形链表问题
    数据库SQL语句：给表添加外键的四种方式
  • 原文地址：https://blog.csdn.net/qq_37342720/article/details/134266679