Tablestore：Gunakan fitur penghitung atomik

Prasyarat

• Sebuah instance OTSClient telah diinisialisasi. Untuk informasi lebih lanjut, lihat Inisialisasi instance OTSClient.

• Tabel data telah dibuat, dan data telah ditulis ke tabel tersebut. Untuk informasi lebih lanjut, lihat Buat tabel data dan Tulis data.

Catatan Penggunaan

• Penghitung atomik hanya dapat diimplementasikan pada kolom INTEGER.

• Jika kolom yang ditentukan sebagai penghitung atomik tidak ada sebelum menulis data, nilai defaultnya adalah 0. Jika kolom bukan bertipe INTEGER, kesalahan OTSParameterInvalid akan terjadi.

• Anda dapat memperbarui penghitung atomik dengan angka positif atau negatif, tetapi hindari overflow integer. Jika terjadi overflow, kesalahan OTSParameterInvalid akan dikembalikan.

• Secara default, nilai penghitung atomik tidak dikembalikan dalam respons pembaruan baris. Namun, Anda dapat menentukan agar nilai penghitung atomik yang diperbarui dikembalikan.

• Anda tidak dapat menetapkan kolom sebagai penghitung atomik dan memperbarui kolom tersebut dalam satu permintaan pembaruan. Sebagai contoh, jika Kolom A ditetapkan sebagai penghitung atomik, Anda tidak dapat melakukan operasi lain seperti timpa atau hapus pada kolom tersebut secara bersamaan.

• Anda dapat melakukan beberapa operasi pembaruan pada baris yang sama melalui permintaan BatchWriteRow. Namun, jika Anda melakukan operasi penghitung atomik pada baris tersebut, hanya satu operasi pembaruan yang dapat dilakukan dalam permintaan BatchWriteRow.

• Hanya nilai versi terbaru dari penghitung atomik yang dapat diperbarui. Anda tidak dapat memperbarui nilai versi tertentu dari penghitung atomik. Setelah pembaruan selesai, versi baru data dimasukkan ke penghitung atomik di baris tersebut.

Operasi API

Parameter

Contoh

public static void Increment(int incrementValue)
{
    Console.WriteLine("Mulai set kolom penambahan...");
    OTSClient otsClient = Config.GetClient();

    // Tentukan primary key dari baris. Primary key harus sesuai dengan primary key yang ditentukan dalam TableMeta saat Anda membuat tabel.
    PrimaryKey primaryKey = new PrimaryKey
    {
        { Pk1, new ColumnValue(0) },
        { Pk2, new ColumnValue("abc") }
    };
    RowUpdateChange rowUpdateChange = new RowUpdateChange(TableName, primaryKey); // Tentukan nama tabel data.
    // Tetapkan parameter ReturnType ke ReturnType.RT_AFTER_MODIFY untuk mengembalikan nilai kolom tempat operasi penghitung atomik dilakukan.
    rowUpdateChange.ReturnType = ReturnType.RT_AFTER_MODIFY;
    rowUpdateChange.ReturnColumnNames = new List<string>() { IncrementCol};
    // Tentukan kolom tempat operasi penghitung atomik dilakukan. Nilai kolom mulai dari 0 dan meningkat sebesar angka yang ditentukan oleh parameter incrementValue.
    rowUpdateChange.Increment(new Column(IncrementCol, new ColumnValue(incrementValue)));

    UpdateRowRequest updateRowRequest = new UpdateRowRequest(rowUpdateChange);

    var response = otsClient.UpdateRow(updateRowRequest);
    Console.WriteLine("set kolom penambahan berhasil Hasil penambahan:" + response.Row.GetColumns()[0].Value);
}