Tablestore:IP data type

Supported IP formats

The IP data type supports the following IP address formats.

Query scenarios

IP type queries support three methods, each suited for different business scenarios.

Step 1: Create a search index that contains an IP type

When creating a search index, map the String field for IP queries to the IP type.

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),
        // Set the index for the Col_Ip column to the IP type.
        new FieldSchema("Col_Ip", FieldType.IP).setIndex(true).setEnableSortAndAgg(true)
    ));
    request.setIndexSchema(indexSchema);
    client.createSearchIndex(request);
}

Step 2: Write IP data to the data table

Write IP address data to the field configured as the IP type.

private static void putRow(SyncClient client) {
    String[] keywords = { "Router", "Phone", "PC1", "PC2", "Home Bot" };
    for (int i = 0; i < 5; i++) {
        // Build the primary key.
        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);

        // Add an attribute column.
        rowPutChange.addColumn("Col_Keyword", ColumnValue.fromString(keywords[i]));
        // Add an attribute column and write the IP address.
        rowPutChange.addColumn("Col_Ip", ColumnValue.fromString("192.168.1." + i));
        client.putRow(new PutRowRequest(rowPutChange));
    }
}

Step 3: Verify the configuration

• Verify a term IP query

  /**
   * To query for an exact IP address, use 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());
  }

• Verify an IP range query

  /**
   * To query for an IP address range, you can use CIDR notation in a TermQuery or use a RangeQuery.
   */
  private static void searchIpSegment(SyncClient client) {
      SearchQuery searchQuery = new SearchQuery();
      // Query for an IP range using CIDR notation.
      TermQuery query = QueryBuilders.term("Col_Ip", "192.168.1.1/24").build();
      // Alternatively, use a RangeQuery to query for an IP range.
      // 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());
  }