public class ServerPrepareResult extends java.lang.Object implements PrepareResult
Modifier and Type | Field and Description |
---|---|
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.
|
ColumnInformation[] |
getColumns() |
int |
getParamCount() |
ColumnInformation[] |
getParameters() |
ColumnType[] |
getParameterTypeHeader() |
int |
getShareCounter() |
java.lang.String |
getSql() |
int |
getStatementId() |
Protocol |
getUnProxiedProtocol() |
boolean |
incrementShareCounter()
Increment share counter.
|
void |
resetParameterTypeHeader() |
void |
setAddToCache() |
void |
setRemoveFromCache() |
private final ColumnInformation[] columns
private final ColumnInformation[] parameters
private final java.lang.String sql
private final java.util.concurrent.atomic.AtomicBoolean inCache
private int statementId
private ColumnType[] parameterTypeHeader
private Protocol unProxiedProtocol
private volatile int shareCounter
private volatile boolean isBeingDeallocate
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()