com.beacon50.jdbc.aws

Class SimpleDBStatement

java.lang.Object

com.beacon50.jdbc.aws.AbstractStatement

com.beacon50.jdbc.aws.SimpleDBStatement

All Implemented Interfaces:

java.lang.AutoCloseable, java.sql.Statement, java.sql.Wrapper

public class SimpleDBStatement
extends AbstractStatement

Field Summary

Fields inherited from interface java.sql.Statement

CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleDBStatement(java.sql.Connection conn)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeOnCompletion()
boolean	execute(java.lang.String sql)
java.sql.ResultSet	executeQuery(java.lang.String sql) SELECT * FROM MY_DOMAIN
int	executeUpdate(java.lang.String sql)
int	executeUpdate(java.lang.String sql, int autoGeneratedKeys)
java.sql.Connection	getConnection()
java.sql.ResultSet	getGeneratedKeys()
protected com.amazonaws.services.simpledb.model.ReplaceableAttribute	getReadReplaceableAttribute(java.lang.String name, java.lang.String expressionVal, boolean replace)
protected com.amazonaws.services.simpledb.model.ReplaceableItem	getReadReplaceableItem(java.util.List<com.amazonaws.services.simpledb.model.ReplaceableAttribute> attributes, java.lang.String id)
protected java.lang.String	getReadTableName(net.sf.jsqlparser.statement.select.FromItem fromItem)
java.sql.ResultSet	getResultSet()
protected java.sql.ResultSet	getSimpleDBResultSet(java.lang.String domain, java.util.List<com.amazonaws.services.simpledb.model.Item> items)
int	getUpdateCount()
protected com.amazonaws.services.simpledb.model.ReplaceableAttribute	getWriteReplaceableAttribute(java.lang.String name, java.lang.String expressionVal, boolean replace)
protected com.amazonaws.services.simpledb.model.ReplaceableItem	getWriteReplaceableItem(java.util.List<com.amazonaws.services.simpledb.model.ReplaceableAttribute> attributes, java.lang.String id)
protected java.lang.String	getWriteTableName(net.sf.jsqlparser.schema.Table table)
boolean	isCloseOnCompletion()

Methods inherited from class com.beacon50.jdbc.aws.AbstractStatement

addBatch, cancel, clearBatch, clearWarnings, execute, execute, execute, executeBatch, executeUpdate, executeUpdate, getFetchDirection, getFetchSize, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getWarnings, isClosed, isPoolable, isWrapperFor, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Statement

executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, getLargeMaxRows, getLargeUpdateCount, setLargeMaxRows

Constructor Detail

SimpleDBStatement

protected SimpleDBStatement(java.sql.Connection conn)

Method Detail

execute

public boolean execute(java.lang.String sql)
                throws java.sql.SQLException

Throws:

java.sql.SQLException

getResultSet

public java.sql.ResultSet getResultSet()
                                throws java.sql.SQLException

Throws:

java.sql.SQLException

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

executeQuery

public java.sql.ResultSet executeQuery(java.lang.String sql)
                                throws java.sql.SQLException

SELECT * FROM MY_DOMAIN

Parameters:

sql - to execute

Returns:

ResultSet

Throws:

java.sql.SQLException

getSimpleDBResultSet

protected java.sql.ResultSet getSimpleDBResultSet(java.lang.String domain,
                                                  java.util.List<com.amazonaws.services.simpledb.model.Item> items)

executeUpdate

public int executeUpdate(java.lang.String sql)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getUpdateCount

public int getUpdateCount()
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getWriteTableName

protected java.lang.String getWriteTableName(net.sf.jsqlparser.schema.Table table)

getReadTableName

protected java.lang.String getReadTableName(net.sf.jsqlparser.statement.select.FromItem fromItem)

getReadReplaceableItem

protected com.amazonaws.services.simpledb.model.ReplaceableItem getReadReplaceableItem(java.util.List<com.amazonaws.services.simpledb.model.ReplaceableAttribute> attributes,
                                                                                       java.lang.String id)

Parameters:

attributes - attributes to replace

id - Item id

Returns:

ReplaceableItem

getWriteReplaceableItem

protected com.amazonaws.services.simpledb.model.ReplaceableItem getWriteReplaceableItem(java.util.List<com.amazonaws.services.simpledb.model.ReplaceableAttribute> attributes,
                                                                                        java.lang.String id)

getWriteReplaceableAttribute

protected com.amazonaws.services.simpledb.model.ReplaceableAttribute getWriteReplaceableAttribute(java.lang.String name,
                                                                                                  java.lang.String expressionVal,
                                                                                                  boolean replace)

Parameters:

name - item name

expressionVal - value

replace - replace value?

Returns:

ReplaceableAttribute

getReadReplaceableAttribute

protected com.amazonaws.services.simpledb.model.ReplaceableAttribute getReadReplaceableAttribute(java.lang.String name,
                                                                                                 java.lang.String expressionVal,
                                                                                                 boolean replace)

executeUpdate

public int executeUpdate(java.lang.String sql,
                         int autoGeneratedKeys)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

closeOnCompletion

public void closeOnCompletion()
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

isCloseOnCompletion

public boolean isCloseOnCompletion()
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

close

public void close()
           throws java.sql.SQLException

Throws:

java.sql.SQLException

getGeneratedKeys

public java.sql.ResultSet getGeneratedKeys()
                                    throws java.sql.SQLException

Throws:

java.sql.SQLException