快捷導(dǎo)航

mybatis-plus根據(jù)任意字段saveOrUpdateBatch更新插入的方法實(shí)現(xiàn)

更新時(shí)間：2026年04月02日 10:14:41 作者：凱醬

Iservice接口下的saveOrUpdateBatch方法默認(rèn)是根據(jù)主鍵來決定是要更新還是插入的,本文就來詳細(xì)的介紹一下saveOrUpdateBatch的使用,感興趣的可以來了解一下

mybatisplus Iservice接口下的saveOrUpdateBatch方法默認(rèn)是根據(jù)主鍵來決定是要更新還是插入的，如果要根據(jù)其他字段（必須是唯一約束，唯一約束字段可以是多個(gè)）更新的話，則需要在項(xiàng)目的service層重寫該方法。

方法源碼

@Transactional(
        rollbackFor = {Exception.class}
    )
    public boolean saveOrUpdateBatch(Collection<T> entityList, int batchSize) {
        TableInfo tableInfo = TableInfoHelper.getTableInfo(this.entityClass);
        Assert.notNull(tableInfo, "error: can not execute. because can not find cache of TableInfo for entity!", new Object[0]);
        String keyProperty = tableInfo.getKeyProperty();
        Assert.notEmpty(keyProperty, "error: can not execute. because can not find column for id from entity!", new Object[0]);
        return SqlHelper.saveOrUpdateBatch(this.entityClass, this.mapperClass, this.log, entityList, batchSize, (sqlSession, entity) -> {
            Object idVal = ReflectionKit.getFieldValue(entity, keyProperty);
            return StringUtils.checkValNull(idVal) || CollectionUtils.isEmpty(sqlSession.selectList(this.getSqlStatement(SqlMethod.SELECT_BY_ID), entity));
        }, (sqlSession, entity) -> {
            MapperMethod.ParamMap<T> param = new MapperMethod.ParamMap();
            param.put("et", entity);
            sqlSession.update(this.getSqlStatement(SqlMethod.UPDATE_BY_ID), param);
        });
    }

從源碼中可以看出實(shí)現(xiàn)saveOrUpdateBatch的主要方法就是SqlHelper.saveOrUpdateBatch

public static <E> boolean saveOrUpdateBatch(Class<?> entityClass, Class<?> mapper, Log log, Collection<E> list, int batchSize, BiPredicate<SqlSession, E> predicate, BiConsumer<SqlSession, E> consumer) {
        String sqlStatement = getSqlStatement(mapper, SqlMethod.INSERT_ONE);
        return executeBatch(entityClass, log, list, batchSize, (sqlSession, entity) -> {
            if (predicate.test(sqlSession, entity)) {
                sqlSession.insert(sqlStatement, entity);
            } else {
                consumer.accept(sqlSession, entity);
            }
        });
    }

該方法的最后兩個(gè)參數(shù)predicate，consumer
predicate 這個(gè)函數(shù)是用于判斷是否要進(jìn)行插入操作 true插入，false：則通過consumer 函數(shù)執(zhí)行更新

方法改造

注意：寫在項(xiàng)目操作對(duì)應(yīng)表的service層
首先在service層定義接口

boolean saveOrUpdateBatchByAgentIdAndPeriodAndType(List<Entity> list);

類為數(shù)據(jù)庫表對(duì)應(yīng)的實(shí)體類，agentId，period，type，這個(gè)三個(gè)字段為表的唯一約束，即當(dāng)表中存在這三個(gè)字段組合對(duì)應(yīng)的記錄時(shí)則進(jìn)行更新操作，不存在則進(jìn)行插入操作
service層接口實(shí)現(xiàn)

@Transactional(rollbackFor = Exception.class)
    @DS("XXXX")//如果為多數(shù)據(jù)源，這里要指明具體操作的數(shù)據(jù)源名稱
    public boolean saveOrUpdateBatchByAgentIdAndPeriodAndType(List<Entity> list) {
        return SqlHelper.saveOrUpdateBatch(entityClass, this.mapperClass, super.log, list, DEFAULT_BATCH_SIZE, (sqlSession, entity) -> {//這里主要是查詢唯一約束對(duì)應(yīng)的記錄是否存在
            LambdaQueryWrapper<Entity> queryWrapper = Wrappers.<Entity>lambdaQuery()
                    .eq(Entity::getAgentId, entity.getAgentId()).eq(Entity::getPeriod,entity.getPeriod())
                    .eq(Entity::getType,entity.getType());
            Map<String, Object> map = CollectionUtils.newHashMapWithExpectedSize(1);
            map.put(Constants.WRAPPER, queryWrapper);
            return CollectionUtils.isEmpty(sqlSession.selectList(getSqlStatement(SqlMethod.SELECT_LIST), map));
        }, (sqlSession, entity) -> {
            LambdaUpdateWrapper<Entity> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
            lambdaUpdateWrapper.eq(Entity::getAgentId, entity.getAgentId()).eq(Entity::getPeriod,entity.getPeriod())
                    .eq(Entity::getType,entity.getType());
            Map<String, Object> param = CollectionUtils.newHashMapWithExpectedSize(2);
            param.put(Constants.ENTITY, entity);
            param.put(Constants.WRAPPER, lambdaUpdateWrapper);
            sqlSession.update(getSqlStatement(SqlMethod.UPDATE), param);
        });
    }

非批量的saveOrUpdate也可以按照這種方式進(jìn)行改造

到此這篇關(guān)于mybatis-plus根據(jù)任意字段saveOrUpdateBatch更新插入的方法實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)mybatis-plus saveOrUpdateBatch內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: