org.apache.derby.client.am
Class Agent
java.lang.Object
org.apache.derby.client.am.Agent
- Direct Known Subclasses:
- NetAgent
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
- 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
- Throws:
SqlException
resetAgent_
protected abstract void resetAgent_(LogWriter logWriter,
int loginTimeout,
java.lang.String server,
int port)
throws SqlException
- 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
- Throws:
DisconnectException
markChainBreakingException_
protected abstract void markChainBreakingException_()
checkForChainBreakingException_
public abstract void checkForChainBreakingException_()
throws SqlException
- 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
- Throws:
SqlException
batchUpdateExceptionGenerated
final boolean batchUpdateExceptionGenerated()
flow
public final void flow(Statement statement)
throws SqlException
- Throws:
SqlException
flowBatch
public final void flowBatch(Statement statement,
int batchSize)
throws SqlException
- Throws:
SqlException
flowOutsideUOW
public final void flowOutsideUOW()
throws SqlException
- Throws:
SqlException
flush_
public abstract void flush_()
throws DisconnectException
- Throws:
DisconnectException
close_
public abstract void close_()
throws SqlException
- Throws:
SqlException
close
public void close()
throws SqlException
- Throws:
SqlException
disconnectEvent
public final void disconnectEvent()
beginWriteChainOutsideUOW
public void beginWriteChainOutsideUOW()
throws SqlException
- Throws:
SqlException
beginWriteChain
public void beginWriteChain(Statement statement)
throws SqlException
- Throws:
SqlException
beginBatchedWriteChain
public final void beginBatchedWriteChain(Statement statement)
throws SqlException
- Throws:
SqlException
endWriteChain
protected void endWriteChain()
endBatchedWriteChain
protected final void endBatchedWriteChain()
beginReadChain
protected void beginReadChain(Statement statement)
throws SqlException
- Throws:
SqlException
beginBatchedReadChain
protected final void beginBatchedReadChain(Statement statement,
int batchSize)
throws SqlException
- Throws:
SqlException
beginReadChainOutsideUOW
protected void beginReadChainOutsideUOW()
throws SqlException
- Throws:
SqlException
endReadChain
public void endReadChain()
throws SqlException
- Throws:
SqlException
endBatchedReadChain
public final void endBatchedReadChain(int[] updateCounts,
SqlException accumulatedExceptions)
throws BatchUpdateException
- Throws:
BatchUpdateException
Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.