Package org.socialsignin.spring.data.dynamodb.core

Class DynamoDBTemplate

java.lang.Object

org.socialsignin.spring.data.dynamodb.core.DynamoDBTemplate

All Implemented Interfaces:

DynamoDBOperations, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class DynamoDBTemplate
extends Object
implements DynamoDBOperations, org.springframework.context.ApplicationContextAware

Constructor Summary

Constructors

Constructor	Description
DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB)	Convenient construcotr to thse the DynamoDBMapperConfig.DEFAULT and default DynamoDBMapper(AmazonDynamoDB)
DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper dynamoDBMapper)	Convenient constructor to use the DynamoDBMapperConfig.DEFAULT
DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig dynamoDBMapperConfig)	Convenient constructor to use the default DynamoDBMapper(AmazonDynamoDB)
DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig dynamoDBMapperConfig, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper dynamoDBMapper)	Initializes a new DynamoDBTemplate.

Method Summary

Modifier and Type	Method	Description
List<com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper.FailedBatch>	batchDelete(Iterable<?> entities)
<T> List<T>	batchLoad(Map<Class<?>,List<com.amazonaws.services.dynamodbv2.datamodeling.KeyPair>> itemsToGet)
List<com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper.FailedBatch>	batchSave(Iterable<?> entities)
<T> int	count(Class<T> domainClass, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBQueryExpression<T> queryExpression)
<T> int	count(Class<T> domainClass, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBScanExpression scanExpression)
<T> int	count(Class<T> clazz, com.amazonaws.services.dynamodbv2.model.QueryRequest mutableQueryRequest)
<T> T	delete(T entity)
<T> String	getOverriddenTableName(Class<T> domainClass, String tableName)
<T> com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperTableModel<T>	getTableModel(Class<T> domainClass)	Provides access to the DynamoDB mapper table model of the underlying domain type.
<T> T	load(Class<T> domainClass, Object hashKey)
<T> T	load(Class<T> domainClass, Object hashKey, Object rangeKey)
protected <T> void	maybeEmitEvent(T source, Function<T,DynamoDBMappingEvent<T>> factory)
<T> com.amazonaws.services.dynamodbv2.datamodeling.PaginatedQueryList<T>	query(Class<T> domainClass, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBQueryExpression<T> queryExpression)
<T> com.amazonaws.services.dynamodbv2.datamodeling.PaginatedQueryList<T>	query(Class<T> clazz, com.amazonaws.services.dynamodbv2.model.QueryRequest queryRequest)
<T> T	save(T entity)
<T> com.amazonaws.services.dynamodbv2.datamodeling.PaginatedScanList<T>	scan(Class<T> domainClass, com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBScanExpression scanExpression)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DynamoDBTemplate

public DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB,
                        com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig dynamoDBMapperConfig)

Convenient constructor to use the default DynamoDBMapper(AmazonDynamoDB)

Parameters:

amazonDynamoDB - The AWS SDK instance to talk to DynamoDB

dynamoDBMapperConfig - The config to use

DynamoDBTemplate

public DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB,
                        com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper dynamoDBMapper)

Convenient constructor to use the DynamoDBMapperConfig.DEFAULT

Parameters:

amazonDynamoDB - The AWS SDK instance to talk to DynamoDB

dynamoDBMapper - The Mapper to use

DynamoDBTemplate

public DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB)

Convenient construcotr to thse the DynamoDBMapperConfig.DEFAULT and default DynamoDBMapper(AmazonDynamoDB)

Parameters:

amazonDynamoDB - The AWS SDK instance to talk to DynamoDB

DynamoDBTemplate

public DynamoDBTemplate(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDB,
                        com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig dynamoDBMapperConfig,
                        com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper dynamoDBMapper)

Initializes a new DynamoDBTemplate. The following combinations are valid:

Parameters:

amazonDynamoDB - must not be null

dynamoDBMapperConfig - can be null - DynamoDBMapperConfig.DEFAULT is used if null is passed in

dynamoDBMapper - can be null - DynamoDBMapper(AmazonDynamoDB, DynamoDBMapperConfig) is used if null is passed in

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

count

public <T> int count(Class<T> domainClass,
                     com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBQueryExpression<T> queryExpression)

Specified by:

count in interface DynamoDBOperations

query

public <T> com.amazonaws.services.dynamodbv2.datamodeling.PaginatedQueryList<T> query(Class<T> domainClass,
                                                                                      com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBQueryExpression<T> queryExpression)

Specified by:

query in interface DynamoDBOperations

count

public <T> int count(Class<T> domainClass,
                     com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBScanExpression scanExpression)

Specified by:

count in interface DynamoDBOperations

load

public <T> T load(Class<T> domainClass,
                  Object hashKey,
                  Object rangeKey)

Specified by:

load in interface DynamoDBOperations

load

public <T> T load(Class<T> domainClass,
                  Object hashKey)

Specified by:

load in interface DynamoDBOperations

scan

public <T> com.amazonaws.services.dynamodbv2.datamodeling.PaginatedScanList<T> scan(Class<T> domainClass,
                                                                                    com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBScanExpression scanExpression)

Specified by:

scan in interface DynamoDBOperations

batchLoad

public <T> List<T> batchLoad(Map<Class<?>,List<com.amazonaws.services.dynamodbv2.datamodeling.KeyPair>> itemsToGet)

Specified by:

batchLoad in interface DynamoDBOperations

save

public <T> T save(T entity)

Specified by:

save in interface DynamoDBOperations

batchSave

public List<com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper.FailedBatch> batchSave(Iterable<?> entities)

Specified by:

batchSave in interface DynamoDBOperations

delete

public <T> T delete(T entity)

Specified by:

delete in interface DynamoDBOperations

batchDelete

public List<com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper.FailedBatch> batchDelete(Iterable<?> entities)

Specified by:

batchDelete in interface DynamoDBOperations

query

public <T> com.amazonaws.services.dynamodbv2.datamodeling.PaginatedQueryList<T> query(Class<T> clazz,
                                                                                      com.amazonaws.services.dynamodbv2.model.QueryRequest queryRequest)

Specified by:

query in interface DynamoDBOperations

count

public <T> int count(Class<T> clazz,
                     com.amazonaws.services.dynamodbv2.model.QueryRequest mutableQueryRequest)

Specified by:

count in interface DynamoDBOperations

getOverriddenTableName

public <T> String getOverriddenTableName(Class<T> domainClass,
                                         String tableName)

Specified by:

getOverriddenTableName in interface DynamoDBOperations

getTableModel

public <T> com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperTableModel<T> getTableModel(Class<T> domainClass)

Provides access to the DynamoDB mapper table model of the underlying domain type.

Specified by:

getTableModel in interface DynamoDBOperations

Type Parameters:

T - The type of the domain type itself

Parameters:

domainClass - A domain type

Returns:

Corresponding DynamoDB table model

maybeEmitEvent

protected <T> void maybeEmitEvent(@Nullable
                                  T source,
                                  Function<T,DynamoDBMappingEvent<T>> factory)