search feature:

search with searchDto model with pagination and sort Order

Author: PouyaPouryaie

src/main/java/ir/bigz/springbootreal/controller/SampleController.java

@@ -2,6 +2,7 @@
 
 import ir.bigz.springbootreal.service.UserService;
 import ir.bigz.springbootreal.viewmodel.UserModel;
+import ir.bigz.springbootreal.viewmodel.search.UserSearchDto;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Sort;
 import org.springframework.http.HttpStatus;
@@ -61,12 +62,12 @@ public ResponseEntity<?> getAllUser() {
     }
 
     @GetMapping(path = "/user/search", produces = MediaType.APPLICATION_JSON_VALUE)
-    public ResponseEntity<?> getUserWithSearch(@RequestParam(name = "searchfield") String searchField,
+    public ResponseEntity<?> getUserWithSearch(@RequestBody UserSearchDto userSearchDto,
                                                @RequestParam(name = "sortorder") String sortOrder,
                                                @RequestParam(name = "direction") String direction,
                                                @RequestParam(name = "pagenumber") Integer pageNumber,
                                                @RequestParam(name = "pagesize") Integer pageSize) {
-        Page<UserModel> userPageResult = userService.getUserSearchResult(searchField, sortOrder, Sort.Direction.fromString(direction), pageNumber, pageSize);
+        Page<UserModel> userPageResult = userService.getUserSearchResult(userSearchDto, sortOrder, Sort.Direction.fromString(direction), pageNumber, pageSize);
         return ResponseEntity.ok(userPageResult);
     }
 

src/main/java/ir/bigz/springbootreal/dal/DaoRepositoryImpl.java

@@ -29,7 +29,7 @@ public abstract class DaoRepositoryImpl<T, K extends Serializable> implements Da
 
     protected Class<T> daoType;
 
-    private CriteriaBuilder criteriaBuilder;
+    protected CriteriaBuilder criteriaBuilder;
 
     @SuppressWarnings("unchecked")
     protected DaoRepositoryImpl() {
@@ -188,7 +188,6 @@ public Page<T> genericSearch(CriteriaQuery<T> query, Pageable pageable){
 
         long totalCount = totalCountOfEntities();
 
-
         TypedQuery<T> typedQuery = entityManager.createQuery(query);
         List<T> resultList = typedQuery
             .setFirstResult((pageable.getPageNumber() - 1) * pageable.getPageSize())

src/main/java/ir/bigz/springbootreal/dal/UserRepository.java

@@ -1,10 +1,15 @@
 package ir.bigz.springbootreal.dal;
 
 import ir.bigz.springbootreal.dao.User;
+import ir.bigz.springbootreal.viewmodel.search.UserSearchDto;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Repository;
 
 @Repository
 public interface UserRepository extends DaoRepository<User,Long> {
 
     User getUserWithNationalCode(String nationalCode);
+
+    Page<User> getUserSearchResult(UserSearchDto userSearchDto, Pageable pageable);
 }

src/main/java/ir/bigz/springbootreal/dal/UserRepositoryImpl.java

@@ -1,10 +1,20 @@
 package ir.bigz.springbootreal.dal;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import ir.bigz.springbootreal.dao.User;
+import ir.bigz.springbootreal.viewmodel.search.UserSearchDto;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Component;
 
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.Collectors;
 
 @Component
 public class UserRepositoryImpl extends DaoRepositoryImpl<User, Long> implements UserRepository {
@@ -22,4 +32,19 @@ public User getUserWithNationalCode(String nationalCode) {
         }
         return null;
     }
+
+    @Override
+    public Page<User> getUserSearchResult(UserSearchDto userSearchDto, Pageable pageable) {
+        CriteriaQuery<User> criteriaQuery = criteriaBuilder.createQuery(User.class);
+        Root<User> userRoot = criteriaQuery.from(User.class);
+        Map<String, String> map = new ObjectMapper().convertValue(userSearchDto, Map.class);
+        List<Predicate> collect = map.keySet().stream().filter(s -> (Objects.nonNull(map.get(s)) && !(map.get(s).equals(""))))
+                .map(s -> criteriaBuilder.like(userRoot.get(s), "%"+map.get(s)+"%"))
+                .collect(Collectors.toList());
+        Predicate[] predicates = collect.stream().toArray(Predicate[]::new);
+        Predicate and = criteriaBuilder.and(predicates);
+        criteriaQuery.where(and);
+        Page<User> users = genericSearch(criteriaQuery, pageable);
+        return users;
+    }
 }

src/main/java/ir/bigz/springbootreal/service/UserService.java

@@ -2,6 +2,7 @@
 
 import ir.bigz.springbootreal.dao.User;
 import ir.bigz.springbootreal.viewmodel.UserModel;
+import ir.bigz.springbootreal.viewmodel.search.UserSearchDto;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Sort;
 import org.springframework.stereotype.Service;
@@ -21,7 +22,7 @@ public interface UserService {
 
     List<UserModel> getAll();
 
-    Page<UserModel> getUserSearchResult(String searchField, String sortOrder, Sort.Direction direction, Integer pageNumber, Integer pageSize);
+    Page<UserModel> getUserSearchResult(UserSearchDto userSearchDto, String sortOrder, Sort.Direction direction, Integer pageNumber, Integer pageSize);
 
     Page<UserModel> getAllUserPage(String sortOrder, Sort.Direction sortDirection, Integer pageNumber, Integer pageSize);
 }

src/main/java/ir/bigz/springbootreal/service/UserServiceImpl.java

@@ -6,6 +6,7 @@
 import ir.bigz.springbootreal.exception.AppException;
 import ir.bigz.springbootreal.exception.HttpErrorCode;
 import ir.bigz.springbootreal.viewmodel.UserModel;
+import ir.bigz.springbootreal.viewmodel.search.UserSearchDto;
 import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.cache.annotation.CachePut;
 import org.springframework.cache.annotation.Cacheable;
@@ -117,11 +118,11 @@ public List<UserModel> getAll() {
 
     @Override
     @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT)
-    public Page<UserModel> getUserSearchResult(String searchField, String sortOrder, Sort.Direction direction, Integer pageNumber, Integer pageSize) {
+    public Page<UserModel> getUserSearchResult(UserSearchDto userSearchDto, String sortOrder, Sort.Direction direction, Integer pageNumber, Integer pageSize) {
         try {
-            Pageable pageable = PageRequest.of(pageNumber, pageSize);
-            String query = "select u from User u order by u.id " + sortOrder;
-            Page<User> users = userRepository.genericSearch(query, pageable);
+            Sort.Order order = new Sort.Order(direction, sortOrder);
+            Pageable pageable = PageRequest.of(pageNumber, pageSize, Sort.by(order));
+            Page<User> users = userRepository.getUserSearchResult(userSearchDto, pageable);
             List<UserModel> collect = users.get().map(userMapper::userToUserModel).collect(Collectors.toList());
             return new PageImpl<>(collect, pageable, users.getTotalElements());
         }catch (RuntimeException exception){
@@ -136,8 +137,8 @@ public Page<UserModel> getUserSearchResult(String searchField, String sortOrder,
 
     @Override
     @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT)
-    public Page<UserModel> getAllUserPage(String sortOrder, Sort.Direction sortDirection, Integer pageNumber, Integer pageSize){
-        Sort.Order order = new Sort.Order(sortDirection, sortOrder);
+    public Page<UserModel> getAllUserPage(String sortOrder, Sort.Direction direction, Integer pageNumber, Integer pageSize){
+        Sort.Order order = new Sort.Order(direction, sortOrder);
         Pageable pageable = PageRequest.of(pageNumber, pageSize, Sort.by(order));
         Page<User> all = userRepository.getAll(pageable);
         List<UserModel> collect = all.get().map(userMapper::userToUserModel).collect(Collectors.toList());

src/main/java/ir/bigz/springbootreal/viewmodel/search/UserSearchDto.java

@@ -0,0 +1,30 @@
+package ir.bigz.springbootreal.viewmodel.search;
+
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+import java.io.Serializable;
+
+@NoArgsConstructor
+@Getter
+@Setter
+@ToString
+public class UserSearchDto implements Serializable {
+
+    private String firstName;
+
+    private String lastName;
+
+    private String userName;
+
+    private String nationalCode;
+
+    private String mobile;
+
+    private String email;
+
+    private String gender;
+
+}