public class ServerSideShardingStatement extends java.lang.Object implements InternalShardingStatement
| Constructor and Description |
|---|
ServerSideShardingStatement(java.sql.Statement aServerSideStmt,
AltibaseShardingConnection aMetaConn) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancel() |
void |
clearForGeneratedKeys() |
void |
clearWarnings() |
void |
close() |
boolean |
execute(java.lang.String aSql) |
boolean |
execute(java.lang.String aSql,
int aAutoGeneratedKeys) |
boolean |
execute(java.lang.String aSql,
int[] aColumnIndexes) |
boolean |
execute(java.lang.String aSql,
java.lang.String[] aColumnNames) |
java.sql.ResultSet |
executeQuery(java.lang.String aSql) |
int |
executeUpdate(java.lang.String aSql) |
int |
executeUpdate(java.lang.String aSql,
int aAutoGeneratedKeys) |
int |
executeUpdate(java.lang.String aSql,
int[] aColumnIndexes) |
int |
executeUpdate(java.lang.String aSql,
java.lang.String[] aColumnNames) |
java.sql.Connection |
getConnection() |
int |
getFetchSize() |
java.sql.ResultSet |
getGeneratedKeys() |
int |
getMaxFieldSize() |
int |
getMaxRows() |
boolean |
getMoreResults() |
boolean |
getMoreResults(int aCurrent) |
int |
getQueryTimeout() |
java.sql.ResultSet |
getResultSet() |
int |
getUpdateCount() |
java.sql.SQLWarning |
getWarnings() |
boolean |
hasNoData() |
boolean |
isPrepared() |
void |
makeQstrForGeneratedKeys(java.lang.String aSql,
int[] aColumnIndexes,
java.lang.String[] aColumnNames) |
void |
setCursorName(java.lang.String aName) |
void |
setEscapeProcessing(boolean aEnable) |
void |
setFetchSize(int aRows) |
void |
setMaxFieldSize(int aMax) |
void |
setMaxRows(int aMax) |
void |
setQueryTimeout(int aSeconds) |
public ServerSideShardingStatement(java.sql.Statement aServerSideStmt,
AltibaseShardingConnection aMetaConn)
public java.sql.ResultSet executeQuery(java.lang.String aSql)
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean execute(java.lang.String aSql)
throws java.sql.SQLException
java.sql.SQLExceptionpublic int executeUpdate(java.lang.String aSql)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void close()
throws java.sql.SQLException
close in interface InternalShardingStatementjava.sql.SQLExceptionpublic int getMaxFieldSize()
throws java.sql.SQLException
getMaxFieldSize in interface InternalShardingStatementjava.sql.SQLExceptionpublic void setMaxFieldSize(int aMax)
throws java.sql.SQLException
setMaxFieldSize in interface InternalShardingStatementjava.sql.SQLExceptionpublic int getMaxRows()
throws java.sql.SQLException
getMaxRows in interface InternalShardingStatementjava.sql.SQLExceptionpublic void setMaxRows(int aMax)
throws java.sql.SQLException
setMaxRows in interface InternalShardingStatementjava.sql.SQLExceptionpublic void setEscapeProcessing(boolean aEnable)
throws java.sql.SQLException
setEscapeProcessing in interface InternalShardingStatementjava.sql.SQLExceptionpublic int getQueryTimeout()
throws java.sql.SQLException
getQueryTimeout in interface InternalShardingStatementjava.sql.SQLExceptionpublic void setQueryTimeout(int aSeconds)
throws java.sql.SQLException
setQueryTimeout in interface InternalShardingStatementjava.sql.SQLExceptionpublic void cancel()
throws java.sql.SQLException
cancel in interface InternalShardingStatementjava.sql.SQLExceptionpublic java.sql.SQLWarning getWarnings()
throws java.sql.SQLException
getWarnings in interface InternalShardingStatementjava.sql.SQLExceptionpublic void clearWarnings()
throws java.sql.SQLException
clearWarnings in interface InternalShardingStatementjava.sql.SQLExceptionpublic void setCursorName(java.lang.String aName)
throws java.sql.SQLException
setCursorName in interface InternalShardingStatementjava.sql.SQLExceptionpublic java.sql.ResultSet getResultSet()
throws java.sql.SQLException
getResultSet in interface InternalShardingStatementjava.sql.SQLExceptionpublic int getUpdateCount()
throws java.sql.SQLException
getUpdateCount in interface InternalShardingStatementjava.sql.SQLExceptionpublic boolean getMoreResults()
throws java.sql.SQLException
getMoreResults in interface InternalShardingStatementjava.sql.SQLExceptionpublic void setFetchSize(int aRows)
throws java.sql.SQLException
setFetchSize in interface InternalShardingStatementjava.sql.SQLExceptionpublic int getFetchSize()
throws java.sql.SQLException
getFetchSize in interface InternalShardingStatementjava.sql.SQLExceptionpublic java.sql.Connection getConnection()
throws java.sql.SQLException
getConnection in interface InternalShardingStatementjava.sql.SQLExceptionpublic boolean getMoreResults(int aCurrent)
throws java.sql.SQLException
getMoreResults in interface InternalShardingStatementjava.sql.SQLExceptionpublic java.sql.ResultSet getGeneratedKeys()
throws java.sql.SQLException
getGeneratedKeys in interface InternalShardingStatementjava.sql.SQLExceptionpublic int executeUpdate(java.lang.String aSql,
int[] aColumnIndexes)
throws java.sql.SQLException
java.sql.SQLExceptionpublic int executeUpdate(java.lang.String aSql,
java.lang.String[] aColumnNames)
throws java.sql.SQLException
java.sql.SQLExceptionpublic int executeUpdate(java.lang.String aSql,
int aAutoGeneratedKeys)
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean execute(java.lang.String aSql,
int[] aColumnIndexes)
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean execute(java.lang.String aSql,
java.lang.String[] aColumnNames)
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean execute(java.lang.String aSql,
int aAutoGeneratedKeys)
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean isPrepared()
isPrepared in interface InternalShardingStatementpublic boolean hasNoData()
hasNoData in interface InternalShardingStatementpublic void makeQstrForGeneratedKeys(java.lang.String aSql,
int[] aColumnIndexes,
java.lang.String[] aColumnNames)
throws java.sql.SQLException
makeQstrForGeneratedKeys in interface InternalShardingStatementjava.sql.SQLExceptionpublic void clearForGeneratedKeys()
clearForGeneratedKeys in interface InternalShardingStatement