本文主要为您介绍排序和翻页的操作接口。

索引预排序(IndexSort)

多元索引默认会按照索引中配置的IndexSort进行排序(含有NESTED类型的索引不支持IndexSort,没有预排序),默认的IndexSort为主键排序,用户可以在创建索引时自定义预排序方式。

IndexSort决定了多元索引查询时默认的返回顺序,若用户未自定义IndexSort,即按照主键顺序返回。

查询时指定排序方式

在每次查询时,用户也可以指定排序方式,多元索引支持以下四种排序方式(Sorter)。用户也可以使用多个Sorter,实现先按照某种方式排序,再按照某种方式排序的需求。

  • ScoreSort

    按照分数进行排序,应用在全文索引等有相关性的场景下。需要注意的时,必须手动设置ScoreSort,才能按照相关性打分进行排序,否则会按照索引设置的IndexSort进行排序返回。

    
    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setSort(new Sort(Arrays.asList(new ScoreSort())));
  • PrimaryKeySort
    按照主键排序。
    正序:
    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setSort(new Sort(Arrays.asList(new PrimaryKeySort())));
    
    逆序:
    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setSort(new Sort(Arrays.asList(new PrimaryKeySort(SortOrder.DESC))));
  • FieldSort

    按照某列进行排序。

    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setSort(new Sort(Arrays.asList(new FieldSort("col", SortOrder.ASC))));

    先按照某列排序,再按照另一列排序。

    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setSort(new Sort(Arrays.asList(
        new FieldSort("col1", SortOrder.ASC), new FieldSort("col2", SortOrder.ASC))));
  • GeoDistanceSort

    根据地理点距离进行排序。

    SearchQuery searchQuery = new SearchQuery();
    // geo这一列为GEOPOINT类型,按照这一列的值距离"0,0"点的距离排序。
    Sort.Sorter sorter = new GeoDistanceSort("geo", Arrays.asList("0, 0"));
    searchQuery.setSort(new Sort(Arrays.asList(sorter)));

翻页方式

  • 使用limit和offset

    当需要获取的总条数小于2000行时,可以通过limit和offset进行翻页,limit+offset <= 2000。

    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setQuery(new MatchAllQuery());
    searchQuery.setLimit(100);
    searchQuery.setOffset(100);
  • 使用token进行翻页

    如果符合查询条件的数据没有读完,服务端会返回NextToken,用户可以使用NextToken继续读取后面的数据。使用Token后排序方式会跟上一次请求一致(不管是系统默认采用IndexSort排序还是用户自定义排序),因此设置了Token不能再设置Sort。另外,使用Token后不能设置Offset,只能一次一次往后读,即无法跳页。

    
    /**
     * 使用Token进行翻页,这个例子会把所有数据读出,放到一个List中。
     * @param client
     */
    private static void readMoreRowsWithToken(SyncClient client) {
        SearchQuery searchQuery = new SearchQuery();
        searchQuery.setQuery(new MatchAllQuery());
        searchQuery.setGetTotalCount(true);
        SearchRequest searchRequest = new SearchRequest(TABLE_NAME, INDEX_NAME, searchQuery);
        SearchResponse resp = client.search(searchRequest);
        if (!resp.isAllSuccess()) {
            throw new RuntimeException("not all success");
        }
        List<Row> rows = resp.getRows();
        while (resp.getNextToken()!=null) { //读到NextToken为null为止,即读出全部数据
            //把Token设置到下一次请求中
            searchRequest.getSearchQuery().setToken(resp.getNextToken()); 
            resp = client.search(searchRequest);
            if (!resp.isAllSuccess()) {
                throw new RuntimeException("not all success");
            }
            rows.addAll(resp.getRows());
        }
        System.out.println("RowSize: " + rows.size());
        System.out.println("TotalCount: " + resp.getTotalCount());
    }