org.mule.module.db.internal.processor

Class DynamicBulkUpdateMessageProcessor

java.lang.Object

org.mule.AbstractAnnotatedObject

org.mule.processor.AbstractInterceptingMessageProcessorBase

org.mule.processor.AbstractInterceptingMessageProcessor

org.mule.module.db.internal.processor.AbstractDbMessageProcessor

org.mule.module.db.internal.processor.AbstractBulkUpdateMessageProcessor

org.mule.module.db.internal.processor.DynamicBulkUpdateMessageProcessor

All Implemented Interfaces:

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

public class DynamicBulkUpdateMessageProcessor
extends AbstractBulkUpdateMessageProcessor

Executes an update dynamic query in bulk mode on a database *

A dynamic update query can be 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.AbstractBulkUpdateMessageProcessor

autoGeneratedKeyStrategy, bulkUpdateExecutorFactory, queryResolver, source, validQueryTypes

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

Constructors

Constructor and Description
DynamicBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction, List<QueryType> validQueryTypes)

Method Summary

Methods

Modifier and Type	Method and Description
protected Object	executeQuery(DbConnection connection, MuleEvent muleEvent)
protected List<FieldDebugInfo<?>>	getMessageProcessorDebugInfo(DbConnection connection, MuleEvent muleEvent)

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

getIterator, getSource, getValidQueryTypes, setAutoGeneratedKeyStrategy, setSource

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

getDebugInfo, getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setStatementStreamingResultSetCloser, setTarget, validateQueryType

Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase

addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString

Methods inherited from class org.mule.AbstractAnnotatedObject

getAnnotation, getAnnotations, setAnnotations

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

DynamicBulkUpdateMessageProcessor

public DynamicBulkUpdateMessageProcessor(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

getMessageProcessorDebugInfo

protected List<FieldDebugInfo<?>> getMessageProcessorDebugInfo(DbConnection connection,
                                                   MuleEvent muleEvent)

Specified by:

getMessageProcessorDebugInfo in class AbstractDbMessageProcessor