在查询 DSL 中返回页面 <Object>

Returning Page<Object> in Query DSL

我正在使用查询 DSL 并希望我的结果集 return 一个页面对象。有没有办法在查询 DSL 中做到这一点?如果是这样,我的查询会是什么样子? 我正在使用 JPAQuery 并且我有我的 QClasses

方法结构是这样的

public Page<Object> searchPerson(String name,String phone){
 Page<Object> results=null;
 JPQLQuery query = new JPAQuery(entityManager);
 QPerson person = QPerson.person;
   //I am assuming my query would go here 
  results = query.from(person). ?????  


return results;} 

求助!

这是我使用 QueryDSL 对 Paging 的实现。 PageRequest 定义了我们查询的参数(限制和页面):

public class PageRequest {
    protected Long page = 1l;// 1 is the first page
    protected Integer limit = 10;

    public PageRequest(Long page, Integer limit) {
        this.limit = limit;
        this.page = page;   
    }

    public Long getPage() {
        return page;
    }

    public Integer getLimit() {
        return limit;
    }

    public Long getOffset() {
        return (page - 1l) * limit;
    }
}

Page Class 包含查询的结果(这里是属性 objects),并且可以实现创建漂亮的分页链接的方法。

public class Page<T> extends PageRequest {

    protected Collection<T> objects;
    private Long totalCount;
    private Long pageCount;
    private Boolean hasPageLinkPrev;
    private Boolean hasPageLinkNext;
    private Collection<Long> pageLinks;

    public Page(Long page, Integer limit, Long totalCount, Collection<T> objects) {

        this.page = page;
        this.limit = limit;
        this.totalCount = totalCount;
        this.objects = objects;

        this.pageCount = totalCount / limit;
        if (totalCount % limit > 0) {
            this.pageCount = this.pageCount + 1;
        }

        this.hasPageLinkPrev = page > 1;
        this.hasPageLinkNext = page < this.pageCount;

        this.pageLinks = new ArrayList<>();
        if (this.pageCount != 1) {
            this.pageLinks.add(1l);
            if (page > 3l) {
                this.pageLinks.add(-1l);
            }
            if (page > 2l) {
                if (page.equals(this.pageCount) && this.pageCount > 3l) {
                    this.pageLinks.add(page - 2l);
                }
                this.pageLinks.add(page - 1l);
            }
            if (page != 1l && !page.equals(this.pageCount)) {
                this.pageLinks.add(page);
            }
            if (page < this.pageCount - 1l) {
                this.pageLinks.add(page + 1l);

                if (page == 1l && this.pageCount > 3l) {
                    this.pageLinks.add(page + 2l);
                }
            }
            if (page < this.pageCount - 2l) {
                this.pageLinks.add(-1l);
            }
            this.pageLinks.add(this.pageCount);
        }
    }

    public Page(PageRequest pageRequest, Long totalCount, Collection<T> objects) {
        this(pageRequest.getPage(), pageRequest.getLimit(), totalCount, objects);
    }

    public Long getTotalCount() {
        return this.totalCount;
    }

    public Long getPageCount() {
        return this.pageCount;
    }

    public Long getPage() {
        return this.page;
    }

    public Integer getLimit() {
        return this.limit;
    }

    public Boolean getHasPageLinkPrev() {
        return this.hasPageLinkPrev;
    }

    public Boolean getHasPageLinkNext() {
        return hasPageLinkNext;
    }

    public Collection<Long> getPageLinks() {
        return pageLinks;
    }

    public Collection<T> getObjects() {
        return objects;
    }
}

有了这些东西,创建查询并将结果放入我们的页面对象中并不是很难。一种可能性是在存储库 class 的基础 class 中编写通用方法:

    protected <T> Page<T> getPage(JPQLQuery<T> query, PageRequest pageRequest) {

        List<T> resultList = query
            .offset(pageRequest.getOffset())
            .limit(pageRequest.getLimit())
            .fetch();

        Long totalCount = query.fetchCount();
        return new Page<T>(pageRequest, totalCount, resultList);
    }

在您的存储库 class 中,您可以为特定用例创建查询。然后你可以使用方法 getPage 来得到 Page.

中的结果
public Page<Person> searchPerson(String name,
                                 String phone,
                                 PageRequest request){
  Page<Person> results=null;
  JPQLQuery<Person> query = new JPAQuery<>(entityManager);
  QPerson person = QPerson.person;
  query = query.from(person)
     .where(person.name.eq(name)
         .and(person.phone.eq(phone)));
  return getPage(query, request);
} 

上述解决方案是使用在上述方法上实现的 BooleanBuilder,并将方法名称更改为 return Person Object。 请检查 BooleanBuilder

QPerson person= QPerson.person;
BooleanBuilder builder = this.getBuilder(name, phone,page, pageSize, sortFlag, sortItem);
    PageRequest pg = getPRequest(page, pageSize);
    Page<Person> pages personRepo.findAll(builder,pg);
  return pages;

然后为其实现了 getBuilder 方法,即下面的方法

public BooleanBuilder getBuilder(String name, String phone, Integer page, Integer pageSize, String sortFlag, String sortItem) {

    QPerson person = QPerson.person;
    BooleanBuilder builder = new BooleanBuilder();
    builder.and(person.name.startsWith(name));
    return builder;
}

最终实现getPRequest方法如下

public PageRequest getPRequest(Integer page, Integer pageSize) {
    return new PageRequest(page, pageSize);
}

哦哦快乐的日子!