Package org.apache.derby.client.am
Class Agent
java.lang.Object
org.apache.derby.client.am.Agent
- Direct Known Subclasses:
NetAgent
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) SqlException
private boolean[]
private int
(package private) ClientConnection
(package private) final CrossConverters
private SqlException
private boolean
(package private) SectionManager
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal void
(package private) void
private void
final void
private void
beginBatchedReadChain
(ClientStatement statement, int batchSize) (package private) final void
beginBatchedWriteChain
(ClientStatement statement) protected void
beginReadChain
(ClientStatement statement) protected void
void
beginWriteChain
(ClientStatement statement) abstract void
abstract void
(package private) void
protected final void
(package private) void
checkForSupportedDataType
(int dataType) Checks whether a data type is supported forsetObject(int, Object, int)
andsetObject(int, Object, int, int)
.void
close()
abstract void
close_()
(package private) final void
(package private) final void
private final void
enableBatchedExceptionTracking
(int batchSize) (package private) final void
endBatchedReadChain
(long[] updateCounts, SqlException accumulatedExceptions) private final void
void
protected abstract void
final void
flow
(ClientStatement statement) (package private) final void
flowBatch
(ClientStatement statement, int batchSize) final void
abstract void
flush_()
final PrintWriter
private final SqlException
labelAsBatchedException
(SqlException e, int index) final boolean
protected abstract void
(package private) void
resetAgent
(ClientConnection connection, LogWriter logWriter, int loginTimeout, String server, int port) private void
resetAgent
(LogWriter logWriter) protected abstract void
resetAgent_
(LogWriter logWriter, int loginTimeout, String server, int port) final void
setBatchedExceptionLabelIndex
(int index) final void
setLogWriter
(LogWriter logWriter)
-
Field Details
-
accumulatedReadExceptions_
SqlException accumulatedReadExceptions_ -
enableBatchedExceptionTracking_
private boolean enableBatchedExceptionTracking_ -
batchedExceptionLabelIndex_
private int batchedExceptionLabelIndex_ -
batchedExceptionGenerated_
private boolean[] batchedExceptionGenerated_ -
connection_
ClientConnection connection_ -
sectionManager_
SectionManager sectionManager_ -
logWriter_
-
crossConverters_
-
deferredException_
-
-
Constructor Details
-
Agent
-
-
Method Details
-
checkForDeferredExceptions
- Throws:
SqlException
-
checkForSupportedDataType
Checks whether a data type is supported forsetObject(int, Object, int)
andsetObject(int, Object, int, int)
.- Parameters:
dataType
- the data type to check- Throws:
SqlException
- if the type is not supported
-
accumulateDeferredException
-
resetAgent
-
resetAgent
void resetAgent(ClientConnection connection, LogWriter logWriter, int loginTimeout, String server, int port) throws SqlException - Throws:
SqlException
-
resetAgent_
protected abstract void resetAgent_(LogWriter logWriter, int loginTimeout, String server, int port) throws SqlException - Throws:
SqlException
-
loggingEnabled
public final boolean loggingEnabled() -
setLogWriter
-
getLogWriter
-
accumulateReadException
-
accumulateDisconnectException
-
accumulateChainBreakingReadExceptionAndThrow
public final void accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) throws DisconnectException - Throws:
DisconnectException
-
markChainBreakingException_
protected abstract void markChainBreakingException_() -
checkForChainBreakingException_
- Throws:
SqlException
-
enableBatchedExceptionTracking
private final void enableBatchedExceptionTracking(int batchSize) -
disableBatchedExceptionTracking
final void disableBatchedExceptionTracking() -
setBatchedExceptionLabelIndex
public final void setBatchedExceptionLabelIndex(int index) -
labelAsBatchedException
-
checkForExceptions
- Throws:
SqlException
-
flow
- Throws:
SqlException
-
flowBatch
- Throws:
SqlException
-
flowOutsideUOW
- Throws:
SqlException
-
flush_
- Throws:
DisconnectException
-
close_
- Throws:
SqlException
-
close
- Throws:
SqlException
-
disconnectEvent
final void disconnectEvent() -
beginWriteChainOutsideUOW
- Throws:
SqlException
-
beginWriteChain
- Throws:
SqlException
-
beginBatchedWriteChain
- Throws:
SqlException
-
endWriteChain
protected abstract void endWriteChain() -
endBatchedWriteChain
private final void endBatchedWriteChain() -
beginReadChain
- Throws:
SqlException
-
beginBatchedReadChain
- Throws:
SqlException
-
beginReadChainOutsideUOW
- Throws:
SqlException
-
endReadChain
- Throws:
SqlException
-
endBatchedReadChain
final void endBatchedReadChain(long[] updateCounts, SqlException accumulatedExceptions) throws BatchUpdateException - Throws:
BatchUpdateException
-