Class Agent

  • Direct Known Subclasses:
    NetAgent

    public abstract class Agent
    extends java.lang.Object
    • Field Detail

      • accumulatedReadExceptions_

        SqlException accumulatedReadExceptions_
      • enableBatchedExceptionTracking_

        private boolean enableBatchedExceptionTracking_
      • batchedExceptionLabelIndex_

        private int batchedExceptionLabelIndex_
      • batchedExceptionGenerated_

        private boolean[] batchedExceptionGenerated_
      • deferredException_

        private SqlException deferredException_
    • Method Detail

      • checkForSupportedDataType

        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 - the data type to check
        Throws:
        SqlException - if the type is not supported
      • accumulateDeferredException

        void accumulateDeferredException​(SqlException e)
      • resetAgent

        private void resetAgent​(LogWriter logWriter)
      • 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()
      • accumulateReadException

        public final void accumulateReadException​(SqlException e)
      • accumulateDisconnectException

        private void accumulateDisconnectException​(DisconnectException e)
      • 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)
      • disconnectEvent

        final void disconnectEvent()
      • endWriteChain

        protected abstract void endWriteChain()
      • endBatchedWriteChain

        private final void endBatchedWriteChain()
      • endBatchedReadChain

        final void endBatchedReadChain​(long[] updateCounts,
                                       SqlException accumulatedExceptions)
                                throws java.sql.BatchUpdateException
        Throws:
        java.sql.BatchUpdateException