Tablestore：Baca data

Baca satu baris data

Anda dapat menentukan versi data dan kolom yang ingin dibaca, serta memfilter data menggunakan filter atau ekspresi reguler.

• Baca data versi terbaru dari kolom tertentu dalam satu baris

  Contoh kode berikut menunjukkan cara membaca data versi terbaru dari kolom tertentu dalam satu baris tabel data.

  private static void getRow(SyncClient client, String pkValue) {
      // Konstruksi kunci primer. 
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // Tentukan nama tabel dan kunci primer untuk membaca satu baris data. 
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // Setel parameter MaxVersions ke 1 untuk membaca versi data terbaru. 
      criteria.setMaxVersions(1);
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("Baca selesai. Hasil:");
      System.out.println(row);
  
      // Tentukan kolom yang ingin Anda baca. 
      criteria.addColumnsToGet("Col0");
      getRowResponse = client.getRow(new GetRowRequest(criteria));
      row = getRowResponse.getRow();
  
      System.out.println("Baca selesai. Hasil:");
      System.out.println(row);
  } 

• Gunakan filter untuk memfilter data yang dibaca

  Contoh kode berikut menunjukkan cara membaca data versi terbaru dari satu baris tabel data dan menggunakan filter untuk memfilter data berdasarkan nilai kolom Col0.

  private static void getRow(SyncClient client, String pkValue) {
      // Konstruksi kunci primer. 
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // Tentukan nama tabel dan kunci primer untuk membaca satu baris data. 
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // Setel parameter MaxVersions ke 1 untuk membaca versi data terbaru. 
      criteria.setMaxVersions(1);
  
      // Konfigurasikan filter untuk mengembalikan baris di mana nilai kolom Col0 adalah 0. 
      SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter("Col0",
              SingleColumnValueFilter.CompareOperator.EQUAL, ColumnValue.fromLong(0));
      // Jika kolom Col0 tidak ada, baris tidak dikembalikan. 
      singleColumnValueFilter.setPassIfMissing(false);
      criteria.setFilter(singleColumnValueFilter);
  
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("Baca selesai. Hasil:");
      System.out.println(row);
  }

• Gunakan ekspresi reguler untuk memfilter data yang dibaca

  Contoh kode berikut menunjukkan cara membaca data kolom Col1 dari satu baris tabel data dan menggunakan ekspresi reguler untuk memfilter data di kolom tersebut.

  private static void getRow(SyncClient client, String pkValue) {
      // Tentukan nama tabel data. 
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>");
   
      // Konstruksi kunci primer. 
      PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue))
          .build();
      criteria.setPrimaryKey(primaryKey);
   
      // Setel parameter MaxVersions ke 1 untuk membaca versi data terbaru. 
      criteria.setMaxVersions(1);
   
      // Konfigurasikan filter. Baris dikembalikan ketika cast<int>(regex(Col1)) lebih besar dari 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("Baca selesai. Hasil:");
      System.out.println(row);
  }

Baca beberapa baris data sekaligus

Contoh kode berikut menunjukkan cara mengonfigurasi kondisi versi, kolom yang akan dibaca, dan filter untuk membaca 10 baris data.

private static void batchGetRow(SyncClient client) {
    // Tentukan nama tabel data. 
    MultiRowQueryCriteria multiRowQueryCriteria = new MultiRowQueryCriteria("<TABLE_NAME>");
    // Tentukan 10 baris yang ingin Anda baca. 
    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);
    }
    // Tambahkan kondisi. 
    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();
    // Operasi BatchGetRow memungkinkan Anda membaca data dari beberapa tabel. Setiap parameter multiRowQueryCriteria menentukan kondisi kueri untuk satu tabel. Anda dapat menambahkan beberapa parameter multiRowQueryCriteria untuk membaca data dari beberapa tabel. 
    batchGetRowRequest.addMultiRowQueryCriteria(multiRowQueryCriteria);

    BatchGetRowResponse batchGetRowResponse = client.batchGetRow(batchGetRowRequest);

    System.out.println("Apakah semua operasi berhasil:" + batchGetRowResponse.isAllSucceed());
    System.out.println("Baca selesai. Hasil:");
    for (BatchGetRowResponse.RowResult rowResult : batchGetRowResponse.getSucceedRows()) {
        System.out.println(rowResult.getRow());
    }
    if (!batchGetRowResponse.isAllSucceed()) {
        for (BatchGetRowResponse.RowResult rowResult : batchGetRowResponse.getFailedRows()) {
            System.out.println("Baris gagal:" + batchGetRowRequest.getPrimaryKey(rowResult.getTableName(), rowResult.getIndex()));
            System.out.println("Penyebab kegagalan:" + rowResult.getError());
        }

        /**
         * Anda dapat menggunakan metode createRequestForRetry untuk membuat permintaan lain untuk mencoba kembali operasi pada baris yang gagal. Dalam contoh ini, hanya permintaan ulang yang dibuat. 
         * Kami sarankan Anda menggunakan kebijakan ulang kustom dalam SDK Tablestore sebagai metode ulang. Dengan cara ini, Anda dapat mencoba kembali baris yang gagal setelah operasi batch dilakukan. Setelah Anda menentukan kebijakan ulang, Anda tidak perlu menambahkan kode ulang untuk memanggil operasi. 
         */
        BatchGetRowRequest retryRequest = batchGetRowRequest.createRequestForRetry(batchGetRowResponse.getFailedRows());
    }
}

Baca data yang nilai kunci primernya berada dalam rentang tertentu

• Baca data dengan nilai kunci primer dalam rentang tertentu

  Contoh kode berikut menunjukkan cara membaca data dengan nilai kunci primer dalam rentang tertentu dalam arah maju. Jika nilai parameter nextStartPrimaryKey dalam respons kosong, semua data dalam rentang telah dibaca. Jika tidak, ajukan permintaan lain hingga semua data dalam rentang dikembalikan.

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // Tentukan nama tabel data. 
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      // Tentukan kunci primer awal. 
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(startPkValue));
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // Tentukan kunci primer akhir. 
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(endPkValue));
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("Hasil GetRange:");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          // Jika nilai parameter nextStartPrimaryKey tidak null, lanjutkan operasi baca. 
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }         

• Baca data dalam rentang yang ditentukan oleh nilai kolom kunci primer pertama

  Contoh kode berikut menunjukkan cara membaca data dalam rentang yang ditentukan oleh nilai kolom kunci primer pertama dalam arah maju. Dalam contoh ini, nilai awal kolom kunci primer kedua disetel ke INF_MIN, dan nilai akhir disetel ke INF_MAX. Jika nilai parameter nextStartPrimaryKey adalah null dalam respons, semua data dalam rentang telah dibaca. Jika tidak, ajukan permintaan lain hingga semua data dalam rentang dikembalikan.

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // Tentukan nama tabel data. 
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
      // Tentukan kunci primer awal. Dalam contoh ini, dua kolom kunci primer digunakan. 
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(startPkValue));// Setel nilai kolom kunci primer pertama ke nilai tertentu. 
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN);// Setel nilai kolom kunci primer kedua ke nilai tak terbatas kecil. 
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // Tentukan kunci primer akhir. 
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(endPkValue));// Setel nilai kolom kunci primer pertama ke nilai tertentu. 
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX);// Setel nilai kolom kunci primer kedua ke nilai tak terbatas besar. 
      rangeRowQueryCriteria.setExclusiveEndPrimaryKey(primaryKeyBuilder.build());
  
      rangeRowQueryCriteria.setMaxVersions(1);
  
      System.out.println("Hasil GetRange:");
      while (true) {
          GetRangeResponse getRangeResponse = client.getRange(new GetRangeRequest(rangeRowQueryCriteria));
          for (Row row : getRangeResponse.getRows()) {
              System.out.println(row);
          }
  
          // Jika nilai parameter nextStartPrimaryKey tidak null, lanjutkan operasi baca. 
          if (getRangeResponse.getNextStartPrimaryKey() != null) {
              rangeRowQueryCriteria.setInclusiveStartPrimaryKey(getRangeResponse.getNextStartPrimaryKey());
          } else {
              break;
          }
      }
  }    

• Baca data dengan nilai kunci primer dalam rentang tertentu dan gunakan ekspresi reguler untuk memfilter data di kolom tertentu

  Contoh kode berikut menunjukkan cara membaca data dengan nilai kunci primer dalam rentang ["pk:2020-01-01.log", "pk:2021-01-01.log") dari kolom Col1 dan menggunakan ekspresi reguler untuk memfilter data di kolom Col1.

  private static void getRange(SyncClient client) {
      // Tentukan nama tabel data. 
      RangeRowQueryCriteria criteria = new RangeRowQueryCriteria("<TABLE_NAME>");
   
      // Tentukan ["pk:2020-01-01.log", "pk:2021-01-01.log") sebagai rentang kunci primer dari data yang ingin Anda baca. Rentang tersebut adalah interval tertutup kiri, terbuka kanan. 
      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);
   
      // Setel parameter MaxVersions ke 1 untuk membaca versi data terbaru. 
      criteria.setMaxVersions(1);
   
      // Konfigurasikan filter. Baris dikembalikan ketika cast<int>(regex(Col1)) lebih besar dari 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()) {
              // lakukan sesuatu
              System.out.println(row);
          }
          if (resp.getNextStartPrimaryKey() != null) {
              criteria.setInclusiveStartPrimaryKey(resp.getNextStartPrimaryKey());
          } else {
              break;
          }
     }
  }