Tablestore：Menulis data

Parameter

Tabel berikut menjelaskan parameter yang dapat dikonfigurasi untuk menulis data ke Tablestore.

Menulis satu baris data

Operasi PutRow digunakan untuk menulis satu baris data. Jika baris sudah ada, operasi PutRow akan menghapus semua versi data dari kolom pada baris tersebut sebelum menulis data baru.

Contoh kode berikut menunjukkan cara menggunakan nomor versi data yang dihasilkan otomatis oleh sistem, menentukan nomor versi data kustom, dan menentukan kondisi untuk menulis data:

private static void putRow(SyncClient client, String pkValue) {
    // Konstruksi kunci utama.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Tentukan nama tabel data.
    RowPutChange rowPutChange = new RowPutChange("your_tableName", primaryKey);

    // Tambahkan kolom atribut.
    for (int i = 0; i < 10; i++) {
        rowPutChange.addColumn(new Column("Col" + i, ColumnValue.fromLong(i)));
    }

    client.putRow(new PutRowRequest(rowPutChange));
}

private static void putRow(SyncClient client, String pkValue) {
    // Konstruksi kunci utama.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Tentukan nama tabel data.
    RowPutChange rowPutChange = new RowPutChange("your_tableName", primaryKey);

    // Tambahkan kolom atribut.
    long ts = System.currentTimeMillis();
    for (int i = 0; i < 10; i++) {
        for (int j = 0; j < 3; j++) {
            rowPutChange.addColumn(new Column("Col" + i, ColumnValue.fromLong(j), ts + j));
        }
    }

    client.putRow(new PutRowRequest(rowPutChange));
}

private static void putRow(SyncClient client, String pkValue) {
    // Konstruksi kunci utama.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Tentukan nama tabel data.
    RowPutChange rowPutChange = new RowPutChange("your_tableName", primaryKey);

    // Tentukan kondisi untuk operasi PutRow. Dalam contoh ini, data ditulis ke tabel data hanya jika baris yang ditentukan tidak ada.
    rowPutChange.setCondition(new Condition(RowExistenceExpectation.EXPECT_NOT_EXIST));

    // Tambahkan kolom atribut.
    long ts = System.currentTimeMillis();
    for (int i = 0; i < 10; i++) {
        for (int j = 0; j < 3; j++) {
            rowPutChange.addColumn(new Column("Col" + i, ColumnValue.fromLong(j), ts + j));
        }
    }

    client.putRow(new PutRowRequest(rowPutChange));
}

private static void putRow(SyncClient client, String pkValue) {
    // Konstruksi kunci utama.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Tentukan nama tabel data.
    RowPutChange rowPutChange = new RowPutChange("your_tableName", primaryKey);

    // Tentukan kondisi untuk operasi PutRow. Dalam contoh ini, baris ditulis ke tabel data hanya jika baris ada dan nilai kolom Col0 lebih besar dari 100.
    Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);
    condition.setColumnCondition(new SingleColumnValueCondition("Col0",
            SingleColumnValueCondition.CompareOperator.GREATER_THAN, ColumnValue.fromLong(100)));
    rowPutChange.setCondition(condition);

    // Tambahkan kolom atribut.
    long ts = System.currentTimeMillis();
    for (int i = 0; i < 10; i++) {
        for (int j = 0; j < 3; j++) {
            rowPutChange.addColumn(new Column("Col" + i, ColumnValue.fromLong(j), ts + j));
        }
    }

    client.putRow(new PutRowRequest(rowPutChange));
}

Memperbarui satu baris data

Contoh kode berikut menunjukkan cara memperbarui kolom tertentu, menghapus versi data tertentu dari kolom Col1, dan menghapus kolom Col0 baik dengan atau tanpa menentukan kondisi:

private static void updateRow(SyncClient client, String pkValue) {
    // Konstruksi kunci utama.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Tentukan nama tabel data.
    RowUpdateChange rowUpdateChange = new RowUpdateChange("your_tableName", primaryKey);

    // Perbarui kolom tertentu.
    for (int i = 0; i < 10; i++) {
        rowUpdateChange.put(new Column("Col" + i, ColumnValue.fromLong(i)));
    }

    // Hapus versi data tertentu dari kolom.
    rowUpdateChange.deleteColumn("Col1", 1465373223000L);

    // Hapus kolom.
    rowUpdateChange.deleteColumns("Col0");

    client.updateRow(new UpdateRowRequest(rowUpdateChange));
}

private static void updateRow(SyncClient client, String pkValue) {
    // Konstruksi kunci utama.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString(pkValue));
    PrimaryKey primaryKey = primaryKeyBuilder.build();
    // Tentukan nama tabel data.
    RowUpdateChange rowUpdateChange = new RowUpdateChange("your_tableName", primaryKey);

    // Tentukan kondisi untuk operasi UpdateRow. Dalam contoh ini, baris data diperbarui hanya jika baris ada dan nilai kolom Col0 lebih besar dari 100.
    Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);
    condition.setColumnCondition(new SingleColumnValueCondition("Col0",
            SingleColumnValueCondition.CompareOperator.GREATER_THAN, ColumnValue.fromLong(100)));
    rowUpdateChange.setCondition(condition);

    // Perbarui kolom tertentu.
    for (int i = 0; i < 10; i++) {
        rowUpdateChange.put(new Column("Col" + i, ColumnValue.fromLong(i)));
    }

    // Hapus versi data tertentu dari kolom.
    rowUpdateChange.deleteColumn("Col1", 1465373223000L);

    // Hapus kolom.
    rowUpdateChange.deleteColumns("Col0");

    client.updateRow(new UpdateRowRequest(rowUpdateChange));
}

Menulis beberapa baris data sekaligus

Operasi BatchWriteRow digunakan untuk menulis beberapa baris data ke satu atau lebih tabel sekaligus.

Operasi BatchWriteRow mencakup beberapa operasi PutRow, UpdateRow, dan DeleteRow. Saat memanggil operasi BatchWriteRow, proses pembuatan suboperasi serupa dengan pemanggilan operasi PutRow, UpdateRow, atau DeleteRow secara individual. Setiap operasi PutRow, UpdateRow, atau DeleteRow diproses secara terpisah oleh Tablestore, dan respons untuk setiap operasi dikembalikan secara independen.

Contoh kode berikut menunjukkan cara mengirim permintaan untuk operasi BatchWriteRow, yang terdiri dari dua operasi PutRow, satu operasi DeleteRow, dan satu operasi UpdateRow:

private static void batchWriteRow(SyncClient client) {
    BatchWriteRowRequest batchWriteRowRequest = new BatchWriteRowRequest();

    // Konstruksi rowPutChange pertama.
    PrimaryKeyBuilder pk1Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    pk1Builder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString("pkValue1"));
    // Tentukan nama tabel data.
    RowPutChange rowPutChange1 = new RowPutChange("your_tableName", pk1Builder.build());
    // Tambahkan kolom.
    for (int i = 0; i < 10; i++) {
        rowPutChange1.addColumn(new Column("Col" + i, ColumnValue.fromLong(i)));
    }
    // Tambahkan rowPutChange1 ke kode operasi batch.
    batchWriteRowRequest.addRowChange(rowPutChange1);

    // Konstruksi rowPutChange kedua.
    PrimaryKeyBuilder pk2Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    pk2Builder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString("pkValue2"));
    // Tentukan nama tabel data.
    RowPutChange rowPutChange2 = new RowPutChange("your_tableName", pk2Builder.build());
    // Tambahkan kolom.
    for (int i = 0; i < 10; i++) {
        rowPutChange2.addColumn(new Column("Col" + i, ColumnValue.fromLong(i)));
    }
    // Tambahkan rowPutChange2 ke kode operasi batch.
    batchWriteRowRequest.addRowChange(rowPutChange2);

    // Konstruksi rowUpdateChange.
    PrimaryKeyBuilder pk3Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    pk3Builder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString("pkValue3"));
    // Tentukan nama tabel data.
    RowUpdateChange rowUpdateChange = new RowUpdateChange("your_tableName", pk3Builder.build());
    // Tambahkan kolom.
    for (int i = 0; i < 10; i++) {
        rowUpdateChange.put(new Column("Col" + i, ColumnValue.fromLong(i)));
    }
    // Hapus kolom.
    rowUpdateChange.deleteColumns("Col0");
    // Tambahkan rowUpdateChange ke kode operasi batch.
    batchWriteRowRequest.addRowChange(rowUpdateChange);

    // Konstruksi rowDeleteChange.
    PrimaryKeyBuilder pk4Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    pk4Builder.addPrimaryKeyColumn("your_primaryKey", PrimaryKeyValue.fromString("pkValue4"));
    // Tentukan nama tabel data.
    RowDeleteChange rowDeleteChange = new RowDeleteChange("your_tableName", pk4Builder.build());
    // Tambahkan rowDeleteChange ke kode operasi batch.
    batchWriteRowRequest.addRowChange(rowDeleteChange);

    BatchWriteRowResponse response = client.batchWriteRow(batchWriteRowRequest);

    System.out.println("Apakah semua operasi berhasil:" + response.isAllSucceed());
    if (!response.isAllSucceed()) {
        for (BatchWriteRowResponse.RowResult rowResult : response.getFailedRows()) {
            System.out.println("Baris yang gagal:" + batchWriteRowRequest.getRowChange(rowResult.getTableName(), rowResult.getIndex()).getPrimaryKey());
            System.out.println("Penyebab kegagalan:" + rowResult.getError());
        }
        /**
         * Anda dapat menggunakan metode createRequestForRetry untuk membangun permintaan lain untuk mencoba kembali operasi pada baris yang gagal. Dalam contoh ini, hanya permintaan ulang yang dibangun.
         * Kami merekomendasikan agar Anda menggunakan kebijakan ulang kustom dalam SDK Tablestore sebagai metode ulang. Dengan cara ini, Anda dapat mencoba kembali baris yang gagal setelah operasi batch dilakukan. Setelah Anda menentukan kebijakan ulang, Anda tidak perlu menambahkan kode ulang untuk memanggil operasi.
         */
        BatchWriteRowRequest retryRequest = batchWriteRowRequest.createRequestForRetry(response.getFailedRows());
    }
}