Comment éviter le streaming multiple lors de l'utilisation de collecte

Question

J'ai une combinaison d'interrogation d'une base de données avec jooq et de post-traitement du résultat avec les flux. Cependant, je pense que mon code n'est pas très lisible et pas assez concis. Comment puis-je améliorer mon code de manière à mieux exprimer mon intention.

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()))); 

D'abord j'ai des problèmes avec le streaming multiple. Je commence par diffuser le résultat de jooq puis je diffuse la carte collectée. Le comparateur semble également être important. Bien sûr, je pourrais en faire une classe, mais il y a peut-être une autre solution.

Answer 1

Je ne peux pas parler de la partie JOOQ, mais la partie de l'API de Stream semble très bien. Vous devez collecter de façon intermédiaire pour connaître les comptes avant le tri. Notez qu'un tel comparateur est déjà implémenté dans JDK: c'est Map.Entry.comparingByValue(). Vous pouvez l'utiliser (ajouter Comparator.reverseOrder() paramètre à trier dans l'ordre inverse):

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

moins que ce soit une version simplifiée radicalement d'une requête plus complexe, je passerions toute logique à SQL. L'équivalent requête SQL (en utilisant le dialecte Oracle) est:

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(*) 

Ou, avec jOOQ:

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();