栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

MyBatis-Puls学习教程

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

MyBatis-Puls学习教程

首先,学习他是为什么?主要是可以偷懒,不需要太多的代码量!个人理解就是一个仓库,你需要什么,就调用什么!

MyBatis-Plus(简称 MP)是一个 MyBatis 的增强工具,在 MyBatis 的基础上只做增强不做改变,为简化开发、提高效率而生。

我们的愿景是成为 MyBatis 最好的搭档,就像 魂斗罗 中的 1P、2P,基友搭配,效率翻倍。

特性的话我就不在介绍了。

话不多说开干!

目录

一、创建项目

        进入Idea,创建spring boot项目名字就写一个MyBatisPlus:

二、快速入门

1.向pom.xml文件中复制以下的代码:

2.创建数据库mybatis_plus、表user

3.连接数据库(我这里采用的数据库是8.0版本)是在resources文件夹下application.properties文件中添加:

4.在pojo文件夹下建一个User类:

5.在mapper文件夹下建一个UserMapper类:

6.在MybatisplusApplication主类中增加

7.测试类中测试

三、CRUD扩展

1.插入(insert)

2.我们需要配置主键自增:

3.更新(update)

4.自动填充

 5.乐观锁

6.查询操作 

 6.分页查询

 7.删除操作

8.逻辑删除

9.性能分析插件

10.条件构造器


一、创建项目

        进入Idea,创建spring boot项目名字就写一个MyBatisPlus:

 选好之后,就点击“下一步”:

 选中web中的springWeb选项,点击完成。

二、快速入门

1.向pom.xml文件中复制以下的代码:



    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.6.4
         
    
    com.xiaoming
    mybatisplus
    0.0.1-SNAPSHOT
    mybatisplus
    Demo project for Spring Boot
    
        1.8
    
    

        
        
            mysql
            mysql-connector-java
        
        
        
            org.projectlombok
            lombok
        
        
        
        
            com.baomidou
            mybatis-plus-boot-starter
            3.0.5
        

        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
            
                
                    org.junit.vintage
                    junit-vintage-engine
                
            
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            
        
    


2.创建数据库mybatis_plus、表user


DROp TABLE IF EXISTS user;
CREATE TABLE user
(
        id BIGINT(20) NOT NULL COMMENT '主键ID',
        name VARCHAr(30) NULL DEFAULT NULL COMMENT '姓名',
        age INT(11) NULL DEFAULT NULL COMMENT '年龄',
        email VARCHAr(50) NULL DEFAULT NULL COMMENT '邮箱',
        PRIMARY KEY (id)
);
INSERT INTO user (id, name, age, email) VALUES
                (1, 'Jone', 18, 'test1@baomidou.com'),
                (2, 'Jack', 20, 'test2@baomidou.com'),
                (3, 'Tom', 28, 'test3@baomidou.com'),
                (4, 'Sandy', 21, 'test4@baomidou.com'),
                (5, 'Billie', 24, 'test5@baomidou.com');
-- 真实开发中,version(乐观锁)、deleted(逻辑删除)、gmt_create、gmt_modified

3.连接数据库(我这里采用的数据库是8.0版本)是在resources文件夹下application.properties文件中添加:

# 数据库连接配置
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.url=jdbc:mysql://localhost:3306/mybatis_plus?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

# 配置日志 主要是我们所有的sql现在是不可见的,我们希望知道它是怎么执行的,所以我们必须要看日志!
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

注意:如果你是5.*数据库版本,就需要将com.mysql.cj.jdbc.Driver改为:com.mysql.jdbc.Driver。

4.在pojo文件夹下建一个User类:

package com.xiaoming.pojo;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

public class User {
    // 对应数据库中的主键 (uuid、自增id、雪花算法、redis、zookeeper!)
    //@TableId(type = IdType.AUTO)
    private Long id;
    private String name;
    private Integer age;
    private String email;
}

5.在mapper文件夹下建一个UserMapper类:

package com.xiaoming.mapper;

import com.baomidou.mybatisplus.core.mapper.baseMapper;
import com.xiaoming.pojo.User;
import org.springframework.stereotype.Repository;


// 在对应的Mapper上面继承基本的类 baseMapper
@Repository //代表持久层
public interface UserMapper extends baseMapper {
    // 所有的CRUD操作都已经编写完成了
    // 你不需要像以前的配置一大堆文件了
}

6.在MybatisplusApplication主类中增加

package com.xiaoming;

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

@SpringBootApplication
@MapperScan("com.xiaoming.mapper")
public class MybatisplusApplication {

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

}

7.测试类中测试

  @Test
    void contextLoads() {
        // 参数是一个 Wrapper ,条件构造器,这里我们先不用 null
        // 查询全部用户
        List users = userMapper.selectList(null);
        users.forEach(System.out::println);
    }

三、CRUD扩展

1.插入(insert)
  @Test
    public void testInsert(){
        User user = new User();
        user.setName("小明");
        user.setAge(10);
        user.setEmail("3396207869@qq.com");
        int result = userMapper.insert(user);//帮我们自动生成id
        System.out.println(result);//受影响的行数
        System.out.println(user);//id自动填充,并且是唯一的id
    }

数据库插入的id的默认值为:全局的唯一id

雪花算法:
snowflake是Twitter开源的分布式ID生成算法,结果是一个long型的ID。其核心思想是:使用41bit作为
毫秒数,10bit作为机器的ID(5个bit是数据中心,5个bit的机器ID),12bit作为毫秒内的流水号(意味
着每个节点在每毫秒可以产生 4096 个 ID),最后还有一个符号位,永远是0。可以保证几乎全球唯
一!

2.我们需要配置主键自增:

1、实体类字段上 @TableId(type = IdType.AUTO)

2、数据库字段一定要是自增!

 再次测试后就可以了。

3.更新(update)
    //测试更新
    @Test
    public void testUpdate(){
        //通过条件自动拼接动态sql
        User user=new User();
        user.setId(6L);
        user.setName("张三");
        user.setAge(18);

        // 注意:updateById 但是参数是一个 对象!
        int i=userMapper.updateById(user);
        System.out.println(i);
    }

4.自动填充

创建时间、修改时间!这些个操作一遍都是自动化完成的,我们不希望手动更新!
阿里巴巴开发手册:所有的数据库表:gmt_create、gmt_modified几乎所有的表都要配置上!而且需要自动化!

1、在表中新增字段 create_time, update_time

2、再次测试插入方法,我们需要先把实体类同步!

// 字段添加填充内容

    @TableField(fill = FieldFill.INSERT)
    private Date createTime;

    @TableField(fill = FieldFill.INSERT_UPDATE)
    private Date updateTime;

3、编写处理器来处理这个注解即可!

import com.baomidou.mybatisplus.core.handlers.metaObjectHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.reflection.metaObject;
import org.springframework.stereotype.Component;

import java.util.Date;

@Slf4j
@Component // 一定不要忘记把处理器加到IOC容器中!
public class MymetaObjectHandler implements metaObjectHandler {
    // 插入时的填充策略
    @Override
    public void insertFill(metaObject metaObject) {
        log.info("start insert fill.....");
        // setFieldValByName(String fieldName, Object fieldVal, metaObject metaObject
        this.setFieldValByName("createTime",new Date(),metaObject);
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }

    // 更新时的填充策略
    @Override
    public void updateFill(metaObject metaObject) {
        log.info("start update fill.....");
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }
}

 4、测试插入

5、测试更新

 5.乐观锁

乐观锁 : 故名思意十分乐观,它总是认为不会出现问题,无论干什么不去上锁!如果出现了问题,
再次更新值测试
悲观锁:故名思意十分悲观,它总是认为总是出现问题,无论干什么都会上锁!再去操作!

乐观锁实现方式:

取出记录时,获取当前 version更新时,带上这个version执行更新时, set version = newVersion where version = oldVersion如果version不对,就更新失败

乐观锁:1、先查询,获得版本号 version = 1
-- A
update user set name = "小明", version = version + 1
where id = 2 and version = 1
-- B 线程抢先完成,这个时候 version = 2,会导致 A 修改失败!
update user set name = "小明", version = version + 1
where id = 2 and version = 1

1.先去数据库中增加一个字段version,默认值设置为1。

2.在实体类User中增加一个字段

@Version //乐观锁Version注解
private Integer version;

3.注册组件

// 扫描我们的 mapper 文件夹
@MapperScan("com.xiaoming.mapper")
@EnableTransactionManagement
@Configuration // 配置类
public class MyBatisPlusConfig {
  // 注册乐观锁插件
  @Bean
  public OptimisticLockerInterceptor optimisticLockerInterceptor() {
    return new OptimisticLockerInterceptor();
 }
}

4.测试一下

/ 测试乐观锁成功!
@Test
public void testOptimisticLocker(){
  // 1、查询用户信息
  User user = userMapper.selectById(1L);
  // 2、修改用户信息
  user.setName("xiaoming");
  user.setEmail("24736743@qq.com");
  // 3、执行更新操作
  userMapper.updateById(user);
}

// 测试乐观锁失败!多线程下
@Test
public void testOptimisticLocker2(){
  // 线程 1
  User user = userMapper.selectById(1L);
  user.setName("xiaoming");
  user.setEmail("24736743@qq.com");
  // 模拟另外一个线程执行了插队操作
  User user2 = userMapper.selectById(1L);
  user2.setName("xiaoming2");
  user2.setEmail("24736743@qq.com");
  userMapper.updateById(user2);
  // 自旋锁来多次尝试提交!
  userMapper.updateById(user); // 如果没有乐观锁就会覆盖插队线程的值!

6.查询操作 
// 测试查询
@Test
public void testSelectById(){
  User user = userMapper.selectById(1L);
  System.out.println(user);
}
// 测试批量查询!
@Test
public void testSelectByBatchId(){
  List users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3));
  users.forEach(System.out::println);
}
// 按条件查询之一使用map操作
@Test
public void testSelectByBatchIds(){
  HashMap map = new HashMap<>();
  // 自定义要查询
  map.put("name","小明");
  map.put("age",10);
  List users = userMapper.selectByMap(map);
  users.forEach(System.out::println);
}

 6.分页查询

1、原始的 limit 进行分页
2、pageHelper 第三方插件
3、MP 其实也内置了分页插件!

使用方法:

1、配置拦截器组件即可

// 分页插件
@Bean
public PaginationInterceptor paginationInterceptor() {
  return  new PaginationInterceptor();
}

2、测试分页查询

// 测试分页查询
    @Test
    public void testPage(){
        //  参数一:当前页
        //  参数二:页面大小
        //  使用了分页插件之后,所有的分页操作也变得简单的!
        Page page = new Page<>(1,5);
        userMapper.selectPage(page,null);

        page.getRecords().forEach(System.out::println);
        System.out.println(page.getTotal());

    }

 7.删除操作

1、根据id删除记录

/ 测试删除
@Test
public void testDeleteById(){
  userMapper.deleteById(1240620674645544965L);
}
// 通过id批量删除
@Test
public void testDeleteBatchId(){
 userMapper.deleteBatchIds(Arrays.asList(1240620674645544961L,124062067464554496
2L));
}
// 通过map删除
@Test
public void testDeleteMap(){
  HashMap map = new HashMap<>();
  map.put("name","小明");
  userMapper.deleteByMap(map);
}

8.逻辑删除

物理删除 :从数据库中直接移除
逻辑删除 :再数据库中没有被移除,而是通过一个变量来让他失效! deleted = 0 => deleted = 1

管理员可以查看被删除的记录!防止数据的丢失,类似于回收站!

测试一下:
1、在数据表中增加一个 deleted 字段


2、实体类中增加属性

@TableLogic //逻辑删除
private Integer deleted;

3、配置!

在config文件夹下MyBatisPlusConfig类中加入组件

// 逻辑删除组件!
@Bean
public ISqlInjector sqlInjector() {
  return new LogicSqlInjector();
}
# 配置逻辑删除
mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0

4、测试一下删除

9.性能分析插件

作用:性能分析拦截器,用于输出每条 SQL 语句及其执行时间
MP也提供性能分析插件,如果超过这个时间就停止运行!

1、导入插件

# 设置开发环境
spring.profiles.active=dev

注意,要在SpringBoot中配置环境为dev或者 test 环境!
   
    @Bean
    @Profile({"dev","test"})//设置dev test环境开启,保证我们的效率。
    public PerformanceInterceptor performanceInterceptor(){
        PerformanceInterceptor performanceInterceptor=new PerformanceInterceptor();

        performanceInterceptor.setMaxTime(100);
        //ms 设置sql执行的最大时间,如果超过了则不执行

        performanceInterceptor.setFormat(true);
        return performanceInterceptor;
    }

2、测试

    @Autowired
    private UserMapper userMapper;

    @Test
    void contextLoads() {
        // 参数是一个 Wrapper ,条件构造器,这里我们先不用 null
        // 查询全部用户
        List users = userMapper.selectList(null);
        users.forEach(System.out::println);
    }

10.条件构造器

十分重要:Wrapper
我们写一些复杂的sql就可以使用它来替代!

条件构造器 | MyBatis-Plus

1、测试一,记住查看输出的SQL进行分析

@Test
void contextLoads() {
  // 查询name不为空的用户,并且邮箱不为空的用户,年龄大于等于12
  QueryWrapper wrapper = new QueryWrapper<>();
  wrapper
   .isNotNull("name")
   .isNotNull("email")
   .ge("age",12);
  userMapper.selectList(wrapper).forEach(System.out::println); // 和我们刚才学习
的map对比一下
}

2、测试二,记住查看输出的SQL进行分析

@Test
void test2(){
  // 查询名字狂神说
  QueryWrapper wrapper = new QueryWrapper<>();
  wrapper.eq("name","狂神说");
  User user = userMapper.selectOne(wrapper); // 查询一个数据,出现多个结果使用List
或者 Map
  System.out.println(user);
}

3、测试三,记住查看输出的SQL进行分析

@Test
void test3(){
  // 查询年龄在 20 ~ 30 岁之间的用户
  QueryWrapper wrapper = new QueryWrapper<>();
  wrapper.between("age",20,30); // 区间
  Integer count = userMapper.selectCount(wrapper);// 查询结果数
  System.out.println(count);
}

4、测试四,记住查看输出的SQL进行分析

// 模糊查询
@Test
void test4(){
  // 查询年龄在 20 ~ 30 岁之间的用户
  QueryWrapper wrapper = new QueryWrapper<>();
  // 左和右 t%
  wrapper
     .notLike("name","e")
     .likeRight("email","t");
  List> maps = userMapper.selectMaps(wrapper);
  maps.forEach(System.out::println);
}

5、测试五

// 模糊查询
@Test
void test5(){
  QueryWrapper wrapper = new QueryWrapper<>();
  // id 在子查询中查出来
  wrapper.inSql("id","select id from user where id<3");
  List objects = userMapper.selectObjs(wrapper);
  objects.forEach(System.out::println);
} 

6、测试六

//测试六
@Test
void test6(){
  QueryWrapper wrapper = new QueryWrapper<>();
  // 通过id进行排序
  wrapper.orderByAsc("id");
  List users = userMapper.selectList(wrapper);
  users.forEach(System.out::println);
}
转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号