批量插入限制优化

2024年9月27日11:13:24

modules/thing/src/main/java/com/thing/thing/dictRelation/service/impl/IotThingDictRelationServiceImpl.java

@@ -463,7 +463,7 @@ public class IotThingDictRelationServiceImpl extends BaseServiceImpl<IotThingDic
                     return dictRelation;
                 })).toList();
         if (CollectionUtils.isNotEmpty(insertList)) {
-            mapper.insertBatch(insertList);
+            mapper.insertBatch(insertList,1000);
             insertList.forEach(entity -> cache.updateAccurateKeyEntity(CacheNameEnum.THING_DICT_RELATION,
                     entity.getTenantCode()+CacheInit.KEY+entity.getEntityCode()+CacheInit.KEY+entity.getCode()+CacheInit.KEY+entity.getId(),ConvertUtils.sourceToTarget(entity, IotThingDictRelationDTO.class)));
         }