Tablestore:データの読み取り

単一行のデータの読み取り

データバージョンと読み取る列を指定し、フィルタまたは正規表現を使用してデータをフィルタリングできます。

• 行の指定された列から最新バージョンのデータを読み取る

  次のサンプルコードは、データテーブルの行の指定された列から最新バージョンのデータを読み取る方法の例を示しています。

  private static void getRow(SyncClient client, String pkValue) {
      // プライマリキーを構築します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // テーブル名とプライマリキーを指定して、データの行を読み取ります。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // MaxVersionsパラメータを1に設定して、最新バージョンのデータを読み取ります。
      criteria.setMaxVersions(1);
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("読み取り完了。結果：");
      System.out.println(row);
  
      // 読み取る列を指定します。
      criteria.addColumnsToGet("Col0");
      getRowResponse = client.getRow(new GetRowRequest(criteria));
      row = getRowResponse.getRow();
  
      System.out.println("読み取り完了。結果：");
      System.out.println(row);
  } 

• フィルタを使用して、読み取られるデータをフィルタリングする

  次のサンプルコードは、データテーブルの行から最新バージョンのデータを読み取り、フィルタを使用してCol0列の値に基づいてデータをフィルタリングする方法の例を示しています。

  private static void getRow(SyncClient client, String pkValue) {
      // プライマリキーを構築します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // テーブル名とプライマリキーを指定して、データの行を読み取ります。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // MaxVersionsパラメータを1に設定して、最新バージョンのデータを読み取ります。
      criteria.setMaxVersions(1);
  
      // Col0列の値が0である行を返すようにフィルタを構成します。
      SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter("Col0",
              SingleColumnValueFilter.CompareOperator.EQUAL, ColumnValue.fromLong(0));
      // Col0列が存在しない場合、行は返されません。
      singleColumnValueFilter.setPassIfMissing(false);
      criteria.setFilter(singleColumnValueFilter);
  
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("読み取り完了。結果：");
      System.out.println(row);
  }

• 正規表現を使用して、読み取られるデータをフィルタリングする

  次のサンプルコードは、データテーブルの行からCol1列のデータを読み取り、正規表現を使用して列内のデータをフィルタリングする方法の例を示しています。

  private static void getRow(SyncClient client, String pkValue) {
      // データテーブルの名前を指定します。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>");
  
      // プライマリキーを構築します。
      PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue))
          .build();
      criteria.setPrimaryKey(primaryKey);
  
      // MaxVersionsパラメータを1に設定して、最新バージョンのデータを読み取ります。
      criteria.setMaxVersions(1);
  
      // フィルタを構成します。cast<int>(regex(Col1))が100より大きい場合、行が返されます。
      RegexRule regexRule = new RegexRule("t1:([0-9]+),", RegexRule.CastType.VT_INTEGER);
      SingleColumnValueRegexFilter filter =  new SingleColumnValueRegexFilter("Col1",
          regexRule,SingleColumnValueRegexFilter.CompareOperator.GREATER_THAN, ColumnValue.fromLong(100));
      criteria.setFilter(filter);
  
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("読み取り完了。結果：");
      System.out.println(row);
  }

一度に複数の行のデータを読み取る

次のサンプルコードは、バージョン条件、読み取る列、およびフィルタを構成して10行のデータを読み取る方法の例を示しています。

private static void batchGetRow(SyncClient client) {
    // データテーブルの名前を指定します。
    MultiRowQueryCriteria multiRowQueryCriteria = new MultiRowQueryCriteria("<TABLE_NAME>");
    // 読み取る10行を指定します。
    for (int i = 0; i < 10; i++) {
        PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
        primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("pk" + i));
        PrimaryKey primaryKey = primaryKeyBuilder.build();
        multiRowQueryCriteria.addRow(primaryKey);
    }
    // 条件を追加します。
    multiRowQueryCriteria.setMaxVersions(1);
    multiRowQueryCriteria.addColumnsToGet("Col0");
    multiRowQueryCriteria.addColumnsToGet("Col1");
    SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter("Col0",
            SingleColumnValueFilter.CompareOperator.EQUAL, ColumnValue.fromLong(0));
    singleColumnValueFilter.setPassIfMissing(false);
    multiRowQueryCriteria.setFilter(singleColumnValueFilter);

    BatchGetRowRequest batchGetRowRequest = new BatchGetRowRequest();
    // BatchGetRowを使用すると、複数のテーブルからデータを読み取ることができます。各multiRowQueryCriteriaパラメータは、1つのテーブルのクエリ条件を指定します。複数のmultiRowQueryCriteriaパラメータを追加して、複数のテーブルからデータを読み取ることができます。
    batchGetRowRequest.addMultiRowQueryCriteria(multiRowQueryCriteria);

    BatchGetRowResponse batchGetRowResponse = client.batchGetRow(batchGetRowRequest);

    System.out.println("すべての操作が成功したかどうか：" + batchGetRowResponse.isAllSucceed());
    System.out.println("読み取り完了。結果：");
    for (BatchGetRowResponse.RowResult rowResult : batchGetRowResponse.getSucceedRows()) {
        System.out.println(rowResult.getRow());
    }
    if (!batchGetRowResponse.isAllSucceed()) {
        for (BatchGetRowResponse.RowResult rowResult : batchGetRowResponse.getFailedRows()) {
            System.out.println("失敗した行：" + batchGetRowRequest.getPrimaryKey(rowResult.getTableName(), rowResult.getIndex()));
            System.out.println("失敗の原因：" + rowResult.getError());
        }

        /**
         * createRequestForRetryメソッドを使用して、別のリクエストを構築して、失敗した行の操作を再試行できます。ここでは、再試行リクエストのみが構築されます。
         * Tablestore SDKのカスタム再試行ポリシーを再試行方法として使用することをお勧めします。この機能を使用すると、バッチ操作後に失敗した行を再試行できます。再試行ポリシーを設定した後、操作を呼び出すために再試行コードを追加する必要はありません。
         */
        BatchGetRowRequest retryRequest = batchGetRowRequest.createRequestForRetry(batchGetRowResponse.getFailedRows());
    }
}

プライマリキー値が指定された範囲内にあるデータを読み取る

• プライマリキー値が指定された範囲内にあるデータを読み取る

  次のサンプルコードは、プライマリキー値が指定された範囲内にあるデータを前方方向に読み取る方法の例を示しています。レスポンスでnextStartPrimaryKeyパラメータの値が空の場合、プライマリキー値が指定された範囲内にあるすべてのデータが読み取られます。

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // データテーブルの名前を指定します。
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      // 開始プライマリキーを指定します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(startPkValue));
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // 終了プライマリキーを指定します。
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(endPkValue));
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("GetRangeの結果：");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          // nextStartPrimaryKeyパラメータの値がnullでない場合は、読み取り操作を続行します。
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }         

• 最初のプライマリキー列の値によって決定された範囲内のデータを読み取る

  次のサンプルコードは、最初のプライマリキー列の値によって決定された範囲内のデータを前方方向に読み取る方法の例を示しています。2番目のプライマリキー列の開始値はINF_MIN型です。2番目のプライマリキー列の終了値はINF_MAX型です。レスポンスでnextStartPrimaryKeyパラメータの値がnullの場合、指定された範囲内のすべてのデータが読み取られます。

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // データテーブルの名前を指定します。
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
      // 開始プライマリキーを指定します。この例では、2つのプライマリキー列が使用されます。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(startPkValue));// 最初のプライマリキー列の値を特定の値に設定します。
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN);// 2番目のプライマリキー列の値を無限に小さい値に設定します。
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // 終了プライマリキーを指定します。
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(endPkValue));// 最初のプライマリキー列の値を特定の値に設定します。
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX);// 2番目のプライマリキー列の値を無限に大きい値に設定します。
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("GetRangeの結果：");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          // nextStartPrimaryKeyパラメータの値がnullでない場合は、読み取り操作を続行します。
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }    

• プライマリキー値が指定された範囲内にあるデータを読み取り、正規表現を使用して指定された列のデータをフィルタリングする

  次のサンプルコードは、プライマリキー値が["pk:2020-01-01.log", "pk:2021-01-01.log")の範囲内にあるデータをCol1列から読み取り、正規表現を使用してCol1列のデータをフィルタリングする方法の例を示しています。

  private static void getRange(SyncClient client) {
      // データテーブルの名前を指定します。
      RangeRowQueryCriteria criteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      // 読み取るデータのプライマリキーの範囲として["pk:2020-01-01.log", "pk:2021-01-01.log"]を指定します。範囲は左閉区間、右開区間です。
      PrimaryKey pk0 = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("2020-01-01.log"))
          .build();
      PrimaryKey pk1 = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("2021-01-01.log"))
          .build();
      criteria.setInclusiveStartPrimaryKey(pk0);
      criteria.setExclusiveEndPrimaryKey(pk1);
  
      // MaxVersionsパラメータを1に設定して、最新バージョンのデータを読み取ります。
      criteria.setMaxVersions(1);
  
      // フィルタを構成します。cast<int>(regex(Col1))が100より大きい場合、行が返されます。
      RegexRule regexRule = new RegexRule("t1:([0-9]+),", RegexRule.CastType.VT_INTEGER);
      SingleColumnValueRegexFilter filter =  new SingleColumnValueRegexFilter("Col1",
          regexRule,SingleColumnValueRegexFilter.CompareOperator.GREATER_THAN,ColumnValue.fromLong(100));
      criteria.setFilter(filter);
  
      while (true) {
          GetRangeResponse resp = client.getRange(new GetRangeRequest(criteria));
          for (Row row : resp.getRows()) {
              // 何かをする
              System.out.println(row);
          }
          if (resp.getNextStartPrimaryKey() != null) {
              criteria.setInclusiveStartPrimaryKey(resp.getNextStartPrimaryKey());
          } else {
              break;
          }
     }
  }