IP类型

IP格式支持

IP类型支持多种IP地址格式，具体格式说明请参见下表。

查询场景

IP类型查询支持精确查询（即等值查询）、范围查询和混合查询三种方式，适用于不同的业务场景。

步骤一：创建包含IP类型的多元索引

在创建多元索引时，将要进行IP查询的String类型字段配置为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),
        // 给Col_Ip这一列设置IP类型的索引
        new FieldSchema("Col_Ip", FieldType.IP).setIndex(true).setEnableSortAndAgg(true)
    ));
    request.setIndexSchema(indexSchema);
    client.createSearchIndex(request);
}

步骤二：写入IP数据到数据表

向配置了IP类型索引的字段写入IP地址数据：

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

        // 添加属性列
        rowPutChange.addColumn("Col_Keyword", ColumnValue.fromString(keywords[i]));
        // 添加属性列，写入IP
        rowPutChange.addColumn("Col_Ip", ColumnValue.fromString("192.168.1." + i));
        client.putRow(new PutRowRequest(rowPutChange));
    }
}

步骤三：验证配置效果

• 验证精确IP查询

  /**
   * 精确IP地址查询，需要精确匹配一个IP地址的时候，请使用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());
  }

• 验证IP范围查询

  /**
   * IP地址范围查询，可以通过在TermQuery中使用CIDR表示法或者使用RangeQuery实现
   */
  private static void searchIpSegment(SyncClient client) {
      SearchQuery searchQuery = new SearchQuery();
      // 通过CIDR表示法查询IP范围
      TermQuery query = QueryBuilders.term("Col_Ip", "192.168.1.1/24").build();
      // 或者使用Range查询来查询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());
  }