链接：https://pan.baidu.com/s/1COUezkMwPMZdNQPAskXbCg 

提取码：gsh5 

 

SpringBoot整合mybatis-plus实现多数据源的动态切换且支持分页查询

1、引入Maven依赖

2、添加application.properties配置文件

3、添加DataSourceConfig配置类

<dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus</artifactId> <version>3.2.0</version> </dependency> <dependency> <groupId>org.postgresql</groupId> <artifactId>postgresql</artifactId> <version>42.2.16</version> </dependency> <dependency> <groupId>com.oracle</groupId> <artifactId>ojdbc6</artifactId> <version>11.2.0.3</version> </dependency> <dependency> <groupId>com.github.pagehelper</groupId> <artifactId>pagehelper</artifactId> <version>5.1.6</version> </dependency> #mybatis-plus配置 mybatis-plus.mapper-locations=classpath:mapper/*Mapper.xml mybatis-plus.type-aliases-package=com.example.domain #多数据源的配置 # master DB properties: spring.datasource.url=jdbc:postgresql://localhost:5432/postgres spring.datasource.username=postgres spring.datasource.password=postgres spring.datasource.driver-class-name=org.postgresql.Driver #slave DB properties spring.datasource.master.url=jdbc:oracle:thin:@127.0.0.1:1521/orcl spring.datasource.master.username=system spring.datasource.master.password=system spring.datasource.master.driver-class-name=oracle.jdbc.OracleDriver

import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor; import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean; import com.github.pagehelper.PageInterceptor; import com.hikvision.insurance.datasource.DynamicDataSource; import com.zaxxer.hikari.HikariDataSource; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import javax.sql.DataSource; import java.util.HashMap; import java.util.Map; @Configuration @MapperScan(basePackages = {"com.example.mapper"}, sqlSessionFactoryRef = "sqlSessionFactory") public class DataSourceConfig { @Value("${spring.datasource.url}") private String defaultDBUrl; @Value("${spring.datasource.username}") private String defaultDBUser; @Value("${spring.datasource.password}") private String defaultDBPassword; @Value("${spring.datasource.driver-class-name}") private String defaultDBDreiverName; @Value("${spring.datasource.master.url}") private String masterDBUrl; @Value("${spring.datasource.master.username}") private String masterDBUser; @Value("${spring.datasource.master.password}") private String masterDBPassword; @Value("${spring.datasource.master.driver-class-name}") private String masterDBDreiverName; @Bean public DynamicDataSource dynamicDataSource() { DynamicDataSource dynamicDataSource = DynamicDataSource.getInstance(); HikariDataSource defaultDataSource = new HikariDataSource(); defaultDataSource.setJdbcUrl(defaultDBUrl); defaultDataSource.setUsername(defaultDBUser); defaultDataSource.setPassword(defaultDBPassword); defaultDataSource.setDriverClassName(defaultDBDreiverName); HikariDataSource masterDataSource = new HikariDataSource(); masterDataSource.setJdbcUrl(masterDBUrl); masterDataSource.setUsername(masterDBUser); masterDataSource.setPassword(masterDBPassword); masterDataSource.setDriverClassName(masterDBDreiverName); Map<Object,Object> map = new HashMap<>(); map.put("default", defaultDataSource); map.put("master", masterDataSource); dynamicDataSource.setTargetDataSources(map);

4、添加DynamicDataSource配置类

dynamicDataSource.setDefaultTargetDataSource(defaultDataSource); return dynamicDataSource; } //mybatis-plus分页插件 @Bean public PaginationInterceptor paginationInterceptor() { return new PaginationInterceptor(); } //pagehelper分页插件 @Bean public PageInterceptor pageInterceptor(){ return new PageInterceptor(); }@Bean public SqlSessionFactory sqlSessionFactory(DataSource dynamicDataSource) throws Exception { MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean(); bean.setDataSource(dynamicDataSource); bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*Mapper.xml ")); bean.setPlugins(paginationInterceptor(),pageInterceptor()); return bean.getObject(); } }