Tablestore：Membaca data

Parameter

Contoh

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

private static void getRow(SyncClient client, String pkValue) {
    // Konstruksi primary key. 
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();

    // Tentukan nama tabel dan primary key untuk membaca satu baris data. 
    SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
    // Atur parameter MaxVersions ke 1 untuk membaca versi terbaru data. 
    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);
} 

private static void getRow(SyncClient client, String pkValue) {
    // Konstruksi primary key. 
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();

    // Tentukan nama tabel dan primary key untuk membaca satu baris data. 
    SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>", primaryKey);
    // Atur parameter MaxVersions ke 1 untuk membaca versi terbaru data. 
    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);
}

private static void getRow(SyncClient client, String pkValue) {
    // Tentukan nama tabel data. 
    SingleRowQueryCriteria criteria = new SingleRowQueryCriteria("<TABLE_NAME>");
 
    // Konstruksi primary key. 
    PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder()
        .addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue))
        .build();
    criteria.setPrimaryKey(primaryKey);
 
    // Atur parameter MaxVersions ke 1 untuk membaca versi terbaru data. 
    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);
}

Catatan penggunaan

• Operasi BatchGetRow menggunakan konfigurasi parameter yang sama untuk semua baris. Misalnya, jika parameter ColumnsToGet diatur ke [colA], hanya nilai kolom colA yang dibaca dari semua baris.

• Jika beberapa baris gagal dibaca saat memanggil operasi BatchGetRow, Tablestore tidak mengembalikan pengecualian tetapi mengembalikan BatchGetRowResponse, yang mencakup pesan kesalahan untuk baris yang gagal. Periksa nilai pengembalian menggunakan metode isAllSucceed atau getFailedRows dari BatchGetRowResponse.

• Anda dapat membaca hingga 100 baris secara bersamaan menggunakan operasi BatchGetRow.

Parameter

Untuk informasi lebih lanjut, lihat bagian Parameter untuk Membaca Satu Baris Data dari topik ini.

Contoh

Kode sampel berikut menunjukkan cara mengonfigurasi kondisi versi, kolom yang ingin 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 ulang operasi pada baris yang gagal. Dalam contoh ini, hanya permintaan ulang yang dibuat. 
         * Kami merekomendasikan Anda menggunakan kebijakan ulang kustom dalam Tablestore SDK sebagai metode ulang. Dengan cara ini, Anda dapat mencoba ulang 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());
    }
}

Catatan Penggunaan

Operasi GetRange mengikuti prinsip pencocokan paling kiri. Tablestore membandingkan nilai secara berurutan dari kolom primary key pertama hingga terakhir untuk membaca data yang nilai primary key-nya berada dalam rentang tertentu. Sebagai contoh, primary key tabel data terdiri dari kolom primary key berikut: PK1, PK2, dan PK3. Saat membaca data, Tablestore pertama-tama memeriksa apakah nilai PK1 dari sebuah baris berada dalam rentang yang ditentukan untuk kolom primary key pertama. Jika nilai PK1 berada dalam rentang, Tablestore menghentikan pemeriksaan lebih lanjut dan langsung mengembalikan baris tersebut. Namun, jika nilai PK1 tidak berada dalam rentang, Tablestore melanjutkan dengan memeriksa nilai kolom primary key lainnya (PK2 dan PK3) menggunakan metode yang sama.

Operasi GetRange mungkin berhenti dan mengembalikan data jika salah satu dari kondisi berikut terpenuhi:

• Jumlah data yang dipindai mencapai 4 MB.

• Jumlah baris yang dipindai mencapai 5.000.

• Jumlah baris yang dikembalikan mencapai batas atas.

• Throughput baca tidak cukup untuk membaca baris data berikutnya karena semua throughput baca cadangan telah habis digunakan.

Setiap pemanggilan GetRange memindai data sekali. Jika ukuran data yang ingin dipindai melalui operasi GetRange besar, pemindaian akan berhenti ketika jumlah baris mencapai 5.000 atau ukuran data mencapai 4 MB. Tablestore tidak mengembalikan data tersisa yang memenuhi kondisi kueri. Anda dapat menggunakan metode paging untuk mendapatkan sisa data yang memenuhi kondisi tersebut.

Parameter

Contoh

private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
    // Tentukan nama tabel data. 
    RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");

    // Tentukan primary key awal. 
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(startPkValue));
    rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());

    // Tentukan primary key 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;
        }
    }
}         

private static void getRange(SyncClient client, String startPkValue, String endPkValue) {
    // Tentukan nama tabel data. 
    RangeRowQueryCriteria rangeRowQueryCriteria = new RangeRowQueryCriteria("<TABLE_NAME>");
    // Tentukan primary key awal. Dalam contoh ini, dua kolom primary key digunakan. 
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(startPkValue));// Atur nilai kolom primary key pertama ke nilai tertentu. 
    primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN);// Atur nilai kolom primary key kedua ke nilai yang sangat kecil. 
    rangeRowQueryCriteria.setInclusiveStartPrimaryKey(primaryKeyBuilder.build());

    // Tentukan primary key akhir. 
    primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString(endPkValue));// Atur nilai kolom primary key pertama ke nilai tertentu. 
    primaryKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX);// Atur nilai kolom primary key kedua ke nilai yang sangat 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;
        }
    }
}    

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 primary key 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);
 
    // Atur parameter MaxVersions ke 1 untuk membaca versi terbaru data. 
    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;
        }
   }
}

Memulai

1. Konstruksi TableStoreReader.

   // Tentukan nama instance.
   String instanceName = "yourInstanceName";
   // Tentukan endpoint instance.
   String endpoint = "yourEndpoint";
   // Dapatkan ID AccessKey dan Rahasia AccessKey dari variabel lingkungan.
   String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
   String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");
   
   AsyncClientInterface client = new AsyncClient(endpoint, accessKeyId, accessKeySecret, instanceName);
   TableStoreReaderConfig config = new TableStoreReaderConfig();
   ThreadPoolExecutor executor = new ThreadPoolExecutor(4, 4, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(1024))
   
   TableStoreReader reader = new DefaultTableStoreReader(client, config, executor, null);

2. Konstruksi permintaan kueri.

   Cached data yang ingin Anda kueri di memori. Anda dapat menambahkan satu atau lebih baris data pada saat yang bersamaan.

   PrimaryKey pk1 = PrimaryKeyBuilder.createPrimaryKeyBuilder()
           .addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(0))
           .addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(0))
           .build();
   // Tambahkan primary key dengan nilai pk1 untuk mengkueri kolom atribut baris. 
   Future<ReaderResult> readerResult = reader.addPrimaryKeyWithFuture("<TABLE_NAME1>", pk1);
   // Anda juga dapat menggunakan metode List untuk menambahkan beberapa nilai primary key pada saat yang bersamaan untuk mengkueri baris. 
   List<PrimaryKey> primaryKeyList = new ArrayList<PrimaryKey>();
   Future<ReaderResult> readerResult = reader.addPrimaryKeysWithFuture("<TABLE_NAME2>", primaryKeyList);

3. Kueri data.

   Kirim permintaan untuk mengkueri data yang dicached di memori. Anda dapat mengkueri data dalam mode sinkron atau asinkron.

   • Kueri data dalam mode sinkron

     reader.flush();

   • Kueri data dalam mode asinkron

     reader.send();

4. Dapatkan hasil kueri.

   // Tampilkan informasi tentang kueri yang berhasil dan gagal. 
   for (RowReadResult success : readerResult.get().getSucceedRows()) {
       System.out.println(success.getRowResult());
   }
   
   for (RowReadResult fail : readerResult.get().getFailedRows()) {
       System.out.println(fail.getRowResult());
   }

5. Tutup TableStoreReader.

   reader.close();
   // Tutup klien dan executor berdasarkan kebutuhan bisnis Anda. 
   client.shutdown();
   executor.shutdown();

Parameter

Anda dapat memodifikasi TableStoreReaderConfig untuk menentukan konfigurasi kustom untuk TableStoreReader.

Tentukan kondisi kueri

Anda dapat menentukan parameter tingkat tabel untuk mengkueri data, seperti jumlah maksimum versi data, kolom yang ingin Anda kueri, dan rentang waktu di mana Anda ingin mengkueri data.

// Kueri data hingga 10 versi dalam kolom col1 dari tabel yang ditentukan dalam 60 detik terakhir. 
// Tentukan nama tabel data. 
RowQueryCriteria criteria = new RowQueryCriteria("<TABLE_NAME>");
// Tentukan kolom yang ingin Anda kembalikan. 
criteria.addColumnsToGet("col1");
// Tentukan jumlah maksimum versi yang ingin Anda kembalikan. 
criteria.setMaxVersions(10);
criteria.setTimeRange(new TimeRange(System.currentTimeMillis() - 60 * 1000, System.currentTimeMillis()));
reader.setRowQueryCriteria(criteria);

Kode sampel lengkap

public class TableStoreReaderDemo {
    // Tentukan nama instance.
    private static final String instanceName = "yourInstanceName";
    // Tentukan endpoint instance.
    private static final String endpoint = "yourEndpoint";
    // Dapatkan ID AccessKey dan Rahasia AccessKey dari variabel lingkungan.
    private static final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
    private static final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");
    private static AsyncClientInterface client;
    private static ExecutorService executor;
    private static AtomicLong succeedRows = new AtomicLong();
    private static AtomicLong failedRows = new AtomicLong();

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        /**
         * Langkah 1: Konstruksi TableStoreReader. 
         */
        // Konstruksi AsyncClient. 
        client = new AsyncClient(endpoint, accessKeyId, accessKeySecret, instanceName);
        // Konstruksi kelas konfigurasi TableStoreReader. 
        TableStoreReaderConfig config = new TableStoreReaderConfig();
        {
            // Parameter berikut memiliki nilai default dan dapat dibiarkan kosong. 
            // Periksa skema tabel sebelum Anda menambahkan nilai primary key dari baris yang ingin Anda kueri. 
            config.setCheckTableMeta(true);  
            // Tentukan jumlah maksimum baris yang dapat Anda kueri menggunakan permintaan. Dalam contoh ini, hingga 100 baris dapat dikueri menggunakan permintaan. 
            config.setMaxBatchRowsCount(100);    
            // Tentukan jumlah maksimum versi yang dapat dikembalikan. 
            config.setDefaultMaxVersions(1);
            // Jumlah total permintaan konkuren yang dapat dikirim. 
            config.setConcurrency(16); 
            // Tentukan jumlah bucket di memori. 
            config.setBucketCount(4);      
            // Tentukan interval di mana semua data yang dicached di-flush. 
            config.setFlushInterval(10000);      
            // Tentukan interval di mana status TableStoreReader dicatat. 
            config.setLogInterval(10000);                   
        }
        // Konstruksi executor yang digunakan untuk mengirim permintaan. 
        ThreadFactory threadFactory = new ThreadFactory() {
            private final AtomicInteger counter = new AtomicInteger(1);

            @Override
            public Thread newThread(Runnable r) {
                return new Thread(r, "reader-" + counter.getAndIncrement());
            }
        };
        executor = new ThreadPoolExecutor(4, 4, 0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue(1024), threadFactory, new ThreadPoolExecutor.CallerRunsPolicy());

        // Konstruksi fungsi callback TableStoreReader. 
        TableStoreCallback<PrimaryKeyWithTable, RowReadResult> callback = new TableStoreCallback<PrimaryKeyWithTable, RowReadResult>() {
            @Override
            public void onCompleted(PrimaryKeyWithTable req, RowReadResult res) {
                succeedRows.incrementAndGet();
            }

            @Override
            public void onFailed(PrimaryKeyWithTable req, Exception ex) {
                failedRows.incrementAndGet();
            }
        };
        TableStoreReader reader = new DefaultTableStoreReader(client, config, executor, callback);
        /**
         * Langkah 2: Konstruksi permintaan. 
         */
        // Tambahkan nilai primary key dari baris yang ingin Anda kueri ke memori. 
        PrimaryKey pk1 = PrimaryKeyBuilder.createPrimaryKeyBuilder()
                .addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(0))
                .addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(0))
                .build();
        reader.addPrimaryKey("<TABLE_NAME1>", pk1);

        // Tambahkan nilai primary key dari baris lain yang ingin Anda kueri ke memori dan dapatkan objek Future. 
        PrimaryKey pk2 = PrimaryKeyBuilder.createPrimaryKeyBuilder()
                .addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(0))
                .addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(0))
                .build();
        Future<ReaderResult> readerResult = reader.addPrimaryKeyWithFuture("<TABLE_NAME2>", pk2);
        /**
         * Langkah 3: Kueri data. 
         */
        // Kirim data di memori dalam mode asinkron. 
        reader.send();
        /**
         * Langkah 4: Dapatkan hasil kueri. 
         */
        // Tampilkan informasi tentang kueri yang berhasil dan gagal. 
        for (RowReadResult success : readerResult.get().getSucceedRows()) {
            System.out.println(success.getRowResult());
        }
        for (RowReadResult fail : readerResult.get().getFailedRows()) {
            System.out.println(fail.getRowResult());
        }
        /**
         * Langkah 5: Tutup TableStoreReader. 
         */
        reader.close();
        client.shutdown();
        executor.shutdown();
    }
}