Tablestore：Tulis data

Prasyarat

• Instance OTSClient telah diinisialisasi. Untuk detail lebih lanjut, lihat Inisialisasi Instance OTSClient.

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

Tulis satu baris data

Operasi API

/**
 * Masukkan data ke baris tertentu. Jika baris sudah ada, data yang ada akan ditimpa. Jika tidak, baris baru akan ditambahkan.
 */
putRow(params, callback)

Parameter

Contoh

Berikut adalah contoh kode untuk menulis satu baris data:

var TableStore = require('../index.js');
var Long = TableStore.Long;
var client = require('./client');

var currentTimeStamp = Date.now();
var params = {
  tableName: "sampleTable",
  condition: new TableStore.Condition(TableStore.RowExistenceExpectation.IGNORE, null),
  primaryKey: [{ 'gid': Long.fromNumber(20013) }, { 'uid': Long.fromNumber(20013) }],
  attributeColumns: [
    { 'col1': 'Tablestore' },
    { 'col2': '2', 'timestamp': currentTimeStamp },
    { 'col3': 3.1 },
    { 'col4': -0.32 },
    { 'col5': Long.fromNumber(123456789) }
  ],
  returnContent: { returnType: TableStore.ReturnType.Primarykey }
};

client.putRow(params, function (err, data) {
  if (err) {
    console.log('error:', err);
    return;
  }

  console.log('success:', data);
});

Untuk kode contoh terperinci, kunjungi PutRow@GitHub.

Perbarui satu baris data

Operasi API

/**
 * Perbarui data baris yang ditentukan. Jika baris tidak ada, baris baru ditambahkan. Jika baris ada, nilai kolom yang ditentukan dari baris tersebut ditambahkan, diubah, atau dihapus berdasarkan konten permintaan.
 */
updateRow(params, callback)

Parameter

Contoh

Berikut adalah contoh kode untuk memperbarui satu baris data:

var TableStore = require('../index.js');
var Long = TableStore.Long;
var client = require('./client');

var params = {
    tableName: "sampleTable",
    condition: new TableStore.Condition(TableStore.RowExistenceExpectation.IGNORE, null),
    primaryKey: [{ 'gid': Long.fromNumber(9) }, { 'uid': Long.fromNumber(90) }],
    updateOfAttributeColumns: [
        { 'PUT': [{ 'col4': Long.fromNumber(4) }, { 'col5': '5' }, { 'col6': Long.fromNumber(6) }] },
        { 'DELETE': [{ 'col1': Long.fromNumber(1496826473186) }] },
        { 'DELETE_ALL': ['col2'] }
    ]
};

client.updateRow(params,
    function (err, data) {
        if (err) {
            console.log('error:', err);
            return;
        }

        console.log('success:', data);
    });                

Untuk kode contoh terperinci, kunjungi UpdateRow@GitHub.

Tulis beberapa baris data sekaligus

Catatan penggunaan

• Ketika menggunakan operasi BatchWriteRow untuk menulis beberapa baris data sekaligus, beberapa baris mungkin gagal ditulis. Dalam hal ini, Tablestore tidak mengembalikan pengecualian. Sebagai gantinya, Tablestore mengembalikan BatchWriteRowResponse yang mencakup indeks dan pesan kesalahan dari baris yang gagal. Oleh karena itu, pastikan untuk memeriksa nilai pengembalian untuk menentukan apakah semua baris berhasil ditulis. Jika tidak, baris yang gagal mungkin diabaikan.

• Anda dapat menggunakan operasi BatchWriteRow untuk menulis hingga 4 MB data dalam maksimal 200 baris sekaligus.

Operasi API

/**
 // Tambahkan, hapus, atau perbarui beberapa baris data di beberapa tabel.
 */
batchWriteRow(params, callback)

Parameter

Contoh

Berikut adalah contoh kode untuk menulis beberapa baris data sekaligus:

var client = require('./client');
var TableStore = require('../index.js');
var Long = TableStore.Long;

var params = {

    tables: [
        {
            tableName: 'sampleTable',
            rows: [
                {
                    type: 'UPDATE',
                    condition: new TableStore.Condition(TableStore.RowExistenceExpectation.IGNORE, null),
                    primaryKey: [{ 'gid': Long.fromNumber(20010) }, { 'uid': Long.fromNumber(20010) }],
                    attributeColumns: [{ 'PUT': [{ 'col1': 'test3' }, { 'col2': 'test4' }] }],
                    returnContent: { returnType: 1 }
                },
                {
                    type: 'PUT',
                    condition: new TableStore.Condition(TableStore.RowExistenceExpectation.IGNORE, null),
                    primaryKey: [{ 'gid': Long.fromNumber(20020) }, { 'uid': Long.fromNumber(20020) }],
                    attributeColumns: [{ 'col1': 'test1' }, { 'col2': 'test2' }],
                    returnContent: { returnType: TableStore.ReturnType.Primarykey }
                },
                {
                    type: 'DELETE',
                    condition: new TableStore.Condition(TableStore.RowExistenceExpectation.IGNORE, null),
                    primaryKey: [{ 'gid': Long.fromNumber(20018) }, { 'uid': Long.fromNumber(20018) }],
                }
            ]
        }
    ],
};

client.batchWriteRow(params, function (err, data) {

    if (err) {
        console.log('error:', err);
        return;
    }

    console.log('success:', data);
});                   

Untuk kode contoh terperinci, kunjungi BatchWriteRow@GitHub.

FAQ

• Apa yang harus dilakukan jika pengecualian Validate PK size fail terjadi saat menggunakan SDK?

• Apa yang harus dilakukan jika pengecualian Validate PK name fail terjadi saat menggunakan SDK?

• Apa yang dapat dilakukan jika terjadi kesalahan terkait tipe data yang didukung oleh kolom kunci utama?

• Apa yang harus dilakukan jika OTSParameterInvalid dilaporkan saat menggunakan BatchWriteRow untuk mengirimkan 100 entri data sekaligus?

Referensi

• Untuk memperbarui data dalam aplikasi dengan konkurensi tinggi berdasarkan kondisi tertentu, Anda dapat menggunakan fitur pembaruan bersyarat. Untuk informasi lebih lanjut, lihat Konfigurasikan Pembaruan Bersyarat.

• Untuk mengumpulkan statistik waktu nyata tentang aplikasi online, seperti jumlah tampilan halaman (PV) pada berbagai topik, Anda dapat menggunakan fitur penghitung atomik. Untuk informasi lebih lanjut, lihat Gunakan Fitur Penghitung Atomik.

• Untuk melakukan operasi atomik untuk menulis satu atau beberapa baris data, Anda dapat menggunakan fitur transaksi lokal. Untuk informasi lebih lanjut, lihat Konfigurasikan Transaksi Lokal.

• Setelah menulis data ke tabel, Anda dapat membaca atau menghapus data sesuai kebutuhan bisnis. Untuk informasi lebih lanjut, lihat Baca Data dan Hapus Data.