org.apache.shardingsphere.shardingjdbc.jdbc.adapter

Class AbstractStatementAdapter

java.lang.Object

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter

org.apache.shardingsphere.shardingjdbc.jdbc.unsupported.AbstractUnsupportedOperationStatement

org.apache.shardingsphere.shardingjdbc.jdbc.adapter.AbstractStatementAdapter

All Implemented Interfaces:

AutoCloseable, Statement, Wrapper

Direct Known Subclasses:

AbstractUnsupportedOperationPreparedStatement, MasterSlaveStatement, ShardingStatement

public abstract class AbstractStatementAdapter
extends AbstractUnsupportedOperationStatement

Adapter for Statement.

Author:

zhangliang, gaohongtao, yangyi

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

Constructor and Description
AbstractStatementAdapter()

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	clearWarnings()
void	close()
int	getFetchSize()
int	getMaxFieldSize()
int	getMaxRows()
boolean	getMoreResults()
boolean	getMoreResults(int current)
int	getQueryTimeout()
protected abstract Collection<? extends Statement>	getRoutedStatements()
int	getUpdateCount()
SQLWarning	getWarnings()
protected abstract boolean	isAccumulate()
boolean	isClosed()
boolean	isPoolable()
void	setEscapeProcessing(boolean enable)
void	setFetchSize(int rows)
void	setMaxFieldSize(int max)
void	setMaxRows(int max)
void	setPoolable(boolean poolable)
void	setQueryTimeout(int seconds)

Methods inherited from class org.apache.shardingsphere.shardingjdbc.jdbc.unsupported.AbstractUnsupportedOperationStatement

addBatch, clearBatch, closeOnCompletion, executeBatch, getFetchDirection, isCloseOnCompletion, setCursorName, setFetchDirection

Methods inherited from class org.apache.shardingsphere.shardingjdbc.jdbc.adapter.WrapperAdapter

isWrapperFor, recordMethodInvocation, replayMethodsInvocation, 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

execute, execute, execute, execute, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getConnection, getGeneratedKeys, getLargeMaxRows, getLargeUpdateCount, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, setLargeMaxRows

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

AbstractStatementAdapter

public AbstractStatementAdapter()

Method Detail

close

public final void close()
                 throws SQLException

Throws:

SQLException

isClosed

public final boolean isClosed()

isPoolable

public final boolean isPoolable()

setPoolable

public final void setPoolable(boolean poolable)
                       throws SQLException

Throws:

SQLException

getFetchSize

public final int getFetchSize()

setFetchSize

public final void setFetchSize(int rows)
                        throws SQLException

Throws:

SQLException

setEscapeProcessing

public final void setEscapeProcessing(boolean enable)
                               throws SQLException

Throws:

SQLException

cancel

public final void cancel()
                  throws SQLException

Throws:

SQLException

getUpdateCount

public final int getUpdateCount()
                         throws SQLException

Throws:

SQLException

getWarnings

public final SQLWarning getWarnings()

clearWarnings

public final void clearWarnings()

getMoreResults

public final boolean getMoreResults()
                             throws SQLException

Throws:

SQLException

getMoreResults

public final boolean getMoreResults(int current)

getMaxFieldSize

public final int getMaxFieldSize()
                          throws SQLException

Throws:

SQLException

setMaxFieldSize

public final void setMaxFieldSize(int max)
                           throws SQLException

Throws:

SQLException

getMaxRows

public final int getMaxRows()
                     throws SQLException

Throws:

SQLException

setMaxRows

public final void setMaxRows(int max)
                      throws SQLException

Throws:

SQLException

getQueryTimeout

public final int getQueryTimeout()
                          throws SQLException

Throws:

SQLException

setQueryTimeout

public final void setQueryTimeout(int seconds)
                           throws SQLException

Throws:

SQLException

isAccumulate

protected abstract boolean isAccumulate()

getRoutedStatements

protected abstract Collection<? extends Statement> getRoutedStatements()