1. 程式人生 > >SpringBoot整合Mybatis動態多資料來源後,MybatisPlus的IPage失效的問題解決方案

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);

    }

總結

至此我們標題探討的問題就已經解決了,同時給大家提供了動態資料來源的解決方案