java 利用stream对比jdbc查询结果集过滤多余的key
程序员文章站
2022-04-08 22:49:03
...
背景描述:已知key大集合(基准),已知key小集合,需要将小集合的key存在在大集合中的key过滤掉,只剩下小集合中独有的key。
代码对比:
反面教材:
思路:循环小集合,得到每个key,然后拿这个key去查数据库,count为0加到新的list中。
//第一段得到全部结果集,queryP2F01DetailCount 查询数据库key是否有数据
private List<String> getInceasekey(String entName,JSONArray keyDataArray,String traceId){
List<String> list = new ArrayList<String>();
for (int i = 0; i < keyDataArray.size(); i++) {
JSONObject jsonObject = keyDataArray.getJSONObject(i);
String key = JSONTools.getString(jsonObject, "key");
int count = dao.queryP2F01DetailCount(entName,key);
if(count==0) list.add(key);
}
return list;
}
//
public int queryP2F01DetailCount(String entName, String pdescId) {
String sql = "select count(1) from ZAX_CPWS_LIST where pdescId = ? and entName= ?";
LOGGER.info(LogsUtils.getSqlLog(sql, new Object[] {pdescId,entName}));
return readJdbcTemplate.queryForObject(sql, int.class, new Object[] {pdescId,entName});
}
其实你不知道java8新特性 lambda 流概念 ,于是一次查库获取全部。
正解:先将大集合一次性查出得到一个list,然后循环小集合的key看是否包含在这个list里面,非常避免了多次查询数据库。
//查一次库获取所有key
public List<String> queryP2F01DetailPdescId(String entName) {
String sql = "select pdescId from ZAX_CPWS_LIST where entName= ?";
LOGGER.info(LogsUtils.getSqlLog(sql, new Object[] {entName}));
List<Record> recordList = readJdbcTemplate.query(sql, new Object[] {entName}, new DefaultRowMapper());
return recordList.stream().map(e -> e.getStringValueByName("pdescId")).collect(Collectors.toList());
}
private List<String> getInceasekey(String entName,JSONArray keyDataArray,String traceId){
List<String> list = new ArrayList<String>();
List<String> recordList = dao.queryP2F01DetailPdescId(entName);
for (int i = 0; i < keyDataArray.size(); i++) {
JSONObject jsonObject = keyDataArray.getJSONObject(i);
String key = JSONTools.getString(jsonObject, "key");
if(!recordList.contains(key)) {
list.add(key);
}
}
return list;
}
简直就是耻辱,但是呢,确实长记性了。旁边大哥评论我上面的方法时说,如果jsonArray里面有10000条数据,你就查10000次数据库吗?顿时哑口无言。*结束,说说 流的使用。
collect(Collectors.toList());后缀用于有返回值的时候,并且和.stream().map搭配使用;如果对于无法返回值(void),一般用foreach,且不需要collect(Collectors.toList());后缀。此处只是机械式操作,原理还请百度。
上一篇: iOS block源码分析
下一篇: MongoDB 节点宕机引发的思考