Tablestore：Tulis Data

Operasi API

/// <summary>
/// Tulis satu baris data berdasarkan nama tabel, kunci utama, dan atribut yang ditentukan. Jumlah unit kapasitas (CUs) yang dikonsumsi oleh operasi ini dikembalikan. 
/// </summary>
/// <param name="request">Permintaan penyisipan data</param>
/// <returns>Jumlah CUs yang dikonsumsi oleh operasi</returns>
public PutRowResponse PutRow(PutRowRequest request);

/// <summary>
/// Mode asinkron dari PutRow. 
/// </summary>
public Task<PutRowResponse> PutRowAsync(PutRowRequest request);                    

Parameter

Contoh

// Tentukan kunci utama baris. Skema kunci utama harus sama dengan skema yang ditentukan dalam TableMeta saat tabel dibuat. 
var primaryKey = new PrimaryKey();
primaryKey.Add("pk0", new ColumnValue(0));
primaryKey.Add("pk1", new ColumnValue("abc"));

// Tentukan kolom atribut baris. 
var attribute = new AttributeColumns();
attribute.Add("col0", new ColumnValue(0));
attribute.Add("col1", new ColumnValue("a"));
attribute.Add("col2", new ColumnValue(true));

try
{
    // Konstruksi objek permintaan untuk menyisipkan satu baris data. RowExistenceExpectation.IGNORE menentukan bahwa data disisipkan tanpa memandang apakah baris yang ditentukan ada. 
    var request = new PutRowRequest("SampleTable", new Condition(RowExistenceExpectation.IGNORE),
                            primaryKey, attribute);

    // Panggil operasi PutRow untuk menyisipkan data. 
    otsClient.PutRow(request);

    // Jika operasi berhasil, tidak ada pengecualian yang dikembalikan. 
    Console.WriteLine("Penyisipan baris berhasil.");
}
catch (Exception ex)
{
    // Jika operasi gagal, pengecualian dikembalikan. Tangani pengecualian. 
    Console.WriteLine("Penyisipan baris gagal, pengecualian:{0}", ex.Message);
}                    

// Tentukan kunci utama baris. Skema kunci utama harus sama dengan skema yang ditentukan dalam TableMeta saat tabel dibuat. 
var primaryKey = new PrimaryKey();
primaryKey.Add("pk0", new ColumnValue(0));
primaryKey.Add("pk1", new ColumnValue("abc"));

// Tentukan kolom atribut baris. 
AttributeColumns attribute = new AttributeColumns();
attribute.Add("col0", new ColumnValue(0));
attribute.Add("col1", new ColumnValue("a"));
attribute.Add("col2", new ColumnValue(true));

// Ketika nilai kolom col0 lebih besar dari 24, baris dapat disisipkan untuk menimpa nilai aslinya. 
try
{
    var request = new PutRowRequest("SampleTable", new Condition(RowExistenceExpectation.EXPECT_EXIST),
                            primaryKey, attribute);
    request.Condition.ColumnCondition = new RelationalCondition("col0",
                                        CompareOperator.GREATER_THAN,
                                        new ColumnValue(24));
    otsClient.PutRow(request);

    Console.WriteLine("Penyisipan baris berhasil.");
}
catch (Exception ex)
{
    Console.WriteLine("Penyisipan baris gagal. error:{0}", ex.Message);
}                   

try
{
    var putRowTaskList = new List<Task<PutRowResponse>>();
    for (int i = 0; i < 100; i++)
    {
        // Tentukan kunci utama baris. Skema kunci utama harus sama dengan skema yang ditentukan dalam TableMeta saat tabel dibuat. 
        var primaryKey = new PrimaryKey();
        primaryKey.Add("pk0", new ColumnValue(i));
        primaryKey.Add("pk1", new ColumnValue("abc"));

        // Tentukan kolom atribut baris. 
        var attribute = new AttributeColumns();
        attribute.Add("col0", new ColumnValue(i));
        attribute.Add("col1", new ColumnValue("a"));
        attribute.Add("col2", new ColumnValue(true));

        var request = new PutRowRequest("SampleTable", new Condition(RowExistenceExpectation.IGNORE),
                                        primaryKey, attribute);

        putRowTaskList.Add(otsClient.PutRowAsync(request));
    }

    // Tunggu hingga setiap panggilan asinkron mengembalikan hasil dan menampilkan CUs yang dikonsumsi. 
    foreach (var task in putRowTaskList)
    {
        task.Wait();
        Console.WriteLine("konsumsi baca:{0}, tulis:{1}", task.Result.ConsumedCapacityUnit.Read,
                            task.Result.ConsumedCapacityUnit.Write);
    }

    // Jika operasi berhasil, tidak ada pengecualian yang dikembalikan. 
    Console.WriteLine("Penyisipan baris asinkron berhasil.");
}
catch (Exception ex)
{
    // Jika operasi gagal, pengecualian dikembalikan. Tangani pengecualian. 
    Console.WriteLine("Penyisipan baris asinkron gagal. pengecualian:{0}", ex.Message);
}                   

Operasi API

/// <summary>
/// Anda dapat memanggil operasi ini untuk memperbarui data baris tertentu. Jika baris tidak ada, baris baru ditambahkan. Jika baris ada, nilai kolom yang ditentukan ditambahkan, dimodifikasi, atau dihapus berdasarkan isi permintaan. 
/// </summary>
/// <param name="request">Instance permintaan.</param>
public UpdateRowResponse UpdateRow(UpdateRowRequest request);

/// <summary>
/// Mode asinkron dari UpdateRow. 
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public Task<UpdateRowResponse> UpdateRowAsync(UpdateRowRequest request);            

Parameter

Contoh

Berikut adalah contoh kode untuk memperbarui satu baris data:

// Tentukan kunci utama baris. Skema kunci utama harus sama dengan skema yang ditentukan dalam TableMeta saat tabel dibuat. 
PrimaryKey primaryKey = new PrimaryKey();
primaryKey.Add("pk0", new ColumnValue(0));
primaryKey.Add("pk1", new ColumnValue("abc"));

// Tentukan kolom atribut baris. 
UpdateOfAttribute attribute = new UpdateOfAttribute();
attribute.AddAttributeColumnToPut("col0", new ColumnValue(0));
attribute.AddAttributeColumnToPut("col1", new ColumnValue("b")); // Ubah nilai kolom dari a menjadi b.
attribute.AddAttributeColumnToPut("col2", new ColumnValue(true));

try
{
    // Konstruksi objek permintaan untuk memperbarui baris. RowExistenceExpectation.IGNORE menentukan bahwa data diperbarui tanpa memandang apakah baris yang ditentukan ada. 
    var request = new UpdateRowRequest("SampleTable", new Condition(RowExistenceExpectation.IGNORE),
                                primaryKey, attribute);
    // Panggil operasi UpdateRow untuk memperbarui data. 
    otsClient.UpdateRow(request);

    // Jika operasi berhasil, tidak ada pengecualian yang dikembalikan. 
    Console.WriteLine("Pembaruan baris berhasil.");
}
catch (Exception ex)
{
    // Jika operasi gagal, pengecualian dikembalikan. Tangani pengecualian. 
    Console.WriteLine("Pembaruan baris gagal, pengecualian:{0}", ex.Message);
}           

Untuk kode sampel terperinci, kunjungi UpdateRow@GitHub.

Catatan penggunaan

Operasi API

/// <summary>
/// <para>Sisipkan, modifikasi, atau hapus beberapa baris data dalam satu atau lebih tabel. </para>
/// <para>Operasi BatchWriteRow adalah serangkaian operasi PutRow, UpdateRow, dan DeleteRow. Eksekusi, pengembalian hasil, dan konsumsi unit kapasitas (CU) dari setiap operasi individu dilakukan secara independen. </para>
/// <para>Dibandingkan dengan eksekusi sejumlah besar operasi penulisan satu baris, penggunaan BatchWriteRow dapat mengurangi waktu respons permintaan dan meningkatkan laju penulisan data. </para>
/// </summary>
/// <param name="request">Instance permintaan.</param>
/// <returns>Instance respons</returns>
public BatchWriteRowResponse BatchWriteRow(BatchWriteRowRequest request);

/// <summary>
/// Mode asinkron dari BatchWriteRow. 
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public Task<BatchWriteRowResponse> BatchWriteRowAsync(BatchWriteRowRequest request);            

Contoh

Berikut adalah contoh kode untuk menulis 100 baris data sekaligus:

var TableName = "SampleTable";
// Konstruksi objek permintaan untuk menulis 100 baris data sekaligus. Tentukan kunci utama untuk 100 baris data. 
var request = new BatchWriteRowRequest();
var rowChanges = new RowChanges(TableName);
for (int i = 0; i < 100; i++)
{
    PrimaryKey primaryKey = new PrimaryKey();
    primaryKey.Add("pk0", new ColumnValue(i));
    primaryKey.Add("pk1", new ColumnValue("abc"));

    // Tentukan kolom atribut baris. 
UpdateOfAttribute attribute = new UpdateOfAttribute();
    attribute.AddAttributeColumnToPut("col0", new ColumnValue(0));
    attribute.AddAttributeColumnToPut("col1", new ColumnValue("a"));
    attribute.AddAttributeColumnToPut("col2", new ColumnValue(true));

    rowChanges.AddUpdate(new Condition(RowExistenceExpectation.IGNORE), primaryKey, attribute);
}

request.Add(TableName, rowChanges);

try
{
    // Panggil operasi BatchWriteRow. 
    var response = otsClient.BatchWriteRow(request);
    var tableRows = response.TableRespones;
    var rows = tableRows[TableName];

    // Saat menulis beberapa baris data sekaligus, beberapa baris mungkin gagal ditulis. Anda harus memeriksa nilai pengembalian dan memeriksa apakah status setiap baris berhasil. Untuk informasi lebih lanjut, lihat tautan GitHub dalam kode sampel. 
}
catch (Exception ex)
{
    // Jika operasi gagal, pengecualian dikembalikan. Tangani pengecualian. 
    Console.WriteLine("Penulisan batch baris gagal, pengecualian:{0}", ex.Message);
}           

Untuk kode sampel terperinci, kunjungi BatchWriteRow@GitHub.