Tablestore:Transaksi lokal

Skenario sederhana: Baca dan tulis data

Gunakan dua metode berikut untuk melakukan operasi baca, modifikasi, dan tulis (RMW). Setiap metode memiliki batasan tertentu.

• Pembaruan bersyarat (Conditional update): hanya memproses satu permintaan yang melibatkan satu baris dalam satu waktu. Metode ini tidak dapat digunakan untuk memproses permintaan yang melibatkan beberapa baris data atau beberapa operasi tulis. Untuk informasi selengkapnya, lihat Pembaruan bersyarat.

• Penghitung atomik (Atomic counter): hanya memproses satu permintaan yang melibatkan satu baris dalam satu waktu dan hanya mendukung penambahan nilai kolom. Untuk informasi selengkapnya, lihat Menggunakan fitur penghitung atomik.

Untuk mengatasi keterbatasan tersebut, Anda dapat membuat transaksi lokal guna melakukan operasi RMW pada data dalam rentang yang ditentukan oleh nilai kunci partisi.

1. Panggil operasi StartLocalTransaction untuk membuat transaksi lokal berdasarkan nilai kunci partisi tertentu dan mendapatkan ID transaksi lokal.

2. Panggil operasi GetRow atau GetRange untuk membaca data. Permintaan harus menyertakan ID transaksi lokal.

3. Modifikasi data di sisi klien.

4. Panggil operasi PutRow, UpdateRow, DeleteRow, atau BatchWriteRow untuk menulis kembali data yang telah dimodifikasi. Permintaan harus menyertakan ID transaksi lokal.

5. Panggil operasi CommitTransaction untuk menetapkan (commit) transaksi lokal.

Skenario kompleks: Skenario kotak surat

Buat transaksi lokal untuk melakukan operasi atomik pada email pengguna tertentu.

Untuk menggunakan fitur transaksi lokal secara efektif, buat dua tabel indeks pada tabel data. Tabel berikut mencantumkan kolom kunci primer untuk masing-masing tabel. Dalam tabel ini, kolom Type membedakan tabel data dari tabel indeks. Setiap baris indeks menggunakan kolom IndexField untuk menyimpan bidang dengan makna tertentu, sedangkan tabel data tidak memiliki kolom IndexField.

Secara khusus, Anda dapat menggunakan fitur transaksi lokal untuk melakukan operasi berikut pada email.

Menggunakan fitur transaksi lokal untuk menulis baris data

Kode contoh berikut menunjukkan cara membuat transaksi lokal berdasarkan nilai kunci partisi tertentu dalam tabel dan cara menulis baris data dalam transaksi lokal tersebut:

private static void transactionPutRow(SyncClient client) {
    // Tentukan nama tabel data. 
    String tableName="<TABLE_NAME>";
    // Buat transaksi lokal berdasarkan nilai kunci partisi tertentu.  
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci partisi. 
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Buat permintaan untuk membuat transaksi lokal. 
    StartLocalTransactionRequest request = new StartLocalTransactionRequest(tableName, primaryKey);
    // Kirim permintaan untuk membuat transaksi lokal dan dapatkan ID transaksi lokal. 
    String txnId = client.startLocalTransaction(request).getTransactionID();
    
    // Tulis baris data dalam transaksi lokal. 
    // Konfigurasikan informasi kunci primer baris tersebut. 
    PrimaryKeyBuilder primaryKeyBuilder1 = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci primer. Jika kunci primer tabel terdiri dari beberapa kolom kunci primer, konfigurasikan informasi kolom kunci primer tersebut secara berurutan. 
    primaryKeyBuilder1.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
    primaryKeyBuilder1.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
    PrimaryKey primaryKey1 = primaryKeyBuilder1.build();
    // Konfigurasikan kolom atribut baris tersebut. 
    RowPutChange rowPutChange = new RowPutChange(tableName, primaryKey1);
    // Tentukan nama kolom, tipe data, dan nilai kolom untuk setiap kolom atribut. Tambahkan lebih banyak kolom atribut sesuai kebutuhan. 
    rowPutChange.addColumn(new Column("col1", ColumnValue.fromString("colvalue")));
    rowPutChange.addColumn(new Column("col2", ColumnValue.fromLong(10)));
    PutRowRequest request1 = new PutRowRequest(rowPutChange);
    // Sertakan ID transaksi lokal ke dalam permintaan. 
    request1.setTransactionId(txnId);
    client.putRow(request1);
    
    // Tetapkan atau batalkan transaksi lokal.  
    // Tetapkan transaksi lokal agar semua modifikasi data dalam transaksi lokal berlaku. 
    CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
    client.commitTransaction(commitRequest);
    // Batalkan transaksi lokal agar semua modifikasi data dalam transaksi lokal tidak berlaku. 
    //AbortTransactionRequest abortRequest = new AbortTransactionRequest(txnId);
    //client.abortTransaction(abortRequest);
}

Menggunakan fitur transaksi lokal untuk membaca baris data

Kode contoh berikut menunjukkan cara membuat transaksi lokal berdasarkan nilai kunci partisi tertentu dalam tabel dan cara membaca baris data dalam transaksi lokal tersebut:

private static void transactionGetRow(SyncClient client) {
    // Tentukan nama tabel data. 
    String tableName="exampletabled";
    // Buat transaksi lokal berdasarkan nilai kunci partisi tertentu. 
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci partisi. 
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("111"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Buat permintaan untuk membuat transaksi lokal. 
    StartLocalTransactionRequest request = new StartLocalTransactionRequest(tableName, primaryKey);
    // Kirim permintaan untuk membuat transaksi lokal dan dapatkan ID transaksi lokal. 
    String txnId = client.startLocalTransaction(request).getTransactionID();

    // Baca baris data dalam transaksi lokal. 
    // Konfigurasikan informasi kunci primer baris tersebut. 
    PrimaryKeyBuilder primaryKeyBuilder1 = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci primer. Jika kunci primer tabel terdiri dari beberapa kolom kunci primer, konfigurasikan informasi kolom kunci primer tersebut secara berurutan. 
    primaryKeyBuilder1.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("111"));
    primaryKeyBuilder1.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
    PrimaryKey primaryKey1 = primaryKeyBuilder1.build();
    SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(tableName, primaryKey1);
    // Baca versi data terbaru. 
    criteria.setMaxVersions(1);
    GetRowRequest request1 = new GetRowRequest(criteria);
    // Sertakan ID transaksi lokal ke dalam permintaan. 
    request1.setTransactionId(txnId);
    GetRowResponse getRowResponse = client.getRow(request1);
  
    // Tetapkan atau batalkan transaksi lokal. Untuk operasi baca, menetapkan atau membatalkan transaksi lokal memiliki efek yang sama. 
    // Tetapkan transaksi lokal agar semua modifikasi data dalam transaksi lokal berlaku. 
    CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
    client.commitTransaction(commitRequest);
    // Batalkan transaksi lokal agar semua modifikasi data dalam transaksi lokal tidak berlaku. 
    //AbortTransactionRequest abortRequest = new AbortTransactionRequest(txnId);
    //client.abortTransaction(abortRequest);
    
    // Dapatkan dan tampilkan baris data. 
    Row row = getRowResponse.getRow();
    System.out.println("Baris data dibaca dan ditampilkan sebagai berikut:");
    System.out.println(row);
}