java 利用stream对比jdbc查询结果集过滤多余的key

￡神魔★判官ぃ 2023-10-10 08:29 54阅读 0赞

背景描述：已知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());后缀。此处只是机械式操作，原理还请百度。