SpringBoot集成Mybatis动态多数据源后，MybatisPlus的IPage失效的问题解决方案

背景

之前做数据抽取的时候，搭了一个mybatis动态数据源切换的架子。方便他们写抽取的代码。今天同事问我，架子里面的mybatisplus的IPage失效了是什么问题。想了一下，应该是写动态数据源的时候，我自定义的mybatis的配置覆盖了已有的配置。于是我让他先把我写的配置进行删除，看是否正常。得到回复，删除后正常。那么到此问题原因找到，接下来的解决方法，只要在配置中增加分页器即可。

解决方案

建立一个分页器的bean配置

@Bean
public PaginationInterceptor paginationInterceptor() {
    return new PaginationInterceptor();
}

我们随便自定义一个类即可，这里主要是将这个类作为一个bean交给spring容器管理。

在sqlSessionFactory中注入

    @Bean(name="sessionFactory")
    public SqlSessionFactory sessionFactory(
            @Qualifier("bigDataDataSource") DataSource bigDataDataSource,
            @Qualifier("branchDataSource") DataSource branchDataSource,
            @Qualifier("basicDataSource") DataSource basicDataSource,
            org.apache.ibatis.session.Configuration config) throws Exception{
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        //构造方法，解决动态数据源循环依赖问题。
        MybatisConfiguration configuration = new MybatisConfiguration();
        configuration.addInterceptor(new PaginationInterceptor());
        sessionFactoryBean.setConfiguration(configuration);
        sessionFactoryBean.setConfiguration(config);
        sessionFactoryBean.setDataSource(this.DataSource(bigDataDataSource,branchDataSource, basicDataSource));
        return sessionFactoryBean.getObject();
    }

文中总结

至此，我们的mybatisplus的分页插件就好使了。下面给大家提供MyBatis多数据源的解决方案。

动态数据源解决方案

数据库配置文件

我们项目使用的是yml形式的配置文件，采用的是hikari的数据库连接池。第一步我们自然是配置多个数据库源头。
我们找到spring的datasource，在下方配置三个数据源。

spring:
  application:
    name: dynamicDatasource
  datasource:
    test1:
      driver-class-name: com.mysql.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/test1?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
      username: root
      password: 123456
    test2:
      driver-class-name: com.mysql.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/test2?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
      username: root
      password: 123456
    test3:
      driver-class-name: com.mysql.jdbc.Driver
      url: jdbc:mysql://127.0.0.1:3306/test3?serverTimezone=GMT%2B8&characterEncoding=utf-8&useSSL=false
      username: root
      password: 123456
    hikari:
      leak-detection-threshold: 2000

定义数据源实体类

我们可以建立个datasourceBean文件夹专门管理数据源的实体类。
我们这里要建立三个实体类。分别对应test1，test2，test3

@Configuration
public class Test1DataSourceBean {

    @Value("${spring.datasource.test1.driver-class-name}")
    private String test1Driver;

    @Value("${spring.datasource.test1.url}")
    private String test1Url;

    @Value("${spring.datasource.test1.username}")
    private String test1Username;

    @Value("${spring.datasource.test1.password}")
    private String test1Password;

    @Bean(name="test1DataSource")
    public DataSource test1DataSource() throws Exception{
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setDriverClassName(test1Driver);
        dataSource.setJdbcUrl(test1Url);
        dataSource.setUsername(test1Username);
        dataSource.setPassword(test1Password);
        return dataSource;
    }
}
@Configuration
public class Test2DataSourceBean {

    @Value("${spring.datasource.test2.driver-class-name}")
    private String test2Driver;

    @Value("${spring.datasource.test2.url}")
    private String test2Url;

    @Value("${spring.datasource.test2.username}")
    private String test2Username;

    @Value("${spring.datasource.test2.password}")
    private String test2Password;

    @Bean(name="test2DataSource")
    public DataSource test2DataSource() throws Exception{
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setDriverClassName(test2Driver);
        dataSource.setJdbcUrl(test2Url);
        dataSource.setUsername(test2Username);
        dataSource.setPassword(test2Password);
        return dataSource;
    }
}
@Configuration
public class Test3DataSourceBean {

    @Value("${spring.datasource.test3.driver-class-name}")
    private String test3Driver;

    @Value("${spring.datasource.test3.url}")
    private String test3Url;

    @Value("${spring.datasource.test3.username}")
    private String test3Username;

    @Value("${spring.datasource.test3.password}")
    private String test3Password;

    @Bean(name="test3DataSource")
    public DataSource test3DataSource() throws Exception{
        HikariDataSource dataSource = new HikariDataSource();
        dataSource.setDriverClassName(test3Driver);
        dataSource.setJdbcUrl(test3Url);
        dataSource.setUsername(test3Username);
        dataSource.setPassword(test3Password);
        return dataSource;
    }
}

定义一个枚举类管理数据源

public enum DatabaseType {

    test1("test1", "test1"),
    test2("test2", "test2"),
    test3("test3","test3");

    private String name;
    private String value;

    DatabaseType(String name, String value){
        this.name = name;
        this.value = value;
    }

    public String getName(){
        return name;
    }

    public String getValue(){
        return value;
    }
}

定义一个线程安全的数据源容器

public class DatabaseContextHolder {

    private static final ThreadLocal<DatabaseType> contextHolder = new ThreadLocal<>();

    public static void setDatabaseType(DatabaseType type){
        contextHolder.set(type);
    }

    public static DatabaseType getDatabaseType(){
        return contextHolder.get();
    }
}

定义动态数据源

public class DynamicDataSource extends AbstractRoutingDataSource{

    protected Object determineCurrentLookupKey() {
        return DatabaseContextHolder.getDatabaseType();
    }
}

mybatis配置类

网上的很多文章配置出来都会产生数据源循环依赖的问题，这里解决了这个问题。

@Configuration
@MapperScan(basePackages="cn.test.jichi", sqlSessionFactoryRef="sessionFactory")
public class MybatisConfig {

    /**
     *  @Description:设置动态数据源
     */
    @Bean(name="dynamicDataSource")
    @Primary
    public DynamicDataSource DataSource(
            @Qualifier("test1DataSource") DataSource test1DataSource,
            @Qualifier("test2DataSource") DataSource test2DataSource,
            @Qualifier("test3DataSource") DataSource test3DataSource){
        Map<Object, Object> targetDataSource = new HashMap<>();
        targetDataSource.put(DatabaseType.test1, test1DataSource);
        targetDataSource.put(DatabaseType.test2, test2DataSource);
        targetDataSource.put(DatabaseType.test3, test3DataSource);
        DynamicDataSource dataSource = new DynamicDataSource();
        dataSource.setTargetDataSources(targetDataSource);
        dataSource.setDefaultTargetDataSource(test1DataSource);
        return dataSource;
    }

    /**
     *  @Description:根据动态数据源创建sessionFactory
     */
    @Bean(name="sessionFactory")
    public SqlSessionFactory sessionFactory(
            @Qualifier("test1DataSource") DataSource test1DataSource,
            @Qualifier("test2DataSource") DataSource test2DataSource,
            @Qualifier("test3DataSource") DataSource test3DataSource) throws Exception{
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        //构造方法，解决动态数据源循环依赖问题。
        sessionFactoryBean.setDataSource(this.DataSource(test1DataSource,test2DataSource, test3DataSource));
        return sessionFactoryBean.getObject();
    }
}

提供一个示例

    public void testDymnaicDatasource(){
        //不切换数据源默认是自己的。
        System.out.println("-----默认数据源");
        DemoEntity totalCount = demoMapper.getTotalCount();
        String nameCount1 = totalCount.getNameCount();
        String ageCount2 = totalCount.getAgeCount();
        System.out.println("nameCount:"+nameCount1);
        System.out.println("ageCount:"+ageCount2);
        //数据源切换为branch
        System.out.println("-----数据源为test2");
        DynamicDataSourceUtils.chooseBranchDataSource();
        Integer nameCount = demoMapper.getNameCount();
        Integer ageCount = demoMapper.getAgeCount();
        System.out.println("nameCount:"+nameCount);
        System.out.println("ageCount:"+ageCount);
        //数据源为basic
        System.out.println("-----数据源为test3");
        DynamicDataSourceUtils.chooseBasicDataSource();
        Integer ageCount1 = demoMapper.getAgeCount();
        System.out.println("ageCount:"+ageCount1);

    }

总结

至此我们标题探讨的问题就已经解决了，同时给大家提供了动态数据源的解决方案。

原文地址：https://www.cnblogs.com/jichi/p/12163777.html

时间： 2024-10-08 08:45:50

SpringBoot集成Mybatis动态多数据源后，MybatisPlus的IPage失效的问题解决方案的相关文章

springboot集成mybatis进行开发

1.首先创建springboot项目 点击:http://start.spring.io/  可以在线创建springboot项目 2.加入mybatis的pom文件 <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.4</version

SpringBoot集成MyBatis的Bean配置方式

SpringBoot集成MyBatis的Bean配置方式 SpringBoot是一款轻量级开发的框架,简化了很多原先的xml文件配置方式,接下来就介绍一下如何不适用XML来配置Mybatis springboot的yml文件 spring: profiles: active: dev application: name: service-fishkk ##MySql datasource: url: jdbc:mysql://47.94.200.0:3306/mybatis?useSSL=fal

springboot 集成mybatis

1:依赖mybaits分页插件 <dependency> <groupId>com.github.pagehelper</groupId> <artifactId>pagehelper-spring-boot-starter</artifactId> <version>1.2.3</version> </dependency> 2:启动类中@MapperScan 扫描接口包 @MapperScan("

SpringBoot集成Mybatis实现多表查询的两种方式(基于xml)

 下面将在用户和账户进行一对一查询的基础上进行介绍SpringBoot集成Mybatis实现多表查询的基于xml的两种方式.   首先我们先创建两个数据库表,分别是user用户表和account账户表     user表:  account表:  然后创建实体类        **第一种通过创建子类的方式查询                             需求:查询所有的用户基础信息以及其所属的账户中的金额     1.创建想要得到多表查询数据的实体类(子类)            

springboot集成mybatis

springboot如何配置web项目请参考前一章,在此基础上集成mybatis. 在pom文件中添加mybatis的依赖: <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.2.0</version> </dependency&

SpringBoot集成MyBatis的分页插件PageHelper

俗话说:好??不吃回头草,但是在这里我建议不管你是好马还是不好马,都来吃吃,带你复习一下分页插件PageHelper. 昨天给各位总结了本人学习springboot整合mybatis第一阶段的一些学习心得和源码,主要就算是敲了一下SpringBoot的门儿,希望能给各位的入门带给一点儿捷径,今天给各位温习一下MyBatis的分页插件PageHelper和SpringBoot的集成,它的使用也非常简单,开发更为高效.因为PageHelper插件是属于MyBatis框架的,所以相信很多哥们儿都已经用

SpringBoot集成MyBatis的分页插件PageHelper(回头草)

俗话说:好??不吃回头草,但是在这里我建议不管你是好马还是不好马,都来吃吃,带你复习一下分页插件PageHelper. 昨天给各位总结了本人学习springboot整合mybatis第一阶段的一些学习心得和源码,主要就算是敲了一下SpringBoot的门儿,希望能给各位的入门带给一点儿捷径,今天给各位温习一下MyBatis的分页插件PageHelper和SpringBoot的集成,它的使用也非常简单,开发更为高效.因为PageHelper插件是属于MyBatis框架的,所以相信很多哥们儿都已经用

springboot集成mybatis环境搭建以及实现快速开发微服务商品模块基本的增删改查!

之前学习了springboot和mybatis3的一些新特性,初步体会了springboot的强大(真的好快,,,,,),最近趁着复习,参考着以前学习的教程,动手写了一个springboot实战的小例子! 一 创建表以及实体 使用简单的五个字段商品表,主键采用UUID字符串,价格使用BigDecimal,本来是想在linux数据库中建立表的,实在是懒不想启动虚拟机(这么简单也觉得没必要),,sql语句如下: create table products( pid varchar(32) not n

SpringBoot+Druid+Mybatis配置多数据源

我们在开发一个项目的时候,可能会遇到需要对多个数据库进行读写的需求,这时候就得在项目中配置多个数据源了.在Java项目的开发中,目前最常用的数据操作框架是 Mybatis,开发框架也都基本用上了SpringBoot.而Druid号称最好的数据库连接池,自然也是被广泛使用. 所以本文将演示一下,SpringBoot+Druid+Mybatis如何去配置多数据源.首先在IDEA中创建一个SpringBoot工程: 选择一些基本的包: 完成创建: pom.xml配置的依赖如下: <dependenci