Tablestore：Bagaimana cara menggunakan kolom routing?

Saat membuat indeks pencarian di konsol Tablestore, aktifkan Advanced Settings dan tentukan kolom routing, seperti yang ditunjukkan pada gambar berikut. Untuk informasi lebih lanjut, lihat Memulai Cepat.

Anda dapat menggunakan CLI Tablestore untuk menjalankan perintah create_search_index guna membuat indeks pencarian. Untuk informasi lebih lanjut, lihat Indeks Pencarian.

1. Tentukan kolom routing saat membuat indeks pencarian.

   Kode sampel berikut menunjukkan cara membuat indeks pencarian bernama mysearchindex. Indeks pencarian mencakup bidang gid tipe LONG, uid tipe LONG, col2 tipe LONG, col3 tipe TEXT, col1 tipe KEYWORD, dan col3V tipe LONG. Bidang col3V adalah kolom virtual yang sesuai dengan kolom col3 di tabel data. Dalam contoh ini, kolom routing indeks pencarian adalah uid.

   create_search_index -n mysearchindex

   Ikuti petunjuk di layar untuk menentukan skema indeks pencarian. Modifikasi pengaturan bidang dalam kode sampel sesuai kebutuhan bisnis Anda sebelum menggunakan indeks pencarian untuk mengquery data. Kode sampel:

   {
   
       "IndexSetting": {
           "RoutingFields": ["uid"]
       },
       "FieldSchemas": [
       {
           "FieldName": "gid",
           "FieldType": "LONG",
           "Index": true,
           "EnableSortAndAgg": true,
           "Store": true,
           "IsArray": false,
           "IsVirtualField": false
       },
       {
           "FieldName": "uid",
           "FieldType": "LONG",
           "Index": true,
           "EnableSortAndAgg": true,
           "Store": true,
           "IsArray": false,
           "IsVirtualField": false
       },
       {
           "FieldName": "col2",
           "FieldType": "LONG",
           "Index": true,
           "EnableSortAndAgg": true,
           "Store": true,
           "IsArray": false,
           "IsVirtualField": false
       },
       {
           "FieldName": "col3",
           "FieldType": "TEXT",
           "Index": true,
           "Analyzer": "single_word",
           "AnalyzerParameter": {
           "CaseSensitive": true,
               "DelimitWord": null
           },
           "EnableSortAndAgg": false,
           "Store": true,
           "IsArray": false,
           "IsVirtualField": false
       },
       {
           "FieldName": "col1",
           "FieldType": "KEYWORD",
           "Index": true,
           "EnableSortAndAgg": true,
           "Store": true,
           "IsArray": false,
           "IsVirtualField": false
       },
       {
           "FieldName": "col3V",
           "FieldType": "LONG",
           "Index": true,
           "EnableSortAndAgg": true,
           "Store": true,
           "IsArray": false,
           "IsVirtualField": true,
           "SourceFieldNames": [
           "col3"
           ]
       }]
   }

2. Sertakan kolom routing saat menggunakan indeks pencarian untuk mengquery data.

   Kode sampel berikut menunjukkan cara menggunakan indeks pencarian mysearchindex untuk mengquery baris dengan nilai kolom col2 kurang dari 200. Saat mengquery data, Anda harus menyertakan kolom routing indeks pencarian. Dalam contoh ini, kolom routing adalah uid.

   search -n search_index --return_all_indexed

   Ikuti petunjuk di layar untuk menentukan kondisi query. Modifikasi kondisi query dalam kode sampel sesuai kebutuhan bisnis Anda sebelum menggunakan indeks pencarian untuk mengquery data. Kode sampel:

   Catatan

   Dalam contoh ini, metode query rentang digunakan. Untuk informasi tentang metode query yang didukung oleh fitur indeks pencarian, lihat Fitur Dasar.

   {
       "Offset": -1,
       "Limit": 10,
       "Collapse": null,
       "Sort": null,
       "GetTotalCount": true,
       "Token": null,
   	  "IndexSetting": {
           "RoutingFields": ["uid"]
       },
       "Query": {
           "Name": "RangeQuery",
           "Query": {
               "FieldName": "col2",
               "From": null,
               "To": 200,
               "IncludeLower": false,
               "IncludeUpper": false
            }
        }
   }

Anda dapat menggunakan SDK Tablestore berikut untuk menentukan kolom routing saat membuat indeks pencarian: SDK Tablestore untuk Java, SDK Tablestore untuk Go, SDK Tablestore untuk Python, SDK Tablestore untuk Node.js, SDK Tablestore untuk .NET, dan SDK Tablestore untuk PHP. Dalam contoh ini, SDK Tablestore untuk Java digunakan untuk menjelaskan cara menentukan dan menggunakan kolom routing.

Kode sampel berikut menunjukkan cara membuat indeks pencarian bernama order_index dan menyetel kolom routing ke bidang user_id saat membuat tabel data bernama order, menulis data ke tabel data, dan menyertakan kolom routing dalam permintaan query. Dalam contoh ini, tabel data mencakup kolom kunci utama order_id tipe STRING dan user_id tipe STRING. Indeks pencarian mencakup bidang product_name tipe KEYWORD, order_time tipe LONG, dan user_id tipe KEYWORD.

private static void testRoute(SyncClient client) throws InterruptedException {
    // Buat tabel. 
    TableMeta meta = new TableMeta("order");
    meta.addPrimaryKeyColumn("order_id",PrimaryKeyType.STRING);
    meta.addPrimaryKeyColumn("user_id",PrimaryKeyType.STRING);
    TableOptions options = new TableOptions();
    options.setMaxVersions(1);
    options.setTimeToLive(-1);
    CreateTableRequest request = new CreateTableRequest(meta,options);
    request.setReservedThroughput(new ReservedThroughput(new CapacityUnit(0, 0)));
    CreateTableResponse response = client.createTable(request);

    // Buat indeks pencarian dan tentukan kolom routing. 
    CreateSearchIndexRequest searchIndexRequest = new CreateSearchIndexRequest();
    // Tentukan nama tabel data. 
    searchIndexRequest.setTableName("order"); 
    // Tentukan nama indeks pencarian yang dibuat untuk tabel data. 
    searchIndexRequest.setIndexName("order_index"); 
    IndexSchema indexSchema = new IndexSchema();
    IndexSetting indexSetting = new IndexSetting();
    // Setel kolom routing ke bidang user_id. 
    indexSetting.setRoutingFields(Arrays.asList("user_id"));
    indexSchema.setIndexSetting(indexSetting);

    // Tambahkan bidang indeks. Bidang indeks berikut hanya ditambahkan sebagai referensi. Anda dapat menambahkan bidang indeks berdasarkan kebutuhan bisnis Anda. 
    indexSchema.setFieldSchemas(Arrays.asList(
        new FieldSchema("product_name",FieldType.KEYWORD).setStore(true).setIndex(true),
        new FieldSchema("order_time",FieldType.LONG).setStore(true).setEnableSortAndAgg(true).setIndex(true),
        new FieldSchema("user_id",FieldType.KEYWORD).setStore(true).setIndex(true)
    ));

    searchIndexRequest.setIndexSchema(indexSchema);
    client.createSearchIndex(searchIndexRequest);
    // Tunggu hingga tabel data dimuat. 
    Thread.sleep(6*1000); 

    // Masukkan data untuk pengujian. 

    String[] productName = new String[]{"product a", "product b", "product c"};
    String[] userId = new String[]{"00001", "00002", "00003", "00004", "00005"};
    for (int i = 0; i < 100; i++){

      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("order_id",PrimaryKeyValue.fromString(i+""));
      primaryKeyBuilder.addPrimaryKeyColumn("user_id",PrimaryKeyValue.fromString(userId[i%(userId.length)]));
      PrimaryKey primaryKey = primaryKeyBuilder.build();

      RowPutChange rowPutChange = new RowPutChange("order",primaryKey);

      // Tulis data ke kolom atribut. 
      rowPutChange.addColumn("product_name",ColumnValue.fromString(productName[i%(productName.length)]));
      rowPutChange.addColumn("order_time",ColumnValue.fromLong(System.currentTimeMillis()));
      rowPutChange.setCondition(new Condition(RowExistenceExpectation.IGNORE));

      client.putRow(new PutRowRequest(rowPutChange));

    }
    // Tunggu hingga data disinkronkan ke indeks pencarian. 
    Thread.sleep(20*1000);

    // Berikan kolom routing dalam permintaan query. 
    SearchRequest searchRequest = new SearchRequest();
    searchRequest.setTableName("order");
    searchRequest.setIndexName("order_index");
    MatchQuery matchQuery = new MatchQuery();
    matchQuery.setFieldName("user_id");
    matchQuery.setText("00002");
    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setQuery(matchQuery);
    searchQuery.setGetTotalCount(true);

    SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
    columnsToGet.setReturnAll(true);
    searchRequest.setColumnsToGet(columnsToGet);
    searchRequest.setSearchQuery(searchQuery);

    PrimaryKeyBuilder pkbuild = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    pkbuild.addPrimaryKeyColumn("user_id",PrimaryKeyValue.fromString("00002"));
    PrimaryKey routingValue = pkbuild.build();
    searchRequest.setRoutingValues(Arrays.asList(routingValue));
    SearchResponse searchResponse = client.search(searchRequest);

    System.out.println(searchResponse.isAllSuccess());
    System.out.println("totalCount:"+ searchResponse.getTotalCount());
    System.out.println("RowCount:"+searchResponse.getRows().size());

  }