public class PreparedBulkUpdateMessageProcessor extends AbstractBulkUpdateMessageProcessor
MuleEvent
being processed.autoGeneratedKeyStrategy, bulkUpdateExecutorFactory, queryResolver, source, validQueryTypes
dbConfigResolver
logger, muleContext, next, notificationHandler
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
PreparedBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver,
QueryResolver queryResolver,
BulkQueryExecutorFactory bulkUpdateExecutorFactory,
TransactionalAction transactionalAction,
List<QueryType> validQueryTypes,
ParamValueResolver paramValueResolver) |
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 PreparedBulkUpdateMessageProcessor(DbConfigResolver dbConfigResolver, QueryResolver queryResolver, BulkQueryExecutorFactory bulkUpdateExecutorFactory, TransactionalAction transactionalAction, List<QueryType> validQueryTypes, ParamValueResolver paramValueResolver)
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.