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

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

All Implemented Interfaces:

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

public class PreparedBulkUpdateMessageProcessor
extends AbstractDbMessageProcessor

Executes an update query in bulk mode on a database *

An update query can be parametrized update, insert or delete query or a stored procedure taking input parameters only and returning an update count.

Both database and queries are resolved, if required, using the MuleEvent being processed.

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

PreparedBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction, List<QueryType> validQueryTypes)

Method Summary

protected Object	executeQuery(DbConnection connection, MuleEvent muleEvent)
String	getSource()
protected List<QueryType>	getValidQueryTypes()
void	setAutoGeneratedKeyStrategy(AutoGeneratedKeyStrategy autoGeneratedKeyStrategy)
void	setSource(String source)

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

getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, 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

PreparedBulkUpdateMessageProcessor

public PreparedBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver,
                                          QueryResolver queryResolver,
                                          BulkQueryExecutorFactory bulkUpdateExecutorFactory,
                                          TransactionalAction transactionalAction,
                                          List<QueryType> validQueryTypes)

Method Detail

executeQuery

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

Specified by:

executeQuery in class AbstractDbMessageProcessor

Throws:

SQLException

getValidQueryTypes

protected List<QueryType> getValidQueryTypes()

Specified by:

getValidQueryTypes in class AbstractDbMessageProcessor

getSource

public String getSource()

Overrides:

getSource in class AbstractDbMessageProcessor

setSource

public void setSource(String source)

Overrides:

setSource in class AbstractDbMessageProcessor

setAutoGeneratedKeyStrategy

public void setAutoGeneratedKeyStrategy(AutoGeneratedKeyStrategy autoGeneratedKeyStrategy)