public class ServerPrepareResult extends java.lang.Object implements PrepareResult
Modifier and Type | Field and Description |
---|---|
private Results |
activeCursorResult |
private ColumnInformation[] |
columns |
private java.util.concurrent.atomic.AtomicBoolean |
inCache |
private boolean |
isBeingDeallocate |
private ColumnInformation[] |
parameters |
private ColumnType[] |
parameterTypeHeader |
private int |
shareCounter |
private java.lang.String |
sql |
private int |
statementId |
private Protocol |
unProxiedProtocol |
Constructor and Description |
---|
ServerPrepareResult(java.lang.String sql,
int statementId,
ColumnInformation[] columns,
ColumnInformation[] parameters,
Protocol unProxiedProtocol)
PrepareStatement Result object.
|
Modifier and Type | Method and Description |
---|---|
boolean |
canBeDeallocate()
Asked if can be deallocate (is not shared in other statement and not in cache)
Set deallocate flag to true if so.
|
void |
decrementShareCounter() |
void |
failover(int statementId,
Protocol unProxiedProtocol)
Update information after a failover.
|
void |
fetchAllOpenCursor()
if a new query will be done using this statementId and there is an open cursor,
then fetch all results in resultSet (Cursor will be closed after executing a query).
|
ColumnInformation[] |
getColumns() |
int |
getParamCount() |
ColumnInformation[] |
getParameters() |
ColumnType[] |
getParameterTypeHeader() |
int |
getShareCounter() |
java.lang.String |
getSql() |
int |
getStatementId() |
Protocol |
getUnProxiedProtocol() |
boolean |
incrementShareCounter()
Increment share counter.
|
void |
openCursor(Results result) |
void |
resetParameterTypeHeader() |
void |
setAddToCache() |
void |
setRemoveFromCache() |
private int statementId
private ColumnInformation[] columns
private ColumnInformation[] parameters
private ColumnType[] parameterTypeHeader
private Protocol unProxiedProtocol
private java.lang.String sql
private Results activeCursorResult
private volatile int shareCounter
private volatile boolean isBeingDeallocate
private java.util.concurrent.atomic.AtomicBoolean inCache
public ServerPrepareResult(java.lang.String sql, int statementId, ColumnInformation[] columns, ColumnInformation[] parameters, Protocol unProxiedProtocol)
sql
- querystatementId
- server statement Id.columns
- columns informationparameters
- parameters informationunProxiedProtocol
- indicate the protocol on which the prepare has been donepublic void resetParameterTypeHeader()
public void failover(int statementId, Protocol unProxiedProtocol)
statementId
- new statement IdunProxiedProtocol
- the protocol on which the prepare has been donepublic void setAddToCache()
public void setRemoveFromCache()
public boolean incrementShareCounter()
public void decrementShareCounter()
public boolean canBeDeallocate()
public int getParamCount()
getParamCount
in interface PrepareResult
public int getShareCounter()
public int getStatementId()
public ColumnInformation[] getColumns()
public ColumnInformation[] getParameters()
public Protocol getUnProxiedProtocol()
public java.lang.String getSql()
getSql
in interface PrepareResult
public ColumnType[] getParameterTypeHeader()
public void openCursor(Results result)
public void fetchAllOpenCursor()