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)
还没有任何评论哟~
