Top Fields Constructors Methods
org.apache.derby.client.am

public abstract Class Agent

extends Object
Class Inheritance
Known Direct Subclasses
org.apache.derby.client.net.NetAgent
Imports
java.io.PrintWriter, java.sql.BatchUpdateException, .Types, org.apache.derby.client.ClientAutoloadedDriver, org.apache.derby.shared.common.reference.JDBC40Translation, .SQLState

Field Summary

Modifier and TypeField and Description
pack-priv SqlException
accumulatedReadExceptions_

private boolean[]
batchedExceptionGenerated_

private int
batchedExceptionLabelIndex_

pack-priv ClientConnection
connection_

pack-priv final CrossConverters
crossConverters_

private SqlException
deferredException_

private boolean
enableBatchedExceptionTracking_

public LogWriter
logWriter_

pack-priv SectionManager
sectionManager_

Constructor Summary

AccessConstructor and Description
protected
Agent(ClientConnection connection, LogWriter logWriter)

Method Summary

Modifier and TypeMethod and Description
public final void
accumulateChainBreakingReadExceptionAndThrow(DisconnectException e)

pack-priv void
accumulateDeferredException(SqlException e)

private void
accumulateDisconnectException(DisconnectException e)

public final void
accumulateReadException(SqlException e)

private void
beginBatchedReadChain(ClientStatement statement, int batchSize)

pack-priv final void
beginBatchedWriteChain(ClientStatement statement)

protected void
beginReadChain(ClientStatement statement)

protected void
beginReadChainOutsideUOW()

public void
beginWriteChain(ClientStatement statement)

public abstract void
beginWriteChainOutsideUOW()

public abstract void
checkForChainBreakingException_()

pack-priv void
checkForDeferredExceptions()

protected final void
checkForExceptions()

pack-priv void
checkForSupportedDataType(int
the data type to check
dataType)

Checks whether a data type is supported for setObject(int, Object, int) and setObject(int, Object, int, int).

public void
close()

public abstract void
close_()

pack-priv final void
disableBatchedExceptionTracking()

pack-priv final void
disconnectEvent()

private final void
enableBatchedExceptionTracking(int batchSize)

pack-priv final void
endBatchedReadChain(long[] updateCounts, SqlException accumulatedExceptions)

private final void
endBatchedWriteChain()

public void
endReadChain()

protected abstract void
endWriteChain()

public final void
flow(ClientStatement statement)

pack-priv final void
flowBatch(ClientStatement statement, int batchSize)

public final void
flowOutsideUOW()

public abstract void
flush_()

public final PrintWriter
getLogWriter()

private final SqlException
labelAsBatchedException(SqlException e, int index)

public final boolean
loggingEnabled()

protected abstract void
markChainBreakingException_()

private void
resetAgent(LogWriter logWriter)

pack-priv void
resetAgent(ClientConnection connection, LogWriter logWriter, int loginTimeout, String server, int port)

protected abstract void
resetAgent_(LogWriter logWriter, int loginTimeout, String server, int port)

public final void
setBatchedExceptionLabelIndex(int index)

public final void
setLogWriter(LogWriter logWriter)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

accumulatedReadExceptions_back to summary
pack-priv SqlException accumulatedReadExceptions_
batchedExceptionGenerated_back to summary
private boolean[] batchedExceptionGenerated_
batchedExceptionLabelIndex_back to summary
private int batchedExceptionLabelIndex_
connection_back to summary
pack-priv ClientConnection connection_
crossConverters_back to summary
pack-priv final CrossConverters crossConverters_
deferredException_back to summary
private SqlException deferredException_
enableBatchedExceptionTracking_back to summary
private boolean enableBatchedExceptionTracking_
logWriter_back to summary
public LogWriter logWriter_
sectionManager_back to summary
pack-priv SectionManager sectionManager_

Constructor Detail

Agentback to summary
protected Agent(ClientConnection connection, LogWriter logWriter)

Method Detail

accumulateChainBreakingReadExceptionAndThrowback to summary
public final void accumulateChainBreakingReadExceptionAndThrow(DisconnectException e) throws DisconnectException
accumulateDeferredExceptionback to summary
pack-priv void accumulateDeferredException(SqlException e)
accumulateDisconnectExceptionback to summary
private void accumulateDisconnectException(DisconnectException e)
accumulateReadExceptionback to summary
public final void accumulateReadException(SqlException e)
beginBatchedReadChainback to summary
private void beginBatchedReadChain(ClientStatement statement, int batchSize) throws SqlException
beginBatchedWriteChainback to summary
pack-priv final void beginBatchedWriteChain(ClientStatement statement) throws SqlException
beginReadChainback to summary
protected void beginReadChain(ClientStatement statement) throws SqlException
beginReadChainOutsideUOWback to summary
protected void beginReadChainOutsideUOW() throws SqlException
beginWriteChainback to summary
public void beginWriteChain(ClientStatement statement) throws SqlException
beginWriteChainOutsideUOWback to summary
public abstract void beginWriteChainOutsideUOW() throws SqlException
checkForChainBreakingException_back to summary
public abstract void checkForChainBreakingException_() throws SqlException
checkForDeferredExceptionsback to summary
pack-priv void checkForDeferredExceptions() throws SqlException
checkForExceptionsback to summary
protected final void checkForExceptions() throws SqlException
checkForSupportedDataTypeback to summary
pack-priv void checkForSupportedDataType(int dataType) throws SqlException

Checks whether a data type is supported for setObject(int, Object, int) and setObject(int, Object, int, int).

Parameters
dataType:int

the data type to check

Exceptions
SqlException:
if the type is not supported
closeback to summary
public void close() throws SqlException
close_back to summary
public abstract void close_() throws SqlException
disableBatchedExceptionTrackingback to summary
pack-priv final void disableBatchedExceptionTracking()
disconnectEventback to summary
pack-priv final void disconnectEvent()
enableBatchedExceptionTrackingback to summary
private final void enableBatchedExceptionTracking(int batchSize)
endBatchedReadChainback to summary
pack-priv final void endBatchedReadChain(long[] updateCounts, SqlException accumulatedExceptions) throws BatchUpdateException
endBatchedWriteChainback to summary
private final void endBatchedWriteChain()
endReadChainback to summary
public void endReadChain() throws SqlException
endWriteChainback to summary
protected abstract void endWriteChain()
flowback to summary
public final void flow(ClientStatement statement) throws SqlException
flowBatchback to summary
pack-priv final void flowBatch(ClientStatement statement, int batchSize) throws SqlException
flowOutsideUOWback to summary
public final void flowOutsideUOW() throws SqlException
flush_back to summary
public abstract void flush_() throws DisconnectException
getLogWriterback to summary
public final PrintWriter getLogWriter()
labelAsBatchedExceptionback to summary
private final SqlException labelAsBatchedException(SqlException e, int index)
loggingEnabledback to summary
public final boolean loggingEnabled()
markChainBreakingException_back to summary
protected abstract void markChainBreakingException_()
resetAgentback to summary
private void resetAgent(LogWriter logWriter)
resetAgentback to summary
pack-priv void resetAgent(ClientConnection connection, LogWriter logWriter, int loginTimeout, String server, int port) throws SqlException
resetAgent_back to summary
protected abstract void resetAgent_(LogWriter logWriter, int loginTimeout, String server, int port) throws SqlException
setBatchedExceptionLabelIndexback to summary
public final void setBatchedExceptionLabelIndex(int index)
setLogWriterback to summary
public final void setLogWriter(LogWriter logWriter)