org.apache.derby.client.am
Class Agent

java.lang.Object
  extended by org.apache.derby.client.am.Agent
Direct Known Subclasses:
NetAgent

public abstract class Agent
extends java.lang.Object


Field Summary
 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_
           
 
Constructor Summary
protected Agent(Connection connection, LogWriter logWriter)
           
 
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
 

Field Detail

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_
Constructor Detail

Agent

protected Agent(Connection connection,
                LogWriter logWriter)
Method Detail

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

Built on Thu 2010-12-23 20:49:13+0000, from revision ???

Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.