标签：saveOrUpdate mybatisplus baomidou param entity 3.4 plus import com

• service类通过 SqlHelper.saveOrUpdateBatch 实现通过自定义的 唯一索引 进行 批量保存更新

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.enums.SqlMethod;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.ReflectionKit;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import org.apache.ibatis.binding.MapperMethod;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import cn.com.redboard.modules.mi.base.entity.MesProdMiProc;
import cn.com.redboard.modules.mi.base.mapper.MesProdMiProcMapper;
import cn.com.redboard.modules.mi.base.service.IMesProdMiProcService;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * @Description: MI工艺流程Service
 * @Author: wqc
 * @Date:   2022-03-01
 * @Version: V1.0
 */
@Service
public class MesProdMiProcServiceImpl extends ServiceImpl<MesProdMiProcMapper, MesProdMiProc> implements IMesProdMiProcService {

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
    public void sync(List<MesProdMiProc> prodMiProcList) {

        // 每2000条语句，进行一次sqlSession.flushStatements()
        SqlHelper.saveOrUpdateBatch(this.entityClass, this.mapperClass, this.log, prodMiProcList, 2000, (sqlSession, entity) -> {
            MapperMethod.ParamMap param = new MapperMethod.ParamMap();

            Object erpProcessId = ReflectionKit.getFieldValue(entity, ${otherUniqueIdx});
            LambdaQueryWrapper<MesProdMiProc> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.eq(MesProdMiProc::getErpProcessId, erpProcessId);
            // 自定义查询条件
            param.put("ew", queryWrapper);

            // 判断记录是否存在，存在则更新，否则插入
            return StringUtils.checkValNull(erpProcessId) || CollectionUtils.isEmpty(sqlSession.selectList(this.getSqlStatement(SqlMethod.SELECT_LIST), param));
        }, (sqlSession, entity) -> {
            MapperMethod.ParamMap param = new MapperMethod.ParamMap();
            // 需要更新的当前记录实体
            param.put("et", entity);

            LambdaQueryWrapper<MesProdMiProc> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.eq(MesProdMiProc::getErpProcessId, ReflectionKit.getFieldValue(entity, ${otherUniqueIdx}));

            // 自定义查询条件

            param.put("ew", queryWrapper);

            sqlSession.update(this.getSqlStatement(SqlMethod.UPDATE), param);
        });

    }

}

• SqlHelper.saveOrUpdateBatch具体源码

• SqlHelper.executeBatch具体源码
  

   

   

  
  

标签：saveOrUpdate,mybatisplus,baomidou,param,entity,3.4,plus,import,com
来源： https://www.cnblogs.com/Icwq007/p/16055076.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。