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 Gunakan 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 meng-commit transaksi lokal.

Skenario kompleks: Skenario kotak surat

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

Agar dapat menggunakan fitur transaksi lokal dengan benar, buat dua tabel indeks pada tabel data. Tabel berikut mencantumkan kolom kunci primer untuk masing-masing tabel. 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 tersebut.

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

Gunakan fitur transaksi lokal untuk menulis baris data

Contoh berikut membuat transaksi lokal untuk nilai kunci partisi tertentu dari tabel dan menulis satu baris dalam transaksi lokal tersebut.

String tableName = "local_tx_demo";

// 1. Mulai transaksi lokal untuk nilai kunci partisi tertentu dan dapatkan ID transaksi.
PrimaryKeyBuilder pkBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
pkBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
PrimaryKey partitionKey = pkBuilder.build();

StartLocalTransactionRequest startRequest =
        new StartLocalTransactionRequest(tableName, partitionKey);
String txnId = client.startLocalTransaction(startRequest).getTransactionID();

// 2. Tulis satu baris dalam transaksi. Anda harus menentukan kunci primer lengkap dan menyertakan ID transaksi.
PrimaryKeyBuilder rowKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
rowKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
rowKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
PrimaryKey rowKey = rowKeyBuilder.build();

RowPutChange rowPutChange = new RowPutChange(tableName, rowKey);
rowPutChange.addColumn(new Column("col1", ColumnValue.fromString("colvalue")));
rowPutChange.addColumn(new Column("col2", ColumnValue.fromLong(10)));

PutRowRequest putRequest = new PutRowRequest(rowPutChange);
putRequest.setTransactionId(txnId);
client.putRow(putRequest);

// 3. Commit transaksi agar semua operasi tulis berlaku. Untuk membuang perubahan, panggil abortTransaction() sebagai gantinya.
CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
client.commitTransaction(commitRequest);

Gunakan fitur transaksi lokal untuk membaca baris data

Contoh berikut membuat transaksi lokal untuk nilai kunci partisi tertentu dari tabel dan membaca satu baris dalam transaksi lokal tersebut.

String tableName = "local_tx_demo";

// 1. Mulai transaksi lokal untuk nilai kunci partisi tertentu.
PrimaryKeyBuilder pkBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
pkBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
PrimaryKey partitionKey = pkBuilder.build();

StartLocalTransactionRequest startRequest =
        new StartLocalTransactionRequest(tableName, partitionKey);
String txnId = client.startLocalTransaction(startRequest).getTransactionID();

// 2. Baca satu baris dalam transaksi. Anda harus menentukan kunci primer lengkap dan menyertakan ID transaksi.
PrimaryKeyBuilder rowKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
rowKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
rowKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
PrimaryKey rowKey = rowKeyBuilder.build();

SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(tableName, rowKey);
criteria.setMaxVersions(1);

GetRowRequest getRequest = new GetRowRequest(criteria);
getRequest.setTransactionId(txnId);
GetRowResponse getResponse = client.getRow(getRequest);

// 3. Commit atau batalkan transaksi. Untuk transaksi read-only, keduanya memiliki efek yang sama dan melepaskan transaksi.
CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
client.commitTransaction(commitRequest);

Row row = getResponse.getRow();
System.out.println(row);