Tablestore:Membaca data

Membaca satu baris data

Saat membaca data, Anda dapat menentukan versi data, kolom yang akan dibaca, filter, dan filter ekspresi reguler.

• Membaca versi data terbaru dan kolom tertentu

  Kode contoh berikut menunjukkan cara membaca data versi terbaru dari kolom yang ditentukan pada satu baris dalam tabel data.

  private static void getRow(SyncClient client, String pkValue) {
      // Membuat kunci primer.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // Menentukan nama tabel dan kunci primer untuk membaca satu baris data.
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // Mengatur 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("Pembacaan selesai. Hasil:");
      System.out.println(row);
  
      // Menentukan kolom yang ingin dibaca.
      criteria.addColumnsToGet("Col0");
      getRowResponse = client.getRow(new GetRowRequest(criteria));
      row = getRowResponse.getRow();
  
      System.out.println("Pembacaan selesai. Hasil:");
      System.out.println(row);
  } 

• Membaca data dengan filter

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

  private static void getRow(SyncClient client, String pkValue) {
      // Membuat kunci primer.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
  
      // Menentukan nama tabel dan kunci primer untuk membaca satu baris data.
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
      // Mengatur parameter MaxVersions ke 1 untuk membaca versi data terbaru.
      criteria.setMaxVersions(1);
  
      // Mengonfigurasi 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 tersebut tidak dikembalikan.
      singleColumnValueFilter.setPassIfMissing(false);
      criteria.setFilter(singleColumnValueFilter);
  
      GetRowResponse getRowResponse = client.getRow(new GetRowRequest(criteria));
      Row row = getRowResponse.getRow();
  
      System.out.println("Pembacaan selesai. Hasil:");
      System.out.println(row);
  }

• Menggunakan filter ekspresi reguler saat membaca data

  Kode contoh berikut menunjukkan cara membaca data kolom Col1 dari satu baris dalam tabel data dan menggunakan ekspresi reguler untuk memfilter data dalam kolom tersebut.

  private static void getRow(SyncClient client, String pkValue) {
      // Menentukan nama tabel data.
      SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>");
   
      // Membuat kunci primer.
      PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
          .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue))
          .build();
      criteria.setPrimaryKey(primaryKey);
   
      // Mengatur parameter MaxVersions ke 1 untuk membaca versi data terbaru.
      criteria.setMaxVersions(1);
   
      // Mengonfigurasi 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("Pembacaan selesai. Hasil:");
      System.out.println(row);
  }

Membaca data secara batch

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

private static void batchGetRow(SyncClient client) {
    // Menentukan nama tabel data.
    MultiRowQueryCriteria multiRowQueryCriteria = new MultiRowQueryCriteria("<TABLE_NAME>");
    // Menentukan 10 baris yang ingin dibaca.
    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);
    }
    // Menambahkan 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("Pembacaan 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 yang gagal:" + batchGetRowRequest.getPrimaryKey(rowResult.getTableName(), rowResult.getIndex()));
            System.out.println("Penyebab kegagalan:" + rowResult.getError());
        }

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

Membaca data dalam rentang

• Membaca data dalam rentang yang ditentukan

  Kode contoh berikut menunjukkan cara membaca data yang nilai kunci primernya berada dalam rentang yang ditentukan dalam arah maju. Jika nilai parameter nextStartPrimaryKey kosong dalam respons, semua data yang nilai kunci primernya berada dalam rentang yang ditentukan telah dibaca. Jika tidak, Anda harus mengirim permintaan lain hingga semua data yang nilai kunci primernya berada dalam rentang yang ditentukan dikembalikan.

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // Menentukan nama tabel data.
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
  
      // Menentukan kunci primer awal.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(startPkValue));
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // Menentukan 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;
          }
      }
  }         

• Membaca data berdasarkan rentang yang ditentukan oleh kolom kunci primer pertama

  Kode contoh 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 diatur ke INF_MIN, dan nilai akhir kolom kunci primer kedua diatur ke INF_MAX. Jika nilai parameter nextStartPrimaryKey null dalam respons, semua data dalam rentang yang ditentukan telah dibaca. Jika tidak, Anda harus mengirim permintaan lain hingga semua data dalam rentang yang ditentukan oleh nilai kolom kunci primer pertama dikembalikan.

  private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
      // Menentukan nama tabel data.
      RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
      // Menentukan kunci primer awal. Dalam contoh ini, dua kolom kunci primer digunakan.
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(startPkValue));// Mengatur nilai kolom kunci primer pertama ke nilai tertentu.
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN);// Mengatur nilai kolom kunci primer kedua ke nilai tak hingga kecil.
      rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());
  
      // Menentukan kunci primer akhir.
      primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(endPkValue));// Mengatur nilai kolom kunci primer pertama ke nilai tertentu.
      primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX);// Mengatur nilai kolom kunci primer kedua ke nilai tak hingga 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;
          }
      }
  }    

• Membaca data dalam rentang yang ditentukan dan menerapkan filter ekspresi reguler pada kolom tertentu

  Kode contoh berikut menunjukkan cara membaca data yang nilai kunci primernya berada dalam rentang ["pk:2020-01-01.log", "pk:2021-01-01.log") dari kolom Col1 dan menggunakan ekspresi reguler untuk memfilter data dalam kolom Col1.

  private static void getRange(SyncClient client) {
      // Menentukan nama tabel data.
      RangeRowQueryCriteria criteria = new RangeRowQueryCriteria("<TABLE_NAME>");
   
      // Menentukan ["pk:2020-01-01.log", "pk:2021-01-01.log") sebagai rentang kunci primer data yang ingin dibaca. Rentang ini merupakan interval tertutup-kiri dan 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);
   
      // Mengatur parameter MaxVersions ke 1 untuk membaca versi data terbaru.
      criteria.setMaxVersions(1);
   
      // Mengonfigurasi 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;
          }
     }
  }