springboot整合mybatis-plus+durid数据库连接池

Posted 极速小乌龟

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了springboot整合mybatis-plus+durid数据库连接池相关的知识,希望对你有一定的参考价值。

特别说明:本次项目整合基于idea进行的,如果使用Eclipse可能操作会略有不同,不过总的来说不影响。

springboot整合之如何选择版本及项目搭建

springboot整合之版本号统一管理  

springboot整合mybatis-plus+durid数据库连接池

springboot整合swagger

springboot整合mybatis代码快速生成

springboot整合之统一结果返回

springboot整合之统一异常处理

springboot整合之Validated参数校验 

springboot整合之logback日志配置

springboot整合pagehelper分页

springboot整合本地缓存

springboot整合redis + redisson

springboot整合elasticsearch

springboot整合rabbitMq

springboot整合canal实现缓存一致性

springboot整合springSecurity(前后端不分离版本)

本次项目整合基于第一篇的项目搭建,如果需要的可以参考第一篇。里面讲解了怎么进行版本选择,和基础的项目搭建。本篇主要是基于上一篇的基础上进行数据库操作的整合。

其实这里有一个点我觉得有必要说一下,如果不需要开启监控功能,个人觉得没必要用Druid数据库连接池。不如直接使用磨人的Hikari,而且这个连接池不需要进行额外整合,因为springboot已经帮我们整合好了。下面我们来介绍一下这个连接池,希望对你得数据库连接池选择有所帮助。

Hikari是一款非常强大,高效,并且号称“史上最快连接池”。性能方面的比较:hikariCP>druid>tomcat-jdbc>dbcp>c3p0 。hikariCP的高性能得益于最大限度的避免锁竞争。它的性能几乎是C3P0、DBCP的25倍,十分强悍。

一、整合jar包

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <!--spring-boot 依赖版本-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.12.RELEASE</version>
    </parent>

    <!--当前项目坐标-->
    <groupId>com.example</groupId>
    <artifactId>springboot-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-demo</name>
    <description>springboot-demo</description>

    <!--版本依赖管理-->
    <properties>
        <java.version>8</java.version>
    </properties>


    <dependencies>

        <!--spring-boot-starter 依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!--spring-boot-starter-web 依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--热启动依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <!--lombok 依赖-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <!--spring-boot-starter-test 依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--mysql 链接驱动-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

        <!--druid数据库连接池-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.15</version>
        </dependency>

        <!--mybatis-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.2</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

二、配置applicartion-dev.yml

说明都写在文件里了。大家不懂得可以私信我。

server:
  port: 8080   #  配置启动端口号


spring:
  datasource:
    url: jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT%2B8&useSSL=FALSE
    username: root  #数据库用户名,root为管理员
    password: 123456 #该数据库用户的密码
    # 使用druid数据源
    type: com.alibaba.druid.pool.DruidDataSource

# mybatis-plus相关配置
mybatis-plus:
  # xml扫描,多个目录用逗号或者分号分隔(告诉 Mapper 所对应的 XML 文件位置)
  mapper-locations: classpath:mapper/*.xml
  # 以下配置均有默认值,可以不设置
  global-config:
    db-config:
      #主键类型 AUTO:"数据库ID自增" INPUT:"用户输入ID",ID_WORKER:"全局唯一ID (数字类型唯一ID)", UUID:"全局唯一ID UUID";
      id-type: auto
      #字段策略 IGNORED:"忽略判断"  NOT_NULL:"非 NULL 判断")  NOT_EMPTY:"非空判断"
      field-strategy: NOT_EMPTY
      #数据库类型
      db-type: MYSQL
  configuration:
    # 是否开启自动驼峰命名规则映射:从数据库列名到Java属性驼峰命名的类似映射
    map-underscore-to-camel-case: true
    # 如果查询结果中包含空值的列,则 MyBatis 在映射的时候,不会映射这个字段
    call-setters-on-nulls: true
    # 这个配置会将执行的sql打印出来,在开发或测试的时候可以用
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

三、创建项目所需要的包结构

在开始之前我们先准备好项目后面所要用到的包,具体目录如下,大家可以参考着建一下

 包的分层和结构很简单,相信大家都理解我就不再做特别说明了。

四、修改启动类

在启动类上添加mapper扫描。

package com.example.springbootdemo;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan(basePackages = "com.example.springbootdemo.mapper")
public class SpringbootDemoApplication 

    public static void main(String[] args) 
        SpringApplication.run(SpringbootDemoApplication.class, args);
    


不知道大家清不清楚为什么要使用@MapperScan注解?它和@Mapper有什么区别?

其实这两个作用是相同的。区别就是@Mapper可以单独添加在每个mapper上面,而@MapperScan是只要添加在启动类上就可以了。如果我们在启动类上面添加了@MapperScan注解,那就没有必要再使用@Mapper注解了。如果不使用@MapperScan也可以单独在每一个mapper添加@Mapper注解,效果是一样的,就是比较麻烦而已。

 五、创建数据库

上面都好了我们就可以正式开始创建我们的第一张表来测试我们的整合了。为了简单我这里就直接创建了一个用户表。这样也好理解。好了,不废话了,直接来创建test数据库并创建user表

CREATE TABLE `user` (
  `id` bigint(12) NOT NULL AUTO_INCREMENT,
  `user_name` varchar(8) DEFAULT NULL COMMENT '用户名',
  `password` varchar(50) DEFAULT NULL COMMENT '密码',
  `sex` int(1) DEFAULT '0' COMMENT '性别',
  `phone` varchar(20) DEFAULT NULL COMMENT '手机号',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8

六、创建实体类、mapper、service

表创建完成以后我们就可以按照mybatis-plus来创建我们自己的实体类还有mapper和service了。这里要特别说明一下,使用了Lombok注解,需要安装Lombok的插件,如果没有安装需要自己在idea安装一下。

package com.example.sessiondemo.pojo;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.io.Serializable;

/**
 * @description: User <br>
 * @date: 2022/7/17 17:27 <br>
 * @author: William <br>
 * @version: 1.0 <br>
 */
@Data

@TableName("user")
public class User implements Serializable 


    @TableId(type = IdType.AUTO)
    private Long id;

    /**
     * 用户名
     */
    private String userName;

    /**
     * 密码
     */
    private String password;

    /**
     * 性别
     */
    private Integer sex;

    /**
     * 手机号
     */
    private String phone;


package com.example.sessiondemo.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.sessiondemo.pojo.User;
import org.apache.ibatis.annotations.Mapper;

/**
 * @description: UserMapper <br>
 * @date: 2022/7/17 17:32 <br>
 * @author: William <br>
 * @version: 1.0 <br>
 */
public interface UserMapper extends BaseMapper<User> 

package com.example.sessiondemo.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.example.sessiondemo.pojo.User;

/**
 * @description: UserService <br>
 * @date: 2022/7/17 17:33 <br>
 * @author: William <br>
 * @version: 1.0 <br>
 */
public interface UserService extends IService<User> 

package com.example.sessiondemo.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.sessiondemo.dao.UserMapper;
import com.example.sessiondemo.pojo.User;
import com.example.sessiondemo.service.UserService;
import org.springframework.stereotype.Service;

/**
 * @description: UserServiceImpl <br>
 * @date: 2022/7/17 17:34 <br>
 * @author: William <br>
 * @version: 1.0 <br>
 */
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService 

七、测试配置是否成功

创建测试

package com.example.springbootdemo;

import com.example.springbootdemo.entity.User;
import com.example.springbootdemo.mapper.UserMapper;
import com.example.springbootdemo.service.UserService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class SpringbootDemoApplicationTests 

    @Autowired
    private UserService userService;
    


    @Test
    void testInsert() 
        User user = new User();
        user.setUserName("aaa").setSex(2).setPhone("1111");
        userService.save(user);
    


输出结果如下:

 成功执行,说明我们的整合成功了。后面会接着整合开发中常用到的一些插件或者中间件,感兴趣的欢迎关注~

mybatis-plus整合springboot入门

1、mybatis-plus快速入门

https://mp.baomidou.com/

2、springboot整合mybatis-plus

(1)、映入maven依赖

<!--mybaitsi-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.3.1.tmp</version>
        </dependency>

备注:springboot版本:2.2.6.RELEASE

(2)、yml文件数据库和mybatis-plus配置

#数据库配置
spring:
  datasource:
   username: root
   password: 123456
   url: jdbc:mysql://localhost:3306/mybaits-plus?useUnicode=true&characterEncoding=UTF-8&useSSL=false&nullCatalogMeansCurrent=true&serverTimezone=Asia/Shanghai

#mybatis-plus配置
logging:
   level:
    com:
      example:
       demo:
         mapper: debug
mybatis-plus:
  mapper-locations: classpath*:mappers/*.xml
  # 实体扫描,多个package用逗号或者分号分隔
  type-aliases-package: com.example.demo.model
  configuration:
    # 驼峰下划线转换
    map-underscore-to-camel-case: true
    cache-enabled: false
    call-setters-on-nulls: true
  global-config:
    # 刷新mapper 调试神器
    refresh: true
    banner: false
    #数据库大写下划线转换
    #capital-mode: true
    #序列接口实现类配置
    #key-generator: com.baomidou.springboot.xxx
    # 数据库相关配置
    db-config:
      db-type: mysql
      # 主键类型  AUTO:"数据库ID自增", INPUT:"用户输入ID",ID_WORKER:"全局唯一ID (数字类型唯一ID)", UUID:"全局唯一ID UUID";
      id-type: AUTO
      # 字段策略 IGNORED:"忽略判断",NOT_NULL:"非 NULL 判断"),NOT_EMPTY:"非空判断"
      field-strategy: not_empty
      capital-mode: true
      #逻辑删除配置
      logic-delete-value: 1
      logic-not-delete-value: 0

(3)、数据准备

CREATE TABLE `user` (
  `id` bigint(11) NOT NULL COMMENT 主键ID,
  `name` varchar(30) NOT NULL COMMENT 姓名,
  `age` int(11) NOT NULL COMMENT 年龄,
  `email` varchar(50) NOT NULL COMMENT 邮箱,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

INSERT INTO `mybaits-plus`.`user` (`id`, `name`, `age`, `email`) VALUES (1, Jone, 18, test1@baomidou.com);
INSERT INTO `mybaits-plus`.`user` (`id`, `name`, `age`, `email`) VALUES (2, Jack, 20, test2@baomidou.com);
INSERT INTO `mybaits-plus`.`user` (`id`, `name`, `age`, `email`) VALUES (3, Tom, 28, test3@baomidou.com);
INSERT INTO `mybaits-plus`.`user` (`id`, `name`, `age`, `email`) VALUES (4, Sandy, 21, test4@baomidou.com);
INSERT INTO `mybaits-plus`.`user` (`id`, `name`, `age`, `email`) VALUES (5, Billie, 24, test5@baomidou.com);

CREATE TABLE `course` (
  `id` bigint(20) NOT NULL,
  `course` varchar(10) NOT NULL,
  `user_id` bigint(20) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

INSERT INTO `mybaits-plus`.`course` (`id`, `course`, `user_id`) VALUES (1, 语文, 2);

(4)、创建实体类

@Data
public class User implements Serializable {

    private static final long serialVersionUID = -5817579076869802231L;

    private Long id;
    private String name;
    private Integer age;
    private String email;
}

(5)、service层和dao层

public interface UserService extends IService<User> {
    PageInfo<User> selectPage(int pageNo, int pageSize, User user);

    PageInfo<User> selectPageCustom(int pageNo, int pageSize, User user);

    PageInfo<Map<String, Object>> selectPageCustomMap(int pageNo, int pageSize);
}
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper,User> implements UserService {

    @Resource
    private UserMapper userMapper;

    @Override
    public PageInfo<User> selectPage(int pageNo, int pageSize, User user) {
        Page<User> page = new Page<>(pageNo,pageSize,false);
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.like("name",user.getName());
        wrapper.orderByAsc("id");
        page = userMapper.selectPage(page, wrapper);
        return new PageInfo<>(page);
    }

    @Override
    public PageInfo<User> selectPageCustom(int pageNo, int pageSize, User user) {
        Page<User> page = new Page<>(pageNo,pageSize);
        userMapper.pageMyQuery(page,user.getName());
        return new PageInfo<>(page);
    }

    @Override
    public PageInfo<Map<String, Object>> selectPageCustomMap(int pageNo, int pageSize) {
        Page<Map<String, Object>> page = new Page<>(pageNo,pageSize);
        page = userMapper.pageMyMapQuery(page);
        return new PageInfo<>(page);
    }
public interface UserMapper extends BaseMapper<User> {

    Page<User> pageMyQuery(Page<User> pageInfo, @Param("name") String name);

    Page<Map<String,Object>> pageMyMapQuery(Page pageInfo);
}

mapper文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.demo.mapper.UserMapper">

    <select id="pageMyQuery" parameterType="User" resultType="User">
        select id,name,age from user where name = #{name}
    </select>
    <select id="pageMyMapQuery" resultType="map">
        SELECT * FROM course c
        LEFT JOIN `user` u on c.id = u.id
    </select>
</mapper>

(6)、单元测试

  1 @SpringBootTest
  2 @RunWith(SpringRunner.class)
  3 public class MybatisPlusTest {
  4 
  5     @Autowired
  6     private UserService userService;
  7     /**
  8      * 全局id生成器
  9      */
 10     @Autowired
 11     private DefaultIdentifierGenerator defaultIdentifierGenerator;
 12 
 13     /**
 14      * list查询
 15      */
 16     @Test
 17     public  void selectList(){
 18         List<User> list = userService.list();
 19         Assert.assertEquals(6, list.size());
 20         list.forEach(System.out::println);
 21     }
 22 
 23     /**
 24      *单条插入
 25      */
 26     @Test
 27     public void inset(){
 28         User user = new User();
 29         user.setName("张三");
 30         user.setAge(20);
 31         user.setEmail("1165523762@qq.com");
 32         user.setId(defaultIdentifierGenerator.nextId(user));
 33         userService.save(user);
 34     }
 35 
 36     /**
 37      * 批量插入
 38      */
 39     @Test
 40     public void saveBatch(){
 41         List<User> list = new ArrayList<>();
 42         User user1 = new User();
 43         user1.setName("王五");
 44         user1.setAge(20);
 45         user1.setEmail("1234567@qq.com");
 46         user1.setId(defaultIdentifierGenerator.nextId(user1));
 47         list.add(user1);
 48 
 49         User user2 = new User();
 50         user2.setName("李四");
 51         user2.setAge(20);
 52         user2.setEmail("7654321@qq.com");
 53         user2.setId(defaultIdentifierGenerator.nextId(user1));
 54         list.add(user2);
 55 
 56         userService.saveBatch(list);
 57 
 58     }
 59 
 60     /**
 61      * 按照id集合删除
 62      */
 63     @Test
 64     public void delBatch(){
 65         List<Long> ids = new ArrayList<>();
 66         ids.add(1259742998092120066L);
 67         ids.add(1259749231041806337L);
 68         userService.removeByIds(ids);
 69     }
 70 
 71     /**
 72      * 分页查询
 73      */
 74     @Test
 75     public void queryPage(){
 76         User user = new User();
 77         user.setName("李四");
 78         PageInfo<User> userPageInfo =  userService.selectPage(1,3,user);
 79         System.err.println(userPageInfo);
 80     }
 81 
 82     /**
 83      * 自定义分页查询返回T
 84      */
 85     @Test
 86     public void queryPageCustom(){
 87         User user = new User();
 88         user.setName("李四");
 89         PageInfo<User> userPageInfo =  userService.selectPageCustom(1,3,user);
 90         System.err.println(userPageInfo);
 91     }
 92 
 93     /**
 94      * 自定义分页查询返回map
 95      */
 96     @Test
 97     public void queryPageCustomMap(){
 98         PageInfo<Map<String,Object>> userPageInfo =  userService.selectPageCustomMap(1,3);
 99         System.err.println(userPageInfo);
100     }

补充:PageInfo源码(自定义分页实体类)


@Data
public class PageInfo<T> {

/**
* 当前页
*/
private Long pageNo;

/**
* 每页显示条数
*/
private Long PageSize;

/**
* 总条数
*/
private Long total;

/**
* 结果集
*/
private List<T> result;

public PageInfo(Page<T> page) {
this.pageNo = page.getCurrent();
this.PageSize = page.getSize();
this.total = page.getTotal();
this.result = page.getRecords();
}
}
 

 mybatis-plus配置类

@Configuration
public class MybatisPlusConfig {

/**
* 全局id生成器
* @return
*/
@Bean
public DefaultIdentifierGenerator identifierGenerator(){
return new DefaultIdentifierGenerator();
}

/**
* 分页插件
* @return
*/
@Bean
public PaginationInterceptor paginationInterceptor(){
PaginationInterceptor paginationInterceptor = new PaginationInterceptor();
// 设置请求的页面大于最大页后操作, true调回到首页,false 继续请求 默认false
// paginationInterceptor.setOverflow(false);
// 设置最大单页限制数量,默认 500 条,-1 不受限制
// paginationInterceptor.setLimit(500);
// 开启 count 的 join 优化,只针对部分 left join
paginationInterceptor.setCountSqlParser(new JsqlParserCountOptimize(true));
return paginationInterceptor;
}
}

 

以上是关于springboot整合mybatis-plus+durid数据库连接池的主要内容,如果未能解决你的问题,请参考以下文章

springboot整合mybatis-plus

springboot整合mybatis-plus+durid数据库连接池

mybatis-plus整合springboot入门

mybatis-plus整合springboot入门

Springboot整合Mybatis-Plus

springboot 整合Mybatis-Plus分页自动填充功能