Tablestore:IP データの型

サポートされている IP フォーマット

IP データの型は、複数の IP アドレスフォーマットをサポートしています。次の表に、サポートされているフォーマットを示します。

クエリシナリオ

IP 型のクエリは、term クエリ (完全に一致)、範囲クエリ、複合クエリの 3 つのメソッドをサポートしています。各メソッドは、さまざまなビジネスシナリオに適しています。

ステップ 1: 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);
}

ステップ 2: データテーブルへの 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));
    }
}

ステップ 3: 構成の確認

• term 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();
      // または、RangeQuery を使用して 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());
  }