Skip to content

Instantly share code, notes, and snippets.

@olegon
Last active May 24, 2022 20:04
Show Gist options
  • Save olegon/9e8349e30d164956705ced8e17d40973 to your computer and use it in GitHub Desktop.
Save olegon/9e8349e30d164956705ced8e17d40973 to your computer and use it in GitHub Desktop.
logging.level.root=TRACE
package com.olegon.javadynamodblimit.controller
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBQueryExpression
import com.amazonaws.services.dynamodbv2.datamodeling.PaginatedQueryList
import com.amazonaws.services.dynamodbv2.model.AttributeValue
import com.amazonaws.services.dynamodbv2.model.ReturnConsumedCapacity
import com.olegon.javadynamodblimit.entity.Song
import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.RestController
fun <T> PaginatedQueryList<T>.take(n: Int): List<T> {
val list = ArrayList<T>(n)
val it = this.iterator()
while (list.size < n && it.hasNext()) {
list.add(it.next())
}
return list
}
@RestController
class DynamoDBController {
@GetMapping("/v1/read")
fun v1Read(): List<Song> {
val limit = 1
val client = AmazonDynamoDBClientBuilder.defaultClient()
val mapper = DynamoDBMapper(client)
var queryExpression = DynamoDBQueryExpression<Song>()
.withKeyConditionExpression("pk = :pk AND begins_with(sk, :sk)")
.withExpressionAttributeValues(mapOf(
":pk" to AttributeValue("author#1"),
":sk" to AttributeValue("song#")
))
.withLimit(limit)
.withReturnConsumedCapacity(ReturnConsumedCapacity.TOTAL)
val result = mapper.query(Song::class.java, queryExpression).take(limit)
return result
}
@GetMapping("/v1/write")
fun v1Write(): Unit {
val client = AmazonDynamoDBClientBuilder.defaultClient()
val mapper = DynamoDBMapper(client)
for (i in 1..1000) {
mapper.save(Song(
pk = "author#1",
sk = "song#$i",
lyrics = "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Ut enim ad minim veniam, quis nostrud exercitation ullamco laboris nisi ut aliquip ex ea commodo consequat. Duis aute irure dolor in reprehenderit in voluptate velit esse cillum dolore eu fugiat nulla pariatur. Excepteur sint occaecat cupidatat non proident, sunt in culpa qui officia deserunt mollit anim id est laborum."
))
}
}
}
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.0</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.olegon</groupId>
<artifactId>java-dynamodb-limit</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>java-dynamodb-limit</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>11</java.version>
<kotlin.version>1.6.21</kotlin.version>
</properties>
<dependencies>
<!-- https://mvnrepository.com/artifact/com.amazonaws/aws-java-sdk-dynamodb -->
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk-dynamodb</artifactId>
<version>1.12.226</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.module</groupId>
<artifactId>jackson-module-kotlin</artifactId>
</dependency>
<dependency>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-reflect</artifactId>
</dependency>
<dependency>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-stdlib-jdk8</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<sourceDirectory>${project.basedir}/src/main/kotlin</sourceDirectory>
<testSourceDirectory>${project.basedir}/src/test/kotlin</testSourceDirectory>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-maven-plugin</artifactId>
<configuration>
<args>
<arg>-Xjsr305=strict</arg>
</args>
<compilerPlugins>
<plugin>spring</plugin>
</compilerPlugins>
</configuration>
<dependencies>
<dependency>
<groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-maven-allopen</artifactId>
<version>${kotlin.version}</version>
</dependency>
</dependencies>
</plugin>
</plugins>
</build>
</project>
package com.olegon.javadynamodblimit.entity
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBAttribute
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBHashKey
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBRangeKey
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBTable
@DynamoDBTable(tableName = "SongsTable")
class Song(
@DynamoDBHashKey(attributeName = "pk")
var pk: String = "",
@DynamoDBRangeKey(attributeName = "sk")
var sk: String = "",
@DynamoDBAttribute(attributeName = "lyrics")
var lyrics: String = ""
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment