Tablestore：Transaksi Lokal

Skema Sederhana: Membaca dan Menulis Data

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

• Pembaruan bersyarat: Memproses satu permintaan yang melibatkan satu baris pada satu waktu. Metode ini tidak mendukung permintaan yang melibatkan beberapa baris data atau permintaan dengan beberapa operasi tulis. Untuk informasi lebih lanjut, lihat Pembaruan Bersyarat.

• Penghitung atomik: Memproses satu permintaan yang melibatkan satu baris pada satu waktu, hanya mendukung penambahan nilai kolom. Untuk informasi lebih lanjut, lihat Gunakan Fitur Penghitung Atomik.

Untuk mengatasi keterbatasan di atas, Anda dapat membuat transaksi lokal untuk 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 peroleh ID transaksi lokal.

2. Panggil operasi GetRow atau GetRange untuk membaca data. Permintaan harus mencakup 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 mencakup ID transaksi lokal.

5. Panggil operasi CommitTransaction untuk mengonfirmasi transaksi lokal.

Skema Kompleks: Mengelola Email

Anda dapat membuat transaksi lokal untuk melakukan operasi atomik pada email pengguna tertentu.

Untuk menggunakan fitur transaksi lokal, sertakan dua tabel indeks dalam tabel data. Tabel berikut menjelaskan kolom kunci utama dari tabel data dan tabel indeks. Kolom Type digunakan untuk mengidentifikasi baris-baris tabel data dan tabel indeks. Kolom IndexField menyimpan bidang $Folder untuk tabel indeks Folder, dan bidang $SendTime untuk tabel indeks SendTime. Kolom IndexField kosong untuk tabel data.

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

Gunakan Fitur Transaksi Lokal untuk Menulis Baris Data

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

private static void transactionPutRow(SyncClient client) {
    // Tentukan nama tabel data. 
    String tableName="<TABLE_NAME>";
    // Buat transaksi lokal berdasarkan nilai kunci partisi yang ditentukan.  
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci partisi. 
    primaryKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Konstruksi permintaan untuk membuat transaksi lokal. 
    StartLocalTransactionRequest request = new StartLocalTransactionRequest(tableName, primaryKey);
    // Kirim permintaan untuk membuat transaksi lokal dan peroleh ID transaksi lokal. 
    String txnId = client.startLocalTransaction(request).getTransactionID();
    
    // Tulis baris data dalam transaksi lokal. 
    // Konfigurasikan informasi kunci utama baris. 
    PrimaryKeyBuilder primaryKeyBuilder1 = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci utama. Jika kunci utama tabel terdiri dari beberapa kolom kunci utama, konfigurasikan informasi tentang kolom kunci utama secara berurutan. 
    primaryKeyBuilder1.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
    primaryKeyBuilder1.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
    PrimaryKey primaryKey1 = primaryKeyBuilder1.build();
    // Konfigurasikan kolom atribut baris. 
    RowPutChange rowPutChange = new RowPutChange(tableName, primaryKey1);
    // Tentukan nama kolom, tipe data, dan nilai kolom 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);
    // Teruskan ID transaksi lokal ke permintaan. 
    request1.setTransactionId(txnId);
    client.putRow(request1);
    
    // Konfirmasi atau batalkan transaksi lokal.  
    // Konfirmasi transaksi lokal sehingga semua modifikasi data dalam transaksi lokal berlaku. 
    CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
    client.commitTransaction(commitRequest);
    // Batalkan transaksi lokal sehingga semua modifikasi data dalam transaksi lokal tidak berlaku. 
    //AbortTransactionRequest abortRequest = new AbortTransactionRequest(txnId);
    //client.abortTransaction(abortRequest);
}

Gunakan Fitur Transaksi Lokal untuk Membaca Baris Data

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

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

    // Baca baris data dalam transaksi lokal. 
    // Konfigurasikan informasi kunci utama baris. 
    PrimaryKeyBuilder primaryKeyBuilder1 = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    // Tentukan nama kolom, tipe data, dan nilai kolom kunci utama. Jika kunci utama tabel terdiri dari beberapa kolom kunci utama, konfigurasikan informasi tentang kolom kunci utama 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 terbaru data. 
    criteria.setMaxVersions(1);
    GetRowRequest request1 = new GetRowRequest(criteria);
    // Teruskan ID transaksi lokal ke permintaan. 
    request1.setTransactionId(txnId);
    GetRowResponse getRowResponse = client.getRow(request1);
  
    // Konfirmasi atau batalkan transaksi lokal. Untuk operasi baca, mengonfirmasi atau membatalkan transaksi lokal memiliki efek yang sama. 
    // Konfirmasi transaksi lokal sehingga semua modifikasi data dalam transaksi lokal berlaku. 
    CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
    client.commitTransaction(commitRequest);
    // Batalkan transaksi lokal sehingga semua modifikasi data dalam transaksi lokal tidak berlaku. 
    //AbortTransactionRequest abortRequest = new AbortTransactionRequest(txnId);
    //client.abortTransaction(abortRequest);
    
    // Peroleh dan tampilkan baris data. 
    Row row = getRowResponse.getRow();
    System.out.println("Baris data telah dibaca dan ditampilkan sebagai berikut:");
    System.out.println(row);
}