public class DynamicBulkUpdateMessageProcessor extends AbstractBulkUpdateMessageProcessor
MuleEvent
being processed.autoGeneratedKeyStrategy, bulkUpdateExecutorFactory, queryResolver, source, validQueryTypes
dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
DynamicBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver,
QueryResolver queryResolver,
BulkQueryExecutorFactory bulkUpdateExecutorFactory,
TransactionalAction transactionalAction,
List<QueryType> validQueryTypes) |
Modifier and Type | Method and Description |
---|---|
protected Object |
executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
getIterator, getSource, getValidQueryTypes, setAutoGeneratedKeyStrategy, setSource
getDebugInfo, getInputMetaData, getOutputMetaData, getQueryMetadataProvider, getTarget, initialise, mustCloseConnection, process, resolveSource, setQueryMetadataProvider, setStatementStreamingResultSetCloser, setTarget, validateQueryType
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, setMuleContext, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
public DynamicBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction, List<QueryType> validQueryTypes)
protected Object executeQuery(DbConnection connection, MuleEvent muleEvent) throws SQLException
executeQuery
in class AbstractDbMessageProcessor
SQLException
protected List<FieldDebugInfo<?>> getMessageProcessorDebugInfo(DbConnection connection, MuleEvent muleEvent)
getMessageProcessorDebugInfo
in class AbstractDbMessageProcessor
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.