aws dynamodb

將任何實體上的版本屬性保存到
AWS DynamoDB數據庫，它只是表示已修改實體次數的數字表示。 首次創建實體時，可以將其設置為1，然后在每次更新時遞增。

好處是立竿見影的-指示實體已被修改的次數，可用于審核實體。 此外，還有一種額外的用途是樂觀鎖定 ，其中僅當更新實體的持有人具有正確版本的實體時才允許更新實體。

這篇文章將詳細介紹如何通過AWS開發工具包2的DynamoDB相關庫引入此類字段

模型

考慮一個稱為酒店的模型，該模型將持久化到發電機數據庫中。 在Kotlin中，可以使用以下數據類表示它：

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 )

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

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

DynamoDB的本地版本

使DynamoDB在本地計算機上運行非常有用，這樣就不必在AWS中創建真正的DynamoDB表。

有多種方法可以做到這一點。 一種是使用的docker版本
DynamoDB Local ，可以通過以下方式啟動以偵聽端口4569：

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

我個人的喜好是使用localstack ，該站點上的說明有不同的啟動方式。 我通常使用docker-compose來啟動它。 在DynamoDB Local上使用localstack的原因之一是localstack提供了一套全面的AWS服務用于本地測試，而不僅僅是DynamoDB。

快速演示

我在這里的 github倉庫中有完整的代碼–
https://github.com/bijukunjummen/boot-with-dynamodb

使用dynamoDB的本地版本啟動應用程序后，可以使用以下httpie請求創建實體：

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

響應，其中version字段設置為1：

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

然后，如果實體的名稱已更新：

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

版本字段將更新為2，依此類推：

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

另請注意，如果在更新期間提供了錯誤的版本號，則調用將失敗，因為使用此版本字段存在樂觀鎖定。

實施版本字段

實現版本字段取決于DynamoDB提供的功能強大的UpdateItem API。 UpdateItem API的功能之一是它包含一個“ UpdateExpression”，它是一個dsl，它顯示了應如何更新不同的Dynamo屬性。

對AWS DynamoDB的原始請求如下所示：

{ "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" } } }

從文章角度看，特別關注“ ADD版本：inc”，該表達式告訴AWS DynamoDB使用“：inc”值將版本的值增加，該值使用“ ExpressionAttributeValues”和“ 1”單獨提供。 以json格式處理原始API令人生畏，這是AWS提供的軟件開發工具包（SDK）出現的地方，適用于Java 2的AWS開發工具包是對AWS開發工具包的重寫，其重點是使用最新的Java功能和非通過線路阻塞IO。 使用適用于Java 2的AWS開發工具包，“ 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”，其中所有現有字段均設置為新值，并且version屬性增加了1。關于此調用的另一件事要注意的是“ conditionExpression”，這實際上是告訴DynamoDB更新的一種方式。如果條件匹配，則為屬性；在此特定情況下，如果版本的現有值匹配，則為屬性。 這提供了一種支持樂觀鎖定記錄的巧妙方法。

結論

這里有很多細節–感受它的最簡單方法是嘗試在我的github存儲庫中找到的代碼– https://github.com/bijukunjummen/boot-with-dynamodb 。 自述文件提供了有關如何在本地環境中運行它的詳細信息。

AWS DynamoDB提供了一種巧妙的方法來管理實體上的版本字段，確保對它們進行原子更新，并為它們提供了一種用于樂觀鎖定的方法

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

aws dynamodb

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。