org.refcodes.logger.alt.simpledb.impls

Class SimpleDbQueryLoggerImpl<T>

java.lang.Object

org.refcodes.logger.alt.simpledb.impls.AbstractSimpleDbClient

org.refcodes.logger.alt.simpledb.impls.SimpleDbLoggerImpl<T>

org.refcodes.logger.alt.simpledb.impls.SimpleDbQueryLoggerImpl<T>

Type Parameters:

T - The type of the Record instances managed by the Logger.

All Implemented Interfaces:

Flushable, org.refcodes.component.Component, org.refcodes.component.Decomposeable, org.refcodes.component.Destroyable, org.refcodes.component.Initializable, org.refcodes.logger.Logger<T>, org.refcodes.logger.QueryLogger<T>

Direct Known Subclasses:

SimpleDbTrimLoggerImpl

public class SimpleDbQueryLoggerImpl<T>
extends SimpleDbLoggerImpl<T>
implements org.refcodes.logger.QueryLogger<T>, org.refcodes.component.Component, org.refcodes.component.Initializable, org.refcodes.component.Decomposeable, org.refcodes.component.Flushable

The SimpleDbQueryLoggerImpl extends the SimpleDbLoggerImpl implementation with the QueryLogger functionality.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	SimpleDbQueryLoggerImpl.SimpleDbRecordsImpl This iterator encapsulates an Amazon select request for the business logic to simply iterate through the results. ------------------------------------------------------------------------- TODO Make this unit testable and create unit test: -------------------------------------------------------------------------

Nested classes/interfaces inherited from interface org.refcodes.component.Destroyable

org.refcodes.component.Destroyable.DestroyAutomaton

Nested classes/interfaces inherited from interface org.refcodes.component.Initializable

org.refcodes.component.Initializable.InitializeAutomaton, org.refcodes.component.Initializable.InitializeBuilder<B extends org.refcodes.component.Initializable.InitializeBuilder<B>>, org.refcodes.component.Initializable.UncheckedInitializable

Nested classes/interfaces inherited from interface org.refcodes.component.Decomposeable

org.refcodes.component.Decomposeable.DecomposeAutomaton

Field Summary

Fields inherited from class org.refcodes.logger.alt.simpledb.impls.SimpleDbLoggerImpl

LOGGER

Constructor Summary

Constructors

Constructor and Description
SimpleDbQueryLoggerImpl(String aDomainName, String aAccessKey, String aSecretKey, org.refcodes.tabular.ColumnFactory<T> aColumnFactory) Constructs the SimpleDbQueryLoggerImpl for a given SimpleDB domain.
SimpleDbQueryLoggerImpl(String aDomainName, String aAccessKey, String aSecretKey, String aEndPoint, org.refcodes.tabular.ColumnFactory<T> aColumnFactory) Constructs the SimpleDbQueryLoggerImpl for a given SimpleDB domain.

Method Summary

Modifier and Type	Method and Description
void	destroy()
org.refcodes.tabular.Records<T>	findLogs()
org.refcodes.tabular.Records<T>	findLogs(org.refcodes.criteria.Criteria aCriteria)
org.refcodes.tabular.Records<T>	findLogs(org.refcodes.criteria.Criteria aCriteria, org.refcodes.tabular.Header<T> aHeader)
org.refcodes.tabular.Records<T>	findLogs(org.refcodes.criteria.Criteria aCriteria, org.refcodes.tabular.Header<T> aHeader, int aLimit)
org.refcodes.tabular.Records<T>	findLogs(org.refcodes.criteria.Criteria aCriteria, int aLimit)
org.refcodes.tabular.Records<T>	findLogs(org.refcodes.tabular.Header<T> aHeader, int aLimit)
org.refcodes.tabular.Records<T>	findLogs(int aLimit)
protected String	toSqlQuery(org.refcodes.criteria.Criteria aCriteria, int aLimit) Creates an SQL SELECT query from the given Criteria and the provided limit.

Methods inherited from class org.refcodes.logger.alt.simpledb.impls.SimpleDbLoggerImpl

addHeaderColumn, decompose, flush, flushBuffer, getHeader, initialize, log

Methods inherited from class org.refcodes.logger.alt.simpledb.impls.AbstractSimpleDbClient

clearDomain, getAmazonSimpleDbClient, getAmazonSimpleDbClient, getAmazonSimpleDbDomainName, getDomainNames, hasDomain, isRequestTimeoutException, isServiceUnavailableException, setAmazonSimpleDbDomainName, toMessage

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.refcodes.logger.Logger

log

Methods inherited from interface org.refcodes.component.Initializable

initialize

Methods inherited from interface org.refcodes.component.Decomposeable

decompose

Methods inherited from interface org.refcodes.component.Flushable

flush

Constructor Detail

SimpleDbQueryLoggerImpl

public SimpleDbQueryLoggerImpl(String aDomainName,
                               String aAccessKey,
                               String aSecretKey,
                               org.refcodes.tabular.ColumnFactory<T> aColumnFactory)

Constructs the SimpleDbQueryLoggerImpl for a given SimpleDB domain.

Parameters:

aDomainName - The name for the Amazon SimpleDB domain

aAccessKey - The Amazon access key for Amazon SimpleDB

aSecretKey - The Amazon secret key for Amazon SimpleDB

aColumnFactory - The ColumnFactory to create default Column instances for Record instances to be processed

Throws:

UnknownDomainAliasException - in case the campaigning domain alias cannot be resolved.

SimpleDbQueryLoggerImpl

public SimpleDbQueryLoggerImpl(String aDomainName,
                               String aAccessKey,
                               String aSecretKey,
                               String aEndPoint,
                               org.refcodes.tabular.ColumnFactory<T> aColumnFactory)

Constructs the SimpleDbQueryLoggerImpl for a given SimpleDB domain.

Parameters:

aDomainName - The name for the Amazon SimpleDB domain

aAccessKey - The Amazon access key for Amazon SimpleDB

aSecretKey - The Amazon secret key for Amazon SimpleDB

aEndPoint - The end-point (Amazon region) to use (see AbstractSimpleDbClient's constructor documentation for possible values).

aColumnFactory - The ColumnFactory to create default Column instances for Record instances to be processed

Method Detail

findLogs

public org.refcodes.tabular.Records<T> findLogs()

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

findLogs

public org.refcodes.tabular.Records<T> findLogs(int aLimit)

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

findLogs

public org.refcodes.tabular.Records<T> findLogs(org.refcodes.criteria.Criteria aCriteria)

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

findLogs

public org.refcodes.tabular.Records<T> findLogs(org.refcodes.criteria.Criteria aCriteria,
                                                int aLimit)

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

findLogs

public org.refcodes.tabular.Records<T> findLogs(org.refcodes.criteria.Criteria aCriteria,
                                                org.refcodes.tabular.Header<T> aHeader)

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

findLogs

public org.refcodes.tabular.Records<T> findLogs(org.refcodes.tabular.Header<T> aHeader,
                                                int aLimit)

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

findLogs

public org.refcodes.tabular.Records<T> findLogs(org.refcodes.criteria.Criteria aCriteria,
                                                org.refcodes.tabular.Header<T> aHeader,
                                                int aLimit)

Specified by:

findLogs in interface org.refcodes.logger.QueryLogger<T>

destroy

public void destroy()

Specified by:

destroy in interface org.refcodes.component.Destroyable

Overrides:

destroy in class SimpleDbLoggerImpl<T>

toSqlQuery

protected String toSqlQuery(org.refcodes.criteria.Criteria aCriteria,
                            int aLimit)

Creates an SQL SELECT query from the given Criteria and the provided limit.

Parameters:

aCriteria - The Criteria from which to create the SQL query.

aLimit - The limit to be applied to the result set of the query.

Returns:

A (No)SQL query for SimpleDB.