欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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());后缀。此处只是机械式操作,原理还请百度。

 

相关标签: