Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

分批次插入

Browse Source
This commit is contained in:
hzj
2025-03-12 11:31:05 +08:00
parent e2bbfb5e08
commit 21035dc71b
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java
View File

@@ -18,6 +18,7 @@ import com.njcn.prepare.harmonic.service.mysql.cvt.CvtJobLogService;
import com.njcn.prepare.harmonic.service.mysql.cvt.IDataHarmRateVCvtService; import com.njcn.prepare.harmonic.service.mysql.cvt.IDataHarmRateVCvtService;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.ListUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@@ -111,7 +112,13 @@ public class DataHarmRateVCvtServiceImpl implements IDataHarmRateVCvtService {
result.addAll(dataVCvtDtoList); result.addAll(dataVCvtDtoList);
}); });
dataHarmRateVMapper.insertBatch(result); List<List<DataHarmRateV>> partition = ListUtils.partition(result, 5000);
for (List<DataHarmRateV> dataHarmRateVList : partition) {
List<DataHarmRateV> sublistAsOriginalListType = new ArrayList<>(dataHarmRateVList);
dataHarmRateVMapper.insertBatch(sublistAsOriginalListType);
}
stopWatch.stop(); stopWatch.stop();
one.setRowCount(result.size()); one.setRowCount(result.size());
one.setState(1); one.setState(1);