Tablestore：Lakukan pengurutan dan paging

Skenario

Gunakan SDK Tablestore untuk melakukan pengurutan dan paging

Anda dapat menggunakan SDK Tablestore berikut untuk melakukan pengurutan dan paging:

• Tablestore SDK for Java: Pengurutan dan paging

• Tablestore SDK for Go: Pengurutan dan paging

• Tablestore SDK for Python: Pengurutan dan paging

• Tablestore SDK for Node.js: Pengurutan dan paging

• Tablestore SDK for .NET: Pengurutan dan paging

• Tablestore SDK for PHP: Pengurutan dan paging

Pra-pengurutan indeks

Secara default, data dalam indeks pencarian diurutkan berdasarkan pengaturan pra-pengurutan yang ditentukan oleh parameter IndexSort. Saat menggunakan indeks pencarian untuk menanyakan data, pengaturan pra-pengurutan yang ditentukan oleh parameter IndexSort menentukan urutan default data yang cocok untuk dikembalikan.

Saat membuat indeks pencarian, Anda dapat menentukan pengaturan pra-pengurutan dengan mengonfigurasi parameter IndexSort. Jika Anda tidak menentukan pengaturan pra-pengurutan, data dalam indeks pencarian diurutkan berdasarkan nilai kunci utama.

Tentukan metode pengurutan saat menanyakan data

Pengurutan hanya dapat diaktifkan untuk bidang yang memiliki parameter enableSortAndAgg disetel ke true.

Anda dapat menentukan metode pengurutan untuk setiap kueri. Kueri berbasis indeks pencarian mendukung metode pengurutan berikut. Anda juga dapat menentukan beberapa metode pengurutan berdasarkan prioritas yang berbeda.

ScoreSort

SearchQuery searchQuery = new SearchQuery();
searchQuery.setSort(new Sort(Arrays.asList(new ScoreSort())));

PrimaryKeySort

Gunakan PrimaryKeySort untuk mengurutkan hasil kueri berdasarkan nilai kunci utama.

SearchQuery searchQuery = new SearchQuery();
searchQuery.setSort(new Sort(Arrays.asList(new PrimaryKeySort()))); // Urutkan hasil kueri dalam urutan menaik. 
//searchQuery.setSort(new Sort(Arrays.asList(new PrimaryKeySort(SortOrder.DESC)))); // Urutkan hasil kueri dalam urutan menurun.

FieldSort

Gunakan FieldSort untuk mengurutkan hasil kueri berdasarkan nilai satu atau beberapa kolom tertentu.

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))));

/**
* Urutkan hasil kueri berdasarkan nilai kolom Col_Long dalam urutan menurun. Jika data di kolom Col_Long bertipe Long hilang, Anda dapat menggunakan kolom Col_Long_sec dengan tipe data yang sama sebagai kolom tambahan untuk pengurutan. 
*/
SearchQuery searchQuery = new SearchQuery();
FieldSort fieldSort = new FieldSort("Col_Long");
// Tentukan kolom Col_Long_sec sebagai kolom tambahan untuk pengurutan ketika data di kolom Col_Long hilang. 
fieldSort.setMissingField("Col_Long_sec");
fieldSort.setOrder(SortOrder.DESC); 

// Baris doc1 dan doc2 berisi kolom field1 bertipe Array. Nilai kolom field1 di baris doc1 adalah [2,3] dan nilai kolom field1 di baris doc2 adalah [1,3,4]. 
// Anda dapat menentukan parameter mode untuk menentukan elemen bidang Array di kedua baris yang digunakan untuk mengurutkan kedua baris. 
{
    // Jika Anda menyetel parameter mode ke SortMode.MAX, elemen maksimum dari bidang Array digunakan untuk mengurutkan baris. Dalam contoh ini, 3 di baris doc1 dan 4 di baris doc2 digunakan untuk mengurutkan kedua baris, dan hasil pengurutan adalah doc2 dan doc1. 
    FieldSort fieldSort = new FieldSort("field1", SortOrder.DESC);
    fieldSort.setMode(SortMode.MAX);
}
{
    // Jika Anda menyetel parameter mode ke SortMode.MIN, elemen minimum dari bidang Array digunakan untuk mengurutkan baris. Dalam contoh ini, 2 di baris doc1 dan 1 di baris doc2 digunakan untuk mengurutkan kedua baris, dan hasil pengurutan adalah doc1 dan doc2. 
    FieldSort fieldSort = new FieldSort("field1", SortOrder.DESC);
    fieldSort.setMode(SortMode.MIN);
}

// Baris doc1 dan doc2 berisi kolom field1 bertipe Nested. 
// Nilai kolom field1 di baris doc1 adalah [{"name":"b", "age":1},{"name":"a", "age":7}]. 
// Nilai kolom field1 di baris doc2 adalah [{"name":"a", "age":1},{"name":"c", "age":1},{"name":"d", "age":5}].

{
    // Anda dapat menentukan parameter mode untuk menentukan elemen bidang Nested di kedua baris yang digunakan untuk mengurutkan baris anak. 
    // Jika Anda menyetel parameter mode ke SortMode.MAX, elemen maksimum dari bidang Nested digunakan untuk mengurutkan baris. Dalam contoh ini, 7 di baris doc1 dan 5 di baris doc2 digunakan untuk mengurutkan kedua baris berdasarkan kolom age, dan hasil pengurutan adalah doc1 dan doc2. 
    FieldSort fieldSort = new FieldSort("field1.age", SortOrder.DESC);
    fieldSort.setMode(SortMode.MAX);
    String path = "field1";
    NestedFilter nestedFilter = new NestedFilter(path, QueryBuilders.matchAll().build());
    fieldSort.setNestedFilter(nestedFilter);
}
{
    // Anda dapat menentukan parameter mode untuk menentukan elemen bidang Nested di kedua baris yang digunakan untuk mengurutkan baris anak di mana nilai kolom age adalah 1. 
    {
        // Jika Anda menyetel parameter mode ke SortMode.MAX, elemen maksimum dari bidang Nested digunakan untuk mengurutkan baris. Dalam contoh ini, "b" di baris doc1 dan "a" di baris doc2 digunakan untuk mengurutkan kedua baris berdasarkan kolom name, dan hasil pengurutan adalah doc2 dan doc1.
        FieldSort fieldSort = new FieldSort("field1.name", SortOrder.DESC);
        fieldSort.setMode(SortMode.MAX);
        String path = "field1";
        NestedFilter nestedFilter = new NestedFilter(path, QueryBuilders.term("students.age",1).build());
        fieldSort.setNestedFilter(nestedFilter);
    }
    {
        // Jika Anda menyetel parameter mode ke SortMode.MIN, elemen minimum dari bidang Nested digunakan untuk mengurutkan baris. Dalam contoh ini, "b" di baris doc1 dan "a" di baris doc2 digunakan untuk mengurutkan kedua baris berdasarkan kolom name, dan hasil pengurutan adalah doc1 dan doc2. 
        FieldSort fieldSort = new FieldSort("field1.name", SortOrder.DESC);
        fieldSort.setMode(SortMode.MIN);
        String path = "field1";
        NestedFilter nestedFilter = new NestedFilter(path, QueryBuilders.term("students.age",1).build());
        fieldSort.setNestedFilter(nestedFilter);
    }
}

GeoDistanceSort

Gunakan GeoDistanceSort untuk mengurutkan hasil kueri berdasarkan lokasi geografis.

SearchQuery searchQuery = new SearchQuery();
// Urutkan hasil berdasarkan jarak dari nilai di kolom geo GEOPOINT ke pasangan koordinat (0, 0). 
Sort.Sorter sorter = new GeoDistanceSort("geo", Arrays.asList("0, 0"));
searchQuery.setSort(new Sort(Arrays.asList(sorter)));

Tentukan metode paging

Anda dapat mengonfigurasi parameter limit dan offset atau menggunakan token untuk membagi halaman baris dalam respons.

Konfigurasikan parameter limit dan offset

Jika Anda tidak menentukan nilai untuk parameter limit dan offset, nilai default akan digunakan. Nilai default parameter limit adalah 10. Nilai default parameter offset adalah 0.

SearchQuery searchQuery = new SearchQuery();
searchQuery.setQuery(new MatchAllQuery());
searchQuery.setLimit(100);
searchQuery.setOffset(100);

Gunakan token

Kami merekomendasikan Anda menggunakan token untuk paging dalam karena metode ini tidak memiliki batasan pada kedalaman paging.

Jika Tablestore tidak dapat membaca semua data yang memenuhi kondisi kueri, Tablestore mengembalikan nextToken. Anda dapat menggunakan nextToken untuk terus membaca data berikutnya.

Secara default, Anda hanya dapat melakukan paging mundur saat menggunakan token. Namun, Anda dapat menyimpan cache dan menggunakan token sebelumnya untuk paging maju karena token valid selama kueri.

Saat menggunakan token, metode pengurutan sama dengan metode yang digunakan dalam permintaan sebelumnya. Tablestore mengurutkan data berdasarkan parameter IndexSort secara default atau berdasarkan metode yang Anda tentukan. Anda tidak dapat menentukan metode pengurutan saat menggunakan token. Anda tidak dapat mengonfigurasi parameter offset saat menggunakan token. Data dikembalikan halaman demi halaman secara berurutan. Ini menghasilkan kueri yang lambat.

private static void readMoreRowsWithToken(SyncClient client) {
    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setQuery(new MatchAllQuery());
    searchQuery.setGetTotalCount(true);// Tentukan bahwa jumlah total baris yang memenuhi kondisi kueri dikembalikan. 
    // Tentukan nama tabel data. Contoh: sampleTable. Lalu, tentukan nama indeks pencarian. Contoh: sampleSearchIndex. Untuk mendapatkan nama indeks pencarian, Anda dapat menanyakan daftar indeks pencarian di konsol Tablestore atau menggunakan SDK Tablestore. Jika Anda menanyakan daftar indeks pencarian di konsol Tablestore, Anda dapat melihat daftarnya di tab Indeks halaman Kelola Tabel. 
    SearchRequest searchRequest = new SearchRequest("sampleTable", "sampleSearchIndex", searchQuery);

    SearchResponse resp = client.search(searchRequest);
    if (!resp.isAllSuccess()) {
        throw new RuntimeException("not all success");
    }
    List<Row> rows = resp.getRows();
    while (resp.getNextToken()!=null) { // Jika nilai nextToken dalam respons adalah null, semua data telah dibaca. 
        // Tanyakan nilai nextToken. 
        byte[] nextToken = resp.getNextToken();

        {
            // Jika Anda ingin menyimpan nextToken secara persisten atau mentransfer nextToken ke halaman frontend, Anda dapat menggunakan Base64 untuk mengkodekan nextToken menjadi string. 
            // Token bukan string. Jika Anda menggunakan new String(nextToken) untuk mengkodekan token menjadi string, informasi tentang token akan hilang. 
            String tokenAsString = Base64.toBase64String(nextToken);
            // Dekode string menjadi byte. 
            byte[] tokenAsByte = Base64.fromBase64String(tokenAsString);
        }

        // Setel token dalam permintaan ini ke nilai nextToken dalam respons sebelumnya. 
        searchRequest.getSearchQuery().setToken(nextToken);
        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());// Tentukan bahwa jumlah total baris yang memenuhi kondisi kueri ditampilkan alih-alih jumlah baris yang dikembalikan. 
}