public abstract class Agent
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
SqlException |
accumulatedReadExceptions_ |
private boolean[] |
batchedExceptionGenerated_ |
private int |
batchedExceptionLabelIndex_ |
(package private) Connection |
connection_ |
(package private) CrossConverters |
crossConverters_ |
(package private) SqlException |
deferredException_ |
private boolean |
enableBatchedExceptionTracking_ |
LogWriter |
logWriter_ |
SectionManager |
sectionManager_ |
Modifier | Constructor and Description |
---|---|
protected |
Agent(Connection connection,
LogWriter logWriter) |
Modifier and Type | Method and Description |
---|---|
void |
accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) |
void |
accumulateDeferredException(SqlException e) |
void |
accumulateDisconnectException(DisconnectException e) |
void |
accumulateReadException(SqlException e) |
(package private) boolean |
batchUpdateExceptionGenerated() |
protected void |
beginBatchedReadChain(Statement statement,
int batchSize) |
void |
beginBatchedWriteChain(Statement statement) |
protected void |
beginReadChain(Statement statement) |
protected void |
beginReadChainOutsideUOW() |
void |
beginWriteChain(Statement statement) |
void |
beginWriteChainOutsideUOW() |
abstract void |
checkForChainBreakingException_() |
(package private) void |
checkForDeferredExceptions() |
protected void |
checkForExceptions() |
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() |
void |
disconnectEvent() |
private void |
enableBatchedExceptionTracking(int batchSize) |
void |
endBatchedReadChain(long[] updateCounts,
SqlException accumulatedExceptions) |
protected void |
endBatchedWriteChain() |
void |
endReadChain() |
protected void |
endWriteChain() |
void |
flow(Statement statement) |
void |
flowBatch(Statement 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_() |
abstract LogWriter |
newLogWriter_(java.io.PrintWriter printWriter,
int traceLevel) |
protected abstract void |
resetAgent_(LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port) |
void |
resetAgent(Connection connection,
LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port) |
protected void |
resetAgent(LogWriter logWriter) |
void |
setBatchedExceptionLabelIndex(int index) |
void |
setLogWriter(LogWriter logWriter) |
public SqlException accumulatedReadExceptions_
private boolean enableBatchedExceptionTracking_
private int batchedExceptionLabelIndex_
private boolean[] batchedExceptionGenerated_
Connection connection_
public SectionManager sectionManager_
public LogWriter logWriter_
final CrossConverters crossConverters_
SqlException deferredException_
protected Agent(Connection connection, LogWriter logWriter)
void checkForDeferredExceptions() throws SqlException
SqlException
public 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 supportedpublic void accumulateDeferredException(SqlException e)
protected void resetAgent(LogWriter logWriter)
public void resetAgent(Connection 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 abstract LogWriter newLogWriter_(java.io.PrintWriter printWriter, int traceLevel)
public final void accumulateReadException(SqlException e)
public final 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
final boolean batchUpdateExceptionGenerated()
public final void flow(Statement statement) throws SqlException
SqlException
public final void flowBatch(Statement 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
public final void disconnectEvent()
public void beginWriteChainOutsideUOW() throws SqlException
SqlException
public void beginWriteChain(Statement statement) throws SqlException
SqlException
public final void beginBatchedWriteChain(Statement statement) throws SqlException
SqlException
protected void endWriteChain()
protected final void endBatchedWriteChain()
protected void beginReadChain(Statement statement) throws SqlException
SqlException
protected final void beginBatchedReadChain(Statement statement, int batchSize) throws SqlException
SqlException
protected void beginReadChainOutsideUOW() throws SqlException
SqlException
public void endReadChain() throws SqlException
SqlException
public final void endBatchedReadChain(long[] updateCounts, SqlException accumulatedExceptions) throws java.sql.BatchUpdateException
java.sql.BatchUpdateException
Apache Derby V10.10 Internals - Copyright © 2004,2014 The Apache Software Foundation. All Rights Reserved.