public abstract class Agent
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
(package private) SqlException |
accumulatedReadExceptions_ |
private boolean[] |
batchedExceptionGenerated_ |
private int |
batchedExceptionLabelIndex_ |
(package private) ClientConnection |
connection_ |
(package private) CrossConverters |
crossConverters_ |
private SqlException |
deferredException_ |
private boolean |
enableBatchedExceptionTracking_ |
LogWriter |
logWriter_ |
(package private) SectionManager |
sectionManager_ |
Modifier | Constructor and Description |
---|---|
protected |
Agent(ClientConnection connection,
LogWriter logWriter) |
Modifier and Type | Method and Description |
---|---|
void |
accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) |
(package private) void |
accumulateDeferredException(SqlException e) |
private void |
accumulateDisconnectException(DisconnectException e) |
void |
accumulateReadException(SqlException e) |
private void |
beginBatchedReadChain(ClientStatement statement,
int batchSize) |
(package private) void |
beginBatchedWriteChain(ClientStatement statement) |
protected void |
beginReadChain(ClientStatement statement) |
protected void |
beginReadChainOutsideUOW() |
void |
beginWriteChain(ClientStatement statement) |
abstract void |
beginWriteChainOutsideUOW() |
abstract void |
checkForChainBreakingException_() |
(package private) void |
checkForDeferredExceptions() |
protected void |
checkForExceptions() |
(package private) void |
checkForSupportedDataType(int dataType)
Checks whether a data type is supported for
setObject(int, Object, int) and
setObject(int, Object, int, int) . |
abstract void |
close_() |
void |
close() |
(package private) void |
disableBatchedExceptionTracking() |
(package private) void |
disconnectEvent() |
private void |
enableBatchedExceptionTracking(int batchSize) |
(package private) void |
endBatchedReadChain(long[] updateCounts,
SqlException accumulatedExceptions) |
private void |
endBatchedWriteChain() |
void |
endReadChain() |
protected abstract void |
endWriteChain() |
void |
flow(ClientStatement statement) |
(package private) void |
flowBatch(ClientStatement statement,
int batchSize) |
void |
flowOutsideUOW() |
abstract void |
flush_() |
java.io.PrintWriter |
getLogWriter() |
private SqlException |
labelAsBatchedException(SqlException e,
int index) |
boolean |
loggingEnabled() |
protected abstract void |
markChainBreakingException_() |
protected abstract void |
resetAgent_(LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port) |
(package private) void |
resetAgent(ClientConnection connection,
LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port) |
private void |
resetAgent(LogWriter logWriter) |
void |
setBatchedExceptionLabelIndex(int index) |
void |
setLogWriter(LogWriter logWriter) |
SqlException accumulatedReadExceptions_
private boolean enableBatchedExceptionTracking_
private int batchedExceptionLabelIndex_
private boolean[] batchedExceptionGenerated_
ClientConnection connection_
SectionManager sectionManager_
public LogWriter logWriter_
final CrossConverters crossConverters_
private SqlException deferredException_
protected Agent(ClientConnection connection, LogWriter logWriter)
void checkForDeferredExceptions() throws SqlException
SqlException
void checkForSupportedDataType(int dataType) throws SqlException
setObject(int, Object, int)
and
setObject(int, Object, int, int)
.dataType
- the data type to checkSqlException
- if the type is not supportedvoid accumulateDeferredException(SqlException e)
private void resetAgent(LogWriter logWriter)
void resetAgent(ClientConnection connection, LogWriter logWriter, int loginTimeout, java.lang.String server, int port) throws SqlException
SqlException
protected abstract void resetAgent_(LogWriter logWriter, int loginTimeout, java.lang.String server, int port) throws SqlException
SqlException
public final boolean loggingEnabled()
public final void setLogWriter(LogWriter logWriter)
public final java.io.PrintWriter getLogWriter()
public final void accumulateReadException(SqlException e)
private void accumulateDisconnectException(DisconnectException e)
public final void accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) throws DisconnectException
DisconnectException
protected abstract void markChainBreakingException_()
public abstract void checkForChainBreakingException_() throws SqlException
SqlException
private final void enableBatchedExceptionTracking(int batchSize)
final void disableBatchedExceptionTracking()
public final void setBatchedExceptionLabelIndex(int index)
private final SqlException labelAsBatchedException(SqlException e, int index)
protected final void checkForExceptions() throws SqlException
SqlException
public final void flow(ClientStatement statement) throws SqlException
SqlException
final void flowBatch(ClientStatement statement, int batchSize) throws SqlException
SqlException
public final void flowOutsideUOW() throws SqlException
SqlException
public abstract void flush_() throws DisconnectException
DisconnectException
public abstract void close_() throws SqlException
SqlException
public void close() throws SqlException
SqlException
final void disconnectEvent()
public abstract void beginWriteChainOutsideUOW() throws SqlException
SqlException
public void beginWriteChain(ClientStatement statement) throws SqlException
SqlException
final void beginBatchedWriteChain(ClientStatement statement) throws SqlException
SqlException
protected abstract void endWriteChain()
private final void endBatchedWriteChain()
protected void beginReadChain(ClientStatement statement) throws SqlException
SqlException
private void beginBatchedReadChain(ClientStatement statement, int batchSize) throws SqlException
SqlException
protected void beginReadChainOutsideUOW() throws SqlException
SqlException
public void endReadChain() throws SqlException
SqlException
final void endBatchedReadChain(long[] updateCounts, SqlException accumulatedExceptions) throws java.sql.BatchUpdateException
java.sql.BatchUpdateException
Apache Derby V10.13 Internals - Copyright © 2004,2016 The Apache Software Foundation. All Rights Reserved.