快捷導(dǎo)航

mybatis-plus調(diào)用update方法時(shí),自動(dòng)填充字段不生效問(wèn)題及解決

更新時(shí)間：2024年06月05日 10:59:54 作者：遠(yuǎn)離bug，珍愛(ài)頭發(fā)

這篇文章主要介紹了mybatis-plus調(diào)用update方法時(shí),自動(dòng)填充字段不生效問(wèn)題及解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

項(xiàng)目場(chǎng)景

做定時(shí)任務(wù)，查詢出數(shù)據(jù)后，將他發(fā)往mq隊(duì)列，如果搭建集群相同的數(shù)據(jù)就會(huì)執(zhí)行多次，所以使用樂(lè)觀鎖解決，同時(shí)需要更改更新時(shí)間一列，直接使用mybatisPlus的公共字段填充和樂(lè)觀鎖

問(wèn)題描述

配置好mp的樂(lè)觀鎖和公共字段填充后，執(zhí)行update語(yǔ)句，正常應(yīng)該是

UPDATE tb_task SET update_time=?，version=? WHERE (version = ? AND id = ?)

結(jié)果變成了

UPDATE tb_task SET WHERE (version = ? AND id = ?)

因?yàn)槌诉@兩個(gè)字段沒(méi)有其他需要修改的字段所以直接就報(bào)錯(cuò)了，這么一看肯定是樂(lè)觀鎖和公共字段填充都失效了啊。

@Scheduled(cron = "0 0/1 * * * ?")
    public void addCourseTask(){
        //查詢1分鐘之前的數(shù)據(jù)
        List<TbTask> list = tbTaskService.findBeforeMinuteList();
        for (TbTask tbTask : list) {
            //根據(jù)id version修改
            LambdaUpdateWrapper<TbTask> wrapper = new LambdaUpdateWrapper<>();
            wrapper.eq(TbTask::getId,tbTask.getId());
                    //.set(TbTask::getVersion,tbTask.getVersion()+1);
            //數(shù)據(jù)庫(kù)中的樂(lè)觀鎖， 防止集群下的訂單，重復(fù)向mq中發(fā)送數(shù)據(jù)
            if (tbTaskService.update(wrapper)) {
                String mqExchange = tbTask.getMqExchange();
                String mqRoutingkey = tbTask.getMqRoutingkey();
                //向mq發(fā)送消息
                rabbitTemplate.convertAndSend(mqExchange, mqRoutingkey, JSON.toJSONString(tbTask));

            }


        }
    }

原因分析

檢查了幾遍確定mp的樂(lè)觀鎖和公共字段填充都沒(méi)有問(wèn)題

樂(lè)觀鎖

1.配置樂(lè)觀鎖插件(mp是3.5.1的)

@Configuration
@MapperScan("com.xly.mapper") //掃描mapper接口所在包
public class MybatisPlusConfig {

    @Bean
    //配置分頁(yè)插件
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        //分頁(yè)
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        //樂(lè)觀鎖
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;

    }
}

2.字段上打注解

@TableField(value = "version")
    @Version
    private Integer version;

公共字段填充

1.實(shí)現(xiàn)MetaObjectHandler的公共填充類

@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    //mp執(zhí)行添加操作，這個(gè)方法執(zhí)行
    @Override
    public void insertFill(MetaObject metaObject) {
        metaObject.setValue("createTime",new Date());
        metaObject.setValue("updateTime",new Date());
    }

    //mp執(zhí)行修改操作，這個(gè)方法執(zhí)行
    @Override
    public void updateFill(MetaObject metaObject) {
        metaObject.setValue("updateTime",new Date());
    }
}

2.在字段上添加fill屬性

@TableField(value = "create_time",fill = FieldFill.INSERT)
    private Date createTime;
    @TableField(value = "update_time",fill = FieldFill.INSERT_UPDATE)
    private Date updateTime;

經(jīng)過(guò)查找資料后發(fā)現(xiàn)使用boolean update(Wrapper updateWrapper)這個(gè)方法，自動(dòng)填充會(huì)失效

大概原理就是boolean update(Wrapper updateWrapper)的底層實(shí)現(xiàn)為:

default boolean update(Wrapper<T> updateWrapper) {
        return this.update((Object)null, updateWrapper);
    }

而屬性自動(dòng)填充需要從第一個(gè)參數(shù)獲取Object實(shí)體類，自動(dòng)填充的核心方法:populateKeys中會(huì)判斷

if (null == tableInfo) {
            /* 不處理 */
            return parameterObject;
        }

tableInfo就是獲取的實(shí)體類對(duì)象，所以導(dǎo)致屬性自動(dòng)填充失效。

解決方案

我使用的是上面文章建議的方案一，也是最簡(jiǎn)單的方式:

使用update的重載方法

boolean update(T entity， Wrapper updateWrapper)

修改后的代碼如下：

@Scheduled(cron = "0 0/1 * * * ?")
    public void addCourseTask(){
        //查詢1分鐘之前的數(shù)據(jù)
        List<TbTask> list = tbTaskService.findBeforeMinuteList();
        for (TbTask tbTask : list) {
            //根據(jù)id version修改
            LambdaUpdateWrapper<TbTask> wrapper = new LambdaUpdateWrapper<>();
            wrapper.eq(TbTask::getId,tbTask.getId());
                    //.set(TbTask::getVersion,tbTask.getVersion()+1);
            //數(shù)據(jù)庫(kù)中的樂(lè)觀鎖， 防止集群下的訂單，重復(fù)向mq中發(fā)送數(shù)據(jù)
            if (tbTaskService.update(tbTask,wrapper)) {
                String mqExchange = tbTask.getMqExchange();
                String mqRoutingkey = tbTask.getMqRoutingkey();
                //向mq發(fā)送消息
                rabbitTemplate.convertAndSend(mqExchange, mqRoutingkey, JSON.toJSONString(tbTask));

            }


        }
    }

執(zhí)行sql語(yǔ)句：

UPDATE tb_task
SET create_time=?， update_time=?， delete_time=?， task_type=?， mq_exchange=?， mq_routingkey=?， request_body=?， status=?， version=? WHERE (version = ? AND id = ?)