tests dymodb crud api with spring data

Author: zacscoding

README.md

@@ -95,4 +95,11 @@
 - <a href="springboot-cloud-ribbon-demo">springboot-cloud-ribbon-demo</a>  
 ; client side loadbalancer with spring cloud ribbon  
 
+- <a href="springboot-resilience4j-demo">springboot-resilience4j-demo</a>  
+; circuitbreak with resilence4j  
+
+- <a href="springboot-dynamodb-demo">springboot-dynamodb-demo</a>  
+; demo crud api with aws cli, java sdk, spring-data  
+
+
 

springboot-dynamodb-demo/README.md

@@ -21,8 +21,13 @@ $ scripts/aws-cli.sh
 
 Start dynamodb with testcontainers and tests Create table / Create item / Get item / Update item / Delete item / Drop table.
 
-[See SdkBasicUsage.java](./src/test/java/demo/basic/SdkBasicUsage.java) 
-[See MapperBasicUsage.java](./src/test/java/demo/basic/MapperBasicUsage.java)  
+[See SdkBasicUsage.java](./src/test/java/demo/basic/SdkBasicUsage.java)  
+[See MapperBasicUsage.java](./src/test/java/demo/basic/MapperBasicUsage.java)    
+
+> ## Simple CRUD api with spring data dynamodb  
+
+[See config package](./src/main/java/demo/config)  
+[See rest controller](./src/main/java/demo/rest/CommentController.java)  
 
 ---  
 

springboot-dynamodb-demo/build.gradle

@@ -22,9 +22,12 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     // aws dynamodb sdk
     implementation 'com.amazonaws:aws-java-sdk-dynamodb:1.11.796'
+    // spring data dynamodb
+    implementation 'com.github.derjust:spring-data-dynamodb:5.1.0'
     // guava
     // implementation 'com.google.guava:guava:29.0-jre'
 
+    annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
     compileOnly 'org.projectlombok:lombok'
     annotationProcessor 'org.projectlombok:lombok'
     testImplementation('org.springframework.boot:spring-boot-starter-test') {

springboot-dynamodb-demo/scripts/create-table.sh

@@ -0,0 +1,23 @@
+#!/usr/bin/env bash
+
+set -x
+
+aws dynamodb create-table \
+  --endpoint-url http://localhost:8000 \
+  --table-name Comment \
+  --attribute-definitions \
+  AttributeName=id,AttributeType=S \
+  AttributeName=mentionId,AttributeType=N \
+  AttributeName=createdAt,AttributeType=S \
+  --key-schema AttributeName=id,KeyType=HASH \
+  --provisioned-throughput ReadCapacityUnits=1,WriteCapacityUnits=1 \
+  --global-secondary-indexes IndexName=byMentionId,KeySchema=["{\
+  AttributeName=mentionId,\
+  KeyType=HASH\
+}","{\
+  AttributeName=createdAt,\
+  KeyType=RANGE\
+}"],Projection="{ProjectionType=ALL}",ProvisionedThroughput="{\
+  ReadCapacityUnits=1,\
+  WriteCapacityUnits=1\
+}"

springboot-dynamodb-demo/scripts/drop-table.sh

@@ -0,0 +1,3 @@
+aws dynamodb delete-table \
+    --endpoint-url http://localhost:8000 \
+    --table-name Comment

springboot-dynamodb-demo/src/main/java/demo/config/DynamoDbConfig.java

@@ -0,0 +1,48 @@
+package demo.config;
+
+import org.socialsignin.spring.data.dynamodb.repository.config.EnableDynamoDBRepositories;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
+import com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration;
+import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
+import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
+import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper;
+import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig;
+
+import demo.config.properties.AwsProperties;
+import lombok.RequiredArgsConstructor;
+
+@Configuration
+@EnableConfigurationProperties(AwsProperties.class)
+@EnableDynamoDBRepositories(basePackages = "demo.repository")
+@RequiredArgsConstructor
+public class DynamoDbConfig {
+
+    private final AwsProperties awsProperties;
+
+    @Primary
+    @Bean
+    public DynamoDBMapper dynamoDBMapper() {
+        return new DynamoDBMapper(amazonDynamoDB(), DynamoDBMapperConfig.DEFAULT);
+    }
+
+    @Bean
+    public AmazonDynamoDB amazonDynamoDB() {
+        final AWSStaticCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(
+                new BasicAWSCredentials(awsProperties.getCredential().getAccessKey(),
+                                        awsProperties.getCredential().getSecretKey()));
+        final EndpointConfiguration endpointConfiguration = new EndpointConfiguration(
+                awsProperties.getDynamodb().getEndpoint(),
+                awsProperties.getDynamodb().getRegion());
+
+        return AmazonDynamoDBClientBuilder.standard()
+                                          .withCredentials(credentialsProvider)
+                                          .withEndpointConfiguration(endpointConfiguration)
+                                          .build();
+    }
+}

springboot-dynamodb-demo/src/main/java/demo/config/properties/AwsProperties.java

@@ -0,0 +1,25 @@
+package demo.config.properties;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import lombok.Data;
+
+@ConfigurationProperties(prefix = "aws", ignoreInvalidFields = true)
+@Data
+public class AwsProperties {
+
+    private DynamoDbProperties dynamodb;
+    private Credential credential;
+
+    @Data
+    public static class DynamoDbProperties {
+        private String endpoint;
+        private String region;
+    }
+
+    @Data
+    public static class Credential {
+        private String accessKey;
+        private String secretKey;
+    }
+}

springboot-dynamodb-demo/src/main/java/demo/repository/CommentRepository.java

@@ -0,0 +1,12 @@
+package demo.repository;
+
+import java.util.List;
+
+import org.springframework.data.repository.PagingAndSortingRepository;
+
+import demo.domain.Comment;
+
+public interface CommentRepository extends PagingAndSortingRepository<Comment, String> {
+
+    List<Comment> findAllByMentionIdOrderByCreatedAtAsc(Integer mentionId);
+}

springboot-dynamodb-demo/src/main/java/demo/rest/CommentController.java

@@ -0,0 +1,60 @@
+package demo.rest;
+
+import java.time.LocalDateTime;
+import java.util.Optional;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import demo.domain.Comment;
+import demo.repository.CommentRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@RestController
+@Slf4j
+@RequiredArgsConstructor
+public class CommentController {
+
+    private final CommentRepository commentRepository;
+
+    @GetMapping("/comments")
+    public ResponseEntity<Iterable<Comment>> getComments(@RequestParam(name = "mentionId") Integer mentionId) {
+        return ResponseEntity.ok(commentRepository.findAllByMentionIdOrderByCreatedAtAsc(mentionId));
+    }
+
+    @GetMapping("/comment/{id}")
+    public ResponseEntity<Comment> getComment(@PathVariable("id") String id) {
+        final Optional<Comment> commentOptional = commentRepository.findById(id);
+        return commentOptional.map(ResponseEntity::ok).orElseGet(() -> ResponseEntity.notFound().build());
+    }
+
+    @PostMapping("/comments")
+    public ResponseEntity<Comment> createComment(@RequestBody Comment comment) {
+        comment.setCreatedAt(LocalDateTime.now());
+        comment.setId(null);
+        comment = commentRepository.save(comment);
+        return ResponseEntity.ok(comment);
+    }
+
+    @PutMapping("/comment/{id}")
+    public ResponseEntity<Comment> updateComment(@PathVariable("id") String id,
+                                                 @RequestBody Comment update) {
+        final Optional<Comment> commentOptional = commentRepository.findById(id);
+
+        if (!commentOptional.isPresent()) {
+            return ResponseEntity.notFound().build();
+        }
+
+        final Comment saved = commentOptional.get();
+        saved.setContent(update.getContent());
+
+        return ResponseEntity.ok(commentRepository.save(saved));
+    }
+}

springboot-dynamodb-demo/src/main/resources/application.yaml

@@ -1 +1,10 @@
+server:
+  port: 3000
 
+aws:
+  dynamodb:
+    endpoint: http://localhost:8000
+    region: ap-northeast-2
+  credential:
+    access-key: dummy
+    secret-key: dummy