java.lang.Object
org.apache.derby.client.am.Agent
- public abstract class Agent
- extends java.lang.Object
|
Method Summary |
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()
|
abstract void |
close_()
|
void |
close()
|
(package private) void |
disableBatchedExceptionTracking()
|
void |
disconnectEvent()
|
private void |
enableBatchedExceptionTracking(int batchSize)
|
void |
endBatchedReadChain(int[] 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)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
accumulatedReadExceptions_
public SqlException accumulatedReadExceptions_
enableBatchedExceptionTracking_
private boolean enableBatchedExceptionTracking_
batchedExceptionLabelIndex_
private int batchedExceptionLabelIndex_
batchedExceptionGenerated_
private boolean[] batchedExceptionGenerated_
connection_
Connection connection_
sectionManager_
public SectionManager sectionManager_
logWriter_
public LogWriter logWriter_
crossConverters_
final CrossConverters crossConverters_
deferredException_
SqlException deferredException_
Agent
protected Agent(Connection connection,
LogWriter logWriter)
checkForDeferredExceptions
void checkForDeferredExceptions()
throws SqlException
accumulateDeferredException
public void accumulateDeferredException(SqlException e)
resetAgent
protected void resetAgent(LogWriter logWriter)
resetAgent
public void resetAgent(Connection connection,
LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port)
throws SqlException
resetAgent_
protected abstract void resetAgent_(LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port)
throws SqlException
loggingEnabled
public final boolean loggingEnabled()
setLogWriter
public final void setLogWriter(LogWriter logWriter)
getLogWriter
public final java.io.PrintWriter getLogWriter()
newLogWriter_
public abstract LogWriter newLogWriter_(java.io.PrintWriter printWriter,
int traceLevel)
accumulateReadException
public final void accumulateReadException(SqlException e)
accumulateDisconnectException
public final void accumulateDisconnectException(DisconnectException e)
accumulateChainBreakingReadExceptionAndThrow
public final void accumulateChainBreakingReadExceptionAndThrow(DisconnectException e)
throws DisconnectException
markChainBreakingException_
protected abstract void markChainBreakingException_()
checkForChainBreakingException_
public abstract void checkForChainBreakingException_()
throws SqlException
enableBatchedExceptionTracking
private final void enableBatchedExceptionTracking(int batchSize)
disableBatchedExceptionTracking
final void disableBatchedExceptionTracking()
setBatchedExceptionLabelIndex
public final void setBatchedExceptionLabelIndex(int index)
labelAsBatchedException
private final SqlException labelAsBatchedException(SqlException e,
int index)
checkForExceptions
protected final void checkForExceptions()
throws SqlException
batchUpdateExceptionGenerated
final boolean batchUpdateExceptionGenerated()
flow
public final void flow(Statement statement)
throws SqlException
flowBatch
public final void flowBatch(Statement statement,
int batchSize)
throws SqlException
flowOutsideUOW
public final void flowOutsideUOW()
throws SqlException
flush_
public abstract void flush_()
throws DisconnectException
close_
public abstract void close_()
throws SqlException
close
public void close()
throws SqlException
disconnectEvent
public final void disconnectEvent()
beginWriteChainOutsideUOW
public void beginWriteChainOutsideUOW()
throws SqlException
beginWriteChain
public void beginWriteChain(Statement statement)
throws SqlException
beginBatchedWriteChain
public final void beginBatchedWriteChain(Statement statement)
throws SqlException
endWriteChain
protected void endWriteChain()
endBatchedWriteChain
protected final void endBatchedWriteChain()
beginReadChain
protected void beginReadChain(Statement statement)
throws SqlException
beginBatchedReadChain
protected final void beginBatchedReadChain(Statement statement,
int batchSize)
throws SqlException
beginReadChainOutsideUOW
protected void beginReadChainOutsideUOW()
throws SqlException
endReadChain
public void endReadChain()
throws SqlException
endBatchedReadChain
public final void endBatchedReadChain(int[] updateCounts,
SqlException accumulatedExceptions)
throws BatchUpdateException