讀取單行數(shù)據(jù)

讀取數(shù)據(jù)時(shí)，您可以指定要讀取的數(shù)據(jù)版本、要讀取的列、過濾器、正則過濾等。

• 讀取最新版本數(shù)據(jù)和指定列

  以下示例用于讀取數(shù)據(jù)表中的一行數(shù)據(jù)，設(shè)置讀取最新版本的數(shù)據(jù)和讀取指定的列。

  private static void getRow(SyncClient client, String pkValue) {
      //構(gòu)造主鍵。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      //讀取一行數(shù)據(jù)，設(shè)置數(shù)據(jù)表名稱。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      //設(shè)置讀取最新版本。
      criteria.setMaxVersions(1);
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("讀取完畢，結(jié)果為： ");
      System.out.println(row);
  
      //設(shè)置讀取某些列。
      criteria.addColumnsToGet("Col0");
      getRowResponse = client.getRow(new GetRowRequest(criteria));
      row = getRowResponse.getRow();
  
      System.out.println("讀取完畢，結(jié)果為：");
      System.out.println(row);
  } 

• 讀取數(shù)據(jù)時(shí)使用過濾器

  以下示例用于讀取數(shù)據(jù)表中的一行數(shù)據(jù)，設(shè)置讀取最新版本的數(shù)據(jù)以及根據(jù)Col0列的值過濾數(shù)據(jù)。

  private static void getRow(SyncClient client, String pkValue) {
      //構(gòu)造主鍵。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      //讀取一行數(shù)據(jù)，設(shè)置數(shù)據(jù)表名稱。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      //設(shè)置讀取最新版本。
      criteria.setMaxVersions(1);
  
      //設(shè)置過濾器，當(dāng)Col0列的值為0時(shí)，返回該行。
      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("讀取完畢，結(jié)果為: ");
      System.out.println(row);
  }

• 讀取數(shù)據(jù)時(shí)使用正則過濾

  以下示例用于讀取數(shù)據(jù)表一行中Col1列的數(shù)據(jù)，并對(duì)該列的數(shù)據(jù)執(zhí)行正則過濾。

  private static void getRow(SyncClient client, String pkValue) {
      //設(shè)置數(shù)據(jù)表名稱。
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>");
   
      //構(gòu)造主鍵。
      PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue))
          .build();
      criteria.setPrimaryKey(primaryKey);
   
      // 設(shè)置讀取最新版本。
      criteria.setMaxVersions(1);
   
      // 設(shè)置過濾器，當(dāng)cast<int>(regex(Col1)) > 100時(shí)，返回該行。
      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("讀取完畢，結(jié)果為: ");
      System.out.println(row);
  }

批量讀取數(shù)據(jù)

以下示例用于讀取10行，設(shè)置版本條件、要讀取的列、過濾器等。

private static void batchGetRow(SyncClient client) {
    //設(shè)置數(shù)據(jù)表名稱。
    MultiRowQueryCriteria multiRowQueryCriteria = new MultiRowQueryCriteria("<TABLE_NAME>");
    //加入10個(gè)要讀取的行。
    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支持讀取多個(gè)表的數(shù)據(jù)，一個(gè)multiRowQueryCriteria對(duì)應(yīng)一個(gè)表的查詢條件，可以添加多個(gè)multiRowQueryCriteria。
    batchGetRowRequest.addMultiRowQueryCriteria(multiRowQueryCriteria);

    BatchGetRowResponse batchGetRowResponse = client.batchGetRow(batchGetRowRequest);

    System.out.println("是否全部成功：" + batchGetRowResponse.isAllSucceed());
    System.out.println("讀取完畢，結(jié)果為: ");
    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方法再構(gòu)造一個(gè)請(qǐng)求對(duì)失敗的行進(jìn)行重試。此處只給出構(gòu)造重試請(qǐng)求的部分。
         * 推薦的重試方法是使用SDK的自定義重試策略功能，支持對(duì)batch操作的部分行錯(cuò)誤進(jìn)行重試。設(shè)置重試策略后，調(diào)用接口處無需增加重試代碼。
         */
        BatchGetRowRequest retryRequest = batchGetRowRequest.createRequestForRetry(batchGetRowResponse.getFailedRows());
    }
}

范圍讀取數(shù)據(jù)

• 按照確定范圍讀取數(shù)據(jù)

  以下示例用于按照確定范圍進(jìn)行正序讀取，判斷nextStartPrimaryKey是否為空，讀取完范圍內(nèi)的全部數(shù)據(jù)。

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      //設(shè)置數(shù)據(jù)表名稱。
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      //設(shè)置起始主鍵。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(startPkValue));
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      //設(shè)置結(jié)束主鍵。
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(endPkValue));
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("GetRange的結(jié)果為：");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          //如果NextStartPrimaryKey不為null，則繼續(xù)讀取。
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }         

• 按照第一個(gè)主鍵列確定范圍讀取數(shù)據(jù)

  以下示例用于按照第一個(gè)主鍵列確定范圍、第二主鍵列從最小值（INF_MIN）到最大值（INF_MAX）進(jìn)行正序讀取，判斷nextStartPrimaryKey是否為null，讀取完范圍內(nèi)的全部數(shù)據(jù)。

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      //設(shè)置數(shù)據(jù)表名稱。
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
      //設(shè)置起始主鍵，以兩個(gè)主鍵為例。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(startPkValue));//確定值。
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN);//最小值。
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      //設(shè)置結(jié)束主鍵。
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(endPkValue));//確定值。
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX);//最大值。
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("GetRange的結(jié)果為：");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          //如果nextStartPrimaryKey不為null，則繼續(xù)讀取。
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }    

• 按照確定范圍讀取數(shù)據(jù)并對(duì)指定列使用正則過濾

  以下示例用于讀取主鍵范圍為["pk:2020-01-01.log", "pk:2021-01-01.log")時(shí)Col1列的數(shù)據(jù)，并對(duì)該列的數(shù)據(jù)執(zhí)行正則過濾。

  private static void getRange(SyncClient client) {
      //設(shè)置數(shù)據(jù)表名稱。
      RangeRowQueryCriteria criteria = new RangeRowQueryCriteria("<TABLE_NAME>");
   
      //設(shè)置主鍵范圍為["pk:2020-01-01.log", "pk:2021-01-01.log")，讀取范圍為左閉右開的區(qū)間。
      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);
   
      //設(shè)置讀取最新版本。
      criteria.setMaxVersions(1);
   
      //設(shè)置過濾器，當(dāng)cast<int>(regex(Col1)) > 100時(shí)，返回該行。
      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;
          }
     }
  }