Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Gunakan ekstensi untuk menyesuaikan operasi DynamoDB Enhanced Client

DynamoDB Enhanced Client API mendukung ekstensi plugin yang menyediakan fungsionalitas di luar operasi pemetaan. Ekstensi menggunakan dua metode hook untuk memodifikasi data selama operasi baca dan tulis:

Beberapa operasi (seperti pembaruan item) melakukan penulisan dan kemudian membaca, sehingga kedua metode kait dipanggil.

Bagaimana ekstensi dimuat

Ekstensi dimuat dalam urutan yang Anda tentukan di pembuat klien yang disempurnakan. Urutan pemuatan dapat menjadi penting karena satu ekstensi dapat bertindak berdasarkan nilai yang telah diubah oleh ekstensi sebelumnya.

Secara default, klien yang disempurnakan memuat dua ekstensi:

Anda dapat mengganti perilaku default dengan pembuat klien yang disempurnakan dan memuat ekstensi apa pun. Anda juga dapat menentukan none jika Anda tidak ingin ekstensi default.

Contoh berikut menunjukkan cara memuat ekstensi kustom yang verifyChecksumExtension dinamaiVersionedRecordExtension. AtomicCounterExtensionTidak dimuat dalam contoh ini.

DynamoDbEnhancedClientExtension versionedRecordExtension = VersionedRecordExtension.builder().build();

DynamoDbEnhancedClient enhancedClient = 
    DynamoDbEnhancedClient.builder()
                          .dynamoDbClient(dynamoDbClient)
                          .extensions(versionedRecordExtension, verifyChecksumExtension)
                          .build();

Detail dan konfigurasi ekstensi yang tersedia

Bagian berikut memberikan informasi rinci tentang setiap ekstensi yang tersedia di SDK.

Terapkan penguncian optimis dengan VersionedRecordExtension

VersionedRecordExtensionEkstensi ini memberikan penguncian optimis dengan menambah dan melacak nomor versi item saat item ditulis ke database. Kondisi ditambahkan ke setiap penulisan yang menyebabkan penulisan gagal jika nomor versi item tetap yang sebenarnya tidak cocok dengan nilai yang terakhir dibaca aplikasi.

Konfigurasi

Untuk menentukan atribut mana yang akan digunakan untuk melacak nomor versi item, beri tag atribut numerik dalam skema tabel.

Cuplikan berikut menentukan bahwa version atribut harus menyimpan nomor versi item.

    @DynamoDbVersionAttribute
    public Integer getVersion() {...};
    public void setVersion(Integer version) {...};

Pendekatan skema tabel statis setara ditunjukkan dalam cuplikan berikut.

    .addAttribute(Integer.class, a -> a.name("version")
                                       .getter(Customer::getVersion)
                                       .setter(Customer::setVersion)
                                        // Apply the 'version' tag to the attribute.
                                       .tags(VersionedRecordExtension.AttributeTags.versionAttribute())

Cara kerjanya

Penguncian optimis dengan VersionedRecordExtension memiliki dampak berikut pada ini DynamoDbEnhancedClient dan DynamoDbTable metode:

Cara menonaktifkan

Untuk menonaktifkan penguncian optimis, jangan gunakan @DynamoDbVersionAttribute anotasi.

Menerapkan penghitung dengan AtomicCounterExtension

AtomicCounterExtensionEkstensi menambah atribut numerik yang ditandai setiap kali catatan ditulis ke database. Anda dapat menentukan nilai awal dan kenaikan. Jika tidak ada nilai yang ditentukan, nilai awal diatur ke 0 dan nilai atribut meningkat sebesar 1.

Konfigurasi

Untuk menentukan atribut mana yang merupakan penghitung, beri tag atribut tipe Long dalam skema tabel.

Cuplikan berikut menunjukkan penggunaan nilai awal dan kenaikan default untuk atribut. counter

    @DynamoDbAtomicCounter
    public Long getCounter() {...};
    public void setCounter(Long counter) {...};

Pendekatan skema tabel statis ditunjukkan dalam cuplikan berikut. Ekstensi penghitung atom menggunakan nilai awal 10 dan menambah nilai sebesar 5 setiap kali catatan ditulis.

    .addAttribute(Integer.class, a -> a.name("counter")
                                       .getter(Customer::getCounter)
                                       .setter(Customer::setCounter)
                                        // Apply the 'atomicCounter' tag to the attribute with start and increment values.
                                       .tags(StaticAttributeTags.atomicCounter(10L, 5L))

Tambahkan stempel waktu dengan AutoGeneratedTimestampRecordExtension

AutoGeneratedTimestampRecordExtensionEkstensi secara otomatis memperbarui atribut tipe yang ditandai Instant dengan stempel waktu saat ini setiap kali item berhasil ditulis ke database. Ekstensi ini tidak dimuat secara default.

Konfigurasi

Untuk menentukan atribut mana yang akan diperbarui dengan stempel waktu saat ini, beri tag Instant atribut dalam skema tabel.

lastUpdateAtribut adalah target perilaku ekstensi dalam cuplikan berikut. Perhatikan persyaratan bahwa atribut harus berupa Instant tipe.

    @DynamoDbAutoGeneratedTimestampAttribute
    public Instant getLastUpdate() {...}
    public void setLastUpdate(Instant lastUpdate) {...}

Pendekatan skema tabel statis setara ditunjukkan dalam cuplikan berikut.

     .addAttribute(Instant.class, a -> a.name("lastUpdate")
                                        .getter(Customer::getLastUpdate)
                                        .setter(Customer::setLastUpdate)
                                        // Applying the 'autoGeneratedTimestamp' tag to the attribute.
                                        .tags(AutoGeneratedTimestampRecordExtension.AttributeTags.autoGeneratedTimestampAttribute())

Hasilkan UUID dengan AutoGeneratedUuidExtension

AutoGeneratedUuidExtensionEkstensi menghasilkan UUID unik (Universally Unique Identifier) untuk atribut ketika catatan baru ditulis ke database. Menggunakan metode Java JDK UUID.randomUUId () dan berlaku untuk atribut tipe. java.lang.String Ekstensi ini tidak dimuat secara default.

Konfigurasi

uniqueIdAtribut adalah target perilaku ekstensi dalam cuplikan berikut.

    @AutoGeneratedUuidExtension
    public String getUniqueId() {...}
    public void setUniqueId(String uniqueId) {...}

Pendekatan skema tabel statis setara ditunjukkan dalam cuplikan berikut.

     .addAttribute(String.class, a -> a.name("uniqueId")
                                        .getter(Customer::getUniqueId)
                                        .setter(Customer::setUniqueId)
                                        // Applying the 'autoGeneratedUuid' tag to the attribute.
                                        .tags(AutoGeneratedUuidExtension.AttributeTags.autoGeneratedUuidAttribute())

Jika Anda ingin ekstensi mengisi UUID hanya untuk putItem metode dan bukan untuk updateItem metode, tambahkan anotasi perilaku pembaruan seperti yang ditunjukkan pada cuplikan berikut.

    @AutoGeneratedUuidExtension
    @DynamoDbUpdateBehavior(UpdateBehavior.WRITE_IF_NOT_EXISTS)
    public String getUniqueId() {...}
    public void setUniqueId(String uniqueId) {...}

Jika Anda menggunakan pendekatan skema tabel statis, gunakan kode setara berikut.

     .addAttribute(String.class, a -> a.name("uniqueId")
                                        .getter(Customer::getUniqueId)
                                        .setter(Customer::setUniqueId)
                                        // Applying the 'autoGeneratedUuid' tag to the attribute.
                                        .tags(AutoGeneratedUuidExtension.AttributeTags.autoGeneratedUuidAttribute(),
                                              StaticAttributeTags.updateBehavior(UpdateBehavior.WRITE_IF_NOT_EXISTS))