collectを使用するときに複数のストリーミングを避ける方法

Question

私は、データベースにjooqを照会し、その結果をストリームで後処理する組み合わせを持っています。しかし、私のコードはあまり読みにくく、簡潔ではないと感じています。私の意図をよりよく表現する方法でコードを改善するにはどうすればよいですか？

sql 
    .select(field("USER_NAME", String.class)) 
    .from(table("CWD_USER")) 
    .fetch() 
    .stream() 
    .map(f -> f.getValue(field("USER_NAME", String.class))) 
    .collect(Collectors.groupingBy(s -> StringUtils.split(s, "-")[0], Collectors.counting())) 
    .entrySet().stream() 
    .sorted(new java.util.Comparator<Entry<String, Long>>() { 
     @Override 
     public int compare(Entry<String, Long> o1, 
       Entry<String, Long> o2) { 
      return o2.getValue().compareTo(o1.getValue()); 
     } 
    }) 
    .forEach(e -> System.out.println(String.format("%13s: %3d", e.getKey(), e.getValue()))); 

最初に私はマルチストリーミングに問題があります。私はまずjooqから結果をストリームし、次に収集したマップをストリームします。また、コンパレータは目立つように見えます。確かにクラスを作ることができますが、別の解決策があるかもしれません。

Answer 1

JOOQの部分については言えませんが、Stream APIの部分はうまく見えます。並べ替える前に数を知るためには、中間で収集する必要があります。このコンパレータはすでにJDKに実装されています。つまり、Map.Entry.comparingByValue()です。あなたは（逆の順序でソートするComparator.reverseOrder()パラメータを追加します）、それを使用することができます。

sql 
    .select(field("USER_NAME", String.class)) 
    .from(table("CWD_USER")) 
    .fetch() 
    .stream() 
    .map(f -> f.getValue(field("USER_NAME", String.class))) 
    .collect(Collectors.groupingBy(s -> StringUtils.split(s, "-")[0], Collectors.counting())) 
    .entrySet().stream() 
    .sorted(Map.Entry.comparingByValue(Comparator.reverseOrder())) 
    .forEach(e -> System.out.println(String.format("%13s: %3d", e.getKey(), e.getValue()))); 

Answer 2

これは、より複雑なクエリの大幅な簡略化されたバージョンでない限り、私はSQLにすべてのロジックを移動すると思います。 jOOQで、

SELECT PREFIX, COUNT(*) 
FROM (
    SELECT SUBSTR(USER_NAME, 1, INSTR(USER_NAME, '-') - 1) AS PREFIX 
    FROM CWD_USER 
) T 
GROUP BY PREFIX 
ORDER BY COUNT(*) 

または：：（Oracleの方言を使用して）同等のSQLクエリであるあなたがの存在を知らない場合でも

sql.select(field("PREFIX", String.class), count()) 
    .from(
    select(substring(
     field("USER_NAME", String.class), 
     inline(1), 
     position(field("USER_NAME", String.class), inline("-")).sub(inline(1)) 
    ).as("PREFIX")) 
    .from(table("CWD_USER")) 
    ) 
    .groupBy(field("PREFIX", String.class)) 
    .orderBy(count()) 
    .fetch();