Tablestore:Ler dados

Ler uma única linha de dados

Ao ler dados, você pode especificar a versão dos dados, as colunas a serem lidas, filtros e filtros de expressão regular.

• Ler a versão mais recente dos dados e colunas específicas

  O código de exemplo a seguir demonstra como ler dados da versão mais recente das colunas especificadas de uma linha em uma tabela de dados.

  private static void getRow(SyncClient client, String pkValue) {
      // Construct the primary key.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // Specify the table name and primary key to read a row of data.
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // Set the MaxVersions parameter to 1 to read the latest version of data.
      criteria.setMaxVersions(1);
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("Read complete. Result:");
      System.out.println(row);
  
      // Specify the columns that you want to read.
      criteria.addColumnsToGet("Col0");
      getRowResponse = client.getRow(new GetRowRequest(criteria));
      row = getRowResponse.getRow();
  
      System.out.println("Read complete. Result:");
      System.out.println(row);
  } 

• Ler dados com um filtro

  O código de exemplo a seguir demonstra como ler dados da versão mais recente de uma linha em uma tabela de dados e usar um filtro para filtrar dados com base no valor da coluna Col0.

  private static void getRow(SyncClient client, String pkValue) {
      // Construct the primary key.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // Specify the table name and primary key to read a row of data.
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // Set the MaxVersions parameter to 1 to read the latest version of data.
      criteria.setMaxVersions(1);
  
      // Configure a filter to return a row in which the value of the Col0 column is 0.
      SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter("Col0",
              SingleColumnValueFilter.CompareOperator.EQUAL, ColumnValue.fromLong(0));
      // If the Col0 column does not exist, the row is not returned.
      singleColumnValueFilter.setPassIfMissing(false);
      criteria.setFilter(singleColumnValueFilter);
  
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("Read complete. Result:");
      System.out.println(row);
  }

• Usar um filtro de expressão regular ao ler dados

  O código de exemplo a seguir demonstra como ler os dados da coluna Col1 de uma linha em uma tabela de dados e usar uma expressão regular para filtrar dados na coluna.

  private static void getRow(SyncClient client, String pkValue) {
      // Specify the name of the data table.
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>");
  
      // Construct the primary key.
      PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue))
          .build();
      criteria.setPrimaryKey(primaryKey);
  
      // Set the MaxVersions parameter to 1 to read the latest version of data.
      criteria.setMaxVersions(1);
  
      // Configure a filter. A row is returned when cast<int>(regex(Col1)) is greater than 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("Read complete. Result:");
      System.out.println(row);
  }

Leitura de dados em lote

O código de exemplo a seguir demonstra como configurar as condições de versão, colunas a serem lidas e filtros para ler 10 linhas de dados.

private static void batchGetRow(SyncClient client) {
    // Specify the name of the data table.
    MultiRowQueryCriteria multiRowQueryCriteria = new MultiRowQueryCriteria("<TABLE_NAME>");
    // Specify 10 rows that you want to read.
    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);
    }
    // Add conditions.
    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();
    // The BatchGetRow operation allows you to read data from multiple tables. Each multiRowQueryCriteria parameter specifies query conditions for one table. You can add multiple multiRowQueryCriteria parameters to read data from multiple tables.
    batchGetRowRequest.addMultiRowQueryCriteria(multiRowQueryCriteria);

    BatchGetRowResponse batchGetRowResponse = client.batchGetRow(batchGetRowRequest);

    System.out.println("Whether all operations are successful:" + batchGetRowResponse.isAllSucceed());
    System.out.println("Read complete. Result:");
    for (BatchGetRowResponse.RowResult rowResult : batchGetRowResponse.getSucceedRows()) {
        System.out.println(rowResult.getRow());
    }
    if (!batchGetRowResponse.isAllSucceed()) {
        for (BatchGetRowResponse.RowResult rowResult : batchGetRowResponse.getFailedRows()) {
            System.out.println("Failed rows:" + batchGetRowRequest.getPrimaryKey(rowResult.getTableName(), rowResult.getIndex()));
            System.out.println("Cause of failures:" + rowResult.getError());
        }

        /**
         * You can use the createRequestForRetry method to construct another request to retry the operations on failed rows. In this example, only the retry request is constructed.
         * We recommend that you use the custom retry policy in Tablestore SDKs as the retry method. This way, you can retry failed rows after batch operations are performed. After you specify the retry policy, you do not need to add retry code to call the operation.
         */
        BatchGetRowRequest retryRequest = batchGetRowRequest.createRequestForRetry(batchGetRowResponse.getFailedRows());
    }
}

Ler dados em um intervalo

• Ler dados dentro de um intervalo definido

  O código de exemplo a seguir demonstra como ler dados cujos valores de chave primária estejam no intervalo especificado na direção direta. Se o valor do parâmetro nextStartPrimaryKey estiver vazio na resposta, todos os dados cujos valores de chave primária estejam no intervalo especificado foram lidos. Caso contrário, inicie outra solicitação até que todos os dados cujos valores de chave primária estejam no intervalo especificado sejam retornados.

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // Specify the name of the data table.
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      // Specify the start primary key.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(startPkValue));
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // Specify the end primary key.
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(endPkValue));
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("GetRange result:");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          // If the value of the nextStartPrimaryKey parameter is not null, continue the read operation.
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }         

• Ler dados com base em um intervalo definido pela primeira coluna de chave primária

  O código de exemplo a seguir demonstra como ler dados dentro do intervalo determinado pelo valor da primeira coluna de chave primária na direção direta. Neste exemplo, o valor inicial da segunda coluna de chave primária é definido como INF_MIN e o valor final da segunda coluna de chave primária é definido como INF_MAX. Se o valor do parâmetro nextStartPrimaryKey for nulo na resposta, todos os dados no intervalo especificado foram lidos. Caso contrário, inicie outra solicitação até que todos os dados dentro do intervalo determinado pelo valor da primeira coluna de chave primária sejam retornados.

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // Specify the name of the data table.
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
      // Specify the start primary key. In this example, two primary key columns are used.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(startPkValue));// Set the value of the first primary key column to a specific value.
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN);// Set the value of the second primary key column to an infinitely small value.
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // Specify the end primary key.
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(endPkValue));// Set the value of the first primary key column to a specific value.
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX);// Set the value of the second primary key column to an infinitely great value.
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("GetRange result:");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          // If the value of the nextStartPrimaryKey parameter is not null, continue the read operation.
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }    

• Ler dados dentro de um intervalo definido e aplicar um filtro de expressão regular a uma coluna específica

  O código de exemplo a seguir demonstra como ler dados cujos valores de chave primária estejam no intervalo de ["pk:2020-01-01.log", "pk:2021-01-01.log") da coluna Col1 e usar uma expressão regular para filtrar dados na coluna Col1.

  private static void getRange(SyncClient client) {
      // Specify the name of the data table.
      RangeRowQueryCriteria criteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      // Specify ["pk:2020-01-01.log", "pk:2021-01-01.log") as the range of the primary key of the data that you want to read. The range is a left-closed, right-open interval.
      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);
  
      // Set the MaxVersions parameter to 1 to read the latest version of data.
      criteria.setMaxVersions(1);
  
      // Configure a filter. A row is returned when cast<int>(regex(Col1)) is greater than 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()) {
              // do something
              System.out.println(row);
          }
          if (resp.getNextStartPrimaryKey() != null) {
              criteria.setInclusiveStartPrimaryKey(resp.getNextStartPrimaryKey());
          } else {
              break;
          }
     }
  }