当前位置: 首页 > news >正文

【异常】因为忘加了租户查询条件,导致重复ID导入失败Duplicate entry ‘XXX‘ for key ‘PRIMARY‘

一、异常说明

 Error updating database.  Cause: java.sql.SQLIntegrityConstraintViolationException: Duplicate entry '670' for key 'PRIMARY'The error may exist in /mall/admin/mapper/GoodsCategoryMapper.java (best guess)The error may involve .admin.mapper.GoodsCategoryMapper.insert-InlineThe error occurred while setting parametersSQL: INSERT INTO goods_category (id, tenant_id, enable, parent_id, name, sort, create_time, update_time, del_flag) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)Cause: java.sql.SQLIntegrityConstraintViolationException: Duplicate entry '670' for key 'PRIMARY'
; Duplicate entry '670' for key 'PRIMARY'; nested exception is java.sql.SQLIntegrityConstraintViolationException: Duplicate entry '670' for key 'PRIMARY'at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:247)at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:70)at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:91)at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:441)at com.sun.proxy.Proxy185.insert(Unknown Source)

二、看看代码逻辑

出错的代码逻辑,其实就是个存类目信息到数据库的逻辑

public void saveGoodsCategory(GoodsCategoryImportDTO goodsCategoryImportDTO) {JSONArray goodsCategoryJsonArray = getJSONArray(goodsCategoryImportDTO);for (int i = 0; i < goodsCategoryJsonArray.size(); i++) { List<GoodsCategory> goodsCategoryList = baseMapper.selectList(Wrappers.<GoodsCategory>lambdaQuery().eq(GoodsCategory::getId, JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("id")));//重复类目数据的过滤if (ObjectUtil.isNotEmpty(goodsCategoryList)) {log.info("重复类目数据:levelOneCategoryId = [{}],导入失败,类目数据记录已经存在", goodsCategoryImportDTO.getLevelOneCategoryId());continue;}GoodsCategory goodsCategory = new GoodsCategory();goodsCategory.setId(JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("id"));goodsCategory.setName(JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("name"));goodsCategory.setParentId(JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("parentId"));int sortSize = getSort(GOODS_CATEGORY_JD_KEY);goodsCategory.setSort(sortSize);addSize(GOODS_CATEGORY_JD_KEY);goodsCategory.setTenantId(jDConfigProperties.getTenantId());goodsCategory.setEnable(CommonConstants.YES);goodsCategory.setCreateTime(LocalDateTime.now());goodsCategory.setDelFlag(DelFlagEnum.SHOW.getValue());goodsCategory.setDescription(ProductChannelEnum.JINGDONG.getDesc());baseMapper.insert(goodsCategory);}
}

因为ID设置了主键,因此,当ID重复时,就会提示已经重复了,Duplicate entry '670' for key 'PRIMARY'
故,新增了如下查询逻辑, 用于插入前判断,防止重复导入。

List<GoodsCategory> goodsCategoryList = baseMapper.selectList(Wrappers.<GoodsCategory>lambdaQuery().eq(GoodsCategory::getId, JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("id"))
);
//重复类目数据的过滤
if (ObjectUtil.isNotEmpty(goodsCategoryList)) {log.info("重复类目数据:levelOneCategoryId = [{}],导入失败,类目数据记录已经存在", goodsCategoryImportDTO.getLevelOneCategoryId());continue;
}

但是,这段逻辑,却永远不会进入到if判断语句中。这样就不会按照语句希望的那样,继续下一个循环。
那,为什么不会进到if判断语句中呢?原因就肯定是那段Mybatis的逻辑有问题啦。
怎么看Mybatis的实时输出的SQL脚本呢?IDEA有个插件能帮到你。
【项目实战】IDEA插件推荐——Mybatis Log Plugin查看Mybatis实时输出的SQL脚本

因为项目是基于多租户架构实现的,因此我们编写的Mybatis的脚本一般都需要加上租户信息,才能查询出来结果

本项目中多租户的实现方式,见以下技术文章
【项目实战】商城中多租户功能逻辑设计

三、问题解决

定位了问题,解决就快了呢。直接加上租户进查询条件即可,如下

 @Override
public void saveGoodsCategoryShop(GoodsCategoryImportDTO goodsCategoryImportDTO) {JSONArray goodsCategoryJsonArray = getJSONArray(goodsCategoryImportDTO);for (int i = 0; i < goodsCategoryJsonArray.size(); i++) {// 设置租户IDTenantContextHolder.setTenantId(jDConfigProperties.getTenantId());List<GoodsCategoryShop> goodsCategoryShopList = baseMapper.selectList(Wrappers.<GoodsCategoryShop>lambdaQuery().eq(GoodsCategoryShop::getId, JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("id")));//重复类目数据的过滤if (ObjectUtil.isNotEmpty(goodsCategoryShopList)) {log.info("重复店铺类目数据:levelOneCategoryId = [{}],导入失败,店铺类目数据记录已经存在", goodsCategoryImportDTO.getLevelOneCategoryId());continue;}GoodsCategoryShop goodsCategoryShop = new GoodsCategoryShop();goodsCategoryShop.setId(JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("id"));goodsCategoryShop.setName(JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("name"));goodsCategoryShop.setParentId(JSONUtil.parseObj(goodsCategoryJsonArray.get(i)).getStr("parentId"));int sortSize = getSort(GOODS_CATEGORY_SHOP_JD_KEY);goodsCategoryShop.setSort(sortSize);addSize(GOODS_CATEGORY_SHOP_JD_KEY);goodsCategoryShop.setShopId(jDConfigProperties.getShopId());goodsCategoryShop.setTenantId(jDConfigProperties.getTenantId());goodsCategoryShop.setEnable(CommonConstants.YES);goodsCategoryShop.setCreateTime(LocalDateTime.now());goodsCategoryShop.setDelFlag(DelFlagEnum.SHOW.getValue());goodsCategoryShop.setDescription(ProductChannelEnum.JINGDONG.getDesc());baseMapper.insert(goodsCategoryShop);}
}

注意:重点是加了这一句!

 // 设置租户ID
TenantContextHolder.setTenantId(jDConfigProperties.getTenantId());

加了之后,就可以正常进if分支咯。至此,问题解决!

http://www.lryc.cn/news/18062.html

相关文章:

  • 证明CPU指令是乱序执行的
  • css 属性和属性值的定义
  • Python获取中国大学MOOC某课程评论及其参与人数
  • 【C++】类和对象(完结篇)
  • 低代码开发可以解决哪些问题?
  • Linux 中使用 docker-compose 部署 MongoDB 6 以上版本副本集及配置 SSL / TLS 协议
  • JavaWeb--Mybatis练习
  • Springer-MTA期刊上传Latex要求
  • Graph Embedding基础 图表示学习 什么是Graph Embedding
  • 某直聘tp_token解析
  • 替代启攀微8按键触控八通道触摸芯片-GTC08L
  • Zabbix“专家坐诊”第182期问答汇总
  • PHP、Nginx、openssl ECC证书搭建
  • 秒杀服务------技术点及亮点
  • 【Python数据挖掘入门】一、数据挖掘概况
  • 【python】anaconda 管理 python 环境
  • 线上插画培训班有用吗,教你选靠谱的插画课程
  • 吃鸡用什么蓝牙耳机效果好?手游吃鸡公认最好的几款蓝牙耳机
  • 四个步骤在CRM系统中设置游戏化机制
  • 2023年TikTok营销如何破局?品牌应做好这6点
  • 2023年CDGA考试-第5章-数据建模和设计(含答案)
  • 蓝桥杯入门即劝退(二十)快乐数(我不快乐了)
  • Aspose.Imaging for .NET V23
  • 通信算法复习题纲
  • 交叉编译 MQTT/Mosquitto
  • 无重复字符的最长子串的解法
  • Apache Hadoop生态部署-zookeeper单机安装
  • java面试题-IO流
  • Java性能-GC工具
  • 复赛名单公布!2022隐私计算HACKATHON大赛火热进行中!