SpringBoot整合MyBatis-Plus乐观锁不生效的问题及解决方法

目录

• SpringBoot整合Myabtis-Plus
• 1、依赖导入
• 2、数据库插入
• 3、SpringBoot各个层次的操作
• 3.1、实体类
• 3.2、configuration
• 3.2.1、TableField的insert与update
• 3.2.2、乐观锁配置
• 3.3、mapper层
• 3.4、service层
• 4、控制层测试
• 4.1、查询所有
• 4.2、根据id修改信息

SpringBoot整合Myabtis-Plus

在与官网配置一致的情况下依旧无法生效，如下整合mybatis-plus

1、依赖导入

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

其余的springboot与mysql相关的依赖就无需展示

配置文件配置

mybatis-plus:
  global-config:
    db-config:
      #      逻辑删除，删除标志
      logic-delete-value: 1
      #      逻辑删除，未删除标志
      logic-not-delete-value: 0
  type-aliases-package: com.fang.pojo
  configuration:
    #    mybatis-plus日志
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

2、数据库插入

数据库以此为例

DROP TABLE IF EXISTS sys_user;
CREATE TABLE rbac_plus.sys_user
(
    id INT AUTO_INCREMENT NOT NULL COMMENT '主键ID',
    name VARCHAR(50) NOT NULL COMMENT '名称',
    password VARCHAR(500) NOT NULL COMMENT '密码',
    email VARCHAR(200) NOT NULL  COMMENT '邮箱',
    state INT NOT NULL DEFAULT 0 COMMENT '状态，0为正常，1为异常',
    create_time DATETIME NOT NULL COMMENT '创建时间',
    update_time DATETIME  COMMENT '修改时间',
    deleted INT DEFAULT 0  COMMENT '假删除',
    version INT DEFAULT 1  COMMENT '乐观锁',
    PRIMARY KEY (id)
)ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='user表';
INSERT INTO `rbac_plus`.`sys_user` (`name`, `password`, `email`, `create_time`) VALUES ('一号', '123', '123@qq.com', CURRENT_DATE),
											('二号','234','234.qq.com',CURRENT_DATE),
											('三号','345','345.qq.com',CURRENT_DATE),
											('四号','456','456.qq.com',CURRENT_DATE),
											('五号','567','567.qq.com',CURRENT_DATE),
											('六号','678','678.qq.com',CURRENT_DATE);

3、SpringBoot各个层次的操作

3.1、实体类

/**
 * @author FPH
 * @since 2022.04.27 03点46分
 */
@Data
@TableName("sys_user")
public class SysUser implements Serializable {
    @TableId(type = IdType.AUTO)
    private Integer id;
    private String name;
    private String password;
    private String email;
    private Integer state;
    @TableField(fill = FieldFill.INSERT)
    private Date createTime;
    @TableField(fill = FieldFill.UPDATE)
    private Date updateTime;
    @TableLogic
    private Integer deleted;
    @Version
    private Integer version;

@TableName指定表名

@TableId指定表的主键，并且定义这是一个自增的主键

@TableField表示填充此属性，

@TableLogic表示假删除

@Version表示乐观锁

以上配置均将在configuration层中实现

3.2、configuration

3.2.1、TableField的insert与update

insert表示插入这一数据时，自动将当前时间填充至此属性

update表示修改此数据时，自动将当前时间填充

这里官网有告诉我们如何配置：

package com.fang.configuration;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
/**
 * @author FPH
 * @since 2022年4月27日04:17:56
 */
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        this.setFieldValByName("createTime",new Date(),metaObject);
    }
    @Override
    public void updateFill(MetaObject metaObject) {
        this.setFieldValByName("updateTime",new Date(),metaObject);
    }
}

3.2.2、乐观锁配置

官网也有指出如何配置

package com.fang.configuration;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
 * @author FPH
 * @since 2022.04.27 03点59分
 */
@Configuration
public class MybatisPlus {
    /**
     * 乐观锁
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
}

3.3、mapper层

package com.fang.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.fang.pojo.SysUser;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
 * @author FPH
 * @since 2022年4月27日04:04:16
 */
@Repository
public interface SysUserMapper extends BaseMapper<SysUser> {
}

3.4、service层

package com.fang.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.fang.pojo.SysUser;
import java.util.List;
/**
 * @author FPH
 * @since 2022年4月27日04:06:07
 */
public interface SysUserService extends IService<SysUser> {
}

实现类：

package com.fang.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fang.mapper.SysUserMapper;
import com.fang.pojo.SysUser;
import com.fang.service.SysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
 * @author FPH
 * @since 2022年4月27日04:07:58
 */
@Service("SysUserService")
public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> implements SysUserService {
    @Autowired
    private SysUserMapper sysUserMapper;
}

4、控制层测试

4.1、查询所有

package com.fang.controller;
import com.fang.pojo.SysUser;
import com.fang.service.SysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
 * @author FPH
 * @since 2022年4月27日04:09:41
 */
@RestController
@RequestMapping("/sysUser")
public class SysUserController {
    @Autowired
    private SysUserService sysUserService;

    @GetMapping("/baseSelAll")
    public List<SysUser> BaseSelectAll(){
        return sysUserService.list();
    }
}

ApiPost测试，能够成功获取全部的集合

这里可以发现service层无需写这种简单地查询语句，即可实现基本的sql功能

4.2、根据id修改信息

这里能发现有时候乐观锁不能生效，例如以下例子：

package com.fang.controller;
import com.fang.pojo.SysUser;
import com.fang.service.SysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
 * @author FPH
 * @since 2022年4月27日04:09:41
 */
@RestController
@RequestMapping("/sysUser")
public class SysUserController {
    @Autowired
    private SysUserService sysUserService;

    @PutMapping("updateById")
    public String updateById(SysUser sysUser){
        return sysUserService.updateById(sysUser)+"";
    }
}

apiPost这样测试：

修改成功，但是去查看日志，发现并没有生效

乐观锁并没有自增

解决方案如下：

新增一个version

此时日志显示这样的信息：

数据库中成功自增

如果此时再修改，但version依旧是传1过去，则修改不成功

得出结论：version与当前数据库不一致则修改失败

所以我们需要在每次修改时，传入一个version，通过id查询当前version的值，在通过set传入实体类中一起发送到mybatisPlus自带的修改方法中，则能实现乐观锁

到此这篇关于关于SpringBoot整合MyBatis-Plus乐观锁不生效的问题解决方案的文章就介绍到这了,更多相关SpringBoot整合MyBatis-Plus乐观锁内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！