org.teiid.resource.adapter.simpledb

Class SimpleDBConnectionImpl

java.lang.Object

org.teiid.resource.spi.BasicConnection

org.teiid.resource.adapter.simpledb.SimpleDBConnectionImpl

All Implemented Interfaces:

Connection, SimpleDBConnection

public class SimpleDBConnectionImpl
extends BasicConnection
implements SimpleDBConnection

Nested Class Summary

Nested classes/interfaces inherited from interface org.teiid.translator.simpledb.api.SimpleDBConnection

SimpleDBConnection.SimpleDBAttribute

Field Summary

Fields inherited from interface org.teiid.translator.simpledb.api.SimpleDBConnection

ITEM_NAME

Constructor Summary

Constructors

Constructor and Description
SimpleDBConnectionImpl(String accessKey, String secretAccessKey)

Method Summary

Modifier and Type	Method and Description
void	close()
void	createDomain(String domainName) Create a domain
void	deleteDomain(String domainName) Delete a Domain
Set<SimpleDBConnection.SimpleDBAttribute>	getAttributeNames(String domainName) Get the attributes for given domain name
List<String>	getDomains() Lists all domains of database
int	performDelete(String domainName, String selectExpression) Removes item with given ItemName from domain
int	performInsert(String domainName, List<Column> columns, Iterator<? extends List<?>> valueList) Inserts item into given domain.
com.amazonaws.services.simpledb.model.SelectResult	performSelect(String selectExpression, String nextToken) Performs select expression.
int	performUpdate(String domainName, Map<String,Object> updateAttributes, String selectExpression) Performs update on given domain and items

Methods inherited from class org.teiid.resource.spi.BasicConnection

cleanUp, createInteraction, getLocalTransaction, getMetaData, getResultSetInfo, getXAResource, isAlive

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleDBConnectionImpl

public SimpleDBConnectionImpl(String accessKey,
                              String secretAccessKey)

Method Detail

close

public void close()
           throws javax.resource.ResourceException

Specified by:

close in interface Connection

Throws:

javax.resource.ResourceException

createDomain

public void createDomain(String domainName)
                  throws TranslatorException

Description copied from interface: SimpleDBConnection

Create a domain

Specified by:

createDomain in interface SimpleDBConnection

Throws:

TranslatorException

deleteDomain

public void deleteDomain(String domainName)
                  throws TranslatorException

Description copied from interface: SimpleDBConnection

Delete a Domain

Specified by:

deleteDomain in interface SimpleDBConnection

Throws:

TranslatorException

getDomains

public List<String> getDomains()
                        throws TranslatorException

Description copied from interface: SimpleDBConnection

Lists all domains of database

Specified by:

getDomains in interface SimpleDBConnection

Returns:

Throws:

TranslatorException

getAttributeNames

public Set<SimpleDBConnection.SimpleDBAttribute> getAttributeNames(String domainName)
                                                            throws TranslatorException

Description copied from interface: SimpleDBConnection

Get the attributes for given domain name

Specified by:

getAttributeNames in interface SimpleDBConnection

Returns:

Set of attribute names for given domain

Throws:

TranslatorException

performDelete

public int performDelete(String domainName,
                         String selectExpression)
                  throws TranslatorException

Removes item with given ItemName from domain

Specified by:

performDelete in interface SimpleDBConnection

Throws:

TranslatorException

performSelect

public com.amazonaws.services.simpledb.model.SelectResult performSelect(String selectExpression,
                                                                        String nextToken)
                                                                 throws TranslatorException

Performs select expression. This expression must be in format which is understandable to SimpleDB database

Specified by:

performSelect in interface SimpleDBConnection

Throws:

TranslatorException

performUpdate

public int performUpdate(String domainName,
                         Map<String,Object> updateAttributes,
                         String selectExpression)
                  throws TranslatorException

Performs update on given domain and items

Specified by:

performUpdate in interface SimpleDBConnection

Parameters:

domainName -

updateAttributes -

Throws:

TranslatorException

performInsert

public int performInsert(String domainName,
                         List<Column> columns,
                         Iterator<? extends List<?>> valueList)
                  throws TranslatorException

Inserts item into given domain.

Specified by:

performInsert in interface SimpleDBConnection

Returns:

Throws:

TranslatorException