將任何實(shí)體上的版本屬性保存到
AWS DynamoDB數(shù)據(jù)庫(kù)，它僅是表示實(shí)體已修改次數(shù)的數(shù)字表示。 首次創(chuàng)建實(shí)體時(shí)，可以將其設(shè)置為1，然后在每次更新時(shí)遞增。

好處是立竿見(jiàn)影的-指示實(shí)體已被修改的次數(shù)，可用于審核實(shí)體。 此外，還有一種額外的用途是樂(lè)觀鎖定 ，其中僅當(dāng)更新實(shí)體的持有者具有正確版本的實(shí)體時(shí)才允許更新實(shí)體。

這篇文章將詳細(xì)介紹如何通過(guò)AWS開(kāi)發(fā)工具包2的DynamoDB相關(guān)庫(kù)引入此類(lèi)字段

模型

考慮一個(gè)名為“旅館”的模型，該模型將持久化到發(fā)電機(jī)數(shù)據(jù)庫(kù)中。 在Kotlin中，可以使用以下數(shù)據(jù)類(lèi)表示它：

data class Hotel( val id: String = UUID.randomUUID().toString(), val name: String, val address: String? = val address: String? = null , val state: String? = val state: String? = null , val zip: String? = val zip: String? = null , val version: Long = 1L )

此模型中引入了一個(gè)version字段，其初始值為1。其目的是按原樣保存此字段，然后讓dynamo在保存該實(shí)體時(shí)自動(dòng)管理該字段的增量。

隨著此模型中字段的更改，我希望按照以下內(nèi)容更新版本：

DynamoDB的本地版本

使DynamoDB在本地計(jì)算機(jī)上運(yùn)行非常有用，這樣就不必在AWS中創(chuàng)建真正的DynamoDB表。

有多種方法可以做到這一點(diǎn)。 一種是使用的docker版本
DynamoDB Local ，可以通過(guò)以下方式啟動(dòng)以偵聽(tīng)端口4569：

amazon/dynamodb-local: docker run -p 4569 : 8000 amazon/dynamodb-local: 1.13

我個(gè)人的喜好是使用localstack ，站點(diǎn)上的說(shuō)明有不同的啟動(dòng)方式。 我通常使用docker-compose來(lái)啟動(dòng)它。 在DynamoDB Local上使用localstack的原因之一是localstack提供了一套全面的AWS服務(wù)用于本地測(cè)試，而不僅僅是DynamoDB。

快速演示

我在這里的 github倉(cāng)庫(kù)中有完整的代碼–
https://github.com/bijukunjummen/boot-with-dynamodb

使用dynamoDB的本地版本啟動(dòng)應(yīng)用程序后，可以使用以下httpie請(qǐng)求創(chuàng)建實(shí)體：

http : 9080 /hotels id= 4 name=name address=address zip=zip state=OR

響應(yīng)，其中version字段設(shè)置為1：

{ "address" : "address" , "id" : "4" , "name" : "name" , "state" : "OR" , "version" : 1 , "zip" : "zip" }

然后，如果實(shí)體的名稱(chēng)已更新：

http PUT : 9080 /hotels/ 4 name=name1 address=address zip=zip state=OR version= 1

版本字段將更新為2，依此類(lèi)推：

{ "address" : "address" , "id" : "4" , "name" : "name1" , "state" : "OR" , "version" : 2 , "zip" : "zip" }

還要注意，如果在更新期間提供了錯(cuò)誤的版本號(hào)，則調(diào)用將失敗，因?yàn)槭褂么税姹咀侄未嬖跇?lè)觀鎖定。

實(shí)施版本字段

實(shí)現(xiàn)版本字段取決于DynamoDB提供的功能強(qiáng)大的UpdateItem API。 UpdateItem API的功能之一是它包含一個(gè)“ UpdateExpression”，它是一個(gè)dsl，它顯示了應(yīng)如何更新不同的Dynamo屬性。

對(duì)AWS DynamoDB的原始請(qǐng)求如下所示：

{ "TableName" : "hotels" , "Key" : { "id" : { "S" : "1" } }, "UpdateExpression" : "\nSET #name=:name,\n #state=:state,\naddress=:address,\nzip=:zip\nADD version :inc\n " , "ExpressionAttributeNames" : { "#state" : "state" , "#name" : "name" }, "ExpressionAttributeValues" : { ":name" : { "S" : "testhotel" }, ":address" : { "S" : "testaddress" }, ":state" : { "S" : "OR" }, ":zip" : { "S" : "zip" }, ":inc" : { "N" : "1" } } }

從文章角度看，特別關(guān)注“ ADD版本：inc”，該表達(dá)式告訴AWS DynamoDB將版本的值增加“：inc”值，該值使用“ ExpressionAttributeValues”和“ 1”單獨(dú)提供。 以json格式處理原始API令人生畏，這就是AWS提供的軟件開(kāi)發(fā)套件（SDK）的來(lái)源，適用于Java 2的AWS開(kāi)發(fā)工具包是對(duì)AWS開(kāi)發(fā)工具包的重寫(xiě)，其重點(diǎn)是使用最新的Java功能和非通過(guò)線路阻塞IO。 使用適用于Java 2的AWS開(kāi)發(fā)工具包，“ UpdateItem”如下所示（使用Kotlin代碼）：

val updateItemRequest = UpdateItemRequest.builder() .tableName(TABLE_NAME) .key( mapOf( ID to AttributeValue.builder().s(hotel.id).build() ) ) .updateExpression( "" " SET #name=:name, #state=:state, address=:address, zip=:zip ADD version :inc "" " ) .conditionExpression( "version = :version" ) .expressionAttributeValues( mapOf( ":${NAME}" to AttributeValue.builder().s(hotel.name).build(), ":${ZIP}" to AttributeValue.builder().s(hotel.zip).build(), ":${STATE}" to AttributeValue.builder().s(hotel.state).build(), ":${ADDRESS}" to AttributeValue.builder().s(hotel.address).build(), ":${VERSION}" to AttributeValue.builder().n(hotel.version.toString()).build(), ":inc" to AttributeValue.builder().n( "1" ).build() ) ) .expressionAttributeNames( mapOf( "#name" to "name" , "#state" to "state" ) ) .build() val updateItem: CompletableFuture<UpdateItemResponse> = dynamoClient.updateItem(updateItemRequest) return Mono.fromCompletionStage(updateItem) .flatMap { getHotel(hotel.id) }

高亮顯示的行具有“ Update Expression”，其中所有現(xiàn)有字段均設(shè)置為新值，并且version屬性增加了1。關(guān)于此調(diào)用的另一件事要注意的是“ conditionExpression”，這實(shí)際上是告訴DynamoDB更新的一種方式。如果條件匹配，則為屬性；在此特定情況下，如果版本的現(xiàn)有值匹配，則為屬性。 這提供了一種支持樂(lè)觀鎖定記錄的巧妙方法。

結(jié)論

這里有很多細(xì)節(jié)–感受它的最簡(jiǎn)單方法是嘗試在我的github存儲(chǔ)庫(kù)中找到的代碼– https://github.com/bijukunjummen/boot-with-dynamodb 。 自述文件提供了有關(guān)如何在本地環(huán)境中運(yùn)行它的詳細(xì)信息。

AWS DynamoDB提供了一種巧妙的方法來(lái)管理實(shí)體上的版本字段，確保對(duì)它們進(jìn)行原子更新，并為它們提供了一種用于樂(lè)觀鎖定的方法

翻譯自: https://www.javacodegeeks.com/2020/05/aws-dynamodb-version-field-using-aws-sdk-for-java-2.html

總結(jié)

以上是生活随笔為你收集整理的使用适用于Java 2的AWS开发工具包的AWS DynamoDB版本字段的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。