int page = 1;
int pageNum = 1000;
while (true){
    UserQueryRequest request = new UserQueryRequest();
    request.setPage(page);
    request.setPageSize(pageNum);
    PageInfo<User> pageInfo = userMapper.getUserPage(request);
    if (CollectionUtils.isEmpty(pageInfo.getList()) ){
        break;
    }
    List<User> userList = pageInfo.getList();
    // 具體的處理邏輯 省略
    page ++;
}

<select id="selectUsers" resultType="User" fetchSize="1000">
   SELECT userId from t_user
 </select>

import lombok.extern.slf4j.Slf4j;
import model.User;
import org.apache.ibatis.session.ResultContext;
import org.apache.ibatis.session.ResultHandler;
import java.util.ArrayList;
import java.util.List;

/**
 * @author: jie
 * @create: 2023/3/29 16:51
 * @description:
 */
@Slf4j
public class SyncDataHandler implements ResultHandler<User> {

    /**
     * 每批處理數(shù)量
     */
    private final static int BATCH_SIZE = 1000;

    /**
     * 緩存數(shù)據(jù)
     */
    private List<User> cacheList = new ArrayList<>();

    /**
     * 同步熟慮
     */
    private int total = 0;


    @Override
    public void handleResult(ResultContext<? extends User> resultContext) {
        User coreInfoCyDTO =  resultContext.getResultObject();
        this.cacheList.add(coreInfoCyDTO);
        //每到達(dá)BATCH_SIZE 條數(shù)據(jù)處理一次
        if (this.cacheList.size() >= BATCH_SIZE) {
            this.handle();
        }
        total++;
    }


    /**
     * 處理緩存數(shù)據(jù)
     */
    private void handle() {
        try {
            // 具體的處理邏輯 省略
        } finally {
            // 清除處理過(guò)的緩存數(shù)據(jù)
            this.cacheList.clear();
        }
    }

    /**
     * 處理最后一批沒(méi)有進(jìn)行處理的數(shù)據(jù)
     */
    public int end() {
        this.end();
        return total;
    }
}

SyncDataHandler syncDataHandler = new SyncDataHandler();
userMapper.getUserList("selectUsers", syncDataHandler);
syncDataHandler.end();