我在mysql数据库中有一个非常大的表，表中有2亿条记录 Users .
我使用jdbc进行查询：

public List<Pair<Long, String>> getUsersAll() throws SQLException {
        Connection cnn = null;
        CallableStatement cs = null;
        ResultSet rs = null;
        final List<Pair<Long, String>> res = new ArrayList<>();
        try {
            cnn = dataSource.getConnection();
            cs = cnn.prepareCall("select UserPropertyKindId, login from TEST.users;");
            rs = cs.executeQuery();
            while (rs.next()) {
                res.add(new ImmutablePair<>(rs.getLong(1), rs.getString(2)));
            }
            return res;
        } catch (SQLException ex) {
            throw ex;
        } finally {
            DbUtils.closeQuietly(cnn, cs, rs);
        }
    }

接下来，我处理结果：

List<Pair<Long, String>> users= dao.getUsersAll();
            if (CollectionUtils.isNotEmpty(users)) {
                for (List<Pair<Long, String>> partition : Lists.partition(users, 2000)) {
                    InconsistsUsers.InconsistsUsersCallable callable = new InconsistsUsers.InconsistsUsersCallable (new ArrayList<>(partition));
                    processExecutor.submit(callable);
                }
            }

但由于表非常大，而且都已卸载到内存中，因此我的应用程序会因以下错误而崩溃：
com.mysql.jdbc.exceptions.jdbc4.communicationsexception:通信链路故障
从服务器成功接收的最后一个数据包是105619毫秒前。
如何接收部分数据并按优先级顺序进行处理，以避免将所有结果一次上载到内存中？可以创建一个游标，将数据上传到非阻塞队列，并在数据到达时对其进行处理。如何做到这一点？
更新：
我的数据库结构：https://www.db-fiddle.com/f/v377zhkg1yzcdqsettpm9l/3
当前算法：
获取用户的所有数据 Users 表格： select UserPropertyKindId, login from Users; 此结果分成2000对，并提交给 ThreadPoolTaskExecutor :

List<Pair<Long, String>> users= dao.getUsersAll();

if (CollectionUtils.isNotEmpty(users)) {
    for (List<Pair<Long, String>> partition : Lists.partition(users, 2000)) {
        InconsistsUsers.InconsistsUsersCallable callable = new InconsistsUsers.InconsistsUsersCallable(new ArrayList<>(partition));
        processExecutor.submit(callable));
    }
}

在callable for each pair中进行两个查询：
第一个查询：

select distinct entityId 
from UserPropertyValue 
where userPropertyKindId= ? and value = ? -- value its login from Users table

第二个查询：

select UserIds 
from UserPropertyIndex 
where UserPropertyKindId = ? and Value = ?

可能有两种情况：
第一个查询的结果为空：记录、发送通知、继续下一对
第二个查询的结果不等于第一个查询的结果（varbinary data decoded）。存在存储的编码实体ID）。然后登录，发送通知，转到下一对。
我不能改变基地的结构。所有我必须在java代码方面做的操作。