GTsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(sj_1.3.0-beta1): 批量分页删除，只select id列

Browse Source
This commit is contained in:
dhb52 2024-11-22 17:10:29 +08:00
parent 1900d6dbf1
commit d8b7c53c8f
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobClearLogSchedule.java
View File

@ -120,7 +120,9 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle {
Lists.partition(ids, 500).forEach(jobTaskBatchMapper::deleteByIds); Lists.partition(ids, 500).forEach(jobTaskBatchMapper::deleteByIds);
// Waiting for deletion JobTaskList // Waiting for deletion JobTaskList
List<JobTask> jobTaskList = jobTaskMapper.selectList(new LambdaQueryWrapper<JobTask>().in(JobTask::getTaskBatchId, ids)); List<JobTask> jobTaskList = jobTaskMapper.selectList(new LambdaQueryWrapper<JobTask>()
.select(JobTask::getId)
.in(JobTask::getTaskBatchId, ids));
if (CollectionUtils.isEmpty(jobTaskList)) { if (CollectionUtils.isEmpty(jobTaskList)) {
return; return;
} }
@ -128,7 +130,9 @@ public class JobClearLogSchedule extends AbstractSchedule implements Lifecycle {
Lists.partition(jobTaskListIds, 500).forEach(jobTaskMapper::deleteByIds); Lists.partition(jobTaskListIds, 500).forEach(jobTaskMapper::deleteByIds);
// Waiting for deletion JobLogMessageList // Waiting for deletion JobLogMessageList
List<JobLogMessage> jobLogMessageList = jobLogMessageMapper.selectList(new LambdaQueryWrapper<JobLogMessage>().in(JobLogMessage::getTaskBatchId, ids)); List<JobLogMessage> jobLogMessageList = jobLogMessageMapper.selectList(new LambdaQueryWrapper<JobLogMessage>()
.select(JobLogMessage::getId)
.in(JobLogMessage::getTaskBatchId, ids));
if (CollectionUtils.isEmpty(jobLogMessageList)) { if (CollectionUtils.isEmpty(jobLogMessageList)) {
return; return;
} }