public class FiberStatement extends Object implements Statement
| Modifier and Type | Field and Description |
|---|---|
protected ExecutorService |
executor |
protected Statement |
stmt |
CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO| Constructor and Description |
|---|
FiberStatement(Statement stmt,
ExecutorService exec) |
protected final Statement stmt
protected final ExecutorService executor
public FiberStatement(Statement stmt, ExecutorService exec)
@Suspendable public FiberResultSet executeQuery(String sql) throws SQLException
executeQuery in interface StatementSQLException@Suspendable public int executeUpdate(String sql) throws SQLException
executeUpdate in interface StatementSQLException@Suspendable public void close() throws SQLException
close in interface AutoCloseableclose in interface StatementSQLException@Suspendable public int getMaxFieldSize() throws SQLException
getMaxFieldSize in interface StatementSQLException@Suspendable public void setMaxFieldSize(int max) throws SQLException
setMaxFieldSize in interface StatementSQLException@Suspendable public int getMaxRows() throws SQLException
getMaxRows in interface StatementSQLException@Suspendable public void setMaxRows(int max) throws SQLException
setMaxRows in interface StatementSQLException@Suspendable public void setEscapeProcessing(boolean enable) throws SQLException
setEscapeProcessing in interface StatementSQLException@Suspendable public int getQueryTimeout() throws SQLException
getQueryTimeout in interface StatementSQLException@Suspendable public void setQueryTimeout(int seconds) throws SQLException
setQueryTimeout in interface StatementSQLException@Suspendable public void cancel() throws SQLException
cancel in interface StatementSQLException@Suspendable public SQLWarning getWarnings() throws SQLException
getWarnings in interface StatementSQLException@Suspendable public void clearWarnings() throws SQLException
clearWarnings in interface StatementSQLException@Suspendable public void setCursorName(String name) throws SQLException
setCursorName in interface StatementSQLException@Suspendable public FiberResultSet getResultSet() throws SQLException
getResultSet in interface StatementSQLException@Suspendable public int getUpdateCount() throws SQLException
getUpdateCount in interface StatementSQLException@Suspendable public boolean getMoreResults() throws SQLException
getMoreResults in interface StatementSQLException@Suspendable public void setFetchDirection(int direction) throws SQLException
setFetchDirection in interface StatementSQLException@Suspendable public int getFetchDirection() throws SQLException
getFetchDirection in interface StatementSQLException@Suspendable public void setFetchSize(int rows) throws SQLException
setFetchSize in interface StatementSQLException@Suspendable public int getFetchSize() throws SQLException
getFetchSize in interface StatementSQLException@Suspendable public int getResultSetConcurrency() throws SQLException
getResultSetConcurrency in interface StatementSQLException@Suspendable public int getResultSetType() throws SQLException
getResultSetType in interface StatementSQLException@Suspendable public void addBatch(String sql) throws SQLException
addBatch in interface StatementSQLException@Suspendable public void clearBatch() throws SQLException
clearBatch in interface StatementSQLException@Suspendable public int[] executeBatch() throws SQLException
executeBatch in interface StatementSQLException@Suspendable public FiberConnection getConnection() throws SQLException
getConnection in interface StatementSQLException@Suspendable public boolean getMoreResults(int current) throws SQLException
getMoreResults in interface StatementSQLException@Suspendable public ResultSet getGeneratedKeys() throws SQLException
getGeneratedKeys in interface StatementSQLException@Suspendable public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException
executeUpdate in interface StatementSQLException@Suspendable public int executeUpdate(String sql, int[] columnIndexes) throws SQLException
executeUpdate in interface StatementSQLException@Suspendable public int executeUpdate(String sql, String[] columnNames) throws SQLException
executeUpdate in interface StatementSQLException@Suspendable public boolean execute(String sql) throws SQLException
execute in interface StatementSQLException@Suspendable public boolean execute(String sql, int autoGeneratedKeys) throws SQLException
execute in interface StatementSQLException@Suspendable public boolean execute(String sql, int[] columnIndexes) throws SQLException
execute in interface StatementSQLException@Suspendable public boolean execute(String sql, String[] columnNames) throws SQLException
execute in interface StatementSQLException@Suspendable public int getResultSetHoldability() throws SQLException
getResultSetHoldability in interface StatementSQLException@Suspendable public boolean isClosed() throws SQLException
isClosed in interface StatementSQLException@Suspendable public void setPoolable(boolean poolable) throws SQLException
setPoolable in interface StatementSQLException@Suspendable public boolean isPoolable() throws SQLException
isPoolable in interface StatementSQLException@Suspendable public void closeOnCompletion() throws SQLException
closeOnCompletion in interface StatementSQLException@Suspendable public boolean isCloseOnCompletion() throws SQLException
isCloseOnCompletion in interface StatementSQLExceptionpublic <T> T unwrap(Class<T> iface) throws SQLException
unwrap in interface WrapperSQLExceptionpublic boolean isWrapperFor(Class<?> iface) throws SQLException
isWrapperFor in interface WrapperSQLException