Use a filter to get users

Author: mickablondo

src/main/java/dev/mikablondo/hibernate_reactive_test/controller/UserController.java

@@ -1,6 +1,7 @@
 package dev.mikablondo.hibernate_reactive_test.controller;
 
 import dev.mikablondo.hibernate_reactive_test.dto.User;
+import dev.mikablondo.hibernate_reactive_test.dto.UserFilter;
 import dev.mikablondo.hibernate_reactive_test.services.UserService;
 import io.smallrye.mutiny.Multi;
 import io.smallrye.mutiny.Uni;
@@ -24,11 +25,8 @@ public class UserController {
     private final UserService userService;
 
     @GetMapping
-    public Multi<User> getUsers(@RequestParam(required = false) String nom) {
-        if (nom != null) {
-            return userService.getUsersByNom(nom);
-        }
-        return userService.getAllUsers();
+    public Multi<User> getUsers(UserFilter filtre) {
+        return userService.getUsers(filtre);
     }
 
     @PostMapping

src/main/java/dev/mikablondo/hibernate_reactive_test/dto/UserFilter.java

@@ -0,0 +1,12 @@
+package dev.mikablondo.hibernate_reactive_test.dto;
+
+import lombok.Data;
+
+@Data
+public class UserFilter {
+    private String nom;
+    private String prenom;
+    private Integer ageMin;
+    private Integer ageMax;
+    private String metier;
+}

src/main/java/dev/mikablondo/hibernate_reactive_test/repository/UserRepository.java

@@ -1,5 +1,6 @@
 package dev.mikablondo.hibernate_reactive_test.repository;
 
+import dev.mikablondo.hibernate_reactive_test.dto.UserFilter;
 import dev.mikablondo.hibernate_reactive_test.entity.UserEntity;
 import io.smallrye.mutiny.Multi;
 import io.smallrye.mutiny.Uni;
@@ -23,27 +24,27 @@ public class UserRepository {
     /**
      * This method retrieves all users from the database.
      *
+     * @param filtre the filter criteria for retrieving users
      * @return a Multi stream of UserEntity objects
      */
-    public Multi<UserEntity> findAll() {
-        return sessionFactory.withSession(session ->
-                session.createQuery("from UserEntity", UserEntity.class)
-                        .getResultList()
-        ).onItem().transformToMulti(users -> Multi.createFrom().iterable(users));
-    }
+    public Multi<UserEntity> findByFiltre(UserFilter filtre) {
+        return sessionFactory.withSession(session -> {
+            StringBuilder query = new StringBuilder("from UserEntity where 1=1");
+            if (filtre.getNom() != null) query.append(" and lower(nom) = :nom");
+            if (filtre.getPrenom() != null) query.append(" and lower(prenom) = :prenom");
+            if (filtre.getAgeMin() != null) query.append(" and age >= :ageMin");
+            if (filtre.getAgeMax() != null) query.append(" and age <= :ageMax");
+            if (filtre.getMetier() != null) query.append(" and lower(metier) = :metier");
 
-    /**
-     * This method retrieves all users with a specific name from the database.
-     *
-     * @param nom the name of the users to be retrieved
-     * @return a Multi stream of UserEntity objects
-     */
-    public Multi<UserEntity> findAll(String nom) {
-        return sessionFactory.withSession(session ->
-                session.createQuery("from UserEntity where lower(nom) = :nom", UserEntity.class)
-                        .setParameter("nom", nom.toLowerCase())
-                        .getResultList()
-        ).onItem().transformToMulti(users -> Multi.createFrom().iterable(users));
+            var hQuery = session.createQuery(query.toString(), UserEntity.class);
+            if (filtre.getNom() != null) hQuery.setParameter("nom", filtre.getNom().toLowerCase());
+            if (filtre.getPrenom() != null) hQuery.setParameter("prenom", filtre.getPrenom().toLowerCase());
+            if (filtre.getAgeMin() != null) hQuery.setParameter("ageMin", filtre.getAgeMin());
+            if (filtre.getAgeMax() != null) hQuery.setParameter("ageMax", filtre.getAgeMax());
+            if (filtre.getMetier() != null) hQuery.setParameter("metier", filtre.getMetier().toLowerCase());
+
+            return hQuery.getResultList();
+        }).onItem().transformToMulti(users -> Multi.createFrom().iterable(users));
     }
 
     /**

src/main/java/dev/mikablondo/hibernate_reactive_test/services/UserService.java

@@ -1,6 +1,7 @@
 package dev.mikablondo.hibernate_reactive_test.services;
 
 import dev.mikablondo.hibernate_reactive_test.dto.User;
+import dev.mikablondo.hibernate_reactive_test.dto.UserFilter;
 import dev.mikablondo.hibernate_reactive_test.entity.UserEntity;
 import dev.mikablondo.hibernate_reactive_test.repository.UserRepository;
 import io.smallrye.mutiny.Multi;
@@ -26,8 +27,8 @@ public class UserService {
      *
      * @return a Multi stream of User DTO objects
      */
-    public Multi<User> getAllUsers() {
-        return userRepository.findAll()
+    public Multi<User> getUsers(UserFilter filtre) {
+        return userRepository.findByFiltre(filtre)
                 .onItem().transform(userEntity -> User.builder()
                         .id(userEntity.getId())
                         .nom(userEntity.getNom())
@@ -85,21 +86,4 @@ public Uni<User> getUserById(UUID uuid) {
                     }
                 });
     }
-
-    /**
-     * This method retrieves users by their name from the database.
-     *
-     * @param nom the name of the users to be retrieved
-     * @return a Multi stream of User DTO objects
-     */
-    public Multi<User> getUsersByNom(String nom) {
-        return userRepository.findAll(nom)
-                .onItem().transform(userEntity -> User.builder()
-                        .id(userEntity.getId())
-                        .nom(userEntity.getNom())
-                        .prenom(userEntity.getPrenom())
-                        .age(userEntity.getAge())
-                        .metier(userEntity.getMetier())
-                        .build());
-    }
 }