文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

SpringBoot整合Mybatis Plus多数据源的实现方法是什么

2023-06-25 12:34

关注

这篇文章主要讲解了“SpringBoot整合Mybatis Plus多数据源的实现方法是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“SpringBoot整合Mybatis Plus多数据源的实现方法是什么”吧!

导读

  有一个这样子的需求,线上正在跑的业务,由于业务发展需要,需重新开发一套新系统,等新系统开发完成后,需要无缝对接切换,当初具体设计见草图。

SpringBoot整合Mybatis Plus多数据源的实现方法是什么

添加依赖

  <!--lombok-->        <dependency>            <groupId>org.projectlombok</groupId>            <artifactId>lombok</artifactId>            <version>1.18.16</version>            <!--scope=provided,说明它是在编译阶段生效,不需要打入包中,Lombok在编译期将带Lombok注解的Java文件正确编译为完整的Class文件-->            <scope>provided</scope>        </dependency>        <!--mysql-->        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>        </dependency>        <!--mybatis plus和spring boot整合-->        <dependency>            <groupId>com.baomidou</groupId>            <artifactId>mybatis-plus-boot-starter</artifactId>            <version>3.4.0</version>        </dependency>        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>druid</artifactId>            <version>1.1.10</version>        </dependency>

application.properties

server.port=9999spring.datasource.master.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.master.url=jdbc:mysql://127.0.0.1/test?useUnicode=true&characterEncoding=utf-8&useSSL=falsespring.datasource.master.username=rootspring.datasource.master.password=rootspring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.slave.jdbc-url=jdbc:mysql://127.0.0.1/test2?useUnicode=true&characterEncoding=utf-8&useSSL=falsespring.datasource.slave.username=rootspring.datasource.slave.password=root

2种方式创建DataSource

Master配置,使用druid连接池

import com.alibaba.druid.pool.DruidDataSource;import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.Primary;import org.springframework.core.env.Environment;import javax.sql.DataSource;@Configuration@MapperScan(basePackages = "com.example.demo.mapper", sqlSessionFactoryRef = "masterSqlSessionFactory")public class MasterDataSourceConfig {    @Autowired    private Environment env;    @Primary    @Bean(name = "masterDataSource")//    @ConfigurationProperties("spring.datasource.master")    public DataSource masterDataSource() {//        return DataSourceBuilder.create().build();        DruidDataSource dataSource = new DruidDataSource();        dataSource.setUrl(env.getProperty("spring.datasource.master.url"));        dataSource.setUsername(env.getProperty("spring.datasource.master.username"));        dataSource.setPassword(env.getProperty("spring.datasource.master.password"));        dataSource.setDriverClassName(env.getProperty("spring.datasource.master.driver-class-name"));        //配置初始化大小、最小、最大        dataSource.setMinIdle(10);        //配置初始化大小、最小、最大        dataSource.setMaxActive(200);        //配置初始化大小、最小、最大        dataSource.setInitialSize(10);        //配置获取连接等待超时的时间        dataSource.setMaxWait(60000);        //配置一个连接在池中最小生存的时间,单位是毫秒        dataSource.setMinEvictableIdleTimeMillis(300000);        //配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒        dataSource.setTimeBetweenEvictionRunsMillis(60000);        //默认的testWhileIdle=true,testOnBorrow=false,testOnReturn=false        dataSource.setValidationQuery("SELECT 1");        //申请连接时执行validationQuery检测连接是否有效        dataSource.setTestOnBorrow(false);        //建议配置为true,不影响性能,并且保证安全性。        dataSource.setTestWhileIdle(true);        //是否缓存preparedStatement,也就是PSCache        dataSource.setPoolPreparedStatements(false);        return dataSource;    }    @Bean(name = "masterSqlSessionFactory")    public SqlSessionFactory sqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {        MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();        sessionFactoryBean.setDataSource(dataSource);        return sessionFactoryBean.getObject();    }}

Slave配置

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;import org.apache.ibatis.session.SqlSessionFactory;import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.boot.jdbc.DataSourceBuilder;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import javax.sql.DataSource;@Configuration@MapperScan(basePackages = "com.example.demo.mapper2",sqlSessionFactoryRef = "slaveSqlSessionFactory")public class SlaveDataSourceConfig {    @Bean(name = "slaveDataSource")    @ConfigurationProperties("spring.datasource.slave")    public DataSource slaveDataSource(){        return DataSourceBuilder.create().build();    }    @Bean(name = "slaveSqlSessionFactory")    public SqlSessionFactory sqlSessionFactory(@Qualifier("slaveDataSource") DataSource dataSource) throws Exception {        MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();        sessionFactoryBean.setDataSource(dataSource);        return sessionFactoryBean.getObject();    }}

注意

  master和slave扫描不同的mapper包路径!!!!!!

  如果需要指定.xml文件,需这样配置!!!

@Bean(name = "masterSqlSessionFactory")    public SqlSessionFactory sqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {        MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();        sessionFactoryBean.setDataSource(dataSource);        sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()                .getResources("classpath:mapper*.xml"));        return sessionFactoryBean.getObject();    }

SpringBoot整合Mybatis Plus多数据源的实现方法是什么

MybatisPlus分页插件设置

import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class MybatisPlusPageConfig {        @Bean    public MybatisPlusInterceptor mybatisPlusInterceptor() {        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();        mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor());        return mybatisPlusInterceptor;    }}
  @Bean(name = "masterSqlSessionFactory")    public SqlSessionFactory sqlSessionFactory(            @Qualifier("masterDataSource") DataSource dataSource,            @Qualifier("mybatisPlusInterceptor") MybatisPlusInterceptor mybatisPlusInterceptor    ) throws Exception {        MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();        sessionFactoryBean.setDataSource(dataSource);        sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()                .getResources("classpath:mapper*.xml"));        sessionFactoryBean.setPlugins(mybatisPlusInterceptor);        return sessionFactoryBean.getObject();    }

启动类

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, MybatisPlusAutoConfiguration.class})

启动类上排查,自动装配,使用我们自定义的多数据源!!!

演示

SpringBoot整合Mybatis Plus多数据源的实现方法是什么

SpringBoot整合Mybatis Plus多数据源的实现方法是什么

  多个数据源,同时也是支持事务的

感谢各位的阅读,以上就是“SpringBoot整合Mybatis Plus多数据源的实现方法是什么”的内容了,经过本文的学习后,相信大家对SpringBoot整合Mybatis Plus多数据源的实现方法是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯