org.mule.module.db.internal.processor
Class AbstractSingleQueryDbMessageProcessor

java.lang.Object
  org.mule.processor.AbstractInterceptingMessageProcessorBase
      org.mule.processor.AbstractInterceptingMessageProcessor
          org.mule.module.db.internal.processor.AbstractDbMessageProcessor
              org.mule.module.db.internal.processor.AbstractSingleQueryDbMessageProcessor

All Implemented Interfaces:

AnnotatedObject, MuleContextAware, Initialisable, InterceptingMessageProcessor, MessageProcessor, MessageProcessorContainer, MessageSource, org.mule.common.Capability, org.mule.common.metadata.MetaDataDescriptor, org.mule.common.metadata.OperationMetaDataEnabled

Direct Known Subclasses:

ExecuteDdlMessageProcessor, SelectMessageProcessor, StoredProcedureMessageProcessor, UpdateMessageProcessor

public abstract class AbstractSingleQueryDbMessageProcessor
extends AbstractDbMessageProcessor

Base class for message processors processing only one query

Field Summary

Fields inherited from class org.mule.module.db.internal.processor.AbstractDbMessageProcessor

dbConfigResolver

Fields inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

logger, muleContext, next, notificationHandler

Fields inherited from interface org.mule.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.api.AnnotatedObject

PROPERTY_NAME

Constructor Summary

AbstractSingleQueryDbMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, TransactionalAction transactionalAction)

Method Summary

protected abstract Object	doExecuteQuery(DbConnection connection, Query query)
protected Object	executeQuery(DbConnection connection, MuleEvent muleEvent)

Methods inherited from class org.mule.module.db.internal.processor.AbstractDbMessageProcessor

getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getSource, getTarget, getValidQueryTypes, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setSource, setTarget, validateQueryType

Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

addMessageProcessorPathElements, getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, setMuleContext, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.mule.api.source.MessageSource

setListener

Constructor Detail

AbstractSingleQueryDbMessageProcessor

public AbstractSingleQueryDbMessageProcessor(DbConfigResolver dbConfigResolver,
                                             QueryResolver queryResolver,
                                             TransactionalAction transactionalAction)

Method Detail

executeQuery

protected Object executeQuery(DbConnection connection,
                              MuleEvent muleEvent)
                       throws SQLException

Specified by:

executeQuery in class AbstractDbMessageProcessor

Throws:

SQLException

doExecuteQuery

protected abstract Object doExecuteQuery(DbConnection connection,
                                         Query query)
                                  throws SQLException

Throws:

SQLException