Tablestore：Tipe data IP

Format IP yang didukung

Tipe data IP mendukung berbagai format alamat IP. Tabel berikut menjelaskan format yang didukung.

Skenario kueri

Kueri tipe IP mendukung tiga metode: kueri tepat (cocok persis), kueri rentang, dan kueri komposit. Setiap metode cocok untuk skenario bisnis yang berbeda.

Langkah 1: Buat indeks pencarian yang berisi tipe IP

Saat membuat indeks pencarian, petakan bidang String yang ingin digunakan untuk kueri IP ke tipe IP.

private static void createSearchIndex(SyncClient client) {
    CreateSearchIndexRequest request = new CreateSearchIndexRequest();
    request.setTableName(TABLE_NAME);
    request.setIndexName(INDEX_NAME);
    IndexSchema indexSchema = new IndexSchema();
    indexSchema.setFieldSchemas(Arrays.asList(
        new FieldSchema("Col_Keyword", FieldType.KEYWORD).setIndex(true).setEnableSortAndAgg(true),
        // Tetapkan indeks untuk kolom Col_Ip ke tipe IP.
        new FieldSchema("Col_Ip", FieldType.IP).setIndex(true).setEnableSortAndAgg(true)
    ));
    request.setIndexSchema(indexSchema);
    client.createSearchIndex(request);
}

Langkah 2: Tulis data IP ke tabel data

Tulis data alamat IP ke bidang yang telah dikonfigurasikan sebagai tipe IP.

private static void putRow(SyncClient client) {
    String[] keywords = { "Router", "Phone", "PC1", "PC2", "Home Bot" };
    for (int i = 0; i < 5; i++) {
        // Bangun kunci utama.
        PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
        primaryKeyBuilder.addPrimaryKeyColumn(PRIMARY_KEY_NAME_1, PrimaryKeyValue.fromString("pk1" + i));
        PrimaryKey primaryKey = primaryKeyBuilder.build();

        RowPutChange rowPutChange = new RowPutChange(TABLE_NAME, primaryKey);

        // Tambahkan kolom atribut.
        rowPutChange.addColumn("Col_Keyword", ColumnValue.fromString(keywords[i]));
        // Tambahkan kolom atribut dan tulis alamat IP.
        rowPutChange.addColumn("Col_Ip", ColumnValue.fromString("192.168.1." + i));
        client.putRow(new PutRowRequest(rowPutChange));
    }
}

Langkah 3: Verifikasi konfigurasi

• Verifikasi kueri IP tepat

  /**
   * Untuk mengkueri alamat IP yang tepat, gunakan TermQuery.
   */
  private static void searchExactIp(SyncClient client) {
      SearchQuery searchQuery = new SearchQuery();
      TermQuery query = QueryBuilders.term("Col_Ip", "192.168.1.1").build();
      searchQuery.setQuery(query);
      searchQuery.setLimit(100);
      SearchRequest searchRequest = new SearchRequest(TABLE_NAME, INDEX_NAME, searchQuery);
      SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
      columnsToGet.setReturnAll(true);
      searchRequest.setColumnsToGet(columnsToGet);
      SearchResponse resp = client.search(searchRequest);
      System.out.println("TotalCount: " + resp.getTotalCount());
      System.out.println("Row: " + resp.getRows());
  }

• Verifikasi kueri rentang IP

  /**
   * Untuk mengkueri rentang alamat IP, Anda dapat menggunakan notasi CIDR dalam TermQuery atau menggunakan RangeQuery.
   */
  private static void searchIpSegment(SyncClient client) {
      SearchQuery searchQuery = new SearchQuery();
      // Kueri untuk rentang IP menggunakan notasi CIDR.
      TermQuery query = QueryBuilders.term("Col_Ip", "192.168.1.1/24").build();
      // Sebagai alternatif, gunakan RangeQuery untuk mengkueri rentang IP.
      // RangeQuery query = QueryBuilders.range("Col_Ip").greaterThanOrEqual("192.168.1.0").lessThanOrEqual("192.168.1.255").build();
      searchQuery.setQuery(query);
      searchQuery.setLimit(100);
      SearchRequest searchRequest = new SearchRequest(TABLE_NAME, INDEX_NAME, searchQuery);
  
      SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
      columnsToGet.setReturnAll(true);
      searchRequest.setColumnsToGet(columnsToGet);
  
      SearchResponse resp = client.search(searchRequest);
      System.out.println("TotalCount: " + resp.getTotalCount());
      System.out.println("Row: " + resp.getRows());
  }