DynamoDBMapper Java

// DynamoDBMapper

// 객체 선언
@Autowired
private DynamoDBMapper dynamoDBMapper;

// 검색 조건으로 사용할 Attribute의 Value 지정
HashMap<String, AttributeValue> eav = new HashMap<>();
eav.put(":author", new AttributeValue().withS(author));

// Scan 방식. DB 전체를 조회하므로 속도 느림. Query 방식 권장
DynamoDBScanExpression scanExp = 
	new DynamoDBScanExpression()
		.withFilterExpression("author = :v1")
		.withExpressionAttributeValues(eav);

// Scan 할 Page 계산
int totalItemCount = dynamoDBMapper.count(Article.class, scanExp);
int pageUnitCount = 10;
int totalSegmentCount = totalItemCount / pageUnitCount + (totalItemCount % pageUnitCount == 0 ?  0 : 1);

// Scan 실행
// withTotalSegments와 withTotalSegments와 withSegment로 Page Navigation 구현
ScanResultPage<Article> page = dynamoDBMapper.scanPage(Article.class, scanExp.withTotalSegments(totalSegmentCount).withSegment(pageNo - 1));

String keyConditionExpression = "author = :author";
String filterConditionExpression = "articleId = :articleId";
DynamoDBQueryExpression<Article> scanExp =
	new DynamoDBQueryExpression<Article>()
		.withKeyConditionExpression(keyConditionExpression)  // Partition Key
		.withFilterExpression(filterConditionExpression)  // Sort Key 
		.withIndexName(indexName)  // Index 지정
		.withExpressionAttributeValues(eav)  // Attribute 값 지정
		.withScanIndexForward(false)  // 정렬키로 리스트 정렬(true: 오름차순, false: 내림차순)
		.withLimit(limit); // 개수 제한
QueryResultPage<Article> page = dynamoDBMapper.queryPage(Article.class, scanExp);  // Query 실행
List<Article> items = page.getResults();  // 결과 저장