脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → MybatisPlus IPage失效

MybatisPlus的IPage失效的问题解决方案

 更新时间：2021年01月19日 14:24:17   作者：经典鸡翅  
这篇文章主要介绍了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);

  }

总结

至此我们标题探讨的问题就已经解决了，同时给大家提供了动态数据源的解决方案。更多相关MybatisPlus IPage失效内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • 使用SpringBoot整合Activiti6工作流的操作方法

    使用SpringBoot整合Activiti6工作流的操作方法

    这篇文章主要介绍了使用SpringBoot整合Activiti6工作流，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-07-07
  • 用Java实现一个简单的布隆过滤器

    用Java实现一个简单的布隆过滤器

    这篇文章主要介绍了用Java实现一个简单的布隆过滤器,布隆过滤器是1970年由布隆提出的,它实际上是一个很长的二进制向量和一系列随机映射函数,布隆过滤器可以用于检索一个元素是否在一个集合中,需要的朋友可以参考下
    2023-12-12
  • SpringBoot实现数据源动态切换的最佳姿势

    SpringBoot实现数据源动态切换的最佳姿势

    这篇文章主要为大家详细介绍一下SpringBoot实现数据源动态切换的最佳姿势,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
    2025-03-03
  • java关键字super的骚操作详解

    java关键字super的骚操作详解

    关键字super在Java中用于引用当前类的父类（即超类）的构造方法、访问父类的成员变量和方法,它提供了一种方便的方式来处理继承关系中的父类操作,下面我们就来看看它有哪些骚操作吧
    2023-09-09
  • Spring探秘之如何妙用BeanPostProcessor

    Spring探秘之如何妙用BeanPostProcessor

    BeanPostProcessor也称为Bean后置处理器,它是Spring中定义的接口,在Spring容器的创建过程中会回调BeanPostProcessor中定义的两个方法,这篇文章主要给大家介绍了关于Spring探秘之如何妙用BeanPostProcessor的相关资料,需要的朋友可以参考下
    2022-01-01
  • Java多线程 生产者消费者模型实例详解

    Java多线程 生产者消费者模型实例详解

    这篇文章主要介绍了Java多线程 生产者消费者模型实例详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • Java之next()、nextLine()区别及问题解决

    Java之next()、nextLine()区别及问题解决

    这篇文章主要介绍了Java之next()、nextLine()区别及问题解决,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • Springboot使用切面功能详解

    Springboot使用切面功能详解

    Spring Boot 是一个基于Spring框架的项目,它简化了基于Spring的应用开发,这篇文章主要介绍了 Spring Boot 中的切面功能,需要的可以了解下
    2025-01-01
  • Java使用组合模式实现表示公司组织结构功能示例

    Java使用组合模式实现表示公司组织结构功能示例

    这篇文章主要介绍了Java使用组合模式实现表示公司组织结构功能,简单描述了组合模式的概念、功能并结合实例形式分析了Java使用组合模式实现公司组织结构表示功能具体操作步骤与相关注意事项,需要的朋友可以参考下
    2018-05-05
  • 通过springboot+mybatis+druid配置动态数据源

    通过springboot+mybatis+druid配置动态数据源

    这篇文章主要介绍了通过springboot+mybatis+druid配置动态数据源，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，,需要的朋友可以参考下
    2019-06-06

最新评论