首页 > 其他分享 >SpringBoot3.x+MyBatisPlus+druid多数据源配置

SpringBoot3.x+MyBatisPlus+druid多数据源配置

时间：2024-09-03 18:25:24浏览次数：10  
标签：MyBatisPlus spring 数据源 new SpringBoot3 import org com public

1 引言

本章主要介绍SpringBoot3.x多数据源配置，以及在此基础上配置分页拦截，自动填充功等功能，源码链接在文章最后。下面列出几个重要文件进行介绍。

2 项目结构

整体项目结构如下，主要介绍配置文件和配置类。
在这里插入图片描述

3 主要代码

3.1 pom.xml

注意SpringBoot3.x对应依赖为mybatis-plus-spring-boot3-starte和druid-spring-boot-3-starter。

<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.zeroone</groupId>
    <artifactId>zeroone</artifactId>
    <version>1.0</version>

    <properties>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <!--  为Spring Boot项目提供一系列默认的配置和依赖管理-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>3.3.2</version>
        <relativePath/>
    </parent>

    <dependencies>
        <!--  Spring Boot核心依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!-- Spring Boot单元测试和集成测试的依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- Spring Boot构建Web应用程序的依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- mysql驱动-->
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</artifactId>
        </dependency>
        <!-- mybatis-plus核心依赖-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-spring-boot3-starter</artifactId>
            <version>3.5.7</version>
        </dependency>
        <!-- 阿里数据库连接池 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-3-starter</artifactId>
            <version>1.2.23</version>
        </dependency>


    </dependencies>

</project>

3.2 application.yml

server:
  port: 8080 # 服务器的HTTP端口，默认为8080
  tomcat:
    uri-encoding: UTF-8 # tomcat的URI编码
    accept-count: 1000 # 连接数满后的排队数，默认为100
    threads:
      max: 800 # tomcat最大线程数，默认为200
      min-spare: 100 # Tomcat启动初始化的线程数，默认值10

# Spring配置
spring:
  servlet:
    multipart:
      max-file-size: 10MB  # 单个文件大小
      max-request-size: 20MB # 设置总上传的文件大小
  # 数据源配置
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    druid:
      master: # 主库数据源
        url: jdbc:mysql://127.0.0.1:33066/test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
        username: root
        password: 123456
        initialSize: 5 # 初始连接数
        minIdle: 10 # 最小连接池数量
        maxActive: 20 # 最大连接池数量
        maxWait: 60000 # 配置获取连接等待超时的时间
        connectTimeout: 30000 # 配置连接超时时间
        socketTimeout: 60000 # 配置网络超时时间
        timeBetweenEvictionRunsMillis: 60000 # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
        minEvictableIdleTimeMillis: 300000 # 配置一个连接在池中最小生存的时间，单位是毫秒
        maxEvictableIdleTimeMillis: 900000 # 配置一个连接在池中最大生存的时间，单位是毫秒
      slave:  # 从库数据源
        enabled: true # 从数据源开关/默认关闭
        url: jdbc:mysql://127.0.0.1:33067/test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
        username: root
        password: 123456
      validationQuery: SELECT 1 FROM DUAL # 配置检测连接是否有效
      testWhileIdle: true
      testOnBorrow: false
      testOnReturn: false
      webStatFilter:
        enabled: true
        url-pattern: /*
        exclusions: '*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*'
      statViewServlet:
        enabled: true
        allow:
        url-pattern: /druid/* # 设置白名单，不填则允许所有访问
        login-username: admin  # 控制台管理用户名和密码
        login-password: 123456
      filter:
        stat:
          enabled: true
          log-slow-sql: true # 慢SQL记录
          slow-sql-millis: 1000
          merge-sql: true
        wall:
          config:
            multi-statement-allow: true

# MyBatis配置
mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

3.3 DBMaster.java

这个是主库配置，注意自动填充功能、拦截器功能、application.yml配置均需要在构建SqlSessionFactory 的时候手动添加进去，否则是不生效的。

package com.zeroone.config.database;

import com.alibaba.druid.spring.boot3.autoconfigure.DruidDataSourceBuilder;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.core.MybatisConfiguration;
import com.baomidou.mybatisplus.core.config.GlobalConfig;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.reflection.MetaObject;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;
import java.util.Date;


@Configuration
@MapperScan(basePackages = "com.zeroone.mapper.master", sqlSessionTemplateRef = "sqlSessionTemplateMaster")
public class DBMaster {

    Logger log = LoggerFactory.getLogger(getClass());

    /**
     * MyBatis-Plus自动填充功能
     */
    static class MetaObjectHandlerImplMaster implements MetaObjectHandler {
        @Override
        public void insertFill(MetaObject metaObject) {
            this.setFieldValByName("createTime", new Date(), metaObject);
            this.setFieldValByName("updateTime", new Date(), metaObject);
            this.setFieldValByName("version", Integer.valueOf("0"), metaObject);
        }

        @Override
        public void updateFill(MetaObject metaObject) {
            this.setFieldValByName("updateTime", new Date(), metaObject);
        }
    }

    /**
     * MyBatis-Plus拦截器
     *
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptorMaster() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        //添加分页拦截器
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        //添加乐观锁拦截器
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }


    /**
     * 读取MyBatis-Plus配置
     *
     */
    @Bean
    @ConfigurationProperties(prefix = "mybatis-plus.global-config")
    public GlobalConfig globalConfigMaster() {
        GlobalConfig globalConfig = new GlobalConfig();
        globalConfig.setMetaObjectHandler(new MetaObjectHandlerImplMaster());
        return globalConfig;
    }

    /**
     * 读取MyBatis-Plus配置文件
     *
     */
    @Bean
    @ConfigurationProperties(prefix = "mybatis-plus.configuration")
    public MybatisConfiguration mybatisConfigurationMaster() {
        return new MybatisConfiguration();
    }


    @Primary
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid.master")
    public DataSource dataSourceMaster() {
        return DruidDataSourceBuilder.create().build();
    }


    @Primary
    @Bean
    public SqlSessionFactory sqlSessionFactoryMaster() throws Exception {
        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
        bean.setConfiguration(mybatisConfigurationMaster());
        bean.setGlobalConfig(globalConfigMaster());//加载MyBatis-Plus配置
        bean.setDataSource(dataSourceMaster());//加载MyBatis-Plus配置
        bean.setPlugins(mybatisPlusInterceptorMaster());//加载MyBatis-Plus拦截器
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/master/*.xml"));
        return bean.getObject();
    }

    @Primary
    @Bean
    public SqlSessionTemplate sqlSessionTemplateMaster() throws Exception {
        return new SqlSessionTemplate(sqlSessionFactoryMaster());
    }

    @Primary
    @Bean
    public DataSourceTransactionManager transactionManagerMaster() {
        return new DataSourceTransactionManager(dataSourceMaster());
    }


}

3.4 DBSlave.java.java

这个是从库配置，配置方法与主库相同，注意@bean方法的名称不能与主库配置相同。

package com.zeroone.config.database;

import com.alibaba.druid.spring.boot3.autoconfigure.DruidDataSourceBuilder;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.core.MybatisConfiguration;
import com.baomidou.mybatisplus.core.config.GlobalConfig;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.reflection.MetaObject;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;
import java.util.Date;


@Configuration
@MapperScan(basePackages = "com.zeroone.mapper.slave", sqlSessionTemplateRef = "sqlSessionTemplateSlave")
public class DBSlave {

    Logger log = LoggerFactory.getLogger(getClass());

    /**
     * MyBatis-Plus自动填充功能
     */
    static class MetaObjectHandlerImplSlave implements MetaObjectHandler {
        @Override
        public void insertFill(MetaObject metaObject) {
            this.setFieldValByName("createTime", new Date(), metaObject);
            this.setFieldValByName("updateTime", new Date(), metaObject);
            this.setFieldValByName("version", Integer.valueOf("0"), metaObject);
        }

        @Override
        public void updateFill(MetaObject metaObject) {
            this.setFieldValByName("updateTime", new Date(), metaObject);
        }
    }

    /**
     * MyBatis-Plus拦截器
     *
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptorSlave() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        //添加分页拦截器
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        //添加乐观锁拦截器
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }


    /**
     * 读取MyBatis-Plus配置
     *
     */
    @Bean
    @ConfigurationProperties(prefix = "mybatis-plus.global-config")
    public GlobalConfig globalConfigSlave() {
        GlobalConfig globalConfig = new GlobalConfig();
        globalConfig.setMetaObjectHandler(new MetaObjectHandlerImplSlave());
        return globalConfig;
    }

    /**
     * 读取MyBatis-Plus配置文件
     *
     */
    @Bean
    @ConfigurationProperties(prefix = "mybatis-plus.configuration")
    public MybatisConfiguration mybatisConfigurationSlave() {
        return new MybatisConfiguration();
    }


    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid.slave")
    public DataSource dataSourceSlave() {
        return DruidDataSourceBuilder.create().build();
    }


    @Bean
    public SqlSessionFactory sqlSessionFactorySlave() throws Exception {
        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
        bean.setConfiguration(mybatisConfigurationSlave());
        bean.setGlobalConfig(globalConfigSlave());//加载MyBatis-Plus配置
        bean.setDataSource(dataSourceSlave());//加载MyBatis-Plus配置
        bean.setPlugins(mybatisPlusInterceptorSlave());//加载MyBatis-Plus拦截器
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/slave/*.xml"));
        return bean.getObject();
    }

    @Bean
    public SqlSessionTemplate sqlSessionTemplateSlave() throws Exception {
        return new SqlSessionTemplate(sqlSessionFactorySlave());
    }

    @Bean
    public DataSourceTransactionManager transactionManagerSlave() {
        return new DataSourceTransactionManager(dataSourceSlave());
    }
}

4 测试

启动项目后访问：http://localhost:8080/druid/index.html，账号/密码：admin/123456。可以看到druid监控页面。
在这里插入图片描述

  • 其中有两个数据源，跟我们的配置一致。
    在这里插入图片描述在这里插入图片描述 - 然后随意调用UserController中的接口，并查看sql监控。
    在这里插入图片描述

5 源码

Gitee代码链接

标签：MyBatisPlus,spring,数据源,new,SpringBoot3,import,org,com,public
From： https://blog.csdn.net/qq_40718345/article/details/141868049

相关文章

  • TapData 信创数据源 | 国产信创数据库 Vastbase 数据同步指南，加速国产化进程，推进自主
    随着国家对自主可控的日益重视，目前在各个行业和区域中面临越来越多的国产化，采用有自主知识产权的国产数据库正在成为主流。长期以来，作为拥有纯国产自研背景的TapData，自是非常重视对于更多国产信创数据库的数据连接器支持，旗下产品已陆续与阿里云、华为云、麒麟软件、优炫数据库、A......
  • SpringBoot项目常用配置文件MybatisPlusConfig、RedisConfig、RedissonConfig、Swagge
    MybatisPlusConfig:@Configuration@MapperScan("com.yupi.usercenter.mapper")publicclassMybatisPlusConfig{@BeanpublicMybatisPlusInterceptormybatisPlusInterceptor(){MybatisPlusInterceptorinterceptor=newMybatisPlusInterc......
  • MybatisPlus 主键策略之type=IdType.ASSIGN_ID等详解
    雪花算法（雪花）是微博开源的分布式ID生成算法其核心思想就是：使用一个64位的长型的数字作为全局唯一ID,主要介绍了MybatisPlus 主键策略（type=IdType.ASSIGN_ID等详解）,需要的朋友可以参考下: 我们可以通过@TableId注解的 类型属性来设置主键id的增长策略，一共有几个多个主键策略，......
  • springboot+mybatisplus分页查询
    需求：类似sqlserversql语句查询top100条数据，如何在springboot+mybatisplus中实现（使用的是sqlserver2012数据库）1.pom文件中引入mybatisplus依赖<!--mybatis-plus--><dependency><groupId>com.baomidou</groupId><ar......
  • 阿里Druid数据源：DruidDataSource配置属性全解
    1.前言Druid是Java语言中最好的数据库连接池。Druid能够提供强大的监控和扩展功能。Druid是一个开源项目，源码托管在github上，源代码仓库地址是： https://github.com/alibaba/druid同时每次Druid发布正式版本和快照的时候，都会把源码打包，你可以从上面的下载地址中找到相关版......
  • NocoBase 1.3：REST API 数据源、移动端 V2 和更多功能
    从v1.3开始，NocoBase提供两个关键分支：main和next。main分支，beta版本，专注于缺陷修复，确保为用户提供一个稳定的版本；next分支，alpha版本，包含一些正式未发布的新特性，这个版本不稳定，适用于开发者或测试人员，用于提前体验新功能或进行兼容性测试。本次1.3beta的新特性包括......
  • 多数据源配置
    #数据源配置spring:datasource:#type:com.alibaba.druid.pool.DruidDataSourcetype:com.zaxxer.hikari.HikariDataSourcedriverClassName:com.microsoft.sqlserver.jdbc.SQLServerDriver#com.mysql.cj.jdbc.Driverdruid:#主库数据源master:......
  • MybatisPlus学习笔记
    MyBatisPlus从入门到精通1.概述MybatisPlus是一款Mybatis增强工具，用于简化开发，提高效率。它在MyBatis的基础上只做增强不做改变，为简化开发、提高效率而生。官网：https://baomidou.com/2.快速入门2.0准备工作①准备数据CREATETABLE`user`(`id`bigint(20)NOTNULL......
  • SpringBoot配置动态数据源 原理+实战
    若没空探究原理可直接跳转到“实现方式：注解+切面”目录数据源切换方法Spring对数据源的管理类似于策略模式，不懂策略模式也没关系，其实就是有一个全局的键值对，类型是Map<String,DataSource>。当JDBC操作数据库之时，会根据不同的key值选择不同的数据源。而这个key值可以放到方法的......
  • 最完整版-Springboot3集成Knife4j
    一，前言    在使用swagger-bootstrap-ui时我觉得它的样式和蓝色主色调不符合我的审美，所以我觉得使用一个更强的工具 Knife4j。Knife4j是一个用于SpringBoot和SpringCloud的增强Swagger的工具，提供黑色主题和更多配置选项。Knife4j在更名之前，原来的名称是叫swagger-boots......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99