iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[JAVA-15756] Upgraded dependencies versions + Updated code for dynamodb (#12959)

Browse Source 
* [JAVA-15756] Upgraded dependencies versions + Updated code for dynamodb

* [JAVA-15756] Simplify/Clean up code

Co-authored-by: panagiotiskakos <panagiotis.kakos@libra-is.com>
This commit is contained in:
panos-kakos 2022-11-06 17:24:04 +00:00 committed by GitHub
parent 2495e6f101
commit 198bf2181b
3 changed files with 24 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
aws-modules/aws-lambda/lambda/pom.xml
View File

@ -95,8 +95,8 @@
<properties> <properties>
<json-simple.version>1.1.1</json-simple.version> <json-simple.version>1.1.1</json-simple.version>
<aws-lambda-java-events.version>1.3.0</aws-lambda-java-events.version> <aws-lambda-java-events.version>3.11.0</aws-lambda-java-events.version>
<aws-lambda-java-core.version>1.2.0</aws-lambda-java-core.version> <aws-lambda-java-core.version>1.2.1</aws-lambda-java-core.version>
<gson.version>2.8.2</gson.version> <gson.version>2.8.2</gson.version>
</properties> </properties>

40
aws-modules/aws-lambda/lambda/src/main/java/com/baeldung/lambda/dynamodb/SavePersonHandler.java
View File

@ -1,12 +1,12 @@
package com.baeldung.lambda.dynamodb; package com.baeldung.lambda.dynamodb;
import com.amazonaws.regions.Region; import java.util.HashMap;
import java.util.Map;
import com.amazonaws.regions.Regions; import com.amazonaws.regions.Regions;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClient; import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.document.DynamoDB; import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.document.Item; import com.amazonaws.services.dynamodbv2.model.AttributeValue;
import com.amazonaws.services.dynamodbv2.document.PutItemOutcome;
import com.amazonaws.services.dynamodbv2.document.spec.PutItemSpec;
import com.amazonaws.services.dynamodbv2.model.ConditionalCheckFailedException; import com.amazonaws.services.dynamodbv2.model.ConditionalCheckFailedException;
import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler; import com.amazonaws.services.lambda.runtime.RequestHandler;
@ -15,7 +15,7 @@ import com.baeldung.lambda.dynamodb.bean.PersonResponse;
public class SavePersonHandler implements RequestHandler<PersonRequest, PersonResponse> { public class SavePersonHandler implements RequestHandler<PersonRequest, PersonResponse> {
private DynamoDB dynamoDb; private AmazonDynamoDB amazonDynamoDB;
private String DYNAMODB_TABLE_NAME = "Person"; private String DYNAMODB_TABLE_NAME = "Person";
private Regions REGION = Regions.US_WEST_2; private Regions REGION = Regions.US_WEST_2;
@ -30,20 +30,22 @@ public class SavePersonHandler implements RequestHandler<PersonRequest, PersonRe
return personResponse; return personResponse;
} }
private PutItemOutcome persistData(PersonRequest personRequest) throws ConditionalCheckFailedException { private void persistData(PersonRequest personRequest) throws ConditionalCheckFailedException {
return this.dynamoDb.getTable(DYNAMODB_TABLE_NAME)
.putItem( Map<String, AttributeValue> attributesMap = new HashMap<>();
new PutItemSpec().withItem(new Item()
.withNumber("id", personRequest.getId()) attributesMap.put("id", new AttributeValue(String.valueOf(personRequest.getId())));
.withString("firstName", personRequest.getFirstName()) attributesMap.put("firstName", new AttributeValue(personRequest.getFirstName()));
.withString("lastName", personRequest.getLastName()) attributesMap.put("lastName", new AttributeValue(personRequest.getLastName()));
.withNumber("age", personRequest.getAge()) attributesMap.put("age", new AttributeValue(String.valueOf(personRequest.getAge())));
.withString("address", personRequest.getAddress()))); attributesMap.put("address", new AttributeValue(personRequest.getAddress()));
amazonDynamoDB.putItem(DYNAMODB_TABLE_NAME, attributesMap);
} }
private void initDynamoDbClient() { private void initDynamoDbClient() {
AmazonDynamoDBClient client = new AmazonDynamoDBClient(); this.amazonDynamoDB = AmazonDynamoDBClientBuilder.standard()
client.setRegion(Region.getRegion(REGION)); .withRegion(REGION)
this.dynamoDb = new DynamoDB(client); .build();
} }
} }

2
aws-modules/pom.xml
View File

@ -22,7 +22,7 @@
</modules> </modules>
<properties> <properties>
<aws-java-sdk.version>1.11.290</aws-java-sdk.version> <aws-java-sdk.version>1.12.331</aws-java-sdk.version>
<maven-shade-plugin.version>3.0.0</maven-shade-plugin.version> <maven-shade-plugin.version>3.0.0</maven-shade-plugin.version>
</properties> </properties>