Advertisement

JPA多条件动态复杂查询以及分页复杂查询

阅读量:

JpaRepository 接口拥有常用的 CURD 方法以及分页方法、字段排序等操作,但是没有与或非、like、以及大于等于、小于等于等操作,这些方法都在 JpaSpecificationExecutor 接口中。

一 实体类

复制代码
    import java.math.BigDecimal;
    import java.sql.Timestamp;
    import javax.persistence.Entity;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    import javax.persistence.Table;
    import org.hibernate.annotations.DynamicInsert;
    import org.hibernate.annotations.DynamicUpdate;
    import com.fasterxml.jackson.annotation.JsonFormat;
    import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
    import com.github.liaochong.myexcel.core.annotation.ExcelColumn;
    import io.swagger.annotations.ApiModelProperty;
    import lombok.Getter;
    import lombok.Setter;
    
    @Getter
    @Setter
    @Entity
    @DynamicInsert
    @DynamicUpdate
    @Table(name="order_information")
    @JsonIgnoreProperties(value = {"hibernateLazyInitializer", "handler"})
    public class OrderInformation {
    	private static final String DDFormat = "yyyy-MM-dd HH:mm:ss";
    	private static final String TIME_ZONE = "GMT+8";
    	
    	@Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    Long id;
    	
    	@ApiModelProperty(value = "订单号",example = "123456")
    Long orderId;
    	
    	@ApiModelProperty(value = "机器编号",example = "3220226")
    @ExcelColumn(title = "机器编号")
    String vmId;
    
    @ApiModelProperty(value = "状态",example = "1进行中,9已闭环")
    Integer ccStatus;
       
    @ApiModelProperty(value = "日期",example = "2019-11-07")
    String tranDate;
    
    @ApiModelProperty(value = "开始日期",example = "2019-11-07")
    String tranBeginDate;
    	
    	@ApiModelProperty(value = "结束日期",example = "2019-11-07")
    String tranEndDate;
    
    }

二 持久化层

如果只需要简单的实现 CRUD、分页、排序,则继承 JpaRepository接口即可,如果还需要复杂查询,则可以再继承 JpaSpecificationExecutor 接口
JpaSpecificationExecutor 常用 API
org.springframework.data.jpa.repository.JpaSpecificationExecutor

List findAll(@Nullable Specification spec) 规范查询。没有数据时返回空列表。
Page findAll(@Nullable Specification spec, Pageable pageable) 规范查询。同时进行分页查询。
List findAll(@Nullable Specification spec, Sort sort) 规范查询。同时指定排序字段。
Optional findOne(@Nullable Specification spec) 规范查询单条数据。注意如果结果多余一条,则抛异常。
复制代码
    import java.util.List;
    import org.springframework.data.jpa.repository.JpaRepository;
    import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
    import org.springframework.stereotype.Repository;
    import com.ubox.guest.db.entity.kesu.OrderInformation;
    
    @Repository
    public interface OrderInformationRepository extends JpaRepository<OrderInformation, Long>, JpaSpecificationExecutor<OrderInformation>{
    }

三 service业务层

复制代码
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    import javax.persistence.criteria.CriteriaBuilder;
    import javax.persistence.criteria.CriteriaQuery;
    import javax.persistence.criteria.Predicate;
    import javax.persistence.criteria.Root;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.domain.Page;
    import org.springframework.data.domain.PageRequest;
    import org.springframework.data.domain.Sort;
    import org.springframework.data.jpa.domain.Specification;
    import org.springframework.stereotype.Service;
    import com.ubox.guest.api.req.QueryListSelect;
    import com.ubox.guest.db.entity.kesu.OrderInformation;
    import com.ubox.guest.db.repository.kesu.OrderInformationRepository;
    import lombok.extern.slf4j.Slf4j;
    @Slf4j
    @Service
    public class QueryListService {
    	private final OrderInformationRepository orderInformationRepository;
      
    @Autowired
    public QueryListService(final OrderInformationRepository orderInformationRepository) {
    	this.orderInformationRepository = orderInformationRepository;
    }
    
    	/* * 列表查询
    	*/
    public void listQuery(QueryListSelect req) {
    	try {
    		//创建查询规范
            Specification<OrderInformation> tvSpecification = new Specification<OrderInformation>() {
                @Override
                public Predicate toPredicate(Root<OrderInformation> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
                    List<Predicate> predicateList = new ArrayList<>();                    
                    if (req.getTranBeginDate() != null && req.getTranEndDate()!=null) {
                        predicateList.add(cb.greaterThanOrEqualTo(root.get("tranDate").as(String.class), req.getTranBeginDate()));//greaterThanOrEqualTo(>=)
                        predicateList.add(cb.lessThanOrEqualTo(root.get("tranDate").as(String.class), req.getTranEndDate()));//lessThanOrEqualTo(<=)
                    }
                    if(req.getOrderId()!=null) {
                    	predicateList.add(cb.equal(root.get("orderId").as(Long.class), req.getOrderId()));//equal(=)
                    }
                    if (req.getVmId() != null && !"".equals(req.getVmId())) {
    	   	        	predicateList.add(cb.equal(root.get("vmId").as(String.class), req.getVmId()));
    							//like模糊查询 cb.like(root.get("name").as(String.class), "%" + req.getName() + "%"); 
    	   	        }                   
                    if(req.getCcStatus()!=null) {
                    	predicateList.add(cb.equal(root.get("ccStatus").as(Integer.class), req.getCcStatus()));
                    }                   
                    Predicate[] predicates = new Predicate[predicateList.size()];
                    return query.where(predicateList.toArray(predicates)).getRestriction();
                }
            };
    		
    		//带有分页的复杂动态查询。Sort.Direction.DESC,"id"可去掉,这个是按某个字段排序
            Page<OrderInformation> all = orderInformationRepository.findAll(tvSpecification, PageRequest.of(req.getPage(),req.getPageSize(),Sort.Direction.DESC,"id"));
            
    		//没有分页的复杂动态查询。
            List<OrderInformation> list = orderInformationRepository.findAll(tvSpecification);
    		
    	}catch (Exception e) {
            logger.error("列表查询出错:{}", e.getMessage(), e);
    		}
    }
    }

以上用到了=,>=, <=
还有模糊查询,以下其他关键字可自由选择

复制代码
    	equal,        // filed = value
      	**下面四个用于Number类型的比较**
    gt,   // filed > value
    ge,   // field >= value
    lt,              // field < value
    le,      // field <= value
    notEqual,            // field != value
    like,   // field like value
    notLike,    // field not like value
    **下面四个用于可比较类型(Comparable)的比较**
    greaterThan,        // field > value
    greaterThanOrEqualTo,   // field >= value
    lessThan,               // field < value
    lessThanOrEqualTo,      // field <= value

全部评论 (0)

还没有任何评论哟~