04-CURD

2023-02-16

Insert

@Test//测试插入
public void insertTest(){
User user = new User();
user.setName("wsk");
user.setAge(18);
user.setEmail("2803708553@qq.com");
Integer result = userMapper.insert(user); //会帮我们自动生成id
System.out.println(result); //受影响的行数
System.out.println(user); //通过日志发现id会自动回填
}

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

主键生成策略

源码解释

public enum IdType {
AUTO, //数据库id自增
INPUT, //手动输入
ID_WORKER, //默认的全局唯一id
UUID, //全局唯一id uuid
NONE;//未设置主键
}

默认 : ID_WORKER 全局唯一Id

分布式系统唯一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。

具体实现的代码可以参看https://github.com/twitter/snowflake。

主键自增:AUTO 我们需要配置主键自增

我们需要配置主键自增

在实体类字段上配置@TableId(type = IdType.AUTO)
数据库字段一定是自增

手动输入:INPUT 就需要自己写id

在实体类字段上配置@TableId(type = IdType.INPUT)

Update

@Test//测试更新
public void updateTest(){
User user = new User();
user.setId(2L);//怎么改id??
//通过条件自动拼接动态Sql
user.setName("root");
user.setAge(12);
user.setEmail("root@qq.com");
int i = userMapper.updateById(user);//updateById,但是参数是个user
System.out.println(i);
}

自动填充

创建时间、更改时间! 这些操作一般都是自动化完成,我们不希望手动更新

阿里巴巴开发手册︰几乎所有的表都要配置 gmt_create、gmt_modified !而且需要自动化

方式一:数据库级别(工作中不允许修改数据库级别)

1、在表中增加字段:create_time,update_time

在该字段默认值处填写:CURRENT_TIMESTAMP

2、再次测试插入或更新方法,我们需要在实体类中同步!

private Date createTime;//驼峰命名
private Date updateTime;

方式二:代码级别

    删除数据库默认值、更新操作

    实体类字段属性上需要添加注解
// 字段添加填充内容
@TableField(fill = FieldFill.INSERT)
private Date createTime;
@TableField(fill = FieldFill.INSERT_UPDATE)
private Date updateTime;
    编写处理器来处理这个注解即可
@Slf4j // 打印日志注解
@Component // 一定不要忘记把处理器添加到IOC容器中
public class MyMetaObjectHandler 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);
}
}
    测试插入/更新,观察时间
	@Test//测试更新
public void updateTest(){
User user = new User();
user.setId(2L);//怎么改id??
//通过条件自动拼接动态Sql
user.setName("小枫");
user.setAge(12);
user.setEmail("update@qq.com");
int i = userMapper.updateById(user);//updateById,但是参数是个user
System.out.println(i);
} @Test
public void InsertUser() {
User user = new User();
user.setAge(56);
user.setEmail("xiaofang@qq.com");
user.setName("小芳");
int insert = userMapper.insert(user);
System.out.println(insert);
}

![4}O`XA@R}_@YL4X_1C3IT2.png

乐观锁

在面试过程中经常被问到乐观锁/悲观锁,这个其实很简单

乐观锁:顾名思义十分乐观,他总是认为不会出现问题,无论干什么都不上锁!如果出现了问题,再次更新值测试

悲观锁:顾名思义十分悲观,他总是认为出现问题,无论干什么都会上锁!再去操作!

我们这里主要讲解 乐观锁机制!

乐观锁实现方式:

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

// 乐观锁:先查询,获得版本号
-- A
update user set name = "wsk",version = version+1
where id = 1 and version = 1
-- B (B线程抢先完成,此时version=2,会导致A线程修改失败!)
update user set name = "wsk",version = version+1
where id = 1 and version = 1
    给数据库中增加version字段

    实体类加对应的字段
//乐观锁version注解
@Version
private Integer version;
    注册组件
//扫描mapper文件夹
@MapperScan("com.yefeng.mapper")//交给mybatis做的,可以让这个配置类做扫描
@EnableTransactionManagement//自动管理事务
@Configuration//配置类
public class MyBatisPlusConfig {
//注册乐观锁插件
@Bean
public OptimisticLockerInterceptor optimisticLockerInterceptor(){
return new OptimisticLockerInterceptor();
}
}
    测试一下

成功

	@Test
void TestOptimisticLocker() {
User user = userMapper.selectById(1L);
user.setName("请带好口罩");
user.setAge(8);
userMapper.updateById(user);
}

失败

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

select

通过id查询单个用户

	@Test
void testSelectById() {
User user = userMapper.selectById(1L);
System.out.println(user);
}

通过id查询多个用户

	@Test//通过id查询多个用户
public void testSelectBatchIds(){
List<User> users = userMapper.selectBatchIds(Arrays.asList(1L, 2L, 3L));
users.forEach(System.out::println);
}

![CZTLJOFI%UZ6E{)$4F{8_A.png

条件查询 通过map封装

	@Test//通过条件查询之一  map
public void testMap(){
HashMap<String, Object> map = new HashMap<>();
//自定义要查询的
map.put("name","yefeng");
map.put("age",21);
List<User> users = userMapper.selectByMap(map);
users.forEach(System.out::println);
}

分页查询

分页在网站的使用十分之多!

    原始的limit分页
    pageHelper第三方插件
    MybatisPlus其实也内置了分页插件!

如何使用:

    配置拦截器组件
//分页插件
@Bean
public PaginationInterceptor paginationInterceptor() {
return new PaginationInterceptor();
}
    直接使用page对象即可
@Test//测试分页查询
public void testPage(){
//参数一current:当前页 参数二size:页面大小
//使用了分页插件之后,所有的分页操作都变得简单了
Page<User> page = new Page<>(1,5);
userMapper.selectPage(page,null);
page.getRecords().forEach(System.out::println);
System.out.println("总页数==>"+page.getTotal());
System.out.println("当前页==>" + page.getCurrent());
}

![L(JNT2TL2}1LDJ3Z`D7%_S.png

delete

基本的删除任务:

    @Test
void testDeleteByID() {
userMapper.deleteById(1579109868562907137L);
} @Test
void testDeleteByIDs() {
userMapper.deleteById(1579109868562907137L);
} @Test
void testDeleteByMap() {
HashMap<String, Object> map = new HashMap<>();
map.put("name", "白轴");
userMapper.deleteByMap(map);
}

我们在工作中会遇到一些问题:逻辑删除!

逻辑删除

物理删除:从数据库中直接删除

逻辑删除:在数据库中没有被删除,而是通过一个变量来使他失效! deleted=0 ==> deleted=1

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

测试一下:

    在数据表中增加一个deleted字段

![$2_430}YYNI[7%IRVQ_LZS.png

    实体类中添加对应属性
@TableLogic//逻辑删除注解 3.3.0版本之后不需要添加
private Integer deleted;
    配置

配置类

//逻辑删除组件
@Bean
public ISqlInjector sqlInjector(){
return new LogicSqlInjector();
}

配置yml

mybatis-plus:
# 配置逻辑删除
global-config:
db-config:
logic-delete-value: 1
logic-not-delete-value: 0 # 3.3.0 以上
mybatis-plus:
global-config:
db-config:
logic-delete-field: deleted # 全局逻辑删除的实体字段名,也可实体类字段上加上@TableLogic注解
logic-delete-value: 1 # 逻辑已删除值
logic-not-delete-value: 0 # 逻辑未删除值
    测试一下删除
	@Test
void testDeleteByID() {
userMapper.deleteById(1L);
}

发现: 记录还在,deleted变为1

再次测试查询被删除的用户,发现查询为空

自定义方法

如果我们想要写一些复杂的SQL语句,可以自定义一个映射文件

定义方法

//在对应的接口上面继承一个基本的接口 BaseMapper
@Repository//代表持久层
public interface UserMapper extends BaseMapper<User> {
//所有CRUD操作都编写完成了,不用像以前一样配置一大堆文件
// 自定义方法
Map<String, Object> selectMapByID(Long id);
}

创建映射文件

<?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.yefeng.mapper.UserMapper"> <select id="selectMapByID" resultType="map">
select * from user where id = #{id}
</select> </mapper>

设置映射器路径

mybatis-plus:
mapper-locations: classpath*:/mapper/*.xml

测试

	@Test
void testSelectMapByID() {
Map<String, Object> map = userMapper.selectMapByID(1L);
System.out.println(map);
}

以上所有的CRUD及其扩展操作,我们都必须精通掌握!会大大提高工作写项目的效率!

04-CURD的相关教程结束。

《04-CURD.doc》

下载本文的Word格式文档,以方便收藏与打印。