Mybatis-Plus
1.快速入门地址:安装 | MyBatis-Plus (baomidou.com)
2.创建数据库mybatis-plus
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');
以上数据的运行均在cmd命令运行
3.创建springboot项目,配置yml文件
spring: datasource: username: root password: 123456 url: jdbc:mysql://localhost:3306/mybatis_plus?userSSL=false&Unicode=true&CharacterEncoding=utf-8&serverTimezone=GMT%2B8 driver-class-name: com.mysql.cj.jdbc.Driver
4.导入依赖
<?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> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.5.2</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.sxau</groupId> <artifactId>mybatis_plus</artifactId> <version>0.0.1-SNAPSHOT</version> <name>mybatis_plus</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!-- mysql-connector--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!-- mybatis-plus--> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.4.0</version> </dependency> <!-- lombok--> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
5.创建pojo包,新建User实体类
import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; @Data @NoArgsConstructor @AllArgsConstructor public class User { //主键自增配合 数据库主键自增使用 @TableId(type = IdType.AUTO) private Long id; private String name; private int age; private String email; }
6.创建mapper包,新建UserMapper实体类
package com.sxau.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.sxau.pojo.User; import org.springframework.stereotype.Repository; @Repository public interface Usermapper extends BaseMapper<User> { //所有CRUD操作已经完成 //不需要一大堆的。xml配置文件 }
7.在主启动类中加上Mapperscan注解扫描mapper映射文件
@MapperScan("com.sxau.mapper")
8.查询所有数据测试类
package com.sxau.mybatis_plus; import com.baomidou.mybatisplus.annotation.IdType; import com.sxau.mapper.Usermapper; import com.sxau.pojo.User; import org.junit.jupiter.api.Test; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.util.List; @MapperScan("com.sxau.mapper") @SpringBootTest class MybatisPlusApplicationTests { @Autowired Usermapper usermapper; @Test void contextLoads() { List<User> users = usermapper.selectList(null); users.forEach(System.out::println); } }
遇到这种情况,直接解决
9.开启mybatis-plus日志配置文件
#mybatis-plus日志配置文件 mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
10.主键生成策略
默认 ID_WORKER 全局唯一id
对应数据库中的主键(uuid.自增id.雪花算法.redis.zookeeper)
分布式系统唯一id生成:https://www.cnblogs.com/haoxinyue/p/5208136.html
雪花算法😦Twitter的snowflake算法)
snowflake是Twitter开源的分布式ID生成算法,结果是一个long型的ID。其核心思想是:使用41bit作为毫秒数,10bit作为机器的ID(5个bit是数据中心,5个bit的机器ID),12bit作为毫秒内的流水号(意味着每个节点在每毫秒可以产生 4096 个 ID),最后还有一个符号位,永远是0.可以保证几乎全球唯一
public enum IdType { AUTO(0),//数据库ID自增 NONE(1),//该类型为未设置主键类型 INPUT(2),//手动输入ID //该类型可以通过自己注册自动填充插件进行填充 //以下3种类型、只有当插入对象ID 为空,才自动填充。 ID_WORKER(3),//全局唯一ID (idWorker) UUID(4),//全局唯一ID (UUID) ID_WORKER_STR(5);//字符串全局唯一ID (idWorker 的字符串表示) }
11.增加数据测试类
//主键自增配合 数据库主键自增使用 @TableId(type = IdType.AUTO)
自增搭配使用
12.修改数据测试类
@Test void updateUser(){ User user = new User(); user.setId(new Long(201916129)); // user.setName("张三"); user.setAge(18); usermapper.updateById(user); }
动态拼接sql—简化了平常动态配置sql的麻烦问题
13.自动填充
方式一:数据库级别
设置默认时间,在navicat创建数据库的时候想要该字段的值为插入数据时候的时间:
在default中写:CURRENT_TIMESTAMP即可
private Date createTime; //开始时间 private Date updateTime; //更新时间
方式
二:代码级别
全部设置为null
@TableField(fill = FieldFill.INSERT) private Date createTime; //开始时间 @TableField(fill = FieldFill.INSERT_UPDATE) private Date updateTime; //更新时间
编写handle包,新建myMetaObjectHandle.java
package com.sxau.handle; 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 myMetaObjectHandle implements MetaObjectHandler { //插入时的填充策略 @Override public void insertFill(MetaObject metaObject) { log.info("Start insert fill.... "); 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); } }
非常关键的一步
在springboot启动的主类上加载component组件
@ComponentScan("com.sxau.handle")
测试类
@Test void insertUser(){ User user = new User(); // user.setId(new Long(201916127)); user.setName("渣渣辉"); user.setAge(10); user.setEmail("1016942589@qq.com"); usermapper.insert(user); System.out.println(user.toString()); } @Test void updateUser(){ User user = new User(); user.setId(new Long(201916137)); user.setName("李丽"); user.setAge(20); usermapper.updateById(user); }
14.乐观锁&悲观锁
乐观锁: 顾名思义十分乐观,他总是认为不会出现问题,无论干什么都不去上锁!如果出现了问题,再次更新值测试
悲观锁;顾名思义十分悲观,他总是认为出现问题,无论干什么都会上锁!再去操作!
我们这里主要讲解 乐观锁机制!
乐观锁实现方式:
- 取出记录时,获取当前version
- 更新时,带上这个version
- 执行更新时,set version = newVersion where version = oldVersion
- 如果version不对,就更新失败
15.查询操作
//测试批量查询 @Test public void selectByBatchId(){ List<User> users = usermapper.selectBatchIds(Arrays.asList(1, 2, 3)); users.forEach(System.out::println); } //多条件查询用map @Test public void selectByBatchIds(){ HashMap<String, Object> map = new HashMap<>(); map.put("age",20); List<User> users = usermapper.selectByMap(map); for (User user : users) { System.out.println(user); } }